feat(notify): add proxy support for Telegram notifications

packages/core/package.json

@@ -34,6 +34,7 @@
     "@anthropic-ai/sdk": "^0.78.0",
     "js-yaml": "^4.1.1",
     "openai": "^4.80.0",
+    "undici": "^7.24.2",
     "zod": "^3.24.0"
   },
   "devDependencies": {

packages/core/src/models/project.ts

@@ -18,6 +18,7 @@ export const NotifyChannelSchema = z.discriminatedUnion("type", [
     type: z.literal("telegram"),
     botToken: z.string().min(1),
     chatId: z.string().min(1),
+    proxy: z.string().optional(),
   }),
   z.object({
     type: z.literal("wechat-work"),

packages/core/src/notify/dispatcher.ts

@@ -20,7 +20,7 @@ export async function dispatchNotification(
       switch (channel.type) {
         case "telegram":
           await sendTelegram(
-            { botToken: channel.botToken, chatId: channel.chatId },
+            { botToken: channel.botToken, chatId: channel.chatId, proxy: channel.proxy },
             fullText,
           );
           break;

packages/core/src/notify/telegram.ts

@@ -1,22 +1,38 @@
+import { ProxyAgent } from "undici";
+
 export interface TelegramConfig {
   readonly botToken: string;
   readonly chatId: string;
+  readonly proxy?: string;
 }
 
 export async function sendTelegram(
   config: TelegramConfig,
   message: string,
 ): Promise<void> {
   const url = `https://api.telegram.org/bot${config.botToken}/sendMessage`;
-  const response = await fetch(url, {
+  const proxyUrl =
+    config.proxy ||
+    process.env.HTTPS_PROXY ||
+    process.env.https_proxy ||
+    process.env.HTTP_PROXY ||
+    process.env.http_proxy;
+
+  const fetchOptions: Record<string, unknown> = {
     method: "POST",
     headers: { "Content-Type": "application/json" },
     body: JSON.stringify({
       chat_id: config.chatId,
       text: message,
       parse_mode: "Markdown",
     }),
-  });
+  };
+
+  if (proxyUrl) {
+    fetchOptions.dispatcher = new ProxyAgent(proxyUrl);
+  }
+
+  const response = await fetch(url, fetchOptions as RequestInit);
 
   if (!response.ok) {
     const body = await response.text();