Skip to content

Variable: AdapterSessionStorageNamespace

Makaio Framework


Makaio Framework / services-core / AdapterSessionStorageNamespace

const AdapterSessionStorageNamespace: StorageNamespace<"adapterSession", SubjectRecordFromSchemaRecord<{ countByAdapter: { request: ZodObject<{ adapterName: ZodString; }, $strip>; response: ZodObject<{ discovered: ZodNumber; imported: ZodNumber; total: ZodNumber; }, $strip>; }; createAndLink: { request: ZodObject<{ adapterId: ZodString; adapterName: ZodString; adapterSessionId: ZodString; existingSessionId: ZodOptional<ZodString>; metadata: ZodIntersection<ZodUnion<readonly [ZodObject<{ forkPointMessageId: …; kind: …; parentAdapterSessionId: …; }, $strip>, ZodObject<{ forkPointMessageId: …; kind: …; parentAdapterSessionId: …; }, $strip>, ZodObject<{ forkPointMessageId: …; kind: …; parentAdapterSessionId: …; }, $strip>, ZodObject<{ forkPointMessageId: …; kind: …; parentAdapterSessionId: …; }, $strip>]>, ZodObject<{ cwd: ZodNullable<ZodString>; model: ZodNullable<ZodString>; title: ZodNullable<ZodString>; }, $strip>>; }, $strip>; response: ZodObject<{ created: ZodBoolean; sessionId: ZodString; }, $strip>; }; get: { request: ZodObject<{ adapterSessionId: ZodString; }, $strip>; response: ZodObject<{ session: ZodNullable<ZodObject<{ adapterName: ZodString; adapterSessionId: ZodString; cwd: ZodNullable<ZodString>; discoveredAt: ZodNumber; forkPointMessageId: ZodNullable<ZodString>; kind: ZodEnum<{ compress: …; fork: …; root: …; subagent: …; }>; logFilePath: ZodNullable<ZodString>; model: ZodNullable<ZodString>; parentAdapterSessionId: ZodNullable<ZodString>; sessionId: ZodNullable<ZodString>; startedAt: ZodNumber; status: ZodEnum<{ discovered: …; imported: …; live: …; tracking: …; }>; }, $strip>>; }, $strip>; }; getByLogFilePath: { request: ZodObject<{ logFilePath: ZodString; }, $strip>; response: ZodObject<{ session: ZodNullable<ZodObject<{ adapterName: ZodString; adapterSessionId: ZodString; cwd: ZodNullable<ZodString>; discoveredAt: ZodNumber; forkPointMessageId: ZodNullable<ZodString>; kind: ZodEnum<{ compress: …; fork: …; root: …; subagent: …; }>; logFilePath: ZodNullable<ZodString>; model: ZodNullable<ZodString>; parentAdapterSessionId: ZodNullable<ZodString>; sessionId: ZodNullable<ZodString>; startedAt: ZodNumber; status: ZodEnum<{ discovered: …; imported: …; live: …; tracking: …; }>; }, $strip>>; }, $strip>; }; linkSession: { request: ZodObject<{ adapterSessionId: ZodString; sessionId: ZodString; }, $strip>; response: ZodObject<{ success: ZodBoolean; }, $strip>; }; list: { request: ZodObject<{ }, $strip>; response: ZodObject<{ sessions: ZodArray<ZodObject<{ adapterName: ZodString; adapterSessionId: ZodString; cwd: ZodNullable<ZodString>; discoveredAt: ZodNumber; forkPointMessageId: ZodNullable<ZodString>; kind: ZodEnum<{ compress: …; fork: …; root: …; subagent: …; }>; logFilePath: ZodNullable<ZodString>; model: ZodNullable<ZodString>; parentAdapterSessionId: ZodNullable<ZodString>; sessionId: ZodNullable<ZodString>; startedAt: ZodNumber; status: ZodEnum<{ discovered: …; imported: …; live: …; tracking: …; }>; }, $strip>>; }, $strip>; }; updateStatus: { request: ZodObject<{ adapterSessionId: ZodString; status: ZodEnum<{ discovered: "discovered"; imported: "imported"; live: "live"; tracking: "tracking"; }>; }, $strip>; response: ZodObject<{ success: ZodBoolean; }, $strip>; }; upsert: { request: ZodDiscriminatedUnion<[ZodObject<{ adapterName: ZodString; adapterSessionId: ZodString; cwd: ZodNullable<ZodString>; forkPointMessageId: ZodNull; kind: ZodLiteral<"root">; logFilePath: ZodOptional<ZodNullable<ZodString>>; model: ZodNullable<ZodString>; parentAdapterSessionId: ZodNull; startedAt: ZodOptional<ZodNumber>; }, $strip>, ZodObject<{ adapterName: ZodString; adapterSessionId: ZodString; cwd: ZodNullable<ZodString>; forkPointMessageId: ZodString; kind: ZodLiteral<"fork">; logFilePath: ZodOptional<ZodNullable<ZodString>>; model: ZodNullable<ZodString>; parentAdapterSessionId: ZodString; startedAt: ZodOptional<ZodNumber>; }, $strip>, ZodObject<{ adapterName: ZodString; adapterSessionId: ZodString; cwd: ZodNullable<ZodString>; forkPointMessageId: ZodNull; kind: ZodLiteral<"subagent">; logFilePath: ZodOptional<ZodNullable<ZodString>>; model: ZodNullable<ZodString>; parentAdapterSessionId: ZodString; startedAt: ZodOptional<ZodNumber>; }, $strip>, ZodObject<{ adapterName: ZodString; adapterSessionId: ZodString; cwd: ZodNullable<ZodString>; forkPointMessageId: ZodNull; kind: ZodLiteral<"compress">; logFilePath: ZodOptional<ZodNullable<ZodString>>; model: ZodNullable<ZodString>; parentAdapterSessionId: ZodString; startedAt: ZodOptional<ZodNumber>; }, $strip>], "kind">; response: ZodObject<{ adapterSessionId: ZodString; created: ZodBoolean; sessionId: ZodNullable<ZodString>; }, $strip>; }; }>, {[key: string]: string | number | ({ kind: “fork”; parentAdapterSessionId: string; forkPointMessageId: string; } | { kind: “subagent”; parentAdapterSessionId: string; forkPointMessageId: null; } | { kind: “compress”; parentAdapterSessionId: string; forkPointMessageId: null; } | { …; }) & { …; } | null; }, { drizzle: { adapterSessions: SQLiteTableWithColumns<{ columns: { 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: "adapter_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: true; name: "adapter_session_id"; notNull: true; tableName: "adapter_sessions"; }, { }, { length: number | undefined; }>; 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: "adapter_sessions"; }, { }, { length: number | undefined; }>; discoveredAt: 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: "discovered_at"; notNull: true; tableName: "adapter_sessions"; }, { }, { }>; 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: "adapter_sessions"; }, { }, { length: number | undefined; }>; kind: SQLiteColumn<{ baseColumn: never; columnType: "SQLiteText"; data: "fork" | "subagent" | "compress" | "root"; dataType: "string"; driverParam: string; enumValues: ["root", "fork", "subagent", "compress"]; generated: undefined; hasDefault: true; hasRuntimeDefault: false; identity: undefined; isAutoincrement: false; isPrimaryKey: false; name: "kind"; notNull: true; tableName: "adapter_sessions"; }, { }, { length: number | undefined; }>; logFilePath: 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: "log_file_path"; notNull: false; tableName: "adapter_sessions"; }, { }, { length: number | undefined; }>; 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: "adapter_sessions"; }, { }, { length: number | undefined; }>; parentAdapterSessionId: 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_adapter_session_id"; notNull: false; tableName: "adapter_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: false; name: "session_id"; notNull: false; tableName: "adapter_sessions"; }, { }, { length: number | undefined; }>; startedAt: 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: "started_at"; notNull: true; tableName: "adapter_sessions"; }, { }, { }>; status: SQLiteColumn<{ baseColumn: never; columnType: "SQLiteText"; data: "discovered" | "imported" | "live" | "tracking"; dataType: "string"; driverParam: string; enumValues: ["discovered", "imported", "live", "tracking"]; generated: undefined; hasDefault: true; hasRuntimeDefault: false; identity: undefined; isAutoincrement: false; isPrimaryKey: false; name: "status"; notNull: true; tableName: "adapter_sessions"; }, { }, { length: number | undefined; }>; }; dialect: "sqlite"; name: "adapter_sessions"; schema: undefined; }>; }; }, { countByAdapter: { request: ZodObject<{ adapterName: ZodString; }, $strip>; response: ZodObject<{ discovered: ZodNumber; imported: ZodNumber; total: ZodNumber; }, $strip>; }; createAndLink: { request: ZodObject<{ adapterId: ZodString; adapterName: ZodString; adapterSessionId: ZodString; existingSessionId: ZodOptional<ZodString>; metadata: ZodIntersection<ZodUnion<readonly [ZodObject<{ forkPointMessageId: ZodNull; kind: ZodNull; parentAdapterSessionId: ZodNull; }, $strip>, ZodObject<{ forkPointMessageId: ZodString; kind: ZodLiteral<…>; parentAdapterSessionId: ZodString; }, $strip>, ZodObject<{ forkPointMessageId: ZodNull; kind: ZodLiteral<…>; parentAdapterSessionId: ZodString; }, $strip>, ZodObject<{ forkPointMessageId: ZodNull; kind: ZodLiteral<…>; parentAdapterSessionId: ZodString; }, $strip>]>, ZodObject<{ cwd: ZodNullable<ZodString>; model: ZodNullable<ZodString>; title: ZodNullable<ZodString>; }, $strip>>; }, $strip>; response: ZodObject<{ created: ZodBoolean; sessionId: ZodString; }, $strip>; }; get: { request: ZodObject<{ adapterSessionId: ZodString; }, $strip>; response: ZodObject<{ session: ZodNullable<ZodObject<{ adapterName: ZodString; adapterSessionId: ZodString; cwd: ZodNullable<ZodString>; discoveredAt: ZodNumber; forkPointMessageId: ZodNullable<ZodString>; kind: ZodEnum<{ compress: "compress"; fork: "fork"; root: "root"; subagent: "subagent"; }>; logFilePath: ZodNullable<ZodString>; model: ZodNullable<ZodString>; parentAdapterSessionId: ZodNullable<ZodString>; sessionId: ZodNullable<ZodString>; startedAt: ZodNumber; status: ZodEnum<{ discovered: "discovered"; imported: "imported"; live: "live"; tracking: "tracking"; }>; }, $strip>>; }, $strip>; }; getByLogFilePath: { request: ZodObject<{ logFilePath: ZodString; }, $strip>; response: ZodObject<{ session: ZodNullable<ZodObject<{ adapterName: ZodString; adapterSessionId: ZodString; cwd: ZodNullable<ZodString>; discoveredAt: ZodNumber; forkPointMessageId: ZodNullable<ZodString>; kind: ZodEnum<{ compress: "compress"; fork: "fork"; root: "root"; subagent: "subagent"; }>; logFilePath: ZodNullable<ZodString>; model: ZodNullable<ZodString>; parentAdapterSessionId: ZodNullable<ZodString>; sessionId: ZodNullable<ZodString>; startedAt: ZodNumber; status: ZodEnum<{ discovered: "discovered"; imported: "imported"; live: "live"; tracking: "tracking"; }>; }, $strip>>; }, $strip>; }; linkSession: { request: ZodObject<{ adapterSessionId: ZodString; sessionId: ZodString; }, $strip>; response: ZodObject<{ success: ZodBoolean; }, $strip>; }; list: { request: ZodObject<{ }, $strip>; response: ZodObject<{ sessions: ZodArray<ZodObject<{ adapterName: ZodString; adapterSessionId: ZodString; cwd: ZodNullable<ZodString>; discoveredAt: ZodNumber; forkPointMessageId: ZodNullable<ZodString>; kind: ZodEnum<{ compress: "compress"; fork: "fork"; root: "root"; subagent: "subagent"; }>; logFilePath: ZodNullable<ZodString>; model: ZodNullable<ZodString>; parentAdapterSessionId: ZodNullable<ZodString>; sessionId: ZodNullable<ZodString>; startedAt: ZodNumber; status: ZodEnum<{ discovered: "discovered"; imported: "imported"; live: "live"; tracking: "tracking"; }>; }, $strip>>; }, $strip>; }; updateStatus: { request: ZodObject<{ adapterSessionId: ZodString; status: ZodEnum<{ discovered: "discovered"; imported: "imported"; live: "live"; tracking: "tracking"; }>; }, $strip>; response: ZodObject<{ success: ZodBoolean; }, $strip>; }; upsert: { request: ZodDiscriminatedUnion<[ZodObject<{ adapterName: ZodString; adapterSessionId: ZodString; cwd: ZodNullable<ZodString>; forkPointMessageId: ZodNull; kind: ZodLiteral<"root">; logFilePath: ZodOptional<ZodNullable<ZodString>>; model: ZodNullable<ZodString>; parentAdapterSessionId: ZodNull; startedAt: ZodOptional<ZodNumber>; }, $strip>, ZodObject<{ adapterName: ZodString; adapterSessionId: ZodString; cwd: ZodNullable<ZodString>; forkPointMessageId: ZodString; kind: ZodLiteral<"fork">; logFilePath: ZodOptional<ZodNullable<ZodString>>; model: ZodNullable<ZodString>; parentAdapterSessionId: ZodString; startedAt: ZodOptional<ZodNumber>; }, $strip>, ZodObject<{ adapterName: ZodString; adapterSessionId: ZodString; cwd: ZodNullable<ZodString>; forkPointMessageId: ZodNull; kind: ZodLiteral<"subagent">; logFilePath: ZodOptional<ZodNullable<ZodString>>; model: ZodNullable<ZodString>; parentAdapterSessionId: ZodString; startedAt: ZodOptional<ZodNumber>; }, $strip>, ZodObject<{ adapterName: ZodString; adapterSessionId: ZodString; cwd: ZodNullable<ZodString>; forkPointMessageId: ZodNull; kind: ZodLiteral<"compress">; logFilePath: ZodOptional<ZodNullable<ZodString>>; model: ZodNullable<ZodString>; parentAdapterSessionId: ZodString; startedAt: ZodOptional<ZodNumber>; }, $strip>], "kind">; response: ZodObject<{ adapterSessionId: ZodString; created: ZodBoolean; sessionId: ZodNullable<ZodString>; }, $strip>; }; }>

Defined in: ../../../packages/services/core/src/session/adapter-sessions/namespace.ts:91

Adapter session storage namespace.

Provides bus subjects for managing adapter session records. Adapter sessions track sessions discovered from external adapter logs (e.g., Claude Code) and maintain lineage information for fork detection.