Method process

ui/src/components/pipeline/concurrent/stages.ts:192–308

(node: GraphNode)

  }

  process(node: GraphNode): StageMutation {
    if (node.type !== 'File') {
      return { nodes: [node], relationships: [] };
    }

    const filePath = node.properties?.path as string | undefined;
    if (!filePath) {
      return { nodes: [node], relationships: [] };
    }

    const ext = getExtension(filePath);
    const language = detectLanguage(ext);
    if (!language) {
      return { nodes: [node], relationships: [] };
    }

    const parser = getParserForLanguage(language, ext);
    const extractor = getExtractor(language);
    if (!parser || !extractor) {
      return { nodes: [node], relationships: [] };
    }

    const fileId = node.id;
    const content = this.getContent(fileId);
    if (content === undefined) {
      return { nodes: [node], relationships: [] };
    }

    const nodes: GraphNode[] = [node]; // File node passes through
    const rels: GraphRelationship[] = [];

    try {
      const tree = parser.parse(content);
      if (!tree) {
        return { nodes: [node], relationships: [] };
      }

      const extraction = extractor(tree.rootNode);

      // Initialize file registry entry
      this.registries.fileRegistry.set(fileId, new Map());

      // Process symbols → graph nodes + registries
      for (const sym of extraction.symbols) {
        processSymbol(
          sym,
          fileId,
          language,
          this.registries,
          this.allCallInfo,
          nodes,
          rels,
          this.emittedNodeIds,
        );
      }

      // Import analysis
      const rootNode = extraction.rootNode;