diff --git a/CHANGELOG.md b/CHANGELOG.md
index 4c0549c16..dfaccc1f5 100644
--- a/CHANGELOG.md
+++ b/CHANGELOG.md
@@ -72,7 +72,9 @@ Status: stable.
- **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: 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/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/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 });
});
}