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:
sessionsrows.agents_registryrows.session_handoffsrows.session_workflow_runsmapping.session_auditlifecycle rows.
Per DEC-147, the actual session_messages rows live in @graphorin/store-sqlite's MemoryStore (single source of truth).
Stable
Implements
Constructors
Constructor
new SqliteSessionStore(conn): SqliteSessionStore;Defined in: packages/store-sqlite/src/session-store.ts:31
Parameters
| Parameter | Type |
|---|---|
conn | SqliteConnection |
Returns
SqliteSessionStore
Methods
appendAuditEntry()
appendAuditEntry(entry): Promise<void>;Defined in: packages/store-sqlite/src/session-store.ts:203
Append a session-lifecycle audit row.
Parameters
| Parameter | Type |
|---|---|
entry | SessionAuditEntry |
Returns
Promise<void>
Implementation of
SessionStoreExt.appendAuditEntry
appendHandoff()
appendHandoff(sessionId, record): Promise<void>;Defined in: packages/store-sqlite/src/session-store.ts:135
Parameters
| Parameter | Type |
|---|---|
sessionId | string |
record | HandoffRecord |
Returns
Promise<void>
Implementation of
attachWorkflowRun()
attachWorkflowRun(run): Promise<void>;Defined in: packages/store-sqlite/src/session-store.ts:168
Parameters
| Parameter | Type |
|---|---|
run | SessionWorkflowRun |
Returns
Promise<void>
Implementation of
SessionStoreExt.attachWorkflowRun
closeSession()
closeSession(sessionId, closedAt): Promise<void>;Defined in: packages/store-sqlite/src/session-store.ts:90
Parameters
| Parameter | Type |
|---|---|
sessionId | string |
closedAt | string |
Returns
Promise<void>
Implementation of
createSession()
createSession(metadata): Promise<void>;Defined in: packages/store-sqlite/src/session-store.ts:35
Parameters
| Parameter | Type |
|---|---|
metadata | SessionMetadata |
Returns
Promise<void>
Implementation of
deleteAgent()
deleteAgent(agentId): Promise<void>;Defined in: packages/store-sqlite/src/session-store.ts:117
Hard-delete an agent. Used by AgentRegistry.delete(...).
Parameters
| Parameter | Type |
|---|---|
agentId | string |
Returns
Promise<void>
Implementation of
getSession()
getSession(sessionId): Promise<
| SessionMetadata
| null>;Defined in: packages/store-sqlite/src/session-store.ts:52
Parameters
| Parameter | Type |
|---|---|
sessionId | string |
Returns
Promise< | SessionMetadata | null>
Implementation of
listAgents()
listAgents(): Promise<readonly AgentRegistryEntry[]>;Defined in: packages/store-sqlite/src/session-store.ts:128
List all known agents (including retired ones).
Returns
Promise<readonly AgentRegistryEntry[]>
Implementation of
listAuditEntries()
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
| Parameter | Type |
|---|---|
sessionId | string |
opts | { limit?: number; } |
opts.limit? | number |
Returns
Promise<readonly SessionAuditEntry[]>
Implementation of
SessionStoreExt.listAuditEntries
listHandoffs()
listHandoffs(sessionId): Promise<readonly HandoffRecord[]>;Defined in: packages/store-sqlite/src/session-store.ts:160
Parameters
| Parameter | Type |
|---|---|
sessionId | string |
Returns
Promise<readonly HandoffRecord[]>
Implementation of
listSessions()
listSessions(scope): Promise<readonly SessionMetadata[]>;Defined in: packages/store-sqlite/src/session-store.ts:57
Parameters
| Parameter | Type |
|---|---|
scope | Pick<SessionScope, "userId" | "agentId"> |
Returns
Promise<readonly SessionMetadata[]>
Implementation of
listWorkflowRuns()
listWorkflowRuns(sessionId): Promise<readonly SessionWorkflowRun[]>;Defined in: packages/store-sqlite/src/session-store.ts:187
Parameters
| Parameter | Type |
|---|---|
sessionId | string |
Returns
Promise<readonly SessionWorkflowRun[]>
Implementation of
SessionStoreExt.listWorkflowRuns
pruneAuditEntries()
pruneAuditEntries(beforeEpochMs): Promise<number>;Defined in: packages/store-sqlite/src/session-store.ts:232
Delete audit rows older than the supplied epoch ms.
Parameters
| Parameter | Type |
|---|---|
beforeEpochMs | number |
Returns
Promise<number>
Implementation of
SessionStoreExt.pruneAuditEntries
registerAgent()
registerAgent(entry): Promise<void>;Defined in: packages/store-sqlite/src/session-store.ts:97
Parameters
| Parameter | Type |
|---|---|
entry | AgentRegistryEntry |
Returns
Promise<void>
Implementation of
resolveAgent()
resolveAgent(agentId): Promise<
| AgentRegistryEntry
| null>;Defined in: packages/store-sqlite/src/session-store.ts:121
Parameters
| Parameter | Type |
|---|---|
agentId | string |
Returns
Promise< | AgentRegistryEntry | null>
Implementation of
retireAgent()
retireAgent(agentId, retiredAt): Promise<void>;Defined in: packages/store-sqlite/src/session-store.ts:110
Parameters
| Parameter | Type |
|---|---|
agentId | string |
retiredAt | string |
Returns
Promise<void>
Implementation of
updateSession()
updateSession(sessionId, patch): Promise<void>;Defined in: packages/store-sqlite/src/session-store.ts:73
Parameters
| Parameter | Type |
|---|---|
sessionId | string |
patch | Partial<SessionMetadata> |
Returns
Promise<void>
Implementation of
updateWorkflowRunStatus()
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
| Parameter | Type |
|---|---|
sessionId | string |
workflowId | string |
threadId | string |
status | "running" | "suspended" | "completed" | "failed" |
Returns
Promise<void>