1
/**
2
 * 随机图 API - 腾讯云 EdgeOne 大满贯版
3
 * 特性：直连七牛云目录、极速内存缓存、边缘代理(零跨域、非302)
4
 */
5

6
// ==========================================
7
// 1. 核心配置区
8
// ==========================================
9
const CONFIG = {
10
  AK: "AK密钥",
11
  SK: "SK密钥",
12
  BUCKET: "七牛云存储空间名称",
13
  DOMAIN: "最好填写套一层CDN的，EO的域名", // 你的图床 CDN 域名
14

15
  PC_PREFIX: "blog/bg/",
16
  MOBILE_PREFIX: "blog/bg-m/"
17
};
18

19
// ==========================================
20
// 2. 全局内存缓存
21
// ==========================================
22
let pcImages = [];
23
let mobileImages = [];
24
let lastCheckTime = 0;
25
const CACHE_TTL = 3 * 60 * 1000; // 3 分钟缓存
26

27
addEventListener('fetch', event => {
28
  event.respondWith(handleRequest(event.request))
29
});
30

31
// ==========================================
32
// 3. 密码学：生成七牛云鉴权 Token
33
// ==========================================
34
async function generateQiniuToken(path) {
35
  const signingStr = `${path}\n`;
36
  const encoder = new TextEncoder();
37
  const key = await crypto.subtle.importKey(
38
    'raw', encoder.encode(CONFIG.SK),
39
    { name: 'HMAC', hash: 'SHA-1' }, false, ['sign']
40
  );
41
  const signature = await crypto.subtle.sign('HMAC', key, encoder.encode(signingStr));
42
  const base64 = btoa(String.fromCharCode(...new Uint8Array(signature)));
43
  const encodedSign = base64.replace(/\+/g, '-').replace(/\//g, '_');
44
  return `QBox ${CONFIG.AK}:${encodedSign}`;
45
}
46

47
// ==========================================
48
// 4. 抓取七牛云真实文件列表
49
// ==========================================
50
async function fetchImagesFromQiniu(prefix) {
51
  try {
52
    const apiPath = `/list?bucket=${CONFIG.BUCKET}&prefix=${prefix}&limit=1000`;
53
    const apiHost = 'rsf.qiniuapi.com';
54
    const token = await generateQiniuToken(apiPath);
55

56
    const response = await fetch(`https://${apiHost}${apiPath}`, {
57
      headers: {
58
        'Authorization': token,
59
        'Content-Type': 'application/x-www-form-urlencoded'
60
      }
61
    });
62

63
    if (!response.ok) return [];
64

65
    const data = await response.json();
66
    if (!data.items) return [];
67

68
    return data.items
69
      .filter(item => item.mimeType && item.mimeType.startsWith('image/'))
70
      .map(item => `${CONFIG.DOMAIN}/${item.key}`);
71

72
  } catch (error) {
73
    console.error(`拉取目录 ${prefix} 失败:`, error);
74
    return [];
75
  }
76
}
77

78
// ==========================================
79
// 5. 代理获取图片并注入跨域头 (核心新增逻辑)
80
// ==========================================
81
async function proxyImage(imageUrl) {
82
  try {
83
    // 边缘节点出面去你的 CDN 拿图
84
    const response = await fetch(imageUrl, {
85
      headers: {
86
        "User-Agent": "Mozilla/5.0 (Windows NT 10.0; Win64; x64) EdgeOne-Proxy"
87
      }
88
    });
89

90
    if (response.ok) {
91
      // 拿到图片后，重写响应头，强行允许跨域
92
      const newHeaders = new Headers(response.headers);
93
      newHeaders.set("Access-Control-Allow-Origin", "*");
94
      newHeaders.set("Cache-Control", "no-cache"); // 告诉浏览器不要缓存当前API链接，以免下次拿不到新图
95

96
      // 返回 200 状态码和真实图片数据流
97
      return new Response(response.body, {
98
        status: 200,
99
        headers: newHeaders
100
      });
101
    }
102

103
    // 如果图片代理失败，降级回 302 重定向
104
    return Response.redirect(imageUrl, 302);
105
  } catch (e) {
106
    // 网络异常，降级回 302 重定向
107
    return Response.redirect(imageUrl, 302);
108
  }
109
}
110

111
// ==========================================
112
// 6. 主路由逻辑
113
// ==========================================
114
async function handleRequest(request) {
115
  const url = new URL(request.url);
116
  const route = url.pathname;
117

118
  // 初始化或更新缓存
119
  if (Date.now() - lastCheckTime > CACHE_TTL || pcImages.length === 0 || mobileImages.length === 0) {
120
    try {
121
      const [newPc, newMobile] = await Promise.all([
122
        fetchImagesFromQiniu(CONFIG.PC_PREFIX),
123
        fetchImagesFromQiniu(CONFIG.MOBILE_PREFIX)
124
      ]);
125

126
      if (newPc.length > 0) pcImages = newPc;
127
      if (newMobile.length > 0) mobileImages = newMobile;
128
      lastCheckTime = Date.now();
129
    } catch (e) {
130
      console.error("更新列表失败，暂时使用旧缓存");
131
    }
132
  }
133

134
  // --- 处理电脑壁纸 ---
135
  if (route === '/api') {
136
    if (pcImages.length === 0) return new Response("初始化中...", {status: 503});
137
    const randomImg = pcImages[Math.floor(Math.random() * pcImages.length)];
138
    // 调用代理函数，直接返回图片流
139
    return await proxyImage(randomImg);
140
  }
141

142
  // --- 处理手机壁纸 ---
143
  if (route === '/m-api') {
144
    if (mobileImages.length === 0) return new Response("初始化中...", {status: 503});
145
    const randomImg = mobileImages[Math.floor(Math.random() * mobileImages.length)];
146
    // 调用代理函数，直接返回图片流
147
    return await proxyImage(randomImg);
148
  }
149

150
  return new Response("API 正常运行。电脑壁纸请访问 /api，手机壁纸请访问 /m-api", {
151
    status: 200,
152
    headers: { "Content-Type": "text/html;charset=UTF-8" }
153
  });
154
}