feat: add /kill command to delete sessions

Adds a /kill <name> command that interrupts any active run,
deletes the session and its message history, and auto-switches
to the most recent remaining session.

Co-Authored-By: Claude Opus 4.6 <noreply@anthropic.com>

Author: bluedbird

packages/core/src/interfaces.ts

@@ -94,5 +94,6 @@ export interface SessionStore {
   getActiveSession(channel: string, chatId: string): Promise<Session | null>;
   setSessionStatus(sessionId: string, status: import('./types').SessionStatus): Promise<void>;
   setTitle(sessionId: string, title: string): Promise<void>;
+  deleteSession(sessionId: string): Promise<void>;
   resetStuckSessions(): Promise<number>;
 }

packages/gateway/src/commands.ts

@@ -109,13 +109,57 @@ export function createCommandHandler(deps: CommandDeps): CommandHandler {
     return true;
   }
 
+  async function cmdKill(
+    channel: string,
+    chatId: string,
+    args: string,
+    reply: ReplyFn,
+  ): Promise<true> {
+    const nameOrId = args.trim();
+    if (!nameOrId) {
+      await reply('Usage: /kill <session-name>');
+      return true;
+    }
+
+    try {
+      // Resolve the session first to get its ID for interruption
+      const sessions = await sessionManager.listSessions(channel, chatId);
+      const target =
+        sessions.find((s) => s.name === nameOrId) ??
+        sessions.find((s) => s.id.startsWith(nameOrId));
+
+      if (target) {
+        await deps.agentRunner.interrupt(target.id);
+      }
+
+      const { deletedId, wasActive } = await sessionManager.deleteSession(
+        channel,
+        chatId,
+        nameOrId,
+      );
+
+      let msg = `Killed session \`${nameOrId}\` (${deletedId.slice(0, 8)})`;
+      if (wasActive) {
+        const active = await sessionManager.getActiveSession(channel, chatId);
+        msg += active
+          ? `\nSwitched to \`${sessionLabel(active)}\``
+          : '\nNo sessions left — send a message to start one.';
+      }
+      await reply(msg);
+    } catch (err) {
+      await reply(getErrorMessage(err));
+    }
+    return true;
+  }
+
   async function cmdHelp(reply: ReplyFn): Promise<true> {
     const help = [
       'Available commands:',
       '',
       '/new [name] — Start a new session',
       '/use <name> — Switch to a session',
       '/sessions — List all sessions',
+      '/kill <name> — Delete a session and its history',
       '/ping — Check if Homie is alive',
       '/status — Show system status',
       '/help — Show this help',
@@ -174,6 +218,8 @@ export function createCommandHandler(deps: CommandDeps): CommandHandler {
           return cmdUse(channel, chatId, args, reply);
         case 'sessions':
           return cmdSessions(channel, chatId, reply);
+        case 'kill':
+          return cmdKill(channel, chatId, args, reply);
         case 'ping':
           return cmdPing(reply);
         default:

packages/persistence/src/session-store.ts

@@ -154,6 +154,12 @@ export function createSessionStore(db: Database): SessionStore {
       return rows.reverse().map(rowToMessage);
     },
 
+    async deleteSession(sessionId) {
+      db.prepare('DELETE FROM active_sessions WHERE session_id = ?').run(sessionId);
+      db.prepare('DELETE FROM messages WHERE session_id = ?').run(sessionId);
+      db.prepare('DELETE FROM sessions WHERE id = ?').run(sessionId);
+    },
+
     async resetSession(channel, chatId) {
       const active = await getActiveSession(channel, chatId);
       if (!active) return null;

packages/sessions/src/session-manager.ts

@@ -24,6 +24,11 @@ export interface SessionManager {
   getHistory(sessionId: string, limit: number): Promise<Message[]>;
   getSession(sessionId: string): Promise<Session | null>;
   resetSession(channel: string, chatId: string): Promise<string | null>;
+  deleteSession(
+    channel: string,
+    chatId: string,
+    nameOrId: string,
+  ): Promise<{ deletedId: string; wasActive: boolean }>;
   setProcessing(sessionId: string): Promise<void>;
   setIdle(sessionId: string): Promise<void>;
   setTitle(sessionId: string, title: string): Promise<void>;
@@ -103,6 +108,31 @@ export function createSessionManager(store: SessionStore): SessionManager {
       return store.getById(sessionId);
     },
 
+    async deleteSession(channel, chatId, nameOrId) {
+      let session = await store.getSessionByName(channel, chatId, nameOrId);
+      if (!session) {
+        const all = await store.listSessionsByChat(channel, chatId);
+        session = all.find((s) => s.id.startsWith(nameOrId)) ?? null;
+      }
+      if (!session) throw new Error(`No session "${nameOrId}" found`);
+
+      const active = await store.getActiveSession(channel, chatId);
+      const wasActive = active?.id === session.id;
+
+      await store.deleteSession(session.id);
+
+      if (wasActive) {
+        // Switch to the most recent remaining session
+        const remaining = await store.listSessionsByChat(channel, chatId);
+        if (remaining.length > 0) {
+          await store.setActiveSession(channel, chatId, remaining[0]!.id);
+        }
+      }
+
+      log.info('Session deleted', { sessionId: session.id, name: session.name, chatId });
+      return { deletedId: session.id, wasActive };
+    },
+
     async resetSession(channel, chatId) {
       const oldId = await store.resetSession(channel, chatId);
       if (oldId) {