pantsbuild / pants / 19015773527

from __future__ import annotations

import itertools

from collections.abc import Iterable

from dataclasses import dataclass

from pants.backend.openapi.dependency_inference import ParseOpenApiSources, parse_openapi_sources

from pants.backend.openapi.subsystems.openapi import OpenApiSubsystem

from pants.backend.openapi.target_types import (

from pants.core.goals.tailor import (

from pants.engine.fs import PathGlobs

from pants.engine.intrinsics import path_globs_to_digest, path_globs_to_paths

from pants.engine.rules import Rule, collect_rules, rule

from pants.engine.unions import UnionRule

from pants.util.dirutil import group_by_dir

from pants.util.logging import LogLevel

@dataclass(frozen=True)

class PutativeOpenApiTargetsRequest(PutativeTargetsRequest):

    pass

@rule(level=LogLevel.DEBUG, desc="Determine candidate OpenAPI targets to create")

async def find_putative_targets(

    if not openapi_subsystem.tailor_targets:

        return PutativeTargets()

    all_openapi_files = await path_globs_to_paths(

    targets = {*all_openapi_files.files}

    paths = tuple(targets)

    while paths:

        digest = await path_globs_to_digest(PathGlobs(paths))  # noqa: PNT30: this is inherently sequential

        result = await parse_openapi_sources(

        targets.update(result.dependencies.keys())

        paths = tuple(v for v in itertools.chain(*result.dependencies.values()) if v not in targets)

    unowned_openapi_documents = set(all_openapi_files.files) - set(all_owned_sources)

    unowned_openapi_sources = targets - set(all_owned_sources)

    classified_unowned_openapi_files = {

    putative_targets = []

    for tgt_type, filepaths in classified_unowned_openapi_files.items():

        for dirname, filenames in group_by_dir(filepaths).items():

            name = "openapi" if tgt_type == OpenApiDocumentGeneratorTarget else None

            putative_targets.append(

    return PutativeTargets(putative_targets)

def rules() -> Iterable[Rule | UnionRule]:

    return (