From 6ffca36284cd9cbc4053edb219e6151ee7be1a82 Mon Sep 17 00:00:00 2001
From: Peter Steinberger <steipete@gmail.com>
Date: Sat, 21 Feb 2026 19:53:36 +0100
Subject: [PATCH] fix(config): add shared streaming resolver module

---
 src/config/discord-preview-streaming.ts | 144 ++++++++++++++++++++++++
 1 file changed, 144 insertions(+)
 create mode 100644 src/config/discord-preview-streaming.ts

diff --git a/src/config/discord-preview-streaming.ts b/src/config/discord-preview-streaming.ts
new file mode 100644
index 000000000..684c5eff1
--- /dev/null
+++ b/src/config/discord-preview-streaming.ts
@@ -0,0 +1,144 @@
+export type StreamingMode = "off" | "partial" | "block" | "progress";
+export type DiscordPreviewStreamMode = "off" | "partial" | "block";
+export type TelegramPreviewStreamMode = "off" | "partial" | "block";
+export type SlackLegacyDraftStreamMode = "replace" | "status_final" | "append";
+
+function normalizeStreamingMode(value: unknown): string | null {
+  if (typeof value !== "string") {
+    return null;
+  }
+  const normalized = value.trim().toLowerCase();
+  return normalized || null;
+}
+
+export function parseStreamingMode(value: unknown): StreamingMode | null {
+  const normalized = normalizeStreamingMode(value);
+  if (
+    normalized === "off" ||
+    normalized === "partial" ||
+    normalized === "block" ||
+    normalized === "progress"
+  ) {
+    return normalized;
+  }
+  return null;
+}
+
+export function parseDiscordPreviewStreamMode(value: unknown): DiscordPreviewStreamMode | null {
+  const parsed = parseStreamingMode(value);
+  if (!parsed) {
+    return null;
+  }
+  return parsed === "progress" ? "partial" : parsed;
+}
+
+export function parseSlackLegacyDraftStreamMode(value: unknown): SlackLegacyDraftStreamMode | null {
+  const normalized = normalizeStreamingMode(value);
+  if (normalized === "replace" || normalized === "status_final" || normalized === "append") {
+    return normalized;
+  }
+  return null;
+}
+
+export function mapSlackLegacyDraftStreamModeToStreaming(
+  mode: SlackLegacyDraftStreamMode,
+): StreamingMode {
+  if (mode === "append") {
+    return "block";
+  }
+  if (mode === "status_final") {
+    return "progress";
+  }
+  return "partial";
+}
+
+export function mapStreamingModeToSlackLegacyDraftStreamMode(mode: StreamingMode) {
+  if (mode === "block") {
+    return "append" as const;
+  }
+  if (mode === "progress") {
+    return "status_final" as const;
+  }
+  return "replace" as const;
+}
+
+export function resolveTelegramPreviewStreamMode(
+  params: {
+    streamMode?: unknown;
+    streaming?: unknown;
+  } = {},
+): TelegramPreviewStreamMode {
+  const parsedStreaming = parseStreamingMode(params.streaming);
+  if (parsedStreaming) {
+    if (parsedStreaming === "progress") {
+      return "partial";
+    }
+    return parsedStreaming;
+  }
+
+  const legacy = parseDiscordPreviewStreamMode(params.streamMode);
+  if (legacy) {
+    return legacy;
+  }
+  if (typeof params.streaming === "boolean") {
+    return params.streaming ? "partial" : "off";
+  }
+  return "off";
+}
+
+export function resolveDiscordPreviewStreamMode(
+  params: {
+    streamMode?: unknown;
+    streaming?: unknown;
+  } = {},
+): DiscordPreviewStreamMode {
+  const parsedStreaming = parseDiscordPreviewStreamMode(params.streaming);
+  if (parsedStreaming) {
+    return parsedStreaming;
+  }
+
+  const legacy = parseDiscordPreviewStreamMode(params.streamMode);
+  if (legacy) {
+    return legacy;
+  }
+  if (typeof params.streaming === "boolean") {
+    return params.streaming ? "partial" : "off";
+  }
+  return "off";
+}
+
+export function resolveSlackStreamingMode(
+  params: {
+    streamMode?: unknown;
+    streaming?: unknown;
+  } = {},
+): StreamingMode {
+  const parsedStreaming = parseStreamingMode(params.streaming);
+  if (parsedStreaming) {
+    return parsedStreaming;
+  }
+  const legacyStreamMode = parseSlackLegacyDraftStreamMode(params.streamMode);
+  if (legacyStreamMode) {
+    return mapSlackLegacyDraftStreamModeToStreaming(legacyStreamMode);
+  }
+  // Legacy `streaming` was a Slack native-streaming toggle; preview mode stayed replace.
+  if (typeof params.streaming === "boolean") {
+    return "partial";
+  }
+  return "partial";
+}
+
+export function resolveSlackNativeStreaming(
+  params: {
+    nativeStreaming?: unknown;
+    streaming?: unknown;
+  } = {},
+): boolean {
+  if (typeof params.nativeStreaming === "boolean") {
+    return params.nativeStreaming;
+  }
+  if (typeof params.streaming === "boolean") {
+    return params.streaming;
+  }
+  return true;
+}