pdx-hold-probe

1// Probe 2: does an idle session's peer delivery pass through prompt.submit,
2// and can a prompt.submit hook hold the turn past 10 s inside a $ call?
3let n = 0
4
5async function log($, msg) {
6  const line = new Date().toISOString() + ' ' + msg + '\n'
7  try {
8    const path = (await $.session.cwd()) + '/probe.log'
9    const old = await $.fs.read(path).catch(() => '')
10    await $.fs.write(path, old + line)
11  } catch {}
12}
13
14export function register(on) {
15  on('session.start', async ($, e, next) => {
16    await log($, 'loaded session=' + (await $.session.id()))
17    return next(e)
18  })
19
20  on('session.receive', async ($, e, next) => {
21    await log($, 'receive origin=' + JSON.stringify(e.origin) + ' text=' + JSON.stringify(String(e.text).slice(-60)))
22    return next(e)
23  })
24
25  on('prompt.submit', async ($, e, next) => {
26    const id = ++n
27    await log($, 'submit#' + id + ' origin=' + JSON.stringify(e.origin || null) + ' agentId=' + (e.agentId || '-') + ' text=' + JSON.stringify(String(e.text).slice(-60)))
28    if (String(e.text).includes('HOLD15')) {
29      await log($, 'submit#' + id + ' holding 15s via $.process.run')
30      const r = await $.process.run(['/bin/sleep', '15'], { timeoutMs: 60000 })
31      await log($, 'submit#' + id + ' released exit=' + r.exitCode)
32    }
33    return next(e)
34  })
35
36  on('turn.start', async ($, e, next) => {
37    if (!e.agentId) await log($, 'turn.start')
38    return next(e)
39  })
40}
41