synapse-inbox

1import type { Register } from 'claude-code'
2
3// P22-T134 Mod-Inbox: wartet am lokalen Synapse-Daemon (mod-inbox.ts) auf Nachrichten an den Ausweis dieser Sitzung und
4// startet damit einen Turn. Den Ausweis kennt nur der Daemon (aus dem Transcript); die Mod meldet nur ihre Sitzungs-ID.
5// P22-T151 (Doppelzustellung inbox:1100): $.prompt.submit wartet, bis die Sitzung untaetig ist. Die Abrufschleife wartet deshalb
6// nicht mehr darauf (sonst gilt die Sitzung im Daemon nach 60 s ohne Abruf als beendet und die Nachricht kommt erneut), meldet
7// 'angenommen' sofort und reiht in eine eigene Kette ein (submits nacheinander, in Reihenfolge). Dieselbe Nachricht (id) geht nie
8// zweimal an $.prompt.submit, auch wenn der Daemon sie nach einem Neustart erneut uebergibt.
9const PAUSE_BEI_FEHLER_MS = 10_000
10/** So viele Nachrichten-IDs merkt sich die Mod fuer die Dedup (aelteste fallen heraus). */
11const GEMERKT_MAX = 500
12
13interface ModNachricht { id: string; text: string }
14interface WarteAntwort { nachricht?: ModNachricht | null; aktiv?: boolean; grund?: string | null }
15
16export const register: Register = on => {
17  on('session.start', async ($, e, next) => {
18    const sitzung = await $.session.id()
19    const home = (await $.env.get('HOME')) ?? (await $.env.get('USERPROFILE')) ?? ''
20    const portDatei = `${home}/.synapse/file-watcher/daemon.port`
21    let aktivAngezeigt: boolean | null = null
22    // id -> 'wartet' (eingereiht bzw. submit laeuft) | 'gestartet'
23    const gemerkt = new Map<string, 'wartet' | 'gestartet'>()
24    let kette: Promise<void> = Promise.resolve()
25
26    const merke = (id: string, stand: 'wartet' | 'gestartet'): void => {
27      gemerkt.delete(id)
28      gemerkt.set(id, stand)
29      while (gemerkt.size > GEMERKT_MAX) gemerkt.delete(gemerkt.keys().next().value as string)
30    }
31
32    // Meldung an den Daemon; ein Fehler oder 404 (Daemon vor P22-T151 kennt /angenommen nicht) hat keine Folgen fuer die Schleife.
33    const melde = async (basis: string, pfad: 'angenommen' | 'quittung', body: Record<string, unknown>): Promise<void> => {
34      try {
35        await $.http.fetch(`${basis}/${pfad}`, {
36          method: 'POST',
37          headers: { 'content-type': 'application/json' },
38          body: JSON.stringify({ sitzung, ...body }),
39        })
40      } catch { /* der naechste Job derselben Nachricht fragt erneut, die Antwort kommt dann aus gemerkt */ }
41    }
42
43    const nimmAn = (basis: string, n: ModNachricht): void => {
44      const stand = gemerkt.get(n.id)
45      if (stand === 'gestartet') { void melde(basis, 'quittung', { id: n.id, gestartet: true, grund: null }); return }
46      void melde(basis, 'angenommen', { id: n.id })
47      if (stand === 'wartet') return
48      merke(n.id, 'wartet')
49      kette = kette.then(async () => {
50        // submit wartet, bis die Sitzung untaetig ist, und loest mit dem Turnstart auf. P22-T142: asUser ohne Claude-Code-Rahmen;
51        // die Herkunft nennt der Kopf aus API/Daemon ('[Synapse-Nachricht] ... Von:'), Hooks sehen weiter kind 'plugin'.
52        let drop: string | undefined
53        try { drop = (await $.prompt.submit({ text: n.text, asUser: true })).drop } catch (err) { drop = String(err).slice(0, 200) }
54        // drop: vergessen, damit ein erneuter Versuch der API wieder einen submit ausloest.
55        if (drop === undefined) merke(n.id, 'gestartet')
56        else gemerkt.delete(n.id)
57        await melde(basis, 'quittung', { id: n.id, gestartet: drop === undefined, grund: drop ?? null })
58      })
59    }
60
61    // Laeuft ueber das Ende des Hooks hinaus: ein Abruf haelt am Daemon bis zu 25 s, danach sofort der naechste.
62    const runde = async (): Promise<void> => {
63      let pause = 1
64      try {
65        const basis = `http://127.0.0.1:${(await $.fs.read(portDatei)).trim()}/mod-inbox`
66        const r = await $.http.fetch(`${basis}/warte?sitzung=${sitzung}`)
67        if (!r.ok) throw new Error(`HTTP ${r.status}`)
68        const j = JSON.parse(r.text) as WarteAntwort
69        if ((j.aktiv === true) !== aktivAngezeigt) {
70          aktivAngezeigt = j.aktiv === true
71          $.ui.status(aktivAngezeigt ? 'Synapse-Inbox aktiv' : undefined)
72        }
73        if (j.nachricht) nimmAn(basis, j.nachricht)
74      } catch {
75        pause = PAUSE_BEI_FEHLER_MS
76      }
77      $.clock.after(pause, () => { void runde() })
78    }
79    void runde()
80    return next(e)
81  })
82}
83