Variable: MessageStorageSubjects
Makaio Framework / contracts / MessageStorageSubjects
Variable: MessageStorageSubjects
Section titled “Variable: MessageStorageSubjects”
constMessageStorageSubjects:BusSubjects<FlatSubjectDefinitions<"storage:message", {append: {request:ZodObject<{emitEvent:ZodOptional<ZodBoolean>;message:ZodObject<{adapterMessageId:ZodOptional<ZodString>;adapterSessionId:ZodOptional<ZodString>;agentId:ZodOptional<ZodString>;blocks:ZodArray<ZodDiscriminatedUnion<[…, …, …, …],"type">>;contentText:ZodString;editOf:ZodOptional<ZodString>;messageId:ZodOptional<ZodString>;origin:ZodOptional<ZodEnum<{compact: …;text: …;voice: …; }>>;role:ZodEnum<{assistant:"assistant";user:"user"; }>;sessionId:ZodString;timestamp:ZodNumber;turnId:ZodNullable<ZodString>; },$strip>; },$strip>;response:ZodObject<{message:ZodObject<{adapterMessageId:ZodOptional<ZodString>;adapterSessionId:ZodOptional<ZodString>;agentId:ZodOptional<ZodString>;blocks:ZodArray<ZodDiscriminatedUnion<[…, …, …, …],"type">>;contentText:ZodString;editOf:ZodOptional<ZodString>;messageId:ZodString;origin:ZodOptional<ZodEnum<{compact: …;text: …;voice: …; }>>;role:ZodEnum<{assistant:"assistant";user:"user"; }>;sessionId:ZodString;timestamp:ZodNumber;turnId:ZodNullable<ZodString>; },$strip>; },$strip>; };ftsSearch: {request:ZodObject<{limit:ZodDefault<ZodOptional<ZodNumber>>;query:ZodString;sessionId:ZodOptional<ZodString>; },$strip>;response:ZodObject<{results:ZodArray<ZodObject<{excerpt:ZodString;messageId:ZodString;score:ZodNumber;sessionId:ZodString; },$strip>>;total:ZodNumber; },$strip>; };get: {request:ZodObject<{messageId:ZodString; },$strip>;response:ZodObject<{message:ZodNullable<ZodObject<{adapterMessageId:ZodOptional<ZodString>;adapterSessionId:ZodOptional<ZodString>;agentId:ZodOptional<ZodString>;blocks:ZodArray<ZodDiscriminatedUnion<…, …>>;contentText:ZodString;editOf:ZodOptional<ZodString>;messageId:ZodString;origin:ZodOptional<ZodEnum<…>>;role:ZodEnum<{assistant: …;user: …; }>;sessionId:ZodString;timestamp:ZodNumber;turnId:ZodNullable<ZodString>; },$strip>>; },$strip>; };getByAdapterMessageId: {request:ZodObject<{adapterMessageId:ZodString; },$strip>;response:ZodObject<{message:ZodNullable<ZodObject<{adapterMessageId:ZodOptional<ZodString>;adapterSessionId:ZodOptional<ZodString>;agentId:ZodOptional<ZodString>;blocks:ZodArray<ZodDiscriminatedUnion<…, …>>;contentText:ZodString;editOf:ZodOptional<ZodString>;messageId:ZodString;origin:ZodOptional<ZodEnum<…>>;role:ZodEnum<{assistant: …;user: …; }>;sessionId:ZodString;timestamp:ZodNumber;turnId:ZodNullable<ZodString>; },$strip>>; },$strip>; };getBySession: {request:ZodObject<{after:ZodOptional<ZodObject<{messageId:ZodString;timestamp:ZodNumber; },$strip>>;includeAfter:ZodOptional<ZodBoolean>;limit:ZodOptional<ZodNumber>;order:ZodOptional<ZodEnum<{asc:"asc";desc:"desc"; }>>;sessionId:ZodString; },$strip>;response:ZodObject<{messages:ZodArray<ZodObject<{adapterMessageId:ZodOptional<ZodString>;adapterSessionId:ZodOptional<ZodString>;agentId:ZodOptional<ZodString>;blocks:ZodArray<ZodDiscriminatedUnion<…, …>>;contentText:ZodString;editOf:ZodOptional<ZodString>;messageId:ZodString;origin:ZodOptional<ZodEnum<…>>;role:ZodEnum<{assistant: …;user: …; }>;sessionId:ZodString;timestamp:ZodNumber;turnId:ZodNullable<ZodString>; },$strip>>;nextCursor:ZodNullable<ZodObject<{messageId:ZodString;timestamp:ZodNumber; },$strip>>; },$strip>; };getByTurn: {request:ZodObject<{turnId:ZodString; },$strip>;response:ZodObject<{messages:ZodArray<ZodObject<{adapterMessageId:ZodOptional<ZodString>;adapterSessionId:ZodOptional<ZodString>;agentId:ZodOptional<ZodString>;blocks:ZodArray<ZodDiscriminatedUnion<…, …>>;contentText:ZodString;editOf:ZodOptional<ZodString>;messageId:ZodString;origin:ZodOptional<ZodEnum<…>>;role:ZodEnum<{assistant: …;user: …; }>;sessionId:ZodString;timestamp:ZodNumber;turnId:ZodNullable<ZodString>; },$strip>>; },$strip>; };search: {request:ZodObject<{limit:ZodOptional<ZodNumber>;query:ZodString;sessionId:ZodOptional<ZodString>; },$strip>;response:ZodObject<{messages:ZodArray<ZodObject<{adapterMessageId:ZodOptional<ZodString>;adapterSessionId:ZodOptional<ZodString>;agentId:ZodOptional<ZodString>;blocks:ZodArray<ZodDiscriminatedUnion<…, …>>;contentText:ZodString;editOf:ZodOptional<ZodString>;messageId:ZodString;origin:ZodOptional<ZodEnum<…>>;role:ZodEnum<{assistant: …;user: …; }>;sessionId:ZodString;timestamp:ZodNumber;turnId:ZodNullable<ZodString>; },$strip>>;total:ZodNumber; },$strip>; };stored:ZodObject<{message:ZodObject<{adapterMessageId:ZodOptional<ZodString>;adapterSessionId:ZodOptional<ZodString>;agentId:ZodOptional<ZodString>;blocks:ZodArray<ZodDiscriminatedUnion<[ZodObject<…, …>,ZodObject<…, …>,ZodObject<…, …>,ZodObject<…, …>],"type">>;contentText:ZodString;editOf:ZodOptional<ZodString>;messageId:ZodString;origin:ZodOptional<ZodEnum<{compact:"compact";text:"text";voice:"voice"; }>>;role:ZodEnum<{assistant:"assistant";user:"user"; }>;sessionId:ZodString;timestamp:ZodNumber;turnId:ZodNullable<ZodString>; },$strip>; },$strip>;upsertByAdapterMessageId: {request:ZodObject<{adapterMessageId:ZodString;adapterSessionId:ZodOptional<ZodString>;agentId:ZodOptional<ZodString>;blocks:ZodArray<ZodDiscriminatedUnion<[ZodObject<{content: …;type: …; },$strip>,ZodObject<{source: …;type: …; },$strip>,ZodObject<{source: …;type: …; },$strip>,ZodObject<{attachmentType: …;displayName: …;fileName: …;filePath: …;source: …;type: …; },$strip>],"type">>;contentText:ZodString;origin:ZodOptional<ZodEnum<{compact:"compact";text:"text";voice:"voice"; }>>;role:ZodEnum<{assistant:"assistant";user:"user"; }>;sessionId:ZodString;timestamp:ZodNumber;turnId:ZodNullable<ZodString>; },$strip>;response:ZodObject<{created:ZodBoolean;messageId:ZodString; },$strip>; }; }>,"storage:message"> =MessageStorageNamespace.subjects
Defined in: ../../../packages/contracts/src/session/message-storage-namespace.ts:231
Typed subjects for message storage bus operations.