Deleting a Bot or group chat orphans its scheduled tasks: they stay armed in DSH, vanish from Settings, and schedule-delete refuses them #57

// Repro: deleting a Bot (or a group chat) orphans its scheduled tasks — they stay
// active in DSH's schedule service (and keep firing on the session), but
// vanish from Settings and `schedule-delete` refuses to remove them.
import { mkdtempSync, rmSync, writeFileSync } from 'node:fs'
import { tmpdir } from 'node:os'
import { join } from 'node:path'
import { apply } from './index.js'
import { fakeContext } from './test/fake-ctx.js'

const TEAM = {
  version: 1,
  mainBotIds: ['m1'],
  revision: 1,
  bots: {
    m1: { id: 'm1', sessionId: 'm1', name: 'Chief', role: 'Chief of Staff', instructions: '', createdAt: 1 },
    w1: { id: 'w1', sessionId: 'w2', name: 'Writer', role: '', instructions: '', createdAt: 2, segments: [{ sessionId: 'w1', endedAt: 3 }] },
  },
  rooms: { g1: { id: 'g1', name: 'Launch', named: true, members: ['m1', 'w1'], admin: 'm1', mode: 'admin', notice: '', createdAt: 4 } },
  exchanges: [],
  exchangeTurns: {},
  questions: {},
}

// In-memory stand-in for DSH's schedule service (same shape as test/schedules.test.js).
function scheduleService() {
  const tasks = new Map()
  let next = 1
  return {
    tasks,
    async create(sessionId, request) {
      const id = `schedule-${next++}`
      const kind = Object.keys(request).find(key => !['title', 'prompt'].includes(key))
      const record = { id, kind, title: request.title, prompt: request.prompt, timing: request[kind], scheduledAt: '2030-01-01T01:00:00.000Z' }
      tasks.set(id, { sessionId, record, status: 'active' })
      return record
    },
    async list({ sessionId }) { return [...tasks.values()].filter(task => task.sessionId === sessionId).map(task => task.record) },
    async catalog() { return [...tasks.values()].map(task => ({ ...task.record, sessionId: task.sessionId, status: task.status })) },
    async delete({ sessionId, id }) {
      if (tasks.get(id)?.sessionId !== sessionId) return { id, deleted: false, code: 'schedule_not_found' }
      tasks.delete(id)
      return { id, deleted: true }
    },
  }
}

const schedule = scheduleService()
const home = mkdtempSync(join(tmpdir(), 'repro-sched-'))
writeFileSync(join(home, 'state.json'), JSON.stringify(TEAM))
const ctx = fakeContext({ services: { schedule } })
const sent = []
Object.assign(ctx, {
  workspaceRegistry: { archiveSession: async () => {} },
  sessionController: {
    create: async () => ({ sessionId: 'fresh' }),
    resolveAgent: async sessionId => ({ agent: { session: { id: sessionId }, followup: message => sent.push({ sessionId, message }) } }),
    selectModel: async () => {},
  },
  sessionTitle: { rename: async () => {} },
  sessions: { flush: async () => {} },
})
let route
const register = ctx.connection.fetch.register
ctx.connection.fetch.register = (options) => { route = options; return register(options) }
apply(ctx, { home })
const call = async (endpoint, payload) => (await route.fetch(new Request('http://localhost/api/bot', { method: 'POST', body: JSON.stringify({ endpoint, payload }) }))).json()

// 1. A daily task on Writer (w1) and one on the group chat (g1).
const made = await call('schedule-create', { target: 'w1', title: 'Briefing', prompt: 'Sum up the day', when: { kind: 'daily', time: '09:00', timeZone: 'UTC' } })
console.log('create w1 task ok:', made.ok)
const madeRoom = await call('schedule-create', { target: 'g1', title: 'Standup', prompt: 'Where are we?', when: { kind: 'daily', time: '10:00', timeZone: 'UTC' } })
console.log('create g1 task ok:', madeRoom.ok)
const botTask = [...schedule.tasks.values()].find(task => task.sessionId === 'w2')
const roomTask = [...schedule.tasks.values()].find(task => task.sessionId === 'g1')
console.log('service holds:', [...schedule.tasks.values()].map(t => [t.sessionId, t.record.title, t.status]))

// 2. Delete the Bot and the group chat through the API.
console.log('delete-bot ok:', (await call('delete-bot', { id: 'w1' })).ok)
console.log('delete-room ok:', (await call('delete-room', { id: 'g1' })).ok)

// 3. What does the user see, and can they clean up?
const listed = await call('schedules', {})
console.log('schedules view after delete:', JSON.stringify(listed.value))
const tryDeleteBotTask = await call('schedule-delete', { sessionId: 'w2', id: botTask.record.id })
console.log('delete the Bot task via API:', JSON.stringify(tryDeleteBotTask))
const tryDeleteRoomTask = await call('schedule-delete', { sessionId: 'g1', id: roomTask.record.id })
console.log('delete the room task via API:', JSON.stringify(tryDeleteRoomTask))
console.log('service still holds:', [...schedule.tasks.values()].map(t => [t.sessionId, t.record.title, t.status]))

ctx.dispose()
rmSync(home, { recursive: true, force: true })