Variable: TurnStorageSubjects

Makaio Framework / services-core/turn/namespace / TurnStorageSubjects

Variable: TurnStorageSubjects

const TurnStorageSubjects: BusSubjects<FlatSubjectDefinitions<"storage:turn", { complete: { request: ZodObject<{ error: ZodOptional<ZodString>; expectedStatus: ZodOptional<ZodEnum<{ active: "active"; completed: "completed"; error: "error"; }>>; status: ZodEnum<{ completed: "completed"; error: "error"; }>; turnId: ZodString; usage: ZodOptional<ZodObject<{ byAgent: ZodOptional<ZodRecord<…, …>>; total: ZodObject<{ cost: …; inputTokens: …; outputTokens: …; }, $strip>; }, $strip>>; }, $strip>; response: ZodObject<{ transitioned: ZodBoolean; turn: ZodObject<{ completedAt: ZodOptional<ZodNumber>; error: ZodOptional<ZodString>; sessionId: ZodString; startedAt: ZodNumber; status: ZodEnum<{ active: "active"; completed: "completed"; error: "error"; }>; turnId: ZodString; turnNumber: ZodNumber; usage: ZodOptional<ZodObject<{ byAgent: …; total: …; }, $strip>>; }, $strip>; }, $strip>; }; create: { request: ZodObject<{ sessionId: ZodString; turnId: ZodOptional<ZodString>; }, $strip>; response: ZodObject<{ turn: ZodObject<{ completedAt: ZodOptional<ZodNumber>; error: ZodOptional<ZodString>; sessionId: ZodString; startedAt: ZodNumber; status: ZodEnum<{ active: "active"; completed: "completed"; error: "error"; }>; turnId: ZodString; turnNumber: ZodNumber; usage: ZodOptional<ZodObject<{ byAgent: …; total: …; }, $strip>>; }, $strip>; }, $strip>; }; get: { request: ZodObject<{ turnId: ZodString; }, $strip>; response: ZodObject<{ turn: ZodNullable<ZodObject<{ completedAt: ZodOptional<ZodNumber>; error: ZodOptional<ZodString>; sessionId: ZodString; startedAt: ZodNumber; status: ZodEnum<{ active: …; completed: …; error: …; }>; turnId: ZodString; turnNumber: ZodNumber; usage: ZodOptional<ZodObject<…, …>>; }, $strip>>; }, $strip>; }; getActive: { request: ZodObject<{ sessionId: ZodString; }, $strip>; response: ZodObject<{ turn: ZodNullable<ZodObject<{ completedAt: ZodOptional<ZodNumber>; error: ZodOptional<ZodString>; sessionId: ZodString; startedAt: ZodNumber; status: ZodEnum<{ active: …; completed: …; error: …; }>; turnId: ZodString; turnNumber: ZodNumber; usage: ZodOptional<ZodObject<…, …>>; }, $strip>>; }, $strip>; }; getBySession: { request: ZodObject<{ limit: ZodOptional<ZodNumber>; sessionId: ZodString; status: ZodOptional<ZodEnum<{ active: "active"; completed: "completed"; error: "error"; }>>; }, $strip>; response: ZodObject<{ turns: ZodArray<ZodObject<{ completedAt: ZodOptional<ZodNumber>; error: ZodOptional<ZodString>; sessionId: ZodString; startedAt: ZodNumber; status: ZodEnum<{ active: …; completed: …; error: …; }>; turnId: ZodString; turnNumber: ZodNumber; usage: ZodOptional<ZodObject<…, …>>; }, $strip>>; }, $strip>; }; listActive: { request: ZodObject<{ }, $strip>; response: ZodObject<{ turns: ZodArray<ZodObject<{ completedAt: ZodOptional<ZodNumber>; error: ZodOptional<ZodString>; sessionId: ZodString; startedAt: ZodNumber; status: ZodEnum<{ active: …; completed: …; error: …; }>; turnId: ZodString; turnNumber: ZodNumber; usage: ZodOptional<ZodObject<…, …>>; }, $strip>>; }, $strip>; }; set: { request: ZodObject<{ turn: ZodObject<{ completedAt: ZodOptional<ZodNumber>; error: ZodOptional<ZodString>; sessionId: ZodString; startedAt: ZodNumber; status: ZodEnum<{ active: "active"; completed: "completed"; error: "error"; }>; turnId: ZodString; turnNumber: ZodNumber; usage: ZodOptional<ZodObject<{ byAgent: …; total: …; }, $strip>>; }, $strip>; }, $strip>; response: ZodObject<{ turn: ZodObject<{ completedAt: ZodOptional<ZodNumber>; error: ZodOptional<ZodString>; sessionId: ZodString; startedAt: ZodNumber; status: ZodEnum<{ active: "active"; completed: "completed"; error: "error"; }>; turnId: ZodString; turnNumber: ZodNumber; usage: ZodOptional<ZodObject<{ byAgent: …; total: …; }, $strip>>; }, $strip>; }, $strip>; }; }>, "storage:turn"> = TurnStorageNamespace.subjects

Defined in: ../../../packages/services/core/src/turn/namespace.ts:23

Typed subjects for turn storage operations.