Class D1ThreadStateStorage

Hierarchy

ThreadStateStorage
- D1ThreadStateStorage

Index

Constructors

Methods

dangerouslyClearAll deleteState getState init setState

Constructors

constructor

new D1ThreadStateStorage(
db: SignalDatabase,
tablePrefix?: string,
): D1ThreadStateStorage
Parameters
- db: SignalDatabase
- tablePrefix: string = ''
Returns D1ThreadStateStorage
Overrides ThreadStateStorage.constructor
- Defined in packages/flowsafe/src/signals/thread-state-d1.ts:32

Methods

dangerouslyClearAll

dangerouslyClearAll(): Promise<void>
Delete all thread state. Used for testing.

Returns Promise<void>
Overrides ThreadStateStorage.dangerouslyClearAll
- Defined in packages/flowsafe/src/signals/thread-state-d1.ts:119

deleteState

deleteState(args: { threadId: string; type: string }): Promise<void>
Delete the state value for a (threadId, type) pair.
Parameters
- args: { threadId: string; type: string }
Returns Promise<void>
Overrides ThreadStateStorage.deleteState
- Defined in packages/flowsafe/src/signals/thread-state-d1.ts:111

getState

getState<T = unknown>(
args: { threadId: string; type: string },
): Promise<T | undefined>
Get the state value for a (threadId, type) pair. Returns undefined when no value has been set.
Type Parameters
- T = unknown
Parameters
- args: { threadId: string; type: string }
Returns Promise<T | undefined>
Overrides ThreadStateStorage.getState
- Defined in packages/flowsafe/src/signals/thread-state-d1.ts:74

init

init(): Promise<void>
Initialize the thread-state store (create tables, indexes, etc).

Returns Promise<void>
Overrides ThreadStateStorage.init
- Defined in packages/flowsafe/src/signals/thread-state-d1.ts:70

setState

setState<T = unknown>(
args: { threadId: string; type: string; value: T },
): Promise<void>
Set the state value for a (threadId, type) pair. Full-replacement semantics: the stored value becomes exactly value.
Type Parameters
- T = unknown
Parameters
- args: { threadId: string; type: string; value: T }
Returns Promise<void>
Overrides ThreadStateStorage.setState
- Defined in packages/flowsafe/src/signals/thread-state-d1.ts:89