Class: SupabaseRunStore

Defined in: packages/orchestration/src/run/run-store.ts:9

Supabase-backed run persistence with append-only event log. Follows the stream_chunks pattern from 006_stream_chunks.sql.

Implements

• RunStore

Constructors

Constructor

new SupabaseRunStore(supabase, userId): SupabaseRunStore

Defined in: packages/orchestration/src/run/run-store.ts:10

Parameters

supabase

SupabaseClient

userId

string

Returns

SupabaseRunStore

Methods

appendEvent()

appendEvent(runId, seq, event): Promise<void>

Defined in: packages/orchestration/src/run/run-store.ts:76

Append a stream event for replay

Parameters

runId

string

seq

number

event

BaleybotStreamEvent

Returns

Promise<void>

Implementation of

RunStore.appendEvent

---

create()

create(ticketId, agentName, parentRunId?): Promise<Run>

Defined in: packages/orchestration/src/run/run-store.ts:12

Parameters

ticketId

string

agentName

string

parentRunId?

string

Returns

Promise<Run>

Implementation of

RunStore.create

---

get()

get(id): Promise<Run | null>

Defined in: packages/orchestration/src/run/run-store.ts:31

Parameters

id

string

Returns

Promise<Run | null>

Implementation of

RunStore.get

---

list()

list(filter?): Promise<Run[]>

Defined in: packages/orchestration/src/run/run-store.ts:64

Parameters

filter?

agentName?

string

status?

RunStatus[]

ticketId?

string

Returns

Promise<Run[]>

Implementation of

RunStore.list

---

loadEvents()

loadEvents(runId): Promise<BaleybotStreamEvent[]>

Defined in: packages/orchestration/src/run/run-store.ts:84

Load events for replay

Parameters

runId

string

Returns

Promise<BaleybotStreamEvent[]>

Implementation of

RunStore.loadEvents

---

update()

update(id, changes): Promise<Run>

Defined in: packages/orchestration/src/run/run-store.ts:43

Parameters

id

string

changes

Partial<Run>

Returns

Promise<Run>

Implementation of

RunStore.update