Function springEventEdges

src/resolution/callback-synthesizer.ts:2677–2758

(ctx: ResolutionContext, onYield: MaybeYield)

}

async function springEventEdges(ctx: ResolutionContext, onYield: MaybeYield): Promise<Edge[]> {
  let scannedFiles = 0;
  // Pass 1 — event-type → listener methods, scanning only event-relevant files.
  // This is the ONLY full read sweep: publisher files are recorded here so
  // pass 2 re-reads just those instead of every .java file again (#1212 —
  // the double full-repo read was one of the tail's longest unyielded spans).
  const listeners = new Map<string, Node[]>();
  const publisherFiles: string[] = [];
  for (const file of ctx.getAllFiles()) {
    if ((++scannedFiles & 15) === 0) await onYield();
    if (!SPRING_JAVA_EXT.test(file)) continue;
    const content = ctx.readFile(file);
    if (!content) continue;
    if (content.includes('.publishEvent(')) publisherFiles.push(file);
    const hasAnno = content.includes('@EventListener') || content.includes('@TransactionalEventListener');
    const hasAppListener = SPRING_APP_LISTENER_RE.test(content);
    if (!hasAnno && !hasAppListener) continue;
    const lines = content.split('\n');
    for (const node of ctx.getNodesInFile(file)) {
      if (node.kind !== 'method') continue;
      // Collect this method's own leading annotation block (consecutive `@`-lines from startLine).
      const annoLines: string[] = [];
      for (let i = node.startLine - 1; i < lines.length && i < node.startLine + 7; i++) {
        const t = (lines[i] ?? '').trim();
        if (!t.startsWith('@')) break; // reached the declaration → stop (no bleed into next method)
        annoLines.push(t);
      }
      const head = annoLines.join('\n');
      const annotated = hasAnno && SPRING_LISTENER_ANNO_RE.test(head);
      const isAppListener = hasAppListener && node.name === 'onApplicationEvent';
      if (!annotated && !isAppListener) continue;
      let type = springFirstParamType(node.signature);
      if (!type && annotated) {
        const m = SPRING_ANNO_TYPE_RE.exec(head);
        if (m) type = m[1]!;
      }
      if (!type) continue;
      let arr = listeners.get(type);
      if (!arr) { arr = []; listeners.set(type, arr); }
      arr.push(node);
    }
  }
  if (!listeners.size) return [];

  // Pass 2 — link each publishEvent(new XEvent(...)) site → every listener of
  // XEvent. Only the publisher files recorded in pass 1 are (re-)read.
  const edges: Edge[] = [];
  const seen = new Set<string>();
  for (const file of publisherFiles) {
    if ((++scannedFiles & 15) === 0) await onYield();
    const content = ctx.readFile(file);
    if (!content || !content.includes('.publishEvent(')) continue;
    const safe = stripCommentsForRegex(content, 'java');
    const nodesInFile = ctx.getNodesInFile(file);
    SPRING_PUBLISH_RE.lastIndex = 0;
    let m: RegExpExecArray | null;
    let added = 0;
    while ((m = SPRING_PUBLISH_RE.exec(safe)) && added < SPRING_FANOUT_CAP) {