Fix: use base_url config + manual HTTPS proxy for Telegram (bypass HF firewall)

data/config.json

@@ -19,6 +19,7 @@
     "channels": {
         "telegram": {
             "enabled": true,
+            "base_url": "http://127.0.0.1:7860/tg",
             "token": "8146959380:AAElnoCHNhfFuQGvUz_kA3By59LRh4phfCo",
             "allow_from": [
                 "7261600381"

server.js

@@ -232,23 +232,84 @@ app.post('/api/chat', async (req, res) => {
 });
 
 // ==========================================
-// TELEGRAM API PROXY
+// TELEGRAM API PROXY (manual fetch-based, bypasses HF's HTTPS block)
 // ==========================================
-app.use('/tg', createProxyMiddleware({
-    target: 'https://api.telegram.org',
-    changeOrigin: true,
-    agent: proxyAgent, // Use the custom DNS agent to bypass K8s DNS problems
-    pathRewrite: {
-        '^/tg': '' // remove /tg prefix before forwarding
-    },
-    on: {
-        error: (err, req, res) => {
-            console.error('[TG Proxy Error]', err.message);
-            res.writeHead(500, { 'Content-Type': 'application/json' });
-            res.end(JSON.stringify({ ok: false, error_code: 500, description: "Node Proxy Error" }));
+app.use('/tg', async (req, res) => {
+    // Strip /tg prefix → forward to api.telegram.org
+    const targetPath = req.originalUrl.replace(/^\/tg/, '');
+    const targetUrl = `https://api.telegram.org${targetPath}`;
+
+    try {
+        // Collect request body — Express may have already parsed it
+        let body = undefined;
+        if (req.method === 'POST') {
+            if (req.body !== undefined && req.body !== null) {
+                // Express already parsed the JSON body
+                body = Buffer.from(JSON.stringify(req.body));
+            } else {
+                // Fallback: read raw stream
+                body = await new Promise((resolve, reject) => {
+                    const chunks = [];
+                    req.on('data', c => chunks.push(c));
+                    req.on('end', () => resolve(Buffer.concat(chunks)));
+                    req.on('error', reject);
+                });
+            }
         }
+
+        // Use native https module with our custom DNS-resolving agent
+        const result = await new Promise((resolve, reject) => {
+            const urlObj = new URL(targetUrl);
+            const options = {
+                hostname: urlObj.hostname,
+                port: 443,
+                path: urlObj.pathname + urlObj.search,
+                method: req.method,
+                agent: proxyAgent,
+                headers: {
+                    'Content-Type': req.headers['content-type'] || 'application/json',
+                    'Accept': 'application/json',
+                    ...(body ? { 'Content-Length': body.length } : {})
+                },
+                timeout: 120000 // 2 min for long polling
+            };
+
+            const proxyReq = https.request(options, (proxyRes) => {
+                const chunks = [];
+                proxyRes.on('data', c => chunks.push(c));
+                proxyRes.on('end', () => {
+                    resolve({
+                        status: proxyRes.statusCode,
+                        headers: proxyRes.headers,
+                        body: Buffer.concat(chunks)
+                    });
+                });
+            });
+
+            proxyReq.on('error', reject);
+            proxyReq.on('timeout', () => {
+                proxyReq.destroy();
+                reject(new Error('Telegram API request timed out'));
+            });
+
+            if (body) proxyReq.write(body);
+            proxyReq.end();
+        });
+
+        // Forward response back to Go client
+        res.writeHead(result.status, {
+            'Content-Type': result.headers['content-type'] || 'application/json',
+            'Connection': 'close' // Critical for fasthttp compatibility
+        });
+        res.end(result.body);
+
+    } catch (err) {
+        console.error('[TG Proxy Error]', err.message);
+        addLog('TG-Proxy', `ERROR: ${err.message}`);
+        res.writeHead(502, { 'Content-Type': 'application/json', 'Connection': 'close' });
+        res.end(JSON.stringify({ ok: false, error_code: 502, description: `Proxy error: ${err.message}` }));
     }
-}));
+});
 
 // ==========================================
 // WEBHOOK PROXY TO PICOCLAW