Skip to content

Graphorin API reference v0.15.1


Graphorin API reference / @graphorin/store-sqlite / / SqliteSessionStore

Class: SqliteSessionStore ​

Defined in: packages/store-sqlite/src/session-store.ts:29

Stable

Default SessionStore implementation. Owns:

  • sessions rows.
  • agents_registry rows.
  • session_handoffs rows.
  • session_workflow_runs mapping.
  • session_audit lifecycle rows.

Per DEC-147, the actual session_messages rows live in @graphorin/store-sqlite's MemoryStore (single source of truth).

Implements ​

Constructors ​

Constructor ​

ts
new SqliteSessionStore(conn): SqliteSessionStore;

Defined in: packages/store-sqlite/src/session-store.ts:31

Parameters ​

ParameterType
connSqliteConnection

Returns ​

SqliteSessionStore

Methods ​

appendAuditEntry() ​

ts
appendAuditEntry(entry): Promise<void>;

Defined in: packages/store-sqlite/src/session-store.ts:203

Append a session-lifecycle audit row.

Parameters ​

ParameterType
entrySessionAuditEntry

Returns ​

Promise&lt;void&gt;

Implementation of ​

SessionStoreExt.appendAuditEntry


appendHandoff() ​

ts
appendHandoff(sessionId, record): Promise<void>;

Defined in: packages/store-sqlite/src/session-store.ts:135

Parameters ​

ParameterType
sessionIdstring
recordHandoffRecord

Returns ​

Promise&lt;void&gt;

Implementation of ​

SessionStoreExt.appendHandoff


attachWorkflowRun() ​

ts
attachWorkflowRun(run): Promise<void>;

Defined in: packages/store-sqlite/src/session-store.ts:168

Parameters ​

ParameterType
runSessionWorkflowRun

Returns ​

Promise&lt;void&gt;

Implementation of ​

SessionStoreExt.attachWorkflowRun


closeSession() ​

ts
closeSession(sessionId, closedAt): Promise<void>;

Defined in: packages/store-sqlite/src/session-store.ts:90

Parameters ​

ParameterType
sessionIdstring
closedAtstring

Returns ​

Promise&lt;void&gt;

Implementation of ​

SessionStoreExt.closeSession


createSession() ​

ts
createSession(metadata): Promise<void>;

Defined in: packages/store-sqlite/src/session-store.ts:35

Parameters ​

ParameterType
metadataSessionMetadata

Returns ​

Promise&lt;void&gt;

Implementation of ​

SessionStoreExt.createSession


deleteAgent() ​

ts
deleteAgent(agentId): Promise<void>;

Defined in: packages/store-sqlite/src/session-store.ts:117

Hard-delete an agent. Used by AgentRegistry.delete(...).

Parameters ​

ParameterType
agentIdstring

Returns ​

Promise&lt;void&gt;

Implementation of ​

SessionStoreExt.deleteAgent


deleteSession() ​

ts
deleteSession(sessionId): Promise<void>;

Defined in: packages/store-sqlite/src/session-store.ts:238

Hard-delete a session + its handoffs / workflow runs / audit rows.

Parameters ​

ParameterType
sessionIdstring

Returns ​

Promise&lt;void&gt;

Implementation of ​

SessionStoreExt.deleteSession


getSession() ​

ts
getSession(sessionId): Promise<
  | SessionMetadata
| null>;

Defined in: packages/store-sqlite/src/session-store.ts:52

Parameters ​

ParameterType
sessionIdstring

Returns ​

Promise< | SessionMetadata | null>

Implementation of ​

SessionStoreExt.getSession


listAgents() ​

ts
listAgents(): Promise<readonly AgentRegistryEntry[]>;

Defined in: packages/store-sqlite/src/session-store.ts:128

List all known agents (including retired ones).

Returns ​

Promise&lt;readonly AgentRegistryEntry[]&gt;

Implementation of ​

SessionStoreExt.listAgents


listAuditEntries() ​

ts
listAuditEntries(sessionId, opts?): Promise<readonly SessionAuditEntry[]>;

Defined in: packages/store-sqlite/src/session-store.ts:220

List recent audit rows for a session, newest-first.

Parameters ​

ParameterType
sessionIdstring
opts{ limit?: number; }
opts.limit?number

Returns ​

Promise&lt;readonly SessionAuditEntry[]&gt;

Implementation of ​

SessionStoreExt.listAuditEntries


listHandoffs() ​

ts
listHandoffs(sessionId): Promise<readonly HandoffRecord[]>;

Defined in: packages/store-sqlite/src/session-store.ts:160

Parameters ​

ParameterType
sessionIdstring

Returns ​

Promise&lt;readonly HandoffRecord[]&gt;

Implementation of ​

SessionStoreExt.listHandoffs


listSessions() ​

ts
listSessions(scope): Promise<readonly SessionMetadata[]>;

Defined in: packages/store-sqlite/src/session-store.ts:57

Parameters ​

ParameterType
scopePick&lt;SessionScope, "userId" | "agentId"&gt;

Returns ​

Promise&lt;readonly SessionMetadata[]&gt;

Implementation of ​

SessionStoreExt.listSessions


listWorkflowRuns() ​

ts
listWorkflowRuns(sessionId): Promise<readonly SessionWorkflowRun[]>;

Defined in: packages/store-sqlite/src/session-store.ts:187

Parameters ​

ParameterType
sessionIdstring

Returns ​

Promise&lt;readonly SessionWorkflowRun[]&gt;

Implementation of ​

SessionStoreExt.listWorkflowRuns


pruneAuditEntries() ​

ts
pruneAuditEntries(beforeEpochMs): Promise<number>;

Defined in: packages/store-sqlite/src/session-store.ts:232

Delete audit rows older than the supplied epoch ms.

Parameters ​

ParameterType
beforeEpochMsnumber

Returns ​

Promise&lt;number&gt;

Implementation of ​

SessionStoreExt.pruneAuditEntries


pruneSessions() ​

ts
pruneSessions(opts): Promise<number>;

Defined in: packages/store-sqlite/src/session-store.ts:245

Retention sweep - delete every session matching the policy.

Parameters ​

ParameterType
opts{ beforeEpochMs?: number; closedOnly?: boolean; }
opts.beforeEpochMs?number
opts.closedOnly?boolean

Returns ​

Promise&lt;number&gt;

Implementation of ​

SessionStoreExt.pruneSessions


registerAgent() ​

ts
registerAgent(entry): Promise<void>;

Defined in: packages/store-sqlite/src/session-store.ts:97

Parameters ​

ParameterType
entryAgentRegistryEntry

Returns ​

Promise&lt;void&gt;

Implementation of ​

SessionStoreExt.registerAgent


resolveAgent() ​

ts
resolveAgent(agentId): Promise<
  | AgentRegistryEntry
| null>;

Defined in: packages/store-sqlite/src/session-store.ts:121

Parameters ​

ParameterType
agentIdstring

Returns ​

Promise< | AgentRegistryEntry | null>

Implementation of ​

SessionStoreExt.resolveAgent


retireAgent() ​

ts
retireAgent(agentId, retiredAt): Promise<void>;

Defined in: packages/store-sqlite/src/session-store.ts:110

Parameters ​

ParameterType
agentIdstring
retiredAtstring

Returns ​

Promise&lt;void&gt;

Implementation of ​

SessionStoreExt.retireAgent


updateSession() ​

ts
updateSession(sessionId, patch): Promise<void>;

Defined in: packages/store-sqlite/src/session-store.ts:73

Parameters ​

ParameterType
sessionIdstring
patchPartial&lt;SessionMetadata&gt;

Returns ​

Promise&lt;void&gt;

Implementation of ​

SessionStoreExt.updateSession


updateWorkflowRunStatus() ​

ts
updateWorkflowRunStatus(
   sessionId, 
   workflowId, 
   threadId, 
status): Promise<void>;

Defined in: packages/store-sqlite/src/session-store.ts:175

Update the status of a workflow attachment.

Parameters ​

ParameterType
sessionIdstring
workflowIdstring
threadIdstring
status"running" | "suspended" | "completed" | "failed"

Returns ​

Promise&lt;void&gt;

Implementation of ​

SessionStoreExt.updateWorkflowRunStatus