BridgeSessionStore

Bridge SessionStore that splits concerns between CF and Kuralle.

CF owns messages (via AIChatAgent’s cf_ai_chat_agent_messages table). Kuralle owns orchestration state (via OrchestrationStore).

On get(): reconstructs a Session by combining CF’s messages with Kuralle’s orchestration state.

On save(): extracts orchestration state from the Session and saves it. Does NOT save messages — CF handles that via persistMessages().

Implements

• SessionStore

Constructors

Constructor

new BridgeSessionStore(options): BridgeSessionStore;

Parameters

Parameter	Type
options	{ cfMessages: UIMessage<unknown, UIDataTypes, UITools>[]; defaultAgentId: string; sessionId: string; sqlExecutor: SqlExecutor; }
options.cfMessages	UIMessage<unknown, UIDataTypes, UITools>[]
options.defaultAgentId	string
options.sessionId	string
options.sqlExecutor	SqlExecutor

Returns

BridgeSessionStore

Methods

cleanup()

cleanup(maxAgeMs): Promise<number>;

Garbage-collect orchestration rows older than maxAgeMs.

Parameters

Parameter	Type
maxAgeMs	number

Returns

Promise<number>

Implementation of

SessionStore.cleanup

---

delete()

delete(id): Promise<void>;

Parameters

Parameter	Type
id	string

Returns

Promise<void>

Implementation of

SessionStore.delete

---

get()

get(id): Promise<Session | null>;

Reconstruct a Session from CF messages + orchestration state. Keyed by id: multiple sessions (calls) per DO get isolated rows.

Parameters

Parameter	Type
id	string

Returns

Promise<Session | null>

Implementation of

SessionStore.get

---

list()

list(): Promise<Session[]>;

Returns

Promise<Session[]>

Implementation of

SessionStore.list

---

save()

save(session): Promise<void>;

Save only orchestration state. CF handles message persistence.

Parameters

Parameter	Type
session	Session

Returns

Promise<void>

Implementation of

SessionStore.save