ChainGraph API Documentation / @badaitech/chaingraph-trpc / server / InMemoryFlowStore

Class: InMemoryFlowStore

Defined in: packages/chaingraph-trpc/server/stores/flowStore/inMemoryFlowStore.ts:17

In-memory implementation of flow storage

Implements

• IFlowStore

Constructors

Constructor

new InMemoryFlowStore(): InMemoryFlowStore

Returns

InMemoryFlowStore

Methods

createFlow()

createFlow(metadata): Promise<Flow>

Defined in: packages/chaingraph-trpc/server/stores/flowStore/inMemoryFlowStore.ts:32

Creates a new flow with given metadata

Parameters

metadata

FlowMetadata

Flow metadata

Returns

Promise<Flow>

Created flow ID

Implementation of

IFlowStore.createFlow

---

deleteFlow()

deleteFlow(flowId): Promise<boolean>

Defined in: packages/chaingraph-trpc/server/stores/flowStore/inMemoryFlowStore.ts:115

Deletes flow

Parameters

flowId

string

Flow identifier

Returns

Promise<boolean>

true if flow was deleted, false if not found

Implementation of

IFlowStore.deleteFlow

---

getFlow()

getFlow(flowId): Promise<Flow | null>

Defined in: packages/chaingraph-trpc/server/stores/flowStore/inMemoryFlowStore.ts:46

Retrieves flow by ID

Parameters

flowId

string

Flow identifier

Returns

Promise<Flow | null>

Flow instance or null if not found

Implementation of

IFlowStore.getFlow

---

getFlowMetadata()

getFlowMetadata(flowId): Promise<FlowMetadata>

Defined in: packages/chaingraph-trpc/server/stores/flowStore/inMemoryFlowStore.ts:56

Retrieves flow metadata by ID

Parameters

flowId

string

Flow identifier

Returns

Promise<FlowMetadata>

Flow metadata

Throws

Error if flow not found

Implementation of

IFlowStore.getFlowMetadata

---

hasAccess()

hasAccess(flowId, userId): Promise<boolean>

Defined in: packages/chaingraph-trpc/server/stores/flowStore/inMemoryFlowStore.ts:144

Checks if user has access to flow

Parameters

flowId

string

Flow identifier

userId

string

User identifier

Returns

Promise<boolean>

true if user has access, false otherwise

Implementation of

IFlowStore.hasAccess

---

listFlows()

listFlows(ownerId, orderBy, limit): Promise<FlowMetadata[]>

Defined in: packages/chaingraph-trpc/server/stores/flowStore/inMemoryFlowStore.ts:68

Lists all available flows

Parameters

ownerId

string

orderBy

ListOrderBy

limit

number

Returns

Promise<FlowMetadata[]>

Array of flows

Implementation of

IFlowStore.listFlows

---

lockFlow()

lockFlow(flowId, timeout): Promise<void>

Defined in: packages/chaingraph-trpc/server/stores/flowStore/inMemoryFlowStore.ts:163

Locks a flow to prevent concurrent modifications. If the flow is already locked, this method will block until the lock is released.

Parameters

flowId

string

Flow identifier

timeout

number = 5000

Lock timeout in milliseconds (default: 5000 ms)

Returns

Promise<void>

Throws

Error if flow doesn't exist

Implementation of

IFlowStore.lockFlow

---

unlockFlow()

unlockFlow(flowId): Promise<void>

Defined in: packages/chaingraph-trpc/server/stores/flowStore/inMemoryFlowStore.ts:203

Unlocks a previously locked flow and grants lock to the next waiter if any

Parameters

flowId

string

Flow identifier

Returns

Promise<void>

Throws

Error if flow doesn't exist

Implementation of

IFlowStore.unlockFlow

---

updateFlow()

updateFlow(flow): Promise<Flow>

Defined in: packages/chaingraph-trpc/server/stores/flowStore/inMemoryFlowStore.ts:124

Updates flow with new data

Parameters

flow

Flow

Flow data

Returns

Promise<Flow>

Updated flow

Implementation of

IFlowStore.updateFlow