Function execute

ui/src/components/pipeline/stages/scanning.ts:60–223

(
  input: LoadingInput,
  ctx: PipelineContext,
)

]);

export function* execute(
  input: LoadingInput,
  ctx: PipelineContext,
): Generator<PipelineEvent, ScanResult> {
  const { repo } = input;
  const repoId = `${repo.owner}/${repo.repo}`;

  yield {
    kind: 'stage_start',
    phase: 'scanning',
    message: `Scanning ${repo.files.length} files`,
  };

  const repoProps: Record<string, unknown> = { ref: repo.ref };
  if (repo.url) repoProps.sourceUri = repo.url;
  if (repo.provider) repoProps.provider = repo.provider;

  const repoNode: GraphNode = {
    id: repoId,
    type: 'Repository',
    name: repoId,
    properties: repoProps,
  };

  const dirNodes = new Map<string, GraphNode>();
  const fileNodes: GraphNode[] = [];
  const structureRels: GraphRelationship[] = [];
  const parseableFiles: RepoFile[] = [];
  const packageNodes = new Map<string, GraphNode>();
  const dependencyRels: GraphRelationship[] = [];
  let goModulePath: string | undefined;

  // Pre-compute lookup maps for downstream stages
  const knownPaths = new Set<string>();
  const pathToFileId = new Map<string, string>();

  const total = repo.files.length;

  for (let i = 0; i < repo.files.length; i++) {
    if (ctx.cancelled) break;

    const file = repo.files[i];
    const ext = getExtension(file.path);
    const language = detectLanguage(ext);

    const fileId = `${repoId}/${file.path}`;
    const fileName = file.path.includes('/')
      ? file.path.slice(file.path.lastIndexOf('/') + 1)
      : file.path;

    const fileProps: Record<string, unknown> = {
      path: file.path,
      extension: ext,
    };
    if (language) fileProps.language = language;
    if (repo.url) {
      fileProps.sourceUri = `${repo.url}/blob/${repo.ref}/${file.path}`;
    }