121 lines
3.8 KiB
TypeScript
121 lines
3.8 KiB
TypeScript
import { normalizeAccountId } from "./account-id.js";
|
|
import { normalizeMessageChannel } from "./message-channel.js";
|
|
|
|
export type DeliveryContext = {
|
|
channel?: string;
|
|
to?: string;
|
|
accountId?: string;
|
|
threadId?: string | number;
|
|
};
|
|
|
|
export type DeliveryContextSessionSource = {
|
|
channel?: string;
|
|
lastChannel?: string;
|
|
lastTo?: string;
|
|
lastAccountId?: string;
|
|
lastThreadId?: string | number;
|
|
deliveryContext?: DeliveryContext;
|
|
};
|
|
|
|
export function normalizeDeliveryContext(context?: DeliveryContext): DeliveryContext | undefined {
|
|
if (!context) return undefined;
|
|
const channel =
|
|
typeof context.channel === "string"
|
|
? (normalizeMessageChannel(context.channel) ?? context.channel.trim())
|
|
: undefined;
|
|
const to = typeof context.to === "string" ? context.to.trim() : undefined;
|
|
const accountId = normalizeAccountId(context.accountId);
|
|
const threadId =
|
|
typeof context.threadId === "number" && Number.isFinite(context.threadId)
|
|
? Math.trunc(context.threadId)
|
|
: typeof context.threadId === "string"
|
|
? context.threadId.trim()
|
|
: undefined;
|
|
const normalizedThreadId =
|
|
typeof threadId === "string" ? (threadId ? threadId : undefined) : threadId;
|
|
if (!channel && !to && !accountId && normalizedThreadId == null) return undefined;
|
|
const normalized: DeliveryContext = {
|
|
channel: channel || undefined,
|
|
to: to || undefined,
|
|
accountId,
|
|
};
|
|
if (normalizedThreadId != null) normalized.threadId = normalizedThreadId;
|
|
return normalized;
|
|
}
|
|
|
|
export function normalizeSessionDeliveryFields(source?: DeliveryContextSessionSource): {
|
|
deliveryContext?: DeliveryContext;
|
|
lastChannel?: string;
|
|
lastTo?: string;
|
|
lastAccountId?: string;
|
|
lastThreadId?: string | number;
|
|
} {
|
|
if (!source) {
|
|
return {
|
|
deliveryContext: undefined,
|
|
lastChannel: undefined,
|
|
lastTo: undefined,
|
|
lastAccountId: undefined,
|
|
lastThreadId: undefined,
|
|
};
|
|
}
|
|
|
|
const merged = mergeDeliveryContext(
|
|
normalizeDeliveryContext({
|
|
channel: source.lastChannel ?? source.channel,
|
|
to: source.lastTo,
|
|
accountId: source.lastAccountId,
|
|
threadId: source.lastThreadId,
|
|
}),
|
|
normalizeDeliveryContext(source.deliveryContext),
|
|
);
|
|
|
|
if (!merged) {
|
|
return {
|
|
deliveryContext: undefined,
|
|
lastChannel: undefined,
|
|
lastTo: undefined,
|
|
lastAccountId: undefined,
|
|
lastThreadId: undefined,
|
|
};
|
|
}
|
|
|
|
return {
|
|
deliveryContext: merged,
|
|
lastChannel: merged.channel,
|
|
lastTo: merged.to,
|
|
lastAccountId: merged.accountId,
|
|
lastThreadId: merged.threadId,
|
|
};
|
|
}
|
|
|
|
export function deliveryContextFromSession(
|
|
entry?: DeliveryContextSessionSource,
|
|
): DeliveryContext | undefined {
|
|
if (!entry) return undefined;
|
|
return normalizeSessionDeliveryFields(entry).deliveryContext;
|
|
}
|
|
|
|
export function mergeDeliveryContext(
|
|
primary?: DeliveryContext,
|
|
fallback?: DeliveryContext,
|
|
): DeliveryContext | undefined {
|
|
const normalizedPrimary = normalizeDeliveryContext(primary);
|
|
const normalizedFallback = normalizeDeliveryContext(fallback);
|
|
if (!normalizedPrimary && !normalizedFallback) return undefined;
|
|
return normalizeDeliveryContext({
|
|
channel: normalizedPrimary?.channel ?? normalizedFallback?.channel,
|
|
to: normalizedPrimary?.to ?? normalizedFallback?.to,
|
|
accountId: normalizedPrimary?.accountId ?? normalizedFallback?.accountId,
|
|
threadId: normalizedPrimary?.threadId ?? normalizedFallback?.threadId,
|
|
});
|
|
}
|
|
|
|
export function deliveryContextKey(context?: DeliveryContext): string | undefined {
|
|
const normalized = normalizeDeliveryContext(context);
|
|
if (!normalized?.channel || !normalized?.to) return undefined;
|
|
const threadId =
|
|
normalized.threadId != null && normalized.threadId !== "" ? String(normalized.threadId) : "";
|
|
return `${normalized.channel}|${normalized.to}|${normalized.accountId ?? ""}|${threadId}`;
|
|
}
|