TsangAsuna

1
// Bangumi 反代（NipaPlay 用），参考 makabaka11/bangumi-proxy-workers。
2
// 路由：
3
//   /v0/*        → api.bgm.tv（主 API）
4
//   /p1/*        → next.bgm.tv（评论等 API）
5
//   /img/*       → lain.bgm.tv（图片 CDN）+ 边缘缓存 30 天
6
//   /site/*      → bangumi.tv（主站网页）
7
//   /api/*       → 兼容旧填法（剥掉 /api 后按 /v0 /p1 路由）
8
//   其余任意路径 → api.bgm.tv（旧版无前缀 API：/subject、/search、/calendar 等）
9
const BGM_API = "api.bgm.tv";
10
const BGM_API_NEXT = "next.bgm.tv";
11
const BGM_IMG = "lain.bgm.tv";
12
const BGM_SITE = "bangumi.tv";
13
const IMG_CACHE_TTL = 30 * 24 * 60 * 60;
14

15
export default {
16
  async fetch(req, env, ctx) {
17
    const url = new URL(req.url);
18
    if (req.method === "OPTIONS")
19
      return new Response(null, { status: 204, headers: corsHeaders() });
20

21
    let p = url.pathname;
22
    // 兼容旧 /api 前缀填法：剥掉后按根路径路由
23
    if (p === "/api" || p.startsWith("/api/")) p = p.slice(4) || "/";
24

25
    if (p === "/v0" || p.startsWith("/v0/")) return handleApi(req, url, p, BGM_API);
26
    if (p === "/p1" || p.startsWith("/p1/")) return handleApi(req, url, p, BGM_API_NEXT);
27
    if (p.startsWith("/img/")) return handleImg(req, url, ctx);
28
    if (p === "/site" || p.startsWith("/site/")) return handleSite(req, url, p);
29
    if (p === "/")
30
      return json({ ok: true, api: url.origin, img: url.origin + "/img", site: url.origin + "/site" });
31
    // 兜底：其余路径（旧版无前缀 API：/subject/xxx、/search/xxx、/calendar 等）
32
    // 全部透传 api.bgm.tv，与 makabaka11/bangumi-proxy-workers 语义一致
33
    return handleApi(req, url, p, BGM_API);
34
  },
35
};
36

37
async function handleApi(req, url, p, upstream) {
38
  // /v0 /p1 是上游真实路径前缀，原样透传
39
  const resp = await fetch(new Request(`https://${upstream}${p}${url.search}`, {
40
    method: req.method,
41
    headers: cleanRequestHeaders(req.headers),
42
    body: ["GET", "HEAD"].includes(req.method) ? undefined : req.body,
43
    redirect: "follow",
44
  }));
45
  const ct = resp.headers.get("content-type") || "";
46
  const headers = new Headers(resp.headers);
47
  setCors(headers);
48
  if (ct.includes("application/json") || ct.includes("text/")) {
49
    let text = await resp.text();
50
    // 整 URL 重写（含 scheme），兼容 JSON 转义 https:\/\/lain.bgm.tv 与未转义两种形态
51
    text = text.replace(/https?:\\?\/\\?\/?(?:[\w-]+\.)*lain\.bgm\.tv/g, () => url.origin + "/img");
52
    headers.delete("content-length");
53
    headers.delete("content-encoding");
54
    return new Response(text, { status: resp.status, statusText: resp.statusText, headers });
55
  }
56
  return new Response(resp.body, { status: resp.status, statusText: resp.statusText, headers });
57
}
58

59
async function handleImg(req, url, ctx) {
60
  // 两种形态：/img<path>（lain 图床，path 透传）或 /img<完整URL>（任意图床）
61
  let rest = url.pathname.slice(4); // /img 之后（可能 /pic/... 或 /http(s)://host/...）
62
  let upstreamHost = BGM_IMG;
63
  const full = rest.match(/^\/(?:https?:)?\/(.+)$/i);
64
  if (full) {
65
    try {
66
      const abs = new URL(/^https?:\/\//i.test(full[1]) ? full[1] : (url.protocol + "//" + full[1]));
67
      upstreamHost = abs.host;
68
      rest = abs.pathname + abs.search;
69
    } catch {
70
      upstreamHost = BGM_IMG;
71
    }
72
  }
73
  const upstreamURL = `https://${upstreamHost}${rest}${url.search}`;
74
  const cache = caches.default;
75
  const key = new Request(upstreamURL, { method: "GET" });
76
  const hit = await cache.match(key);
77
  if (hit) {
78
    const r = new Response(hit.body, hit);
79
    r.headers.set("x-cache", "HIT");
80
    setCors(r.headers);
81
    return r;
82
  }
83
  const resp = await fetch(new Request(upstreamURL, {
84
    method: "GET",
85
    headers: cleanRequestHeaders(req.headers),
86
    redirect: "follow",
87
  }));
88
  const out = new Response(resp.body, resp);
89
  out.headers.set("x-cache", "MISS");
90
  setCors(out.headers);
91
  if (resp.status === 200) {
92
    out.headers.set("cache-control", `public, max-age=${IMG_CACHE_TTL}`);
93
    ctx.waitUntil(cache.put(key, out.clone()));
94
  }
95
  return out;
96
}
97

98
async function handleSite(req, url, p) {
99
  const rest = p.slice(5) || "/"; // 去掉 /site
100
  const resp = await fetch(new Request(`https://${BGM_SITE}${rest}${url.search}`, {
101
    method: req.method,
102
    headers: cleanRequestHeaders(req.headers),
103
    body: ["GET", "HEAD"].includes(req.method) ? undefined : req.body,
104
    redirect: "manual",
105
  }));
106
  if (resp.status >= 300 && resp.status < 400) {
107
    const loc = resp.headers.get("location");
108
    if (loc) {
109
      const out = new Response(resp.body, resp);
110
      let target = loc;
111
      target = target.replace(/^https?:\/\/(?:www\.)?(?:bangumi\.tv|bgm\.tv|next\.bgm\.tv)/, url.origin + "/site");
112
      if (/^\/(?!site\/|img\/|v0|p1)/.test(target)) {
113
        target = "/site" + target;
114
      }
115
      out.headers.set("location", target);
116
      return out;
117
    }
118
  }
119
  const headers = new Headers(resp.headers);
120
  setCors(headers);
121
  const ct = resp.headers.get("content-type") || "";
122
  if (ct.includes("text/html")) {
123
    let text = await resp.text();
124
    text = text
125
      .replace(/https?:\/\/(?:[\w-]+\.)*lain\.bgm\.tv/g, url.origin + "/img")
126
      .replace(/\/\/lain\.bgm\.tv/g, url.origin + "/img")
127
      .replace(/https?:\/\/(?:www\.)?(?:bangumi\.tv|(?:www\.)?bgm\.tv|next\.bgm\.tv)/g, url.origin + "/site")
128
      .replace(/(href|src|action)="\/(?!site\/)/g, '$1="/site/');
129
    headers.delete("content-length");
130
    headers.delete("content-encoding");
131
    return new Response(text, { status: resp.status, statusText: resp.statusText, headers });
132
  }
133
  return new Response(resp.body, { status: resp.status, statusText: resp.statusText, headers });
134
}
135

136
function cleanRequestHeaders(h) {
137
  const out = new Headers(h);
138
  out.delete("host");
139
  out.delete("cf-connecting-ip");
140
  out.delete("cf-ipcountry");
141
  out.delete("x-forwarded-host");
142
  return out;
143
}
144
function corsHeaders() {
145
  return {
146
    "Access-Control-Allow-Origin": "*",
147
    "Access-Control-Allow-Methods": "GET,POST,PUT,PATCH,DELETE,OPTIONS",
148
    "Access-Control-Allow-Headers": "Authorization,Content-Type",
149
    "Access-Control-Max-Age": "86400",
150
  };
151
}
152
function setCors(headers) {
153
  headers.set("Access-Control-Allow-Origin", "*");
154
}
155
function json(obj) {
156
  return new Response(JSON.stringify(obj), {
157
    headers: { "content-type": "application/json; charset=utf-8", ...corsHeaders() },
158
  });
159
}

1
104.25.250.101  43.77ms  ✓ 200
2
104.25.252.217  47.86ms  ✓ 200
3
104.25.246.242  51.58ms  ✓ 200
4
104.25.249.207  53.94ms  ✓ 200
5
104.25.245.225  54.45ms  ✓ 200
6
104.18.34.44    60.26ms  ✓ 200
7
104.18.44.24    60.64ms  ✓ 200
8
172.64.146.166  67.21ms  ✓ 200
9
104.21.89.238   67.21ms  ✓ 200
10
104.17.99.241   67.46ms  ✓ 200

1
104.25.250.101 bgm-proxy-iv9.pages.dev
2
104.25.250.101 tsangasuna.pages.dev
3
104.25.250.101 tsangasuna-en.pages.dev