Method register

src/workspaces/transcript-watcher.ts:80–173

(session: PersistentSession, adapter: CliAdapter)

  ) {}

  async register(session: PersistentSession, adapter: CliAdapter): Promise<void> {
    const discovery = adapter.capabilities.transcriptDiscovery;
    if (discovery === 'subprocess') {
      await this.registerSubprocess(session, adapter);
      return;
    }
    if (discovery !== 'fs-watch') return;
    if (!adapter.transcriptDir || !adapter.transcriptFileRe || !adapter.extractSessionId) {
      this.logger.warn('transcript_watch.adapter_missing_fs_methods', { adapter: adapter.id });
      return;
    }

    const dir = adapter.transcriptDir(session.cwd);
    const key = watchKey(session.wsId, dir);

    let existing: ReadonlySet<string>;
    try {
      existing = await snapshotFiles(dir, adapter.transcriptFileRe);
    } catch (err) {
      if (!isENOENT(err)) {
        this.logger.warn('transcript_watch.snapshot_failed', {
          wsId: session.wsId,
          adapter: adapter.id,
          dir,
          err,
        });
      }
      existing = new Set();
    }

    try {
      await mkdir(dir, { recursive: true });
    } catch (err) {
      this.logger.warn('transcript_watch.mkdir_failed', {
        wsId: session.wsId,
        adapter: adapter.id,
        dir,
        err,
      });
      return;
    }

    let entry = this.entries.get(key);
    if (!entry) {
      try {
        const w = watch(dir, (event, filename) => {
          if (typeof filename === 'string') {
            void this.onEvent(key, event, filename);
          }
        });
        w.on('error', (err) => {
          this.logger.warn('transcript_watch.error', {
            wsId: session.wsId,
            adapter: adapter.id,
            dir,
            err,
          });
        });