1
// 域名前缀映射配置
2
const domain_mappings = {
3
  '源站.com': '最终访问头.',
4
//例如：
5
//'gitea.072103.xyz': 'gitea.',
6
//则你设置Worker路由为gitea.*都将会反代到gitea.072103.xyz
7
};
8

9
addEventListener('fetch', event => {
10
  event.respondWith(handleRequest(event.request));
11
});
12

13
async function handleRequest(request) {
14
  const url = new URL(request.url);
15
  const current_host = url.host;
16

17
  // 强制使用 HTTPS
18
  if (url.protocol === 'http:') {
19
    url.protocol = 'https:';
20
    return Response.redirect(url.href, 301);
21
  }
22

23
  const host_prefix = getProxyPrefix(current_host);
24
  if (!host_prefix) {
25
    return new Response('Proxy prefix not matched', { status: 404 });
26
  }
27

28
  // 查找对应目标域名
29
  let target_host = null;
30
  for (const [origin_domain, prefix] of Object.entries(domain_mappings)) {
31
    if (host_prefix === prefix) {
32
      target_host = origin_domain;
33
      break;
34
    }
35
  }
36

37
  if (!target_host) {
38
    return new Response('No matching target host for prefix', { status: 404 });
39
  }
40

41
  // 构造目标 URL
42
  const new_url = new URL(request.url);
43
  new_url.protocol = 'https:';
44
  new_url.host = target_host;
45

46
  // 创建新请求
47
  const new_headers = new Headers(request.headers);
48
  new_headers.set('Host', target_host);
49
  new_headers.set('Referer', new_url.href);
50

51
  try {
52
    const response = await fetch(new_url.href, {
53
      method: request.method,
54
      headers: new_headers,
55
      body: request.method !== 'GET' && request.method !== 'HEAD' ? request.body : undefined,
56
      redirect: 'manual'
57
    });
58

59
    // 复制响应头并添加CORS
60
    const response_headers = new Headers(response.headers);
61
    response_headers.set('access-control-allow-origin', '*');
62
    response_headers.set('access-control-allow-credentials', 'true');
63
    response_headers.set('cache-control', 'public, max-age=600');
64
    response_headers.delete('content-security-policy');
65
    response_headers.delete('content-security-policy-report-only');
66

67
    return new Response(response.body, {
68
      status: response.status,
69
      statusText: response.statusText,
70
      headers: response_headers
71
    });
72
  } catch (err) {
73
    return new Response(`Proxy Error: ${err.message}`, { status: 502 });
74
  }
75
}
76

77
function getProxyPrefix(hostname) {
78
  for (const prefix of Object.values(domain_mappings)) {
79
    if (hostname.startsWith(prefix)) {
80
      return prefix;
81
    }
82
  }
83
  return null;
84
}