Method onEvent

src/workspaces/transcript-watcher.ts:306–349

(key: string, _event: string, filename: string)

  }

  private async onEvent(key: string, _event: string, filename: string): Promise<void> {
    const entry = this.entries.get(key);
    if (!entry || entry.pending.length === 0) return;
    if (!entry.fileRe.test(filename)) return;

    try {
      await stat(join(entry.dir, filename));
    } catch {
      return;
    }

    for (const p of entry.pending) {
      if (p.existingBefore.has(filename)) continue;
      if (p.session.agentSessionId !== null) continue;
      const sessionId = p.adapter.extractSessionId?.(filename);
      if (!sessionId) return;
      p.session.setAgentSessionId(sessionId);
      this.logger.info('transcript.jsonl.detected', {
        wsId: p.session.wsId,
        recordId: p.session.recordId,
        agent: p.adapter.id,
        filename,
        agentSessionId: sessionId,
      });
      if (this.sessionRegistry) {
        // Fire-and-forget — failed write just means we don't get the
        // resumeHint persisted, which downgrades resume to `--continue`
        // semantics next time.
        void this.sessionRegistry
          .update(p.session.wsId, p.session.recordId, {
            resumeHint: { kind: 'agent-session-id', value: sessionId },
          })
          .catch((err) => {
            this.logger.warn('transcript_watch.registry_update_failed', {
              wsId: p.session.wsId,
              id: p.session.recordId,
              err,
            });
          });
      }
      this.unregister(p.session);
      return;
    }
  }
}

async function snapshotFiles(dir: string, fileRe: RegExp): Promise<Set<string>> {