import { DatabaseSync } from "node:sqlite"; import type { EdgeTransfer, EdgeTransferId, NodeAttempt, NodeAttemptId, WorkflowArchiveStateRecord, WorkflowCheckpoint, WorkflowCheckpointId, WorkflowDefinitionSnapshot, WorkflowDefinitionSnapshotId, WorkflowDeleteTombstoneRecord, WorkflowDraftRecord, WorkflowEventId, WorkflowEventRecord, WorkflowHumanActionId, WorkflowHumanActionRecord, WorkflowIdentityRecord, WorkflowPublishedVersionRecord, WorkflowRun, WorkflowRunId, WorkflowWakeup, WorkflowWakeupId, WorkflowWaitToken, WorkflowWaitTokenId } from "../types/index.js"; import type { WorkflowArchiveStateListFilter, WorkflowArchiveStateStore, WorkflowCheckpointListFilter, WorkflowCheckpointStore, WorkflowDefinitionSnapshotListFilter, WorkflowDefinitionSnapshotStore, WorkflowDeleteTombstoneListFilter, WorkflowDeleteTombstoneStore, WorkflowDraftListFilter, WorkflowDraftStore, WorkflowEdgeTransferListFilter, WorkflowEdgeTransferStore, WorkflowEventListFilter, WorkflowEventStore, WorkflowHumanActionListFilter, WorkflowHumanActionStore, WorkflowIdentityListFilter, WorkflowIdentityStore, WorkflowNodeAttemptListFilter, WorkflowNodeAttemptStore, WorkflowPublishedVersionListFilter, WorkflowPublishedVersionStore, WorkflowRunListFilter, WorkflowRunStore, WorkflowWaitTokenListFilter, WorkflowWaitTokenStore, WorkflowWakeupListFilter, WorkflowWakeupStore } from "./contracts.js"; export { assertPublishedWorkflowVersionRecord, assertWorkflowRecordSource, assertWorkflowRecordStatus, createWorkflowPublishedVersionRecord, isWorkflowRecordSource, isWorkflowRecordStatus, WORKFLOW_RECORD_SOURCES, WORKFLOW_RECORD_STATUSES, type CreateWorkflowPublishedVersionRecordInput, } from "./catalog-records.js"; export { createWorkflowSqlitePath, isNormalSessionFactStorageName, WORKFLOW_SQLITE_FILENAME, WORKFLOW_SQLITE_NORMAL_SESSION_FACT_KEYWORDS, WORKFLOW_SQLITE_SCHEMA_VERSION, WORKFLOW_SQLITE_SESSION_LINK_COLUMNS, WORKFLOW_SQLITE_TABLES, type WorkflowSqliteTableName, } from "./schema.js"; export type { WorkflowArchiveStateListFilter, WorkflowArchiveStateStore, WorkflowCheckpointListFilter, WorkflowCheckpointStore, WorkflowDefinitionSnapshotListFilter, WorkflowDefinitionSnapshotStore, WorkflowDeleteTombstoneListFilter, WorkflowDeleteTombstoneStore, WorkflowDraftListFilter, WorkflowDraftStore, WorkflowEdgeTransferListFilter, WorkflowEdgeTransferStore, WorkflowEventListFilter, WorkflowEventStore, WorkflowHumanActionListFilter, WorkflowHumanActionStore, WorkflowIdentityListFilter, WorkflowIdentityStore, WorkflowNodeAttemptListFilter, WorkflowNodeAttemptStore, WorkflowPublishedVersionListFilter, WorkflowPublishedVersionStore, WorkflowRunListFilter, WorkflowRunStore, WorkflowWaitTokenListFilter, WorkflowWaitTokenStore, WorkflowWakeupListFilter, WorkflowWakeupStore, } from "./contracts.js"; export declare class SqliteWorkflowRunStore implements WorkflowRunStore, WorkflowDefinitionSnapshotStore, WorkflowIdentityStore, WorkflowDraftStore, WorkflowPublishedVersionStore, WorkflowArchiveStateStore, WorkflowDeleteTombstoneStore, WorkflowEventStore, WorkflowWaitTokenStore, WorkflowNodeAttemptStore, WorkflowEdgeTransferStore, WorkflowCheckpointStore, WorkflowWakeupStore, WorkflowHumanActionStore { readonly db: DatabaseSync; constructor(path: string); transaction(action: () => T): T; saveDefinitionSnapshot(snapshot: WorkflowDefinitionSnapshot): void; getDefinitionSnapshot(id: WorkflowDefinitionSnapshotId): WorkflowDefinitionSnapshot | undefined; listDefinitionSnapshots(filter?: WorkflowDefinitionSnapshotListFilter): WorkflowDefinitionSnapshot[]; saveWorkflowIdentity(record: WorkflowIdentityRecord): void; getWorkflowIdentity(workflowId: string): WorkflowIdentityRecord | undefined; listWorkflowIdentities(filter?: WorkflowIdentityListFilter): WorkflowIdentityRecord[]; saveWorkflowDraft(record: WorkflowDraftRecord): void; getWorkflowDraft(draftId: string): WorkflowDraftRecord | undefined; listWorkflowDrafts(filter?: WorkflowDraftListFilter): WorkflowDraftRecord[]; saveWorkflowArchiveState(record: WorkflowArchiveStateRecord): void; getWorkflowArchiveState(workflowId: string): WorkflowArchiveStateRecord | undefined; listWorkflowArchiveStates(filter?: WorkflowArchiveStateListFilter): WorkflowArchiveStateRecord[]; saveWorkflowDeleteTombstone(record: WorkflowDeleteTombstoneRecord): void; getWorkflowDeleteTombstone(workflowId: string): WorkflowDeleteTombstoneRecord | undefined; listWorkflowDeleteTombstones(filter?: WorkflowDeleteTombstoneListFilter): WorkflowDeleteTombstoneRecord[]; savePublishedWorkflowVersion(record: WorkflowPublishedVersionRecord): void; getPublishedWorkflowVersion(workflowId: string, version: string): WorkflowPublishedVersionRecord | undefined; listPublishedWorkflowVersions(filter?: WorkflowPublishedVersionListFilter): WorkflowPublishedVersionRecord[]; saveRun(run: WorkflowRun): void; getRun(id: WorkflowRunId): WorkflowRun | undefined; listRuns(filter?: WorkflowRunListFilter): WorkflowRun[]; saveEvent(event: WorkflowEventRecord): void; getEvent(id: WorkflowEventId): WorkflowEventRecord | undefined; listEvents(filter?: WorkflowEventListFilter): WorkflowEventRecord[]; saveNodeAttempt(nodeAttempt: NodeAttempt): void; getNodeAttempt(id: NodeAttemptId): NodeAttempt | undefined; listNodeAttempts(filter?: WorkflowNodeAttemptListFilter): NodeAttempt[]; saveEdgeTransfer(transfer: EdgeTransfer): void; getEdgeTransfer(id: EdgeTransferId): EdgeTransfer | undefined; listEdgeTransfers(filter?: WorkflowEdgeTransferListFilter): EdgeTransfer[]; saveCheckpoint(checkpoint: WorkflowCheckpoint): void; getCheckpoint(id: WorkflowCheckpointId): WorkflowCheckpoint | undefined; listCheckpoints(filter?: WorkflowCheckpointListFilter): WorkflowCheckpoint[]; saveWakeup(wakeup: WorkflowWakeup): void; getWakeup(id: WorkflowWakeupId): WorkflowWakeup | undefined; listWakeups(filter?: WorkflowWakeupListFilter): WorkflowWakeup[]; saveWaitToken(token: WorkflowWaitToken): void; getWaitToken(id: WorkflowWaitTokenId): WorkflowWaitToken | undefined; listWaitTokens(filter?: WorkflowWaitTokenListFilter): WorkflowWaitToken[]; saveHumanAction(action: WorkflowHumanActionRecord): void; getHumanAction(id: WorkflowHumanActionId): WorkflowHumanActionRecord | undefined; listHumanActions(filter?: WorkflowHumanActionListFilter): WorkflowHumanActionRecord[]; close(): void; } //# sourceMappingURL=index.d.ts.map