Interface: ChatPublisher
Defined in: server/chat/outbox.ts:19
Methods
publish()
publish(event:
| {
conversationId: string;
createdAt: string;
id: string;
kind: "message.created";
message: {
clientRequestId: string;
conversationId: string;
createdAt: string;
id: string;
senderActorId: string;
sequence: number;
text: string;
};
messageId: string;
messageSequence: number;
organizationId: string;
schemaVersion: 1;
version: number;
}
| {
conversationId: string;
createdAt: string;
id: string;
kind: "conversation.created" | "members.changed" | "read.updated";
messageId: null;
messageSequence: null;
organizationId: string;
schemaVersion: 1;
version: number;
}, options: {
signal: AbortSignal;
}): Promise<void>;Defined in: server/chat/outbox.ts:22
Resolve on transport acceptance (e.g. Redis acknowledgement), not a local emit return value. This is not proof of recipient delivery. Honor signal to bound abandoned publication attempts.
Parameters
| Parameter | Type |
|---|---|
event | | { conversationId: string; createdAt: string; id: string; kind: "message.created"; message: { clientRequestId: string; conversationId: string; createdAt: string; id: string; senderActorId: string; sequence: number; text: string; }; messageId: string; messageSequence: number; organizationId: string; schemaVersion: 1; version: number; } | { conversationId: string; createdAt: string; id: string; kind: "conversation.created" | "members.changed" | "read.updated"; messageId: null; messageSequence: null; organizationId: string; schemaVersion: 1; version: number; } |
options | { signal: AbortSignal; } |
options.signal | AbortSignal |
Returns
Promise<void>