9d50ebad7d
Implement reply routing based on OriginatingChannel/OriginatingTo fields. This ensures replies go back to the provider where the message originated instead of using the session's lastChannel. Changes: - Add OriginatingChannel/OriginatingTo fields to MsgContext (templating.ts) - Add originatingChannel/originatingTo fields to FollowupRun (queue.ts) - Create route-reply.ts with provider-agnostic router - Update all providers (Telegram, Slack, Discord, Signal, iMessage) to pass originating channel info - Update reply.ts to pass originating channel to followupRun - Update followup-runner.ts to use route-reply for originating channels This addresses the issue where messages from one provider (e.g., Slack) would receive replies on a different provider (e.g., Telegram) because the queue used the last active dispatcher instead of the originating one.
77 lines
2.1 KiB
TypeScript
77 lines
2.1 KiB
TypeScript
/** Valid provider channels for message routing. */
|
|
export type OriginatingChannelType =
|
|
| "telegram"
|
|
| "slack"
|
|
| "discord"
|
|
| "signal"
|
|
| "imessage"
|
|
| "whatsapp"
|
|
| "webchat";
|
|
|
|
export type MsgContext = {
|
|
Body?: string;
|
|
From?: string;
|
|
To?: string;
|
|
SessionKey?: string;
|
|
/** Provider account id (multi-account). */
|
|
AccountId?: string;
|
|
MessageSid?: string;
|
|
ReplyToId?: string;
|
|
ReplyToBody?: string;
|
|
ReplyToSender?: string;
|
|
MediaPath?: string;
|
|
MediaUrl?: string;
|
|
MediaType?: string;
|
|
MediaPaths?: string[];
|
|
MediaUrls?: string[];
|
|
MediaTypes?: string[];
|
|
Transcript?: string;
|
|
ChatType?: string;
|
|
GroupSubject?: string;
|
|
GroupRoom?: string;
|
|
GroupSpace?: string;
|
|
GroupMembers?: string;
|
|
SenderName?: string;
|
|
SenderId?: string;
|
|
SenderUsername?: string;
|
|
SenderTag?: string;
|
|
SenderE164?: string;
|
|
/** Provider label (whatsapp|telegram|discord|imessage|...). */
|
|
Provider?: string;
|
|
/** Provider surface label (e.g. discord, slack). Prefer this over `Provider` when available. */
|
|
Surface?: string;
|
|
WasMentioned?: boolean;
|
|
CommandAuthorized?: boolean;
|
|
CommandSource?: "text" | "native";
|
|
CommandTargetSessionKey?: string;
|
|
/** Telegram forum topic thread ID. */
|
|
MessageThreadId?: number;
|
|
/** Telegram forum supergroup marker. */
|
|
IsForum?: boolean;
|
|
/**
|
|
* Originating channel for reply routing.
|
|
* When set, replies should be routed back to this provider
|
|
* instead of using lastChannel from the session.
|
|
*/
|
|
OriginatingChannel?: OriginatingChannelType;
|
|
/**
|
|
* Originating destination for reply routing.
|
|
* The chat/channel/user ID where the reply should be sent.
|
|
*/
|
|
OriginatingTo?: string;
|
|
};
|
|
|
|
export type TemplateContext = MsgContext & {
|
|
BodyStripped?: string;
|
|
SessionId?: string;
|
|
IsNewSession?: string;
|
|
};
|
|
|
|
// Simple {{Placeholder}} interpolation using inbound message context.
|
|
export function applyTemplate(str: string | undefined, ctx: TemplateContext) {
|
|
if (!str) return "";
|
|
return str.replace(/{{\s*(\w+)\s*}}/g, (_, key) => {
|
|
const value = ctx[key as keyof TemplateContext];
|
|
return value == null ? "" : String(value);
|
|
});
|
|
}
|