🚀 TMDB Proxy

/** * Cloudflare Pages Functions - TMDB Proxy API * 文件位置: functions/api/[[path]].js */ export async function onRequest(context) { const { request, env, params } = context; const url = new URL(request.url); // 移除 /api 前缀，构建TMDB目标URL const path = url.pathname.replace(/^\/api/, ''); const targetUrl = \`https://api.themoviedb.org\${path}\${url.search}\`; // 设置CORS头 const corsHeaders = { 'Access-Control-Allow-Origin': '*', 'Access-Control-Allow-Methods': 'GET, POST, OPTIONS', 'Access-Control-Allow-Headers': 'Content-Type, Authorization', }; // 处理OPTIONS预检请求 if (request.method === 'OPTIONS') { return new Response(null, { status: 204, headers: corsHeaders }); } try { // 检查是否是图片请求（TMDB图片代理） if (path.startsWith('/t/')) { return await handleImageRequest(request, path, url.search, corsHeaders); } // 处理API请求 return await handleApiRequest(request, targetUrl, corsHeaders); } catch (error) { return new Response(JSON.stringify({ error: 'Proxy Error', message: error.message, timestamp: new Date().toISOString() }), { status: 500, headers: { 'Content-Type': 'application/json', ...corsHeaders } }); } } async function handleApiRequest(request, targetUrl, corsHeaders) { const cacheKey = new Request(targetUrl, { method: 'GET', headers: { 'Accept': 'application/json' } }); const cache = caches.default; let response = await cache.match(cacheKey); if (!response) { response = await fetch(targetUrl, { method: request.method, headers: { 'User-Agent': 'Mozilla/5.0 (Windows NT 10.0; Win64; x64) AppleWebKit/537.36', 'Accept': request.headers.get('Accept') || 'application/json', 'Authorization': request.headers.get('Authorization') || '', } }); if (response.ok) { const responseToCache = response.clone(); const cacheHeaders = new Headers(responseToCache.headers); cacheHeaders.set('Cache-Control', 'public, max-age=600'); const cachedResponse = new Response(responseToCache.body, { status: responseToCache.status, headers: cacheHeaders }); context.waitUntil(cache.put(cacheKey, cachedResponse)); } } const newHeaders = new Headers(response.headers); Object.entries(corsHeaders).forEach(([key, value]) => { newHeaders.set(key, value); }); return new Response(response.body, { status: response.status, statusText: response.statusText, headers: newHeaders }); } async function handleImageRequest(request, path, search, corsHeaders) { const targetUrl = \`https://image.tmdb.org\${path}\${search}\`; const cacheKey = new Request(targetUrl, { method: 'GET', headers: { 'Accept': 'image/*' } }); const cache = caches.default; let response = await cache.match(cacheKey); if (!response) { response = await fetch(targetUrl, { method: 'GET', headers: { 'User-Agent': 'Mozilla/5.0 (Windows NT 10.0; Win64; x64) AppleWebKit/537.36', 'Accept': 'image/*', } }); if (response.ok) { const responseToCache = response.clone(); const cacheHeaders = new Headers(responseToCache.headers); cacheHeaders.set('Cache-Control', 'public, max-age=604800'); const cachedResponse = new Response(responseToCache.body, { status: responseToCache.status, headers: cacheHeaders }); context.waitUntil(cache.put(cacheKey, cachedResponse)); } } const newHeaders = new Headers(response.headers); Object.entries(corsHeaders).forEach(([key, value]) => { newHeaders.set(key, value); }); newHeaders.set('Cache-Control', 'public, max-age=604800'); return new Response(response.body, { status: response.status, statusText: response.statusText, headers: newHeaders }); }