Variable: MessageRoutingNamespace

Makaio Framework / services-core / MessageRoutingNamespace

Variable: MessageRoutingNamespace

const MessageRoutingNamespace: StorageNamespace<"messageRouting", SubjectRecordFromSchemaRecord<{ getByMessage: { request: ZodObject<{ messageId: ZodString; }, $strip>; response: ZodObject<{ routing: ZodArray<ZodObject<{ agentId: ZodString; error: ZodOptional<ZodString>; messageId: ZodString; status: ZodEnum<{ acknowledged: …; completed: …; sent: …; }>; timestamp: ZodNumber; }, $strip>>; }, $strip>; }; getCompleted: { request: ZodObject<{ messageId: ZodString; }, $strip>; response: ZodObject<{ agentIds: ZodArray<ZodString>; }, $strip>; }; isComplete: { request: ZodObject<{ messageId: ZodString; targetAgentIds: ZodArray<ZodString>; }, $strip>; response: ZodObject<{ complete: ZodBoolean; pending: ZodArray<ZodString>; }, $strip>; }; record: { request: ZodObject<{ agentId: ZodString; error: ZodOptional<ZodString>; messageId: ZodString; status: ZodEnum<{ acknowledged: "acknowledged"; completed: "completed"; sent: "sent"; }>; timestamp: ZodNumber; }, $strip>; response: ZodObject<{ success: ZodBoolean; }, $strip>; }; }>, { agentId: string; error: never; messageId: string; status: "completed" | "acknowledged" | "sent"; targetAgentIds: string[]; timestamp: number; }, { drizzle: { messageRouting: SQLiteTableWithColumns<{ columns: { agentId: SQLiteColumn<{ baseColumn: never; columnType: "SQLiteText"; data: string; dataType: "string"; driverParam: string; enumValues: [string, ...string[]]; generated: undefined; hasDefault: false; hasRuntimeDefault: false; identity: undefined; isAutoincrement: false; isPrimaryKey: false; name: "agent_id"; notNull: true; tableName: "message_routing"; }, { }, { length: number | undefined; }>; error: SQLiteColumn<{ baseColumn: never; columnType: "SQLiteText"; data: string; dataType: "string"; driverParam: string; enumValues: [string, ...string[]]; generated: undefined; hasDefault: false; hasRuntimeDefault: false; identity: undefined; isAutoincrement: false; isPrimaryKey: false; name: "error"; notNull: false; tableName: "message_routing"; }, { }, { length: number | undefined; }>; messageId: SQLiteColumn<{ baseColumn: never; columnType: "SQLiteText"; data: string; dataType: "string"; driverParam: string; enumValues: [string, ...string[]]; generated: undefined; hasDefault: false; hasRuntimeDefault: false; identity: undefined; isAutoincrement: false; isPrimaryKey: false; name: "message_id"; notNull: true; tableName: "message_routing"; }, { }, { length: number | undefined; }>; status: SQLiteColumn<{ baseColumn: never; columnType: "SQLiteText"; data: "completed" | "acknowledged" | "sent"; dataType: "string"; driverParam: string; enumValues: ["sent", "acknowledged", "completed"]; generated: undefined; hasDefault: false; hasRuntimeDefault: false; identity: undefined; isAutoincrement: false; isPrimaryKey: false; name: "status"; notNull: true; tableName: "message_routing"; }, { }, { length: number | undefined; }>; timestamp: SQLiteColumn<{ baseColumn: never; columnType: "SQLiteInteger"; data: number; dataType: "number"; driverParam: number; enumValues: undefined; generated: undefined; hasDefault: false; hasRuntimeDefault: false; identity: undefined; isAutoincrement: false; isPrimaryKey: false; name: "timestamp"; notNull: true; tableName: "message_routing"; }, { }, { }>; }; dialect: "sqlite"; name: "message_routing"; schema: undefined; }>; }; }, { getByMessage: { request: ZodObject<{ messageId: ZodString; }, $strip>; response: ZodObject<{ routing: ZodArray<ZodObject<{ agentId: ZodString; error: ZodOptional<ZodString>; messageId: ZodString; status: ZodEnum<{ acknowledged: "acknowledged"; completed: "completed"; sent: "sent"; }>; timestamp: ZodNumber; }, $strip>>; }, $strip>; }; getCompleted: { request: ZodObject<{ messageId: ZodString; }, $strip>; response: ZodObject<{ agentIds: ZodArray<ZodString>; }, $strip>; }; isComplete: { request: ZodObject<{ messageId: ZodString; targetAgentIds: ZodArray<ZodString>; }, $strip>; response: ZodObject<{ complete: ZodBoolean; pending: ZodArray<ZodString>; }, $strip>; }; record: { request: ZodObject<{ agentId: ZodString; error: ZodOptional<ZodString>; messageId: ZodString; status: ZodEnum<{ acknowledged: "acknowledged"; completed: "completed"; sent: "sent"; }>; timestamp: ZodNumber; }, $strip>; response: ZodObject<{ success: ZodBoolean; }, $strip>; }; }>

Defined in: ../../../packages/services/core/src/session/message-routing/namespace.ts:12

Message routing storage namespace.

Tracks delivery status of messages to agents in multi-agent sessions. Enables querying completion status for turn coordination.