diff --git a/CHANGELOG.md b/CHANGELOG.md
index 4c0549c16..191c2172d 100644
--- a/CHANGELOG.md
+++ b/CHANGELOG.md
@@ -68,11 +68,15 @@ Status: stable.
- Docs: credit both contributors for Control UI refresh. (#1852) Thanks @EnzeD.
- Docs: keep docs header sticky so navbar stays visible while scrolling. (#2445) Thanks @chenyuan99.
- Docs: update exe.dev install instructions. (#https://github.com/openclaw/openclaw/pull/3047) Thanks @zackerthescar.
+- Build: skip redundant UI install step in the Dockerfile. (#4584) Thanks @obviyus.
### Breaking
- **BREAKING:** Gateway auth mode "none" is removed; gateway now requires token/password (Tailscale Serve identity still allowed).
### Fixes
+- Telegram: use undici fetch for per-account proxy dispatcher. (#4456) Thanks @spiceoogway.
+- Telegram: fix HTML nesting for overlapping styles and links. (#4578) Thanks @ThanhNguyxn.
- Telegram: avoid silent empty replies by tracking normalization skips before fallback. (#3796)
+- Telegram: accept numeric messageId/chatId in react action and honor channelId fallback. (#4533) Thanks @Ayush10.
- Telegram: scope native skill commands to bound agent per bot. (#4360) Thanks @robhparker.
- Mentions: honor mentionPatterns even when explicit mentions are present. (#3303) Thanks @HirokiKobayashi-R.
- Discord: restore username directory lookup in target resolution. (#3131) Thanks @bonald.
diff --git a/Dockerfile b/Dockerfile
index 904d1d97d..ad08bd37c 100644
--- a/Dockerfile
+++ b/Dockerfile
@@ -27,7 +27,6 @@ COPY . .
RUN OPENCLAW_A2UI_SKIP_MISSING=1 pnpm build
# Force pnpm for UI build (Bun may fail on ARM/Synology architectures)
ENV OPENCLAW_PREFER_PNPM=1
-RUN pnpm ui:install
RUN pnpm ui:build
ENV NODE_ENV=production
diff --git a/README.md b/README.md
index 1fd5e074c..49085c76f 100644
--- a/README.md
+++ b/README.md
@@ -481,38 +481,39 @@ Thanks to all clawtributors:
- 
- 
+
+
- ![google-labs-jules[bot]](https://avatars.githubusercontent.com/in/842251?v=4&s=48 "google-labs-jules[bot]")
+
- 
- 
- 
- 
![dependabot[bot]](https://avatars.githubusercontent.com/in/29110?v=4&s=48 "dependabot[bot]")
- 
- 
- 
![blacksmith-sh[bot]](https://avatars.githubusercontent.com/in/807020?v=4&s=48 "blacksmith-sh[bot]")
- 
- 
- 
- 
- 
- 
- 
- 
- 
- 
- 
- 
- 
- 
- 
- 
- 
- 
- 
- 
+
+
+ 
+ 
+
+ 
+
+ 
+
+
+
+
+
+
+
+
+
+ 
+
+
+
+ 
+
+ 
+
+
+
+
diff --git a/src/channels/plugins/actions/telegram.test.ts b/src/channels/plugins/actions/telegram.test.ts
index d41628888..1ccc1e628 100644
--- a/src/channels/plugins/actions/telegram.test.ts
+++ b/src/channels/plugins/actions/telegram.test.ts
@@ -118,4 +118,27 @@ describe("telegramMessageActions", () => {
expect(handleTelegramAction).not.toHaveBeenCalled();
});
+
+ it("accepts numeric messageId and channelId for reactions", async () => {
+ handleTelegramAction.mockClear();
+ const cfg = { channels: { telegram: { botToken: "tok" } } } as OpenClawConfig;
+
+ await telegramMessageActions.handleAction({
+ action: "react",
+ params: {
+ channelId: 123,
+ messageId: 456,
+ emoji: "ok",
+ },
+ cfg,
+ accountId: undefined,
+ });
+
+ expect(handleTelegramAction).toHaveBeenCalledTimes(1);
+ const call = handleTelegramAction.mock.calls[0]?.[0] as Record;
+ expect(call.action).toBe("react");
+ expect(String(call.chatId)).toBe("123");
+ expect(String(call.messageId)).toBe("456");
+ expect(call.emoji).toBe("ok");
+ });
});
diff --git a/src/channels/plugins/actions/telegram.ts b/src/channels/plugins/actions/telegram.ts
index 693e94492..17df9adbc 100644
--- a/src/channels/plugins/actions/telegram.ts
+++ b/src/channels/plugins/actions/telegram.ts
@@ -85,7 +85,7 @@ export const telegramMessageActions: ChannelMessageActionAdapter = {
}
if (action === "react") {
- const messageId = readStringParam(params, "messageId", {
+ const messageId = readStringOrNumberParam(params, "messageId", {
required: true,
});
const emoji = readStringParam(params, "emoji", { allowEmpty: true });
@@ -94,7 +94,9 @@ export const telegramMessageActions: ChannelMessageActionAdapter = {
{
action: "react",
chatId:
- readStringParam(params, "chatId") ?? readStringParam(params, "to", { required: true }),
+ readStringOrNumberParam(params, "chatId") ??
+ readStringOrNumberParam(params, "channelId") ??
+ readStringParam(params, "to", { required: true }),
messageId,
emoji,
remove,
diff --git a/src/markdown/render.ts b/src/markdown/render.ts
index 502ab69ef..9793ab167 100644
--- a/src/markdown/render.ts
+++ b/src/markdown/render.ts
@@ -69,7 +69,6 @@ export function renderMarkdownWithMarkers(ir: MarkdownIR, options: RenderOptions
}
const linkStarts = new Map();
- const linkEnds = new Map();
if (options.buildLink) {
for (const link of ir.links) {
if (link.start === link.end) continue;
@@ -80,47 +79,78 @@ export function renderMarkdownWithMarkers(ir: MarkdownIR, options: RenderOptions
const openBucket = linkStarts.get(rendered.start);
if (openBucket) openBucket.push(rendered);
else linkStarts.set(rendered.start, [rendered]);
- const closeBucket = linkEnds.get(rendered.end);
- if (closeBucket) closeBucket.push(rendered);
- else linkEnds.set(rendered.end, [rendered]);
}
}
const points = [...boundaries].sort((a, b) => a - b);
- const stack: MarkdownStyleSpan[] = [];
+ // Unified stack for both styles and links, tracking close string and end position
+ const stack: { close: string; end: number }[] = [];
+ type OpeningItem =
+ | { end: number; open: string; close: string; kind: "link"; index: number }
+ | {
+ end: number;
+ open: string;
+ close: string;
+ kind: "style";
+ style: MarkdownStyle;
+ index: number;
+ };
let out = "";
for (let i = 0; i < points.length; i += 1) {
const pos = points[i];
+ // Close ALL elements (styles and links) in LIFO order at this position
while (stack.length && stack[stack.length - 1]?.end === pos) {
- const span = stack.pop();
- if (!span) break;
- const marker = styleMarkers[span.style];
- if (marker) out += marker.close;
+ const item = stack.pop();
+ if (item) out += item.close;
}
- const closingLinks = linkEnds.get(pos);
- if (closingLinks && closingLinks.length > 0) {
- for (const link of closingLinks) {
- out += link.close;
- }
- }
+ const openingItems: OpeningItem[] = [];
const openingLinks = linkStarts.get(pos);
if (openingLinks && openingLinks.length > 0) {
- for (const link of openingLinks) {
- out += link.open;
+ for (const [index, link] of openingLinks.entries()) {
+ openingItems.push({
+ end: link.end,
+ open: link.open,
+ close: link.close,
+ kind: "link",
+ index,
+ });
}
}
const openingStyles = startsAt.get(pos);
if (openingStyles) {
- for (const span of openingStyles) {
+ for (const [index, span] of openingStyles.entries()) {
const marker = styleMarkers[span.style];
if (!marker) continue;
- stack.push(span);
- out += marker.open;
+ openingItems.push({
+ end: span.end,
+ open: marker.open,
+ close: marker.close,
+ kind: "style",
+ style: span.style,
+ index,
+ });
+ }
+ }
+
+ if (openingItems.length > 0) {
+ openingItems.sort((a, b) => {
+ if (a.end !== b.end) return b.end - a.end;
+ if (a.kind !== b.kind) return a.kind === "link" ? -1 : 1;
+ if (a.kind === "style" && b.kind === "style") {
+ return (STYLE_RANK.get(a.style) ?? 0) - (STYLE_RANK.get(b.style) ?? 0);
+ }
+ return a.index - b.index;
+ });
+
+ // Open outer spans first (larger end) so LIFO closes stay valid for same-start overlaps.
+ for (const item of openingItems) {
+ out += item.open;
+ stack.push({ close: item.close, end: item.end });
}
}
diff --git a/src/telegram/format.test.ts b/src/telegram/format.test.ts
index 831782815..e267719a8 100644
--- a/src/telegram/format.test.ts
+++ b/src/telegram/format.test.ts
@@ -47,4 +47,26 @@ describe("markdownToTelegramHtml", () => {
const res = markdownToTelegramHtml("```js\nconst x = 1;\n```");
expect(res).toBe("const x = 1;\n
");
});
+
+ it("properly nests overlapping bold and autolink (#4071)", () => {
+ const res = markdownToTelegramHtml("**start https://example.com** end");
+ expect(res).toMatch(
+ /start https:\/\/example\.com<\/a><\/b> end/,
+ );
+ });
+
+ it("properly nests link inside bold", () => {
+ const res = markdownToTelegramHtml("**bold [link](https://example.com) text**");
+ expect(res).toBe('bold link text');
+ });
+
+ it("properly nests bold wrapping a link with trailing text", () => {
+ const res = markdownToTelegramHtml("**[link](https://example.com) rest**");
+ expect(res).toBe('link rest');
+ });
+
+ it("properly nests bold inside a link", () => {
+ const res = markdownToTelegramHtml("[**bold**](https://example.com)");
+ expect(res).toBe('bold');
+ });
});
diff --git a/src/telegram/proxy.test.ts b/src/telegram/proxy.test.ts
new file mode 100644
index 000000000..71fd5f88e
--- /dev/null
+++ b/src/telegram/proxy.test.ts
@@ -0,0 +1,45 @@
+import { describe, expect, it, vi } from "vitest";
+
+const { ProxyAgent, undiciFetch, proxyAgentSpy, getLastAgent } = vi.hoisted(() => {
+ const undiciFetch = vi.fn();
+ const proxyAgentSpy = vi.fn();
+ class ProxyAgent {
+ static lastCreated: ProxyAgent | undefined;
+ proxyUrl: string;
+ constructor(proxyUrl: string) {
+ this.proxyUrl = proxyUrl;
+ ProxyAgent.lastCreated = this;
+ proxyAgentSpy(proxyUrl);
+ }
+ }
+
+ return {
+ ProxyAgent,
+ undiciFetch,
+ proxyAgentSpy,
+ getLastAgent: () => ProxyAgent.lastCreated,
+ };
+});
+
+vi.mock("undici", () => ({
+ ProxyAgent,
+ fetch: undiciFetch,
+}));
+
+import { makeProxyFetch } from "./proxy.js";
+
+describe("makeProxyFetch", () => {
+ it("uses undici fetch with ProxyAgent dispatcher", async () => {
+ const proxyUrl = "http://proxy.test:8080";
+ undiciFetch.mockResolvedValue({ ok: true });
+
+ const proxyFetch = makeProxyFetch(proxyUrl);
+ await proxyFetch("https://api.telegram.org/bot123/getMe");
+
+ expect(proxyAgentSpy).toHaveBeenCalledWith(proxyUrl);
+ expect(undiciFetch).toHaveBeenCalledWith(
+ "https://api.telegram.org/bot123/getMe",
+ expect.objectContaining({ dispatcher: getLastAgent() }),
+ );
+ });
+});
diff --git a/src/telegram/proxy.ts b/src/telegram/proxy.ts
index 19d53d569..84251d7fe 100644
--- a/src/telegram/proxy.ts
+++ b/src/telegram/proxy.ts
@@ -1,11 +1,11 @@
// @ts-nocheck
-import { ProxyAgent } from "undici";
+import { ProxyAgent, fetch as undiciFetch } from "undici";
import { wrapFetchWithAbortSignal } from "../infra/fetch.js";
export function makeProxyFetch(proxyUrl: string): typeof fetch {
const agent = new ProxyAgent(proxyUrl);
return wrapFetchWithAbortSignal((input: RequestInfo | URL, init?: RequestInit) => {
const base = init ? { ...init } : {};
- return fetch(input, { ...base, dispatcher: agent });
+ return undiciFetch(input, { ...base, dispatcher: agent });
});
}