Skip to content
Makaio Framework

Variable: SessionStorageNamespace

Makaio Framework

Makaio Framework / services-core/session/storage/namespace / SessionStorageNamespace

Variable: SessionStorageNamespace

Section titled “Variable: SessionStorageNamespace”

const SessionStorageNamespace: object

Defined in: ../../../packages/services/core/src/session/storage/namespace.ts:29

Session storage namespace with Drizzle extension.

Bus subjects are defined in @makaio/contracts (source of truth). This namespace extends the contracts definition with the Drizzle table schemas so handlers can access the sessions and agents tables.

Type Declaration

Section titled “Type Declaration”

__filterPayload?

Section titled “__filterPayload?”

readonly optional __filterPayload?: object

Phantom property for type extraction. Never accessed at runtime. Enables ExtractFilterPayload<T> to infer the FilterPayload type parameter without relying on complex nested generic inference.

Index Signature

Section titled “Index Signature”

[key: string]: string | number | boolean | { clientId: string; kind: string; observedAt: number; payload: unknown; source: string; } | { adapterId?: string; adapterName?: string; adapterSessionId?: string; agents: object[]; approvalPolicyOverride?: "always-ask" | "reject" | "full-access" | null; branchKind?: "fork" | "branch" | "aside" | "subagent" | "compress" | "rewrite" | "coordinator"; clientAccountId?: string; clientId?: string; createdAt: number; executionTargetId?: string; forkPointMessageId?: string; forkTransforms?: { appliedPipeline?: object[]; removedMessageIds?: string[]; segments?: object[]; }; isImported?: boolean; isOrchestrated?: boolean; lastActivityAt: number; lastClientIdentityObservation?: { clientId: string; kind: string; observedAt: number; payload: unknown; source: string; }; leadAgentId?: string; parentSessionId?: string; rootSessionId?: string; sessionId: string; spawningToolCallId?: string; status: "active" | "closed" | "archived" | "discovered"; summary?: string; summaryUpdatedAt?: number; targetWorkingDirectory?: string; title?: string; } | null

domain

Section titled “domain”

readonly domain: "session"

Storage domain name (without ‘storage:’ prefix).

extensions

Section titled “extensions”

extensions: object

extensions.drizzle

Section titled “extensions.drizzle”

drizzle: object

extensions.drizzle.agents

Section titled “extensions.drizzle.agents”

agents: SQLiteTableWithColumns<{ columns: { adapterId: SQLiteColumn<{ baseColumn: never; columnType: "SQLiteText"; data: string; dataType: "string"; driverParam: string; enumValues: [string, ...string[]]; generated: undefined; hasDefault: false; hasRuntimeDefault: false; identity: undefined; isAutoincrement: false; isPrimaryKey: false; name: "adapter_id"; notNull: true; tableName: "agents"; }, { }, { length: number | undefined; }>; adapterName: SQLiteColumn<{ baseColumn: never; columnType: "SQLiteText"; data: string; dataType: "string"; driverParam: string; enumValues: [string, ...string[]]; generated: undefined; hasDefault: false; hasRuntimeDefault: false; identity: undefined; isAutoincrement: false; isPrimaryKey: false; name: "adapter_name"; notNull: true; tableName: "agents"; }, { }, { length: number | undefined; }>; adapterSessionId: SQLiteColumn<{ baseColumn: never; columnType: "SQLiteText"; data: string; dataType: "string"; driverParam: string; enumValues: [string, ...string[]]; generated: undefined; hasDefault: false; hasRuntimeDefault: false; identity: undefined; isAutoincrement: false; isPrimaryKey: false; name: "adapter_session_id"; notNull: false; tableName: "agents"; }, { }, { length: number | undefined; }>; agentId: SQLiteColumn<{ baseColumn: never; columnType: "SQLiteText"; data: string; dataType: "string"; driverParam: string; enumValues: [string, ...string[]]; generated: undefined; hasDefault: false; hasRuntimeDefault: false; identity: undefined; isAutoincrement: false; isPrimaryKey: true; name: "agent_id"; notNull: true; tableName: "agents"; }, { }, { length: number | undefined; }>; clientId: SQLiteColumn<{ baseColumn: never; columnType: "SQLiteText"; data: string; dataType: "string"; driverParam: string; enumValues: [string, ...string[]]; generated: undefined; hasDefault: false; hasRuntimeDefault: false; identity: undefined; isAutoincrement: false; isPrimaryKey: false; name: "client_id"; notNull: false; tableName: "agents"; }, { }, { length: number | undefined; }>; compressionMode: SQLiteColumn<{ baseColumn: never; columnType: "SQLiteText"; data: string; dataType: "string"; driverParam: string; enumValues: [string, ...string[]]; generated: undefined; hasDefault: false; hasRuntimeDefault: false; identity: undefined; isAutoincrement: false; isPrimaryKey: false; name: "compression_mode"; notNull: false; tableName: "agents"; }, { }, { length: number | undefined; }>; createdAt: SQLiteColumn<{ baseColumn: never; columnType: "SQLiteInteger"; data: number; dataType: "number"; driverParam: number; enumValues: undefined; generated: undefined; hasDefault: false; hasRuntimeDefault: false; identity: undefined; isAutoincrement: false; isPrimaryKey: false; name: "created_at"; notNull: true; tableName: "agents"; }, { }, { }>; cwd: SQLiteColumn<{ baseColumn: never; columnType: "SQLiteText"; data: string; dataType: "string"; driverParam: string; enumValues: [string, ...string[]]; generated: undefined; hasDefault: false; hasRuntimeDefault: false; identity: undefined; isAutoincrement: false; isPrimaryKey: false; name: "cwd"; notNull: false; tableName: "agents"; }, { }, { length: number | undefined; }>; harnessId: SQLiteColumn<{ baseColumn: never; columnType: "SQLiteText"; data: string; dataType: "string"; driverParam: string; enumValues: [string, ...string[]]; generated: undefined; hasDefault: false; hasRuntimeDefault: false; identity: undefined; isAutoincrement: false; isPrimaryKey: false; name: "harness_id"; notNull: false; tableName: "agents"; }, { }, { length: number | undefined; }>; lastActivityAt: SQLiteColumn<{ baseColumn: never; columnType: "SQLiteInteger"; data: number; dataType: "number"; driverParam: number; enumValues: undefined; generated: undefined; hasDefault: false; hasRuntimeDefault: false; identity: undefined; isAutoincrement: false; isPrimaryKey: false; name: "last_activity_at"; notNull: true; tableName: "agents"; }, { }, { }>; model: SQLiteColumn<{ baseColumn: never; columnType: "SQLiteText"; data: string; dataType: "string"; driverParam: string; enumValues: [string, ...string[]]; generated: undefined; hasDefault: false; hasRuntimeDefault: false; identity: undefined; isAutoincrement: false; isPrimaryKey: false; name: "model"; notNull: false; tableName: "agents"; }, { }, { length: number | undefined; }>; personaId: SQLiteColumn<{ baseColumn: never; columnType: "SQLiteText"; data: string; dataType: "string"; driverParam: string; enumValues: [string, ...string[]]; generated: undefined; hasDefault: false; hasRuntimeDefault: false; identity: undefined; isAutoincrement: false; isPrimaryKey: false; name: "persona_id"; notNull: false; tableName: "agents"; }, { }, { length: number | undefined; }>; profileId: SQLiteColumn<{ baseColumn: never; columnType: "SQLiteText"; data: string; dataType: "string"; driverParam: string; enumValues: [string, ...string[]]; generated: undefined; hasDefault: false; hasRuntimeDefault: false; identity: undefined; isAutoincrement: false; isPrimaryKey: false; name: "profile_id"; notNull: false; tableName: "agents"; }, { }, { length: number | undefined; }>; providerConfigId: SQLiteColumn<{ baseColumn: never; columnType: "SQLiteText"; data: string; dataType: "string"; driverParam: string; enumValues: [string, ...string[]]; generated: undefined; hasDefault: false; hasRuntimeDefault: false; identity: undefined; isAutoincrement: false; isPrimaryKey: false; name: "provider_config_id"; notNull: false; tableName: "agents"; }, { }, { length: number | undefined; }>; role: SQLiteColumn<{ baseColumn: never; columnType: "SQLiteText"; data: "lead" | "member"; dataType: "string"; driverParam: string; enumValues: ["lead", "member"]; generated: undefined; hasDefault: false; hasRuntimeDefault: false; identity: undefined; isAutoincrement: false; isPrimaryKey: false; name: "role"; notNull: true; tableName: "agents"; }, { }, { length: number | undefined; }>; sessionId: SQLiteColumn<{ baseColumn: never; columnType: "SQLiteText"; data: string; dataType: "string"; driverParam: string; enumValues: [string, ...string[]]; generated: undefined; hasDefault: false; hasRuntimeDefault: false; identity: undefined; isAutoincrement: false; isPrimaryKey: false; name: "session_id"; notNull: true; tableName: "agents"; }, { }, { length: number | undefined; }>; status: SQLiteColumn<{ baseColumn: never; columnType: "SQLiteText"; data: "active" | "idle" | "dead" | "disposed"; dataType: "string"; driverParam: string; enumValues: ["idle", "active", "dead", "disposed"]; generated: undefined; hasDefault: false; hasRuntimeDefault: false; identity: undefined; isAutoincrement: false; isPrimaryKey: false; name: "status"; notNull: true; tableName: "agents"; }, { }, { length: number | undefined; }>; }; dialect: "sqlite"; name: "agents"; schema: undefined; }>

Agents table schema.

Persistent agent state. The agent is a stable identity shell; the connector is ephemeral and recreated on startup.

Replaces the former session_agents join table. The relationship between agent and session is 1:1, modeled via session_id FK.

extensions.drizzle.sessions

Section titled “extensions.drizzle.sessions”

sessions: SQLiteTableWithColumns<{ columns: { adapterId: SQLiteColumn<{ baseColumn: never; columnType: "SQLiteText"; data: string; dataType: "string"; driverParam: string; enumValues: [string, ...string[]]; generated: undefined; hasDefault: false; hasRuntimeDefault: false; identity: undefined; isAutoincrement: false; isPrimaryKey: false; name: "adapter_id"; notNull: false; tableName: "sessions"; }, { }, { length: number | undefined; }>; adapterName: SQLiteColumn<{ baseColumn: never; columnType: "SQLiteText"; data: string; dataType: "string"; driverParam: string; enumValues: [string, ...string[]]; generated: undefined; hasDefault: false; hasRuntimeDefault: false; identity: undefined; isAutoincrement: false; isPrimaryKey: false; name: "adapter_name"; notNull: false; tableName: "sessions"; }, { }, { length: number | undefined; }>; adapterSessionId: SQLiteColumn<{ baseColumn: never; columnType: "SQLiteText"; data: string; dataType: "string"; driverParam: string; enumValues: [string, ...string[]]; generated: undefined; hasDefault: false; hasRuntimeDefault: false; identity: undefined; isAutoincrement: false; isPrimaryKey: false; name: "adapter_session_id"; notNull: false; tableName: "sessions"; }, { }, { length: number | undefined; }>; approvalPolicyOverride: SQLiteColumn<{ baseColumn: never; columnType: "SQLiteText"; data: "always-ask" | "reject" | "full-access"; dataType: "string"; driverParam: string; enumValues: ["reject", "always-ask", "full-access"]; generated: undefined; hasDefault: false; hasRuntimeDefault: false; identity: undefined; isAutoincrement: false; isPrimaryKey: false; name: "approval_policy_override"; notNull: false; tableName: "sessions"; }, { }, { length: number | undefined; }>; branchKind: SQLiteColumn<{ baseColumn: never; columnType: "SQLiteText"; data: "fork" | "branch" | "aside" | "subagent" | "compress" | "rewrite" | "coordinator"; dataType: "string"; driverParam: string; enumValues: ["fork", "branch", "subagent", "compress", "rewrite", "coordinator", "aside"]; generated: undefined; hasDefault: false; hasRuntimeDefault: false; identity: undefined; isAutoincrement: false; isPrimaryKey: false; name: "branch_kind"; notNull: false; tableName: "sessions"; }, { }, { length: number | undefined; }>; clientAccountId: SQLiteColumn<{ baseColumn: never; columnType: "SQLiteText"; data: string; dataType: "string"; driverParam: string; enumValues: [string, ...string[]]; generated: undefined; hasDefault: false; hasRuntimeDefault: false; identity: undefined; isAutoincrement: false; isPrimaryKey: false; name: "client_account_id"; notNull: false; tableName: "sessions"; }, { }, { length: number | undefined; }>; clientId: SQLiteColumn<{ baseColumn: never; columnType: "SQLiteText"; data: string; dataType: "string"; driverParam: string; enumValues: [string, ...string[]]; generated: undefined; hasDefault: false; hasRuntimeDefault: false; identity: undefined; isAutoincrement: false; isPrimaryKey: false; name: "client_id"; notNull: false; tableName: "sessions"; }, { }, { length: number | undefined; }>; createdAt: SQLiteColumn<{ baseColumn: never; columnType: "SQLiteInteger"; data: number; dataType: "number"; driverParam: number; enumValues: undefined; generated: undefined; hasDefault: false; hasRuntimeDefault: false; identity: undefined; isAutoincrement: false; isPrimaryKey: false; name: "created_at"; notNull: true; tableName: "sessions"; }, { }, { }>; executionTargetId: SQLiteColumn<{ baseColumn: never; columnType: "SQLiteText"; data: string; dataType: "string"; driverParam: string; enumValues: [string, ...string[]]; generated: undefined; hasDefault: false; hasRuntimeDefault: false; identity: undefined; isAutoincrement: false; isPrimaryKey: false; name: "execution_target_id"; notNull: false; tableName: "sessions"; }, { }, { length: number | undefined; }>; forkPointMessageId: SQLiteColumn<{ baseColumn: never; columnType: "SQLiteText"; data: string; dataType: "string"; driverParam: string; enumValues: [string, ...string[]]; generated: undefined; hasDefault: false; hasRuntimeDefault: false; identity: undefined; isAutoincrement: false; isPrimaryKey: false; name: "fork_point_message_id"; notNull: false; tableName: "sessions"; }, { }, { length: number | undefined; }>; forkTransforms: SQLiteColumn<{ baseColumn: never; columnType: "SQLiteText"; data: string; dataType: "string"; driverParam: string; enumValues: [string, ...string[]]; generated: undefined; hasDefault: false; hasRuntimeDefault: false; identity: undefined; isAutoincrement: false; isPrimaryKey: false; name: "fork_transforms"; notNull: false; tableName: "sessions"; }, { }, { length: number | undefined; }>; isImported: SQLiteColumn<{ baseColumn: never; columnType: "SQLiteBoolean"; data: boolean; dataType: "boolean"; driverParam: number; enumValues: undefined; generated: undefined; hasDefault: true; hasRuntimeDefault: false; identity: undefined; isAutoincrement: false; isPrimaryKey: false; name: "is_imported"; notNull: false; tableName: "sessions"; }, { }, { }>; isOrchestrated: SQLiteColumn<{ baseColumn: never; columnType: "SQLiteBoolean"; data: boolean; dataType: "boolean"; driverParam: number; enumValues: undefined; generated: undefined; hasDefault: true; hasRuntimeDefault: false; identity: undefined; isAutoincrement: false; isPrimaryKey: false; name: "is_orchestrated"; notNull: false; tableName: "sessions"; }, { }, { }>; lastActivityAt: SQLiteColumn<{ baseColumn: never; columnType: "SQLiteInteger"; data: number; dataType: "number"; driverParam: number; enumValues: undefined; generated: undefined; hasDefault: false; hasRuntimeDefault: false; identity: undefined; isAutoincrement: false; isPrimaryKey: false; name: "last_activity_at"; notNull: true; tableName: "sessions"; }, { }, { }>; lastClientIdentityObservation: SQLiteColumn<{ baseColumn: never; columnType: "SQLiteText"; data: string; dataType: "string"; driverParam: string; enumValues: [string, ...string[]]; generated: undefined; hasDefault: false; hasRuntimeDefault: false; identity: undefined; isAutoincrement: false; isPrimaryKey: false; name: "last_client_identity_observation"; notNull: false; tableName: "sessions"; }, { }, { length: number | undefined; }>; leadAgentId: SQLiteColumn<{ baseColumn: never; columnType: "SQLiteText"; data: string; dataType: "string"; driverParam: string; enumValues: [string, ...string[]]; generated: undefined; hasDefault: false; hasRuntimeDefault: false; identity: undefined; isAutoincrement: false; isPrimaryKey: false; name: "lead_agent_id"; notNull: false; tableName: "sessions"; }, { }, { length: number | undefined; }>; parentSessionId: SQLiteColumn<{ baseColumn: never; columnType: "SQLiteText"; data: string; dataType: "string"; driverParam: string; enumValues: [string, ...string[]]; generated: undefined; hasDefault: false; hasRuntimeDefault: false; identity: undefined; isAutoincrement: false; isPrimaryKey: false; name: "parent_session_id"; notNull: false; tableName: "sessions"; }, { }, { length: number | undefined; }>; rootSessionId: SQLiteColumn<{ baseColumn: never; columnType: "SQLiteText"; data: string; dataType: "string"; driverParam: string; enumValues: [string, ...string[]]; generated: undefined; hasDefault: false; hasRuntimeDefault: false; identity: undefined; isAutoincrement: false; isPrimaryKey: false; name: "root_session_id"; notNull: false; tableName: "sessions"; }, { }, { length: number | undefined; }>; sessionId: SQLiteColumn<{ baseColumn: never; columnType: "SQLiteText"; data: string; dataType: "string"; driverParam: string; enumValues: [string, ...string[]]; generated: undefined; hasDefault: false; hasRuntimeDefault: false; identity: undefined; isAutoincrement: false; isPrimaryKey: true; name: "session_id"; notNull: true; tableName: "sessions"; }, { }, { length: number | undefined; }>; spawningToolCallId: SQLiteColumn<{ baseColumn: never; columnType: "SQLiteText"; data: string; dataType: "string"; driverParam: string; enumValues: [string, ...string[]]; generated: undefined; hasDefault: false; hasRuntimeDefault: false; identity: undefined; isAutoincrement: false; isPrimaryKey: false; name: "spawning_tool_call_id"; notNull: false; tableName: "sessions"; }, { }, { length: number | undefined; }>; status: SQLiteColumn<{ baseColumn: never; columnType: "SQLiteText"; data: "active" | "closed" | "archived" | "discovered"; dataType: "string"; driverParam: string; enumValues: ["active", "closed", "archived", "discovered"]; generated: undefined; hasDefault: false; hasRuntimeDefault: false; identity: undefined; isAutoincrement: false; isPrimaryKey: false; name: "status"; notNull: true; tableName: "sessions"; }, { }, { length: number | undefined; }>; summary: SQLiteColumn<{ baseColumn: never; columnType: "SQLiteText"; data: string; dataType: "string"; driverParam: string; enumValues: [string, ...string[]]; generated: undefined; hasDefault: false; hasRuntimeDefault: false; identity: undefined; isAutoincrement: false; isPrimaryKey: false; name: "summary"; notNull: false; tableName: "sessions"; }, { }, { length: number | undefined; }>; summaryUpdatedAt: SQLiteColumn<{ baseColumn: never; columnType: "SQLiteInteger"; data: number; dataType: "number"; driverParam: number; enumValues: undefined; generated: undefined; hasDefault: false; hasRuntimeDefault: false; identity: undefined; isAutoincrement: false; isPrimaryKey: false; name: "summary_updated_at"; notNull: false; tableName: "sessions"; }, { }, { }>; targetWorkingDirectory: SQLiteColumn<{ baseColumn: never; columnType: "SQLiteText"; data: string; dataType: "string"; driverParam: string; enumValues: [string, ...string[]]; generated: undefined; hasDefault: false; hasRuntimeDefault: false; identity: undefined; isAutoincrement: false; isPrimaryKey: false; name: "target_working_directory"; notNull: false; tableName: "sessions"; }, { }, { length: number | undefined; }>; title: SQLiteColumn<{ baseColumn: never; columnType: "SQLiteText"; data: string; dataType: "string"; driverParam: string; enumValues: [string, ...string[]]; generated: undefined; hasDefault: false; hasRuntimeDefault: false; identity: undefined; isAutoincrement: false; isPrimaryKey: false; name: "title"; notNull: false; tableName: "sessions"; }, { }, { length: number | undefined; }>; }; dialect: "sqlite"; name: "sessions"; schema: undefined; }>

Sessions table schema.

Stores makaio orchestration sessions. Each session represents a logical conversation context that may span multiple agents and adapters.

SEAM: The sessionId column is the primary key that extensions can reference for their own decorator tables (e.g., extension_chat_messages).

name

Section titled “name”

name: "storage:session"

subjects

Section titled “subjects”

subjects: BusSubjects<FlatSubjectDefinitions<"storage:session", { delete: { request: ZodObject<{ sessionId: ZodString; }, $strip>; response: ZodObject<{ success: ZodBoolean; }, $strip>; }; get: { request: ZodObject<{ sessionId: ZodString; }, $strip>; response: ZodObject<{ session: ZodNullable<ZodObject<{ adapterId: ZodOptional<…>; adapterName: ZodOptional<…>; adapterSessionId: ZodOptional<…>; agents: ZodArray<…>; approvalPolicyOverride: ZodOptional<…>; branchKind: ZodOptional<…>; clientAccountId: ZodOptional<…>; clientId: ZodOptional<…>; createdAt: ZodNumber; executionTargetId: ZodOptional<…>; forkPointMessageId: ZodOptional<…>; forkTransforms: ZodOptional<…>; isImported: ZodOptional<…>; isOrchestrated: ZodOptional<…>; lastActivityAt: ZodNumber; lastClientIdentityObservation: ZodOptional<…>; leadAgentId: ZodOptional<…>; parentSessionId: ZodOptional<…>; rootSessionId: ZodOptional<…>; sessionId: ZodString; spawningToolCallId: ZodOptional<…>; status: ZodEnum<…>; summary: ZodOptional<…>; summaryUpdatedAt: ZodOptional<…>; targetWorkingDirectory: ZodOptional<…>; title: ZodOptional<…>; }, $strip>>; }, $strip>; }; getByAdapterSessionId: { request: ZodObject<{ adapterSessionId: ZodString; }, $strip>; response: ZodObject<{ session: ZodNullable<ZodObject<{ adapterId: ZodOptional<…>; adapterName: ZodOptional<…>; adapterSessionId: ZodOptional<…>; agents: ZodArray<…>; approvalPolicyOverride: ZodOptional<…>; branchKind: ZodOptional<…>; clientAccountId: ZodOptional<…>; clientId: ZodOptional<…>; createdAt: ZodNumber; executionTargetId: ZodOptional<…>; forkPointMessageId: ZodOptional<…>; forkTransforms: ZodOptional<…>; isImported: ZodOptional<…>; isOrchestrated: ZodOptional<…>; lastActivityAt: ZodNumber; lastClientIdentityObservation: ZodOptional<…>; leadAgentId: ZodOptional<…>; parentSessionId: ZodOptional<…>; rootSessionId: ZodOptional<…>; sessionId: ZodString; spawningToolCallId: ZodOptional<…>; status: ZodEnum<…>; summary: ZodOptional<…>; summaryUpdatedAt: ZodOptional<…>; targetWorkingDirectory: ZodOptional<…>; title: ZodOptional<…>; }, $strip>>; }, $strip>; }; getChildren: { request: ZodObject<{ sessionId: ZodString; }, $strip>; response: ZodObject<{ children: ZodArray<ZodObject<{ branchKind: ZodNullable<…>; forkPointMessageId: ZodNullable<…>; hasChildren: ZodBoolean; messageCount: ZodNumber; sessionId: ZodString; spawningToolCallId: ZodOptional<…>; title: ZodNullable<…>; }, $strip>>; }, $strip>; }; getStatusCounts: { request: ZodObject<{ }, $strip>; response: ZodObject<{ active: ZodNumber; all: ZodNumber; archived: ZodNumber; closed: ZodNumber; discovered: ZodNumber; }, $strip>; }; list: { request: ZodObject<{ executionTargetId: ZodOptional<ZodString>; includePreview: ZodOptional<ZodBoolean>; limit: ZodOptional<ZodNumber>; offset: ZodOptional<ZodNumber>; status: ZodOptional<ZodEnum<{ active: "active"; all: "all"; archived: "archived"; closed: "closed"; discovered: "discovered"; }>>; }, $strip>; response: ZodObject<{ sessions: ZodArray<ZodObject<{ adapterId: ZodOptional<…>; adapterName: ZodOptional<…>; adapterSessionId: ZodOptional<…>; agents: ZodArray<…>; approvalPolicyOverride: ZodOptional<…>; branchKind: ZodOptional<…>; clientAccountId: ZodOptional<…>; clientId: ZodOptional<…>; createdAt: ZodNumber; executionTargetId: ZodOptional<…>; forkPointMessageId: ZodOptional<…>; forkTransforms: ZodOptional<…>; isImported: ZodOptional<…>; isOrchestrated: ZodOptional<…>; lastActivityAt: ZodNumber; lastClientIdentityObservation: ZodOptional<…>; leadAgentId: ZodOptional<…>; parentSessionId: ZodOptional<…>; preview: ZodOptional<…>; rootSessionId: ZodOptional<…>; sessionId: ZodString; spawningToolCallId: ZodOptional<…>; status: ZodEnum<…>; summary: ZodOptional<…>; summaryUpdatedAt: ZodOptional<…>; targetWorkingDirectory: ZodOptional<…>; title: ZodOptional<…>; }, $strip>>; total: ZodNumber; }, $strip>; }; search: { request: ZodObject<{ isImported: ZodOptional<ZodBoolean>; limit: ZodOptional<ZodNumber>; query: ZodString; status: ZodOptional<ZodEnum<{ active: "active"; all: "all"; archived: "archived"; closed: "closed"; discovered: "discovered"; }>>; }, $strip>; response: ZodObject<{ sessions: ZodArray<ZodObject<{ adapterId: ZodOptional<…>; adapterName: ZodOptional<…>; adapterSessionId: ZodOptional<…>; agents: ZodArray<…>; approvalPolicyOverride: ZodOptional<…>; branchKind: ZodOptional<…>; clientAccountId: ZodOptional<…>; clientId: ZodOptional<…>; createdAt: ZodNumber; executionTargetId: ZodOptional<…>; forkPointMessageId: ZodOptional<…>; forkTransforms: ZodOptional<…>; isImported: ZodOptional<…>; isOrchestrated: ZodOptional<…>; lastActivityAt: ZodNumber; lastClientIdentityObservation: ZodOptional<…>; leadAgentId: ZodOptional<…>; parentSessionId: ZodOptional<…>; preview: ZodObject<…, …>; rootSessionId: ZodOptional<…>; sessionId: ZodString; spawningToolCallId: ZodOptional<…>; status: ZodEnum<…>; summary: ZodOptional<…>; summaryUpdatedAt: ZodOptional<…>; targetWorkingDirectory: ZodOptional<…>; title: ZodOptional<…>; }, $strip>>; total: ZodNumber; }, $strip>; }; set: { request: ZodObject<{ ifAbsent: ZodOptional<ZodBoolean>; session: ZodObject<{ adapterId: ZodOptional<ZodString>; adapterName: ZodOptional<ZodString>; adapterSessionId: ZodOptional<ZodString>; agents: ZodArray<ZodObject<…, …>>; approvalPolicyOverride: ZodOptional<ZodNullable<…>>; branchKind: ZodOptional<ZodEnum<…>>; clientAccountId: ZodOptional<ZodString>; clientId: ZodOptional<ZodString>; createdAt: ZodNumber; executionTargetId: ZodOptional<ZodString>; forkPointMessageId: ZodOptional<ZodString>; forkTransforms: ZodOptional<ZodObject<…, …>>; isImported: ZodOptional<ZodBoolean>; isOrchestrated: ZodOptional<ZodBoolean>; lastActivityAt: ZodNumber; lastClientIdentityObservation: ZodOptional<ZodObject<…, …>>; leadAgentId: ZodOptional<ZodString>; parentSessionId: ZodOptional<ZodString>; rootSessionId: ZodOptional<ZodString>; sessionId: ZodString; spawningToolCallId: ZodOptional<ZodString>; status: ZodEnum<{ active: …; archived: …; closed: …; discovered: …; }>; summary: ZodOptional<ZodString>; summaryUpdatedAt: ZodOptional<ZodNumber>; targetWorkingDirectory: ZodOptional<ZodString>; title: ZodOptional<ZodString>; }, $strip>; sessionId: ZodString; }, $strip>; response: ZodObject<{ clientAccountChanged: ZodOptional<ZodBoolean>; success: ZodBoolean; }, $strip>; }; update: { request: ZodObject<{ approvalPolicyOverride: ZodOptional<ZodNullable<ZodEnum<{ always-ask: …; full-access: …; reject: …; }>>>; branchKind: ZodOptional<ZodEnum<{ aside: "aside"; branch: "branch"; compress: "compress"; coordinator: "coordinator"; fork: "fork"; rewrite: "rewrite"; subagent: "subagent"; }>>; clientAccountId: ZodOptional<ZodString>; clientId: ZodOptional<ZodString>; createdAt: ZodOptional<ZodNumber>; executionTargetId: ZodOptional<ZodNullable<ZodString>>; forkPointMessageId: ZodOptional<ZodString>; isOrchestrated: ZodOptional<ZodBoolean>; lastActivityAt: ZodOptional<ZodNumber>; lastClientIdentityObservation: ZodOptional<ZodObject<{ clientId: ZodString; kind: ZodString; observedAt: ZodNumber; payload: ZodType<…, …, …>; source: ZodString; }, $strip>>; parentSessionId: ZodOptional<ZodString>; rootSessionId: ZodOptional<ZodString>; sessionId: ZodString; spawningToolCallId: ZodOptional<ZodNullable<ZodString>>; status: ZodOptional<ZodEnum<{ active: "active"; archived: "archived"; closed: "closed"; discovered: "discovered"; }>>; targetWorkingDirectory: ZodOptional<ZodString>; title: ZodOptional<ZodString>; }, $strip>; response: ZodObject<{ clientAccountChanged: ZodOptional<ZodBoolean>; success: ZodBoolean; }, $strip>; }; }>, "storage:session">

scopedBus()

Section titled “scopedBus()”

scopedBus(context?): Promise<ScopedBus<"storage:session", SubjectRecordFromSchemaRecord<{ delete: { request: ZodObject<{ sessionId: ZodString; }, $strip>; response: ZodObject<{ success: ZodBoolean; }, $strip>; }; get: { request: ZodObject<{ sessionId: ZodString; }, $strip>; response: ZodObject<{ session: ZodNullable<ZodObject<{ adapterId: …; adapterName: …; adapterSessionId: …; agents: …; approvalPolicyOverride: …; branchKind: …; clientAccountId: …; clientId: …; createdAt: …; executionTargetId: …; forkPointMessageId: …; forkTransforms: …; isImported: …; isOrchestrated: …; lastActivityAt: …; lastClientIdentityObservation: …; leadAgentId: …; parentSessionId: …; rootSessionId: …; sessionId: …; spawningToolCallId: …; status: …; summary: …; summaryUpdatedAt: …; targetWorkingDirectory: …; title: …; }, $strip>>; }, $strip>; }; getByAdapterSessionId: { request: ZodObject<{ adapterSessionId: ZodString; }, $strip>; response: ZodObject<{ session: ZodNullable<ZodObject<{ adapterId: …; adapterName: …; adapterSessionId: …; agents: …; approvalPolicyOverride: …; branchKind: …; clientAccountId: …; clientId: …; createdAt: …; executionTargetId: …; forkPointMessageId: …; forkTransforms: …; isImported: …; isOrchestrated: …; lastActivityAt: …; lastClientIdentityObservation: …; leadAgentId: …; parentSessionId: …; rootSessionId: …; sessionId: …; spawningToolCallId: …; status: …; summary: …; summaryUpdatedAt: …; targetWorkingDirectory: …; title: …; }, $strip>>; }, $strip>; }; getChildren: { request: ZodObject<{ sessionId: ZodString; }, $strip>; response: ZodObject<{ children: ZodArray<ZodObject<{ branchKind: …; forkPointMessageId: …; hasChildren: …; messageCount: …; sessionId: …; spawningToolCallId: …; title: …; }, $strip>>; }, $strip>; }; getStatusCounts: { request: ZodObject<{ }, $strip>; response: ZodObject<{ active: ZodNumber; all: ZodNumber; archived: ZodNumber; closed: ZodNumber; discovered: ZodNumber; }, $strip>; }; list: { request: ZodObject<{ executionTargetId: ZodOptional<ZodString>; includePreview: ZodOptional<ZodBoolean>; limit: ZodOptional<ZodNumber>; offset: ZodOptional<ZodNumber>; status: ZodOptional<ZodEnum<{ active: …; all: …; archived: …; closed: …; discovered: …; }>>; }, $strip>; response: ZodObject<{ sessions: ZodArray<ZodObject<{ adapterId: …; adapterName: …; adapterSessionId: …; agents: …; approvalPolicyOverride: …; branchKind: …; clientAccountId: …; clientId: …; createdAt: …; executionTargetId: …; forkPointMessageId: …; forkTransforms: …; isImported: …; isOrchestrated: …; lastActivityAt: …; lastClientIdentityObservation: …; leadAgentId: …; parentSessionId: …; preview: …; rootSessionId: …; sessionId: …; spawningToolCallId: …; status: …; summary: …; summaryUpdatedAt: …; targetWorkingDirectory: …; title: …; }, $strip>>; total: ZodNumber; }, $strip>; }; search: { request: ZodObject<{ isImported: ZodOptional<ZodBoolean>; limit: ZodOptional<ZodNumber>; query: ZodString; status: ZodOptional<ZodEnum<{ active: …; all: …; archived: …; closed: …; discovered: …; }>>; }, $strip>; response: ZodObject<{ sessions: ZodArray<ZodObject<{ adapterId: …; adapterName: …; adapterSessionId: …; agents: …; approvalPolicyOverride: …; branchKind: …; clientAccountId: …; clientId: …; createdAt: …; executionTargetId: …; forkPointMessageId: …; forkTransforms: …; isImported: …; isOrchestrated: …; lastActivityAt: …; lastClientIdentityObservation: …; leadAgentId: …; parentSessionId: …; preview: …; rootSessionId: …; sessionId: …; spawningToolCallId: …; status: …; summary: …; summaryUpdatedAt: …; targetWorkingDirectory: …; title: …; }, $strip>>; total: ZodNumber; }, $strip>; }; set: { request: ZodObject<{ ifAbsent: ZodOptional<ZodBoolean>; session: ZodObject<{ adapterId: ZodOptional<…>; adapterName: ZodOptional<…>; adapterSessionId: ZodOptional<…>; agents: ZodArray<…>; approvalPolicyOverride: ZodOptional<…>; branchKind: ZodOptional<…>; clientAccountId: ZodOptional<…>; clientId: ZodOptional<…>; createdAt: ZodNumber; executionTargetId: ZodOptional<…>; forkPointMessageId: ZodOptional<…>; forkTransforms: ZodOptional<…>; isImported: ZodOptional<…>; isOrchestrated: ZodOptional<…>; lastActivityAt: ZodNumber; lastClientIdentityObservation: ZodOptional<…>; leadAgentId: ZodOptional<…>; parentSessionId: ZodOptional<…>; rootSessionId: ZodOptional<…>; sessionId: ZodString; spawningToolCallId: ZodOptional<…>; status: ZodEnum<…>; summary: ZodOptional<…>; summaryUpdatedAt: ZodOptional<…>; targetWorkingDirectory: ZodOptional<…>; title: ZodOptional<…>; }, $strip>; sessionId: ZodString; }, $strip>; response: ZodObject<{ clientAccountChanged: ZodOptional<ZodBoolean>; success: ZodBoolean; }, $strip>; }; update: { request: ZodObject<{ approvalPolicyOverride: ZodOptional<ZodNullable<ZodEnum<…>>>; branchKind: ZodOptional<ZodEnum<{ aside: …; branch: …; compress: …; coordinator: …; fork: …; rewrite: …; subagent: …; }>>; clientAccountId: ZodOptional<ZodString>; clientId: ZodOptional<ZodString>; createdAt: ZodOptional<ZodNumber>; executionTargetId: ZodOptional<ZodNullable<ZodString>>; forkPointMessageId: ZodOptional<ZodString>; isOrchestrated: ZodOptional<ZodBoolean>; lastActivityAt: ZodOptional<ZodNumber>; lastClientIdentityObservation: ZodOptional<ZodObject<{ clientId: …; kind: …; observedAt: …; payload: …; source: …; }, $strip>>; parentSessionId: ZodOptional<ZodString>; rootSessionId: ZodOptional<ZodString>; sessionId: ZodString; spawningToolCallId: ZodOptional<ZodNullable<ZodString>>; status: ZodOptional<ZodEnum<{ active: …; archived: …; closed: …; discovered: …; }>>; targetWorkingDirectory: ZodOptional<ZodString>; title: ZodOptional<ZodString>; }, $strip>; response: ZodObject<{ clientAccountChanged: ZodOptional<ZodBoolean>; success: ZodBoolean; }, $strip>; }; }>, {[key: string]: string | number | boolean | { clientId: string; kind: string; observedAt: number; payload: unknown; source: string; } | { adapterId?: string; adapterName?: string; adapterSessionId?: string; agents: object[]; approvalPolicyOverride?: "always-ask" | "reject" | "full-access" | null; branchKind?: "fork" | "branch" | "aside" | "subagent" | "compress" | "rewrite" | "coordinator"; clientAccountId?: string; clientId?: string; createdAt: number; executionTargetId?: string; forkPointMessageId?: string; forkTransforms?: { appliedPipeline?: object[]; removedMessageIds?: string[]; segments?: object[]; }; isImported?: boolean; isOrchestrated?: boolean; lastActivityAt: number; lastClientIdentityObservation?: { clientId: string; kind: string; observedAt: number; payload: unknown; source: string; }; leadAgentId?: string; parentSessionId?: string; rootSessionId?: string; sessionId: string; spawningToolCallId?: string; status: "active" | "closed" | "archived" | "discovered"; summary?: string; summaryUpdatedAt?: number; targetWorkingDirectory?: string; title?: string; } | null; }>>

Parameters

Section titled “Parameters”
context?
Section titled “context?”

MakaioBusContext

Returns

Section titled “Returns”

Promise<ScopedBus<"storage:session", SubjectRecordFromSchemaRecord<{ delete: { request: ZodObject<{ sessionId: ZodString; }, $strip>; response: ZodObject<{ success: ZodBoolean; }, $strip>; }; get: { request: ZodObject<{ sessionId: ZodString; }, $strip>; response: ZodObject<{ session: ZodNullable<ZodObject<{ adapterId: …; adapterName: …; adapterSessionId: …; agents: …; approvalPolicyOverride: …; branchKind: …; clientAccountId: …; clientId: …; createdAt: …; executionTargetId: …; forkPointMessageId: …; forkTransforms: …; isImported: …; isOrchestrated: …; lastActivityAt: …; lastClientIdentityObservation: …; leadAgentId: …; parentSessionId: …; rootSessionId: …; sessionId: …; spawningToolCallId: …; status: …; summary: …; summaryUpdatedAt: …; targetWorkingDirectory: …; title: …; }, $strip>>; }, $strip>; }; getByAdapterSessionId: { request: ZodObject<{ adapterSessionId: ZodString; }, $strip>; response: ZodObject<{ session: ZodNullable<ZodObject<{ adapterId: …; adapterName: …; adapterSessionId: …; agents: …; approvalPolicyOverride: …; branchKind: …; clientAccountId: …; clientId: …; createdAt: …; executionTargetId: …; forkPointMessageId: …; forkTransforms: …; isImported: …; isOrchestrated: …; lastActivityAt: …; lastClientIdentityObservation: …; leadAgentId: …; parentSessionId: …; rootSessionId: …; sessionId: …; spawningToolCallId: …; status: …; summary: …; summaryUpdatedAt: …; targetWorkingDirectory: …; title: …; }, $strip>>; }, $strip>; }; getChildren: { request: ZodObject<{ sessionId: ZodString; }, $strip>; response: ZodObject<{ children: ZodArray<ZodObject<{ branchKind: …; forkPointMessageId: …; hasChildren: …; messageCount: …; sessionId: …; spawningToolCallId: …; title: …; }, $strip>>; }, $strip>; }; getStatusCounts: { request: ZodObject<{ }, $strip>; response: ZodObject<{ active: ZodNumber; all: ZodNumber; archived: ZodNumber; closed: ZodNumber; discovered: ZodNumber; }, $strip>; }; list: { request: ZodObject<{ executionTargetId: ZodOptional<ZodString>; includePreview: ZodOptional<ZodBoolean>; limit: ZodOptional<ZodNumber>; offset: ZodOptional<ZodNumber>; status: ZodOptional<ZodEnum<{ active: …; all: …; archived: …; closed: …; discovered: …; }>>; }, $strip>; response: ZodObject<{ sessions: ZodArray<ZodObject<{ adapterId: …; adapterName: …; adapterSessionId: …; agents: …; approvalPolicyOverride: …; branchKind: …; clientAccountId: …; clientId: …; createdAt: …; executionTargetId: …; forkPointMessageId: …; forkTransforms: …; isImported: …; isOrchestrated: …; lastActivityAt: …; lastClientIdentityObservation: …; leadAgentId: …; parentSessionId: …; preview: …; rootSessionId: …; sessionId: …; spawningToolCallId: …; status: …; summary: …; summaryUpdatedAt: …; targetWorkingDirectory: …; title: …; }, $strip>>; total: ZodNumber; }, $strip>; }; search: { request: ZodObject<{ isImported: ZodOptional<ZodBoolean>; limit: ZodOptional<ZodNumber>; query: ZodString; status: ZodOptional<ZodEnum<{ active: …; all: …; archived: …; closed: …; discovered: …; }>>; }, $strip>; response: ZodObject<{ sessions: ZodArray<ZodObject<{ adapterId: …; adapterName: …; adapterSessionId: …; agents: …; approvalPolicyOverride: …; branchKind: …; clientAccountId: …; clientId: …; createdAt: …; executionTargetId: …; forkPointMessageId: …; forkTransforms: …; isImported: …; isOrchestrated: …; lastActivityAt: …; lastClientIdentityObservation: …; leadAgentId: …; parentSessionId: …; preview: …; rootSessionId: …; sessionId: …; spawningToolCallId: …; status: …; summary: …; summaryUpdatedAt: …; targetWorkingDirectory: …; title: …; }, $strip>>; total: ZodNumber; }, $strip>; }; set: { request: ZodObject<{ ifAbsent: ZodOptional<ZodBoolean>; session: ZodObject<{ adapterId: ZodOptional<…>; adapterName: ZodOptional<…>; adapterSessionId: ZodOptional<…>; agents: ZodArray<…>; approvalPolicyOverride: ZodOptional<…>; branchKind: ZodOptional<…>; clientAccountId: ZodOptional<…>; clientId: ZodOptional<…>; createdAt: ZodNumber; executionTargetId: ZodOptional<…>; forkPointMessageId: ZodOptional<…>; forkTransforms: ZodOptional<…>; isImported: ZodOptional<…>; isOrchestrated: ZodOptional<…>; lastActivityAt: ZodNumber; lastClientIdentityObservation: ZodOptional<…>; leadAgentId: ZodOptional<…>; parentSessionId: ZodOptional<…>; rootSessionId: ZodOptional<…>; sessionId: ZodString; spawningToolCallId: ZodOptional<…>; status: ZodEnum<…>; summary: ZodOptional<…>; summaryUpdatedAt: ZodOptional<…>; targetWorkingDirectory: ZodOptional<…>; title: ZodOptional<…>; }, $strip>; sessionId: ZodString; }, $strip>; response: ZodObject<{ clientAccountChanged: ZodOptional<ZodBoolean>; success: ZodBoolean; }, $strip>; }; update: { request: ZodObject<{ approvalPolicyOverride: ZodOptional<ZodNullable<ZodEnum<…>>>; branchKind: ZodOptional<ZodEnum<{ aside: …; branch: …; compress: …; coordinator: …; fork: …; rewrite: …; subagent: …; }>>; clientAccountId: ZodOptional<ZodString>; clientId: ZodOptional<ZodString>; createdAt: ZodOptional<ZodNumber>; executionTargetId: ZodOptional<ZodNullable<ZodString>>; forkPointMessageId: ZodOptional<ZodString>; isOrchestrated: ZodOptional<ZodBoolean>; lastActivityAt: ZodOptional<ZodNumber>; lastClientIdentityObservation: ZodOptional<ZodObject<{ clientId: …; kind: …; observedAt: …; payload: …; source: …; }, $strip>>; parentSessionId: ZodOptional<ZodString>; rootSessionId: ZodOptional<ZodString>; sessionId: ZodString; spawningToolCallId: ZodOptional<ZodNullable<ZodString>>; status: ZodOptional<ZodEnum<{ active: …; archived: …; closed: …; discovered: …; }>>; targetWorkingDirectory: ZodOptional<ZodString>; title: ZodOptional<ZodString>; }, $strip>; response: ZodObject<{ clientAccountChanged: ZodOptional<ZodBoolean>; success: ZodBoolean; }, $strip>; }; }>, {[key: string]: string | number | boolean | { clientId: string; kind: string; observedAt: number; payload: unknown; source: string; } | { adapterId?: string; adapterName?: string; adapterSessionId?: string; agents: object[]; approvalPolicyOverride?: "always-ask" | "reject" | "full-access" | null; branchKind?: "fork" | "branch" | "aside" | "subagent" | "compress" | "rewrite" | "coordinator"; clientAccountId?: string; clientId?: string; createdAt: number; executionTargetId?: string; forkPointMessageId?: string; forkTransforms?: { appliedPipeline?: object[]; removedMessageIds?: string[]; segments?: object[]; }; isImported?: boolean; isOrchestrated?: boolean; lastActivityAt: number; lastClientIdentityObservation?: { clientId: string; kind: string; observedAt: number; payload: unknown; source: string; }; leadAgentId?: string; parentSessionId?: string; rootSessionId?: string; sessionId: string; spawningToolCallId?: string; status: "active" | "closed" | "archived" | "discovered"; summary?: string; summaryUpdatedAt?: number; targetWorkingDirectory?: string; title?: string; } | null; }>>

Example

Section titled “Example”
import { SessionStorageNamespace, SessionStorageSubjects } from '@makaio/services-core/session';


// Use bus subjects
const { session } = await bus.request(SessionStorageSubjects.get, { sessionId: '123' });


// Access drizzle schemas for custom queries
const { sessions, agents } = SessionStorageNamespace.extensions.drizzle;