在 Cloudflare Workers 上部署基于 Telegraf 框架的 Telegram Bot

1
function isKoaResponse(response) {
2
  return (
3
    typeof response.set === "function" && typeof response.header === "object"
4
  );
5
}
6

7
function answerToWebhook(response, payload = {}, options) {
8
  if (!includesMedia(payload)) {
9
    if (isKoaResponse(response)) {
10
      response.body = payload;
11
      return Promise.resolve(WEBHOOK_REPLY_STUB);
12
    }
13
    if (!response.headersSent) {
14
      response.setHeader("content-type", "application/json");
15
    }
16
    return new Promise((resolve) => {
17
      if (response.end.length === 2) {
18
        response.end(JSON.stringify(payload), "utf-8");
19
        return resolve(WEBHOOK_REPLY_STUB);
20
      }
21
      response.end(JSON.stringify(payload), "utf-8", () =>
22
        resolve(WEBHOOK_REPLY_STUB),
23
      );
24
    });
25
  }
26

27
  return buildFormDataConfig(payload, options.agent).then(
28
    ({ headers, body }) => {
29
      if (isKoaResponse(response)) {
30
        Object.keys(headers).forEach((key) => response.set(key, headers[key]));
31
        response.body = body;
32
        return Promise.resolve(WEBHOOK_REPLY_STUB);
33
      }
34
      if (!response.headersSent) {
35
        Object.keys(headers).forEach((key) =>
36
          response.setHeader(key, headers[key]),
37
        );
38
      }
39
      return new Promise((resolve) => {
40
        response.on("finish", () => resolve(WEBHOOK_REPLY_STUB));
41
        body.pipe(response);
42
      });
43
    },
44
  );
45
}

1
function getKoaLikeResponse(res) {
2
  return new Proxy(
3
    Object.assign(res, {
4
      set: (...args) => res.headers.set(...args),
5
      header: res.headers,
6
    }),
7
    {
8
      set(obj, prop, value) {
9
        if (
10
          prop === "body" &&
11
          ["Object", "Array"].includes(
12
            Object.getPrototypeOf(value).constructor.name,
13
          )
14
        ) {
15
          obj.body = JSON.stringify(value);
16
          obj.headers.set("content-type", "application/json");
17
          return true;
18
        }
19
        return Reflect.set(...arguments);
20
      },
21
    },
22
  );
23
}