github/openclaw
1
0
Fork 0
mirror of https://github.com/openclaw/openclaw.git synced 2026-05-08 04:41:25 +00:00
Code Issues Packages Projects Releases Wiki Activity

refactor(commands): share preview streaming migration logic

Browse Source
This commit is contained in:
Peter Steinberger
2026-02-21 22:06:26 +00:00
parent 474ba45a2f
commit 244ccc801e
2 changed files with 76 additions and 86 deletions
Download Patch File Download Diff File Expand all files Collapse all files

34
src/commands/doctor-legacy-config.test.ts Normal file
View File

@@ -0,0 +1,34 @@
import { describe, expect, it } from "vitest";
import { normalizeLegacyConfigValues } from "./doctor-legacy-config.js";
describe("normalizeLegacyConfigValues preview streaming aliases", () => {
it("normalizes telegram boolean streaming aliases to enum", () => {
const res = normalizeLegacyConfigValues({
channels: {
telegram: {
streaming: false,
},
},
});
expect(res.config.channels?.telegram?.streaming).toBe("off");
expect(res.config.channels?.telegram?.streamMode).toBeUndefined();
expect(res.changes).toEqual(["Normalized channels.telegram.streaming boolean → enum (off)."]);
});
it("normalizes discord boolean streaming aliases to enum", () => {
const res = normalizeLegacyConfigValues({
channels: {
discord: {
streaming: true,
},
},
});
expect(res.config.channels?.discord?.streaming).toBe("partial");
expect(res.config.channels?.discord?.streamMode).toBeUndefined();
expect(res.changes).toEqual([
"Normalized channels.discord.streaming boolean → enum (partial).",
]);
});
});

128
src/commands/doctor-legacy-config.ts
View File

@@ -97,54 +97,15 @@ export function normalizeLegacyConfigValues(cfg: OpenClawConfig): {
return { entry: updated, changed };
};
const normalizeTelegramStreamingAliases = (params: {
const normalizePreviewStreamingAliases = (params: {
entry: Record<string, unknown>;
pathPrefix: string;
resolveStreaming: (entry: Record<string, unknown>) => string;
}): { entry: Record<string, unknown>; changed: boolean } => {
let updated = params.entry;
const hadLegacyStreamMode = updated.streamMode !== undefined;
const beforeStreaming = updated.streaming;
const resolved = resolveTelegramPreviewStreamMode(updated);
const shouldNormalize =
hadLegacyStreamMode ||
typeof beforeStreaming === "boolean" ||
(typeof beforeStreaming === "string" && beforeStreaming !== resolved);
if (!shouldNormalize) {
return { entry: updated, changed: false };
}
let changed = false;
if (beforeStreaming !== resolved) {
updated = { ...updated, streaming: resolved };
changed = true;
}
if (hadLegacyStreamMode) {
const { streamMode: _ignored, ...rest } = updated;
updated = rest;
changed = true;
changes.push(
`Moved ${params.pathPrefix}.streamMode → ${params.pathPrefix}.streaming (${resolved}).`,
);
}
if (typeof beforeStreaming === "boolean") {
changes.push(`Normalized ${params.pathPrefix}.streaming boolean → enum (${resolved}).`);
} else if (typeof beforeStreaming === "string" && beforeStreaming !== resolved) {
changes.push(
`Normalized ${params.pathPrefix}.streaming (${beforeStreaming}) → (${resolved}).`,
);
}
return { entry: updated, changed };
};
const normalizeDiscordStreamingAliases = (params: {
entry: Record<string, unknown>;
pathPrefix: string;
}): { entry: Record<string, unknown>; changed: boolean } => {
let updated = params.entry;
const hadLegacyStreamMode = updated.streamMode !== undefined;
const beforeStreaming = updated.streaming;
const resolved = resolveDiscordPreviewStreamMode(updated);
const resolved = params.resolveStreaming(updated);
const shouldNormalize =
hadLegacyStreamMode ||
typeof beforeStreaming === "boolean" ||
@@ -229,6 +190,31 @@ export function normalizeLegacyConfigValues(cfg: OpenClawConfig): {
return { entry: updated, changed };
};
const normalizeStreamingAliasesForProvider = (params: {
provider: "telegram" | "slack" | "discord";
entry: Record<string, unknown>;
pathPrefix: string;
}): { entry: Record<string, unknown>; changed: boolean } => {
if (params.provider === "telegram") {
return normalizePreviewStreamingAliases({
entry: params.entry,
pathPrefix: params.pathPrefix,
resolveStreaming: resolveTelegramPreviewStreamMode,
});
}
if (params.provider === "discord") {
return normalizePreviewStreamingAliases({
entry: params.entry,
pathPrefix: params.pathPrefix,
resolveStreaming: resolveDiscordPreviewStreamMode,
});
}
return normalizeSlackStreamingAliases({
entry: params.entry,
pathPrefix: params.pathPrefix,
});
};
const normalizeProvider = (provider: "telegram" | "slack" | "discord") => {
const channels = next.channels as Record<string, unknown> | undefined;
const rawEntry = channels?.[provider];
@@ -247,28 +233,13 @@ export function normalizeLegacyConfigValues(cfg: OpenClawConfig): {
updated = base.entry;
changed = base.changed;
}
if (provider === "telegram") {
const streaming = normalizeTelegramStreamingAliases({
entry: updated,
pathPrefix: `channels.${provider}`,
});
updated = streaming.entry;
changed = changed || streaming.changed;
} else if (provider === "discord") {
const streaming = normalizeDiscordStreamingAliases({
entry: updated,
pathPrefix: `channels.${provider}`,
});
updated = streaming.entry;
changed = changed || streaming.changed;
} else if (provider === "slack") {
const streaming = normalizeSlackStreamingAliases({
entry: updated,
pathPrefix: `channels.${provider}`,
});
updated = streaming.entry;
changed = changed || streaming.changed;
}
const providerStreaming = normalizeStreamingAliasesForProvider({
provider,
entry: updated,
pathPrefix: `channels.${provider}`,
});
updated = providerStreaming.entry;
changed = changed || providerStreaming.changed;
const rawAccounts = updated.accounts;
if (isRecord(rawAccounts)) {
@@ -289,28 +260,13 @@ export function normalizeLegacyConfigValues(cfg: OpenClawConfig): {
accountEntry = res.entry;
accountChanged = res.changed;
}
if (provider === "telegram") {
const streaming = normalizeTelegramStreamingAliases({
entry: accountEntry,
pathPrefix: `channels.${provider}.accounts.${accountId}`,
});
accountEntry = streaming.entry;
accountChanged = accountChanged || streaming.changed;
} else if (provider === "discord") {
const streaming = normalizeDiscordStreamingAliases({
entry: accountEntry,
pathPrefix: `channels.${provider}.accounts.${accountId}`,
});
accountEntry = streaming.entry;
accountChanged = accountChanged || streaming.changed;
} else if (provider === "slack") {
const streaming = normalizeSlackStreamingAliases({
entry: accountEntry,
pathPrefix: `channels.${provider}.accounts.${accountId}`,
});
accountEntry = streaming.entry;
accountChanged = accountChanged || streaming.changed;
}
const accountStreaming = normalizeStreamingAliasesForProvider({
provider,
entry: accountEntry,
pathPrefix: `channels.${provider}.accounts.${accountId}`,
});
accountEntry = accountStreaming.entry;
accountChanged = accountChanged || accountStreaming.changed;
if (accountChanged) {
accounts[accountId] = accountEntry;
accountsChanged = true;