使用Cloudflare Worker代理Telegram Bot Api

Hrlni说道：

现在还能用吗

kkk说道：

请问我如何替换telebot中的接口地址？

张先森说道：

现在添加路由没有环境那一项了 怎么办
在青龙通知测试提示Error: {“ok”:false,”error_code”:400,”description”:”Bad Request: message text is empty”}

hello说道：

/**
* GPT 修改后的版本
* 原版本：https://anerg.com/2022/07/25/reverse-proxy-telegram-bot-api-using-cloudflare-worker.html
* Post 会有问题：
* {“ok”:false,”error_code”:400,”description”:”Bad Request: message text is empty”}
*
* Helper functions to check if the request uses
* the corresponding method.
*/
const Method = (method) => (req) => req.method.toLowerCase() === method.toLowerCase();
const Get = Method(‘get’);
const Post = Method(‘post’);

const Path = (regExp) => (req) => {
const url = new URL(req.url);
const path = url.pathname;
return path.match(regExp) && path.match(regExp)[0] === path;
};

/*
* The regex to get the bot_token and api_method from the request URL
* as the first and second backreference respectively.
*/
const URL_PATH_REGEX = /^\/bot(?[^/]+)\/(?[a-z]+)/i;

/**
* Router handles the logic of what handler is matched given conditions
* for each request.
*/
class Router {
constructor() {
this.routes = [];
}

handle(conditions, handler) {
this.routes.push({
conditions,
handler,
});
return this;
}

get(url, handler) {
return this.handle([Get, Path(url)], handler);
}

post(url, handler) {
return this.handle([Post, Path(url)], handler);
}

all(handler) {
return this.handle([], handler);
}

route(req) {
const route = this.resolve(req);

if (route) {
return route.handler(req);
}

const description = ‘No matching route found’;
const error_code = 404;

return new Response(
JSON.stringify({
ok: false,
error_code,
description,
}),
{
status: error_code,
statusText: description,
headers: {
‘content-type’: ‘application/json’,
},
}
);
}

/**
* It returns the matching route that returns true
* for all the conditions if any.
*/
resolve(req) {
return this.routes.find((r) => {
if (!r.conditions || (Array.isArray(r) && !r.conditions.length)) {
return true;
}

if (typeof r.conditions === ‘function’) {
return r.conditions(req);
}

return r.conditions.every((c) => c(req));
});
}
}

/**
* Sends a POST request with JSON data to Telegram Bot API
* and reads in the response body.
* @param {Request} request the incoming request
*/
async function handler(request) {
// Extract the URL, method, and headers from the request
const { url, method, headers } = request;

// Parse the URL to get the pathname and search parameters
const { pathname: path, search } = new URL(url);

// Use regex to extract the bot token and API method from the path
const { bot_token, api_method } = path.match(URL_PATH_REGEX).groups;

// Construct the Telegram API URL
const api_url = ‘https://api.telegram.org/bot’ + bot_token + ‘/’ + api_method + search;

// Prepare the fetch options, including the method, headers, and body
const fetchOptions = {
method: method,
headers: headers,
};

// If it’s a POST request, clone the request to include the body
if (method.toUpperCase() === ‘POST’) {
const body = await request.text(); // Read the request body as text
fetchOptions.body = body; // Include the body in the fetch options
}

// Forward the request to the Telegram API
const response = await fetch(api_url, fetchOptions);

// Return the response to the client
const result = await response.text();

return new Response(result, {
status: response.status,
statusText: response.statusText,
headers: {
‘Content-Type’: ‘application/json’,
},
});
}

/**
* Handles the incoming request.
* @param {Request} request the incoming request.
*/
async function handleRequest(request) {
const r = new Router();
r.get(URL_PATH_REGEX, (req) => handler(req));
r.post(URL_PATH_REGEX, (req) => handler(req));

const resp = await r.route(request);
return resp;
}

/**
* Hook into the fetch event.
*/
addEventListener(‘fetch’, (event) => {
event.respondWith(handleRequest(event.request));
});