Method updateSessionStatus

server/src/db/si-db.ts:220–244

(
    sessionId: string,
    status: SiSession["status"],
    terminationReason?: string,
    handoffData?: Record<string, unknown>
  )

  }

  async updateSessionStatus(
    sessionId: string,
    status: SiSession["status"],
    terminationReason?: string,
    handoffData?: Record<string, unknown>
  ): Promise<SiSession | null> {
    const result = await query(
      `UPDATE si_sessions
       SET status = $2,
           termination_reason = $3,
           handoff_data = $4,
           terminated_at = CASE WHEN $2::VARCHAR IN ('complete', 'timeout', 'error') THEN NOW() ELSE NULL END
       WHERE session_id = $1
       RETURNING *`,
      [
        sessionId,
        status,
        terminationReason || null,
        handoffData ? JSON.stringify(handoffData) : null,
      ]
    );

    if (result.rows.length === 0) return null;
    return this.deserializeSession(result.rows[0]);
  }

  async getActiveSessions(hostIdentifier?: string): Promise<SiSession[]> {
    let sql = "SELECT * FROM si_sessions WHERE status = 'active'";