Skip to content

Graphorin API reference v0.4.0


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

Class: SqliteSessionStore

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

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).

Stable

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


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


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