mirror of
https://github.com/LibreSpark/LibreTV.git
synced 2026-05-07 06:06:43 +08:00
498 lines
22 KiB
JavaScript
498 lines
22 KiB
JavaScript
// /api/proxy/[...path].mjs - Vercel Serverless Function (ES Module)
|
||
|
||
import fetch from 'node-fetch';
|
||
import { URL } from 'url'; // 使用 Node.js 内置 URL 处理
|
||
import crypto from 'crypto'; // 导入 crypto 模块用于密码哈希
|
||
|
||
// --- 配置 (从环境变量读取) ---
|
||
const DEBUG_ENABLED = process.env.DEBUG === 'true';
|
||
const CACHE_TTL = parseInt(process.env.CACHE_TTL || '86400', 10); // 默认 24 小时
|
||
const MAX_RECURSION = parseInt(process.env.MAX_RECURSION || '5', 10); // 默认 5 层
|
||
|
||
// --- User Agent 处理 ---
|
||
// 默认 User Agent 列表
|
||
let USER_AGENTS = [
|
||
'Mozilla/5.0 (Windows NT 10.0; Win64; x64) AppleWebKit/537.36 (KHTML, like Gecko) Chrome/120.0.0.0 Safari/537.36',
|
||
'Mozilla/5.0 (Macintosh; Intel Mac OS X 10_15_7) AppleWebKit/605.1.15 (KHTML, like Gecko) Version/17.0 Safari/605.1.15'
|
||
];
|
||
// 尝试从环境变量读取并解析 USER_AGENTS_JSON
|
||
try {
|
||
const agentsJsonString = process.env.USER_AGENTS_JSON;
|
||
if (agentsJsonString) {
|
||
const parsedAgents = JSON.parse(agentsJsonString);
|
||
// 检查解析结果是否为非空数组
|
||
if (Array.isArray(parsedAgents) && parsedAgents.length > 0) {
|
||
USER_AGENTS = parsedAgents; // 使用环境变量中的数组
|
||
console.log(`[代理日志] 已从环境变量加载 ${USER_AGENTS.length} 个 User Agent。`);
|
||
} else {
|
||
console.warn("[代理日志] 环境变量 USER_AGENTS_JSON 不是有效的非空数组，使用默认值。");
|
||
}
|
||
} else {
|
||
console.log("[代理日志] 未设置环境变量 USER_AGENTS_JSON，使用默认 User Agent。");
|
||
}
|
||
} catch (e) {
|
||
// 如果 JSON 解析失败，记录错误并使用默认值
|
||
console.error(`[代理日志] 解析环境变量 USER_AGENTS_JSON 出错: ${e.message}。使用默认 User Agent。`);
|
||
}
|
||
|
||
// 广告过滤在代理中禁用，由播放器处理
|
||
const FILTER_DISCONTINUITY = false;
|
||
|
||
|
||
// --- 辅助函数 ---
|
||
|
||
function logDebug(message) {
|
||
if (DEBUG_ENABLED) {
|
||
console.log(`[代理日志] ${message}`);
|
||
}
|
||
}
|
||
|
||
/**
|
||
* 从代理请求路径中提取编码后的目标 URL。
|
||
* @param {string} encodedPath - URL 编码后的路径部分 (例如 "https%3A%2F%2F...")
|
||
* @returns {string|null} 解码后的目标 URL，如果无效则返回 null。
|
||
*/
|
||
function getTargetUrlFromPath(encodedPath) {
|
||
if (!encodedPath) {
|
||
logDebug("getTargetUrlFromPath 收到空路径。");
|
||
return null;
|
||
}
|
||
try {
|
||
const decodedUrl = decodeURIComponent(encodedPath);
|
||
// 基础检查，看是否像一个 HTTP/HTTPS URL
|
||
if (decodedUrl.match(/^https?:\/\/.+/i)) {
|
||
return decodedUrl;
|
||
} else {
|
||
logDebug(`无效的解码 URL 格式: ${decodedUrl}`);
|
||
// 备选检查：原始路径是否未编码但看起来像 URL？
|
||
if (encodedPath.match(/^https?:\/\/.+/i)) {
|
||
logDebug(`警告: 路径未编码但看起来像 URL: ${encodedPath}`);
|
||
return encodedPath;
|
||
}
|
||
return null;
|
||
}
|
||
} catch (e) {
|
||
// 捕获解码错误 (例如格式错误的 URI)
|
||
logDebug(`解码目标 URL 出错: ${encodedPath} - ${e.message}`);
|
||
return null;
|
||
}
|
||
}
|
||
|
||
function getBaseUrl(urlStr) {
|
||
if (!urlStr) return '';
|
||
try {
|
||
const parsedUrl = new URL(urlStr);
|
||
// 处理根目录或只有文件名的情况
|
||
const pathSegments = parsedUrl.pathname.split('/').filter(Boolean); // 移除空字符串
|
||
if (pathSegments.length <= 1) {
|
||
return `${parsedUrl.origin}/`;
|
||
}
|
||
pathSegments.pop(); // 移除最后一段
|
||
return `${parsedUrl.origin}/${pathSegments.join('/')}/`;
|
||
} catch (e) {
|
||
logDebug(`获取 BaseUrl 失败: "${urlStr}": ${e.message}`);
|
||
// 备用方法：查找最后一个斜杠
|
||
const lastSlashIndex = urlStr.lastIndexOf('/');
|
||
if (lastSlashIndex > urlStr.indexOf('://') + 2) { // 确保不是协议部分的斜杠
|
||
return urlStr.substring(0, lastSlashIndex + 1);
|
||
}
|
||
return urlStr + '/'; // 如果没有路径，添加斜杠
|
||
}
|
||
}
|
||
|
||
function resolveUrl(baseUrl, relativeUrl) {
|
||
if (!relativeUrl) return ''; // 处理空的 relativeUrl
|
||
if (relativeUrl.match(/^https?:\/\/.+/i)) {
|
||
return relativeUrl; // 已经是绝对 URL
|
||
}
|
||
if (!baseUrl) return relativeUrl; // 没有基础 URL 无法解析
|
||
|
||
try {
|
||
// 使用 Node.js 的 URL 构造函数处理相对路径
|
||
return new URL(relativeUrl, baseUrl).toString();
|
||
} catch (e) {
|
||
logDebug(`URL 解析失败: base="${baseUrl}", relative="${relativeUrl}". 错误: ${e.message}`);
|
||
// 简单的备用逻辑
|
||
if (relativeUrl.startsWith('/')) {
|
||
try {
|
||
const baseOrigin = new URL(baseUrl).origin;
|
||
return `${baseOrigin}${relativeUrl}`;
|
||
} catch { return relativeUrl; } // 如果 baseUrl 也无效，返回原始相对路径
|
||
} else {
|
||
// 假设相对于包含基础 URL 资源的目录
|
||
return `${baseUrl.substring(0, baseUrl.lastIndexOf('/') + 1)}${relativeUrl}`;
|
||
}
|
||
}
|
||
}
|
||
|
||
// ** 已修正：确保生成 /proxy/ 前缀的链接 **
|
||
function rewriteUrlToProxy(targetUrl) {
|
||
if (!targetUrl || typeof targetUrl !== 'string') return '';
|
||
// 返回与 vercel.json 的 "source" 和前端 PROXY_URL 一致的路径
|
||
return `/proxy/${encodeURIComponent(targetUrl)}`;
|
||
}
|
||
|
||
function getRandomUserAgent() {
|
||
return USER_AGENTS[Math.floor(Math.random() * USER_AGENTS.length)];
|
||
}
|
||
|
||
async function fetchContentWithType(targetUrl, requestHeaders) {
|
||
// 准备请求头
|
||
const headers = {
|
||
'User-Agent': getRandomUserAgent(),
|
||
'Accept': requestHeaders['accept'] || '*/*', // 传递原始 Accept 头（如果有）
|
||
'Accept-Language': requestHeaders['accept-language'] || 'zh-CN,zh;q=0.9,en;q=0.8',
|
||
// 尝试设置一个合理的 Referer
|
||
'Referer': requestHeaders['referer'] || new URL(targetUrl).origin,
|
||
};
|
||
// 清理空值的头
|
||
Object.keys(headers).forEach(key => headers[key] === undefined || headers[key] === null || headers[key] === '' ? delete headers[key] : {});
|
||
|
||
logDebug(`准备请求目标: ${targetUrl}，请求头: ${JSON.stringify(headers)}`);
|
||
|
||
try {
|
||
// 发起 fetch 请求
|
||
const response = await fetch(targetUrl, { headers, redirect: 'follow' });
|
||
|
||
// 检查响应是否成功
|
||
if (!response.ok) {
|
||
const errorBody = await response.text().catch(() => ''); // 尝试获取错误响应体
|
||
logDebug(`请求失败: ${response.status} ${response.statusText} - ${targetUrl}`);
|
||
// 创建一个包含状态码的错误对象
|
||
const err = new Error(`HTTP 错误 ${response.status}: ${response.statusText}. URL: ${targetUrl}. Body: ${errorBody.substring(0, 200)}`);
|
||
err.status = response.status; // 将状态码附加到错误对象
|
||
throw err; // 抛出错误
|
||
}
|
||
|
||
// 读取响应内容
|
||
const content = await response.text();
|
||
const contentType = response.headers.get('content-type') || '';
|
||
logDebug(`请求成功: ${targetUrl}, Content-Type: ${contentType}, 内容长度: ${content.length}`);
|
||
// 返回结果
|
||
return { content, contentType, responseHeaders: response.headers };
|
||
|
||
} catch (error) {
|
||
// 捕获 fetch 本身的错误（网络、超时等）或上面抛出的 HTTP 错误
|
||
logDebug(`请求异常 ${targetUrl}: ${error.message}`);
|
||
// 重新抛出，确保包含原始错误信息
|
||
throw new Error(`请求目标 URL 失败 ${targetUrl}: ${error.message}`);
|
||
}
|
||
}
|
||
|
||
function isM3u8Content(content, contentType) {
|
||
if (contentType && (contentType.includes('application/vnd.apple.mpegurl') || contentType.includes('application/x-mpegurl') || contentType.includes('audio/mpegurl'))) {
|
||
return true;
|
||
}
|
||
return content && typeof content === 'string' && content.trim().startsWith('#EXTM3U');
|
||
}
|
||
|
||
function processKeyLine(line, baseUrl) {
|
||
return line.replace(/URI="([^"]+)"/, (match, uri) => {
|
||
const absoluteUri = resolveUrl(baseUrl, uri);
|
||
logDebug(`处理 KEY URI: 原始='${uri}', 绝对='${absoluteUri}'`);
|
||
return `URI="${rewriteUrlToProxy(absoluteUri)}"`;
|
||
});
|
||
}
|
||
|
||
function processMapLine(line, baseUrl) {
|
||
return line.replace(/URI="([^"]+)"/, (match, uri) => {
|
||
const absoluteUri = resolveUrl(baseUrl, uri);
|
||
logDebug(`处理 MAP URI: 原始='${uri}', 绝对='${absoluteUri}'`);
|
||
return `URI="${rewriteUrlToProxy(absoluteUri)}"`;
|
||
});
|
||
}
|
||
|
||
function processMediaPlaylist(url, content) {
|
||
const baseUrl = getBaseUrl(url);
|
||
if (!baseUrl) {
|
||
logDebug(`无法确定媒体列表的 Base URL: ${url}，相对路径可能无法处理。`);
|
||
}
|
||
const lines = content.split('\n');
|
||
const output = [];
|
||
for (let i = 0; i < lines.length; i++) {
|
||
const line = lines[i].trim();
|
||
// 保留最后一个空行
|
||
if (!line && i === lines.length - 1) { output.push(line); continue; }
|
||
if (!line) continue; // 跳过中间空行
|
||
// 广告过滤已禁用
|
||
if (line.startsWith('#EXT-X-KEY')) { output.push(processKeyLine(line, baseUrl)); continue; }
|
||
if (line.startsWith('#EXT-X-MAP')) { output.push(processMapLine(line, baseUrl)); continue; }
|
||
if (line.startsWith('#EXTINF')) { output.push(line); continue; }
|
||
// 处理 URL 行
|
||
if (!line.startsWith('#')) {
|
||
const absoluteUrl = resolveUrl(baseUrl, line);
|
||
logDebug(`重写媒体片段: 原始='${line}', 解析后='${absoluteUrl}'`);
|
||
output.push(rewriteUrlToProxy(absoluteUrl)); continue;
|
||
}
|
||
// 保留其他 M3U8 标签
|
||
output.push(line);
|
||
}
|
||
return output.join('\n');
|
||
}
|
||
|
||
async function processM3u8Content(targetUrl, content, recursionDepth = 0) {
|
||
// 判断是主列表还是媒体列表
|
||
if (content.includes('#EXT-X-STREAM-INF') || content.includes('#EXT-X-MEDIA:')) {
|
||
logDebug(`检测到主播放列表: ${targetUrl} (深度: ${recursionDepth})`);
|
||
return await processMasterPlaylist(targetUrl, content, recursionDepth);
|
||
}
|
||
logDebug(`检测到媒体播放列表: ${targetUrl} (深度: ${recursionDepth})`);
|
||
return processMediaPlaylist(targetUrl, content);
|
||
}
|
||
|
||
async function processMasterPlaylist(url, content, recursionDepth) {
|
||
// 检查递归深度
|
||
if (recursionDepth > MAX_RECURSION) {
|
||
throw new Error(`处理主播放列表时，递归深度超过最大限制 (${MAX_RECURSION}): ${url}`);
|
||
}
|
||
const baseUrl = getBaseUrl(url);
|
||
const lines = content.split('\n');
|
||
let highestBandwidth = -1;
|
||
let bestVariantUrl = '';
|
||
|
||
// 查找最高带宽的流
|
||
for (let i = 0; i < lines.length; i++) {
|
||
if (lines[i].startsWith('#EXT-X-STREAM-INF')) {
|
||
const bandwidthMatch = lines[i].match(/BANDWIDTH=(\d+)/);
|
||
const currentBandwidth = bandwidthMatch ? parseInt(bandwidthMatch[1], 10) : 0;
|
||
let variantUriLine = '';
|
||
// 找到下一行的 URI
|
||
for (let j = i + 1; j < lines.length; j++) {
|
||
const line = lines[j].trim();
|
||
if (line && !line.startsWith('#')) { variantUriLine = line; i = j; break; }
|
||
}
|
||
if (variantUriLine && currentBandwidth >= highestBandwidth) {
|
||
highestBandwidth = currentBandwidth;
|
||
bestVariantUrl = resolveUrl(baseUrl, variantUriLine);
|
||
}
|
||
}
|
||
}
|
||
// 如果没有找到带宽信息，尝试查找第一个 .m3u8 链接
|
||
if (!bestVariantUrl) {
|
||
logDebug(`主播放列表中未找到 BANDWIDTH 信息，尝试查找第一个 URI: ${url}`);
|
||
for (let i = 0; i < lines.length; i++) {
|
||
const line = lines[i].trim();
|
||
// 更可靠地匹配 .m3u8 链接
|
||
if (line && !line.startsWith('#') && line.match(/\.m3u8($|\?.*)/i)) {
|
||
bestVariantUrl = resolveUrl(baseUrl, line);
|
||
logDebug(`备选方案: 找到第一个子播放列表 URI: ${bestVariantUrl}`);
|
||
break;
|
||
}
|
||
}
|
||
}
|
||
// 如果仍然没有找到子列表 URL
|
||
if (!bestVariantUrl) {
|
||
logDebug(`在主播放列表 ${url} 中未找到有效的子列表 URI，将其作为媒体列表处理。`);
|
||
return processMediaPlaylist(url, content);
|
||
}
|
||
|
||
logDebug(`选择的子播放列表 (带宽: ${highestBandwidth}): ${bestVariantUrl}`);
|
||
// 请求选定的子播放列表内容 (注意：这里传递 {} 作为请求头，不传递客户端的原始请求头)
|
||
const { content: variantContent, contentType: variantContentType } = await fetchContentWithType(bestVariantUrl, {});
|
||
|
||
// 检查获取的内容是否是 M3U8
|
||
if (!isM3u8Content(variantContent, variantContentType)) {
|
||
logDebug(`获取的子播放列表 ${bestVariantUrl} 不是 M3U8 (类型: ${variantContentType})，将其作为媒体列表处理。`);
|
||
return processMediaPlaylist(bestVariantUrl, variantContent);
|
||
}
|
||
|
||
// 递归处理获取到的子 M3U8 内容
|
||
return await processM3u8Content(bestVariantUrl, variantContent, recursionDepth + 1);
|
||
}
|
||
|
||
/**
|
||
* 验证代理请求的鉴权
|
||
*/
|
||
async function validateAuth(req) {
|
||
const authHash = req.query.auth;
|
||
const timestamp = req.query.t;
|
||
|
||
// 获取服务器端密码哈希
|
||
const serverPassword = process.env.PASSWORD;
|
||
if (!serverPassword) {
|
||
console.error('服务器未设置 PASSWORD 环境变量，代理访问被拒绝');
|
||
return false;
|
||
}
|
||
|
||
// 使用 crypto 模块计算 SHA-256 哈希
|
||
const serverPasswordHash = crypto.createHash('sha256').update(serverPassword).digest('hex');
|
||
|
||
if (!authHash || authHash !== serverPasswordHash) {
|
||
console.warn('代理请求鉴权失败：密码哈希不匹配');
|
||
return false;
|
||
}
|
||
|
||
// 验证时间戳（10分钟有效期）
|
||
if (timestamp) {
|
||
const now = Date.now();
|
||
const maxAge = 10 * 60 * 1000; // 10分钟
|
||
if (now - parseInt(timestamp) > maxAge) {
|
||
console.warn('代理请求鉴权失败：时间戳过期');
|
||
return false;
|
||
}
|
||
}
|
||
|
||
return true;
|
||
}
|
||
|
||
// --- Vercel Handler 函数 ---
|
||
export default async function handler(req, res) {
|
||
// --- 记录请求开始 ---
|
||
console.info('--- Vercel 代理请求开始 ---');
|
||
console.info('时间:', new Date().toISOString());
|
||
console.info('方法:', req.method);
|
||
console.info('URL:', req.url); // 原始请求 URL (例如 /proxy/...)
|
||
console.info('查询参数:', JSON.stringify(req.query)); // Vercel 解析的查询参数
|
||
|
||
// --- 提前设置 CORS 头 ---
|
||
res.setHeader('Access-Control-Allow-Origin', '*');
|
||
res.setHeader('Access-Control-Allow-Methods', 'GET, HEAD, OPTIONS');
|
||
res.setHeader('Access-Control-Allow-Headers', '*'); // 允许所有请求头
|
||
|
||
// --- 处理 OPTIONS 预检请求 ---
|
||
if (req.method === 'OPTIONS') {
|
||
console.info("处理 OPTIONS 预检请求");
|
||
res.status(204).setHeader('Access-Control-Max-Age', '86400').end(); // 缓存预检结果 24 小时
|
||
return;
|
||
}
|
||
|
||
let targetUrl = null; // 初始化目标 URL
|
||
|
||
try { // ---- 开始主处理逻辑的 try 块 ----
|
||
|
||
// --- 验证鉴权 ---
|
||
const isAuthorized = await validateAuth(req);
|
||
if (!isAuthorized) {
|
||
console.warn('代理请求鉴权失败');
|
||
res.status(401).json({
|
||
success: false,
|
||
error: '代理访问未授权：请检查密码配置或鉴权参数'
|
||
});
|
||
return;
|
||
}
|
||
|
||
// --- 提取目标 URL (主要依赖 req.query["...path"]) ---
|
||
// Vercel 将 :path* 捕获的内容（可能包含斜杠）放入 req.query["...path"] 数组
|
||
const pathData = req.query["...path"]; // 使用正确的键名
|
||
let encodedUrlPath = '';
|
||
|
||
if (pathData) {
|
||
if (Array.isArray(pathData)) {
|
||
encodedUrlPath = pathData.join('/'); // 重新组合
|
||
console.info(`从 req.query["...path"] (数组) 组合的编码路径: ${encodedUrlPath}`);
|
||
} else if (typeof pathData === 'string') {
|
||
encodedUrlPath = pathData; // 也处理 Vercel 可能只返回字符串的情况
|
||
console.info(`从 req.query["...path"] (字符串) 获取的编码路径: ${encodedUrlPath}`);
|
||
} else {
|
||
console.warn(`[代理警告] req.query["...path"] 类型未知: ${typeof pathData}`);
|
||
}
|
||
} else {
|
||
console.warn(`[代理警告] req.query["...path"] 为空或未定义。`);
|
||
// 备选：尝试从 req.url 提取（如果需要）
|
||
if (req.url && req.url.startsWith('/proxy/')) {
|
||
encodedUrlPath = req.url.substring('/proxy/'.length);
|
||
console.info(`使用备选方法从 req.url 提取的编码路径: ${encodedUrlPath}`);
|
||
}
|
||
}
|
||
|
||
// 如果仍然为空，则无法继续
|
||
if (!encodedUrlPath) {
|
||
throw new Error("无法从请求中确定编码后的目标路径。");
|
||
}
|
||
|
||
// 解析目标 URL
|
||
targetUrl = getTargetUrlFromPath(encodedUrlPath);
|
||
console.info(`解析出的目标 URL: ${targetUrl || 'null'}`); // 记录解析结果
|
||
|
||
// 检查目标 URL 是否有效
|
||
if (!targetUrl) {
|
||
// 抛出包含更多上下文的错误
|
||
throw new Error(`无效的代理请求路径。无法从组合路径 "${encodedUrlPath}" 中提取有效的目标 URL。`);
|
||
}
|
||
|
||
console.info(`开始处理目标 URL 的代理请求: ${targetUrl}`);
|
||
|
||
// --- 获取并处理目标内容 ---
|
||
const { content, contentType, responseHeaders } = await fetchContentWithType(targetUrl, req.headers);
|
||
|
||
// --- 如果是 M3U8，处理并返回 ---
|
||
if (isM3u8Content(content, contentType)) {
|
||
console.info(`正在处理 M3U8 内容: ${targetUrl}`);
|
||
const processedM3u8 = await processM3u8Content(targetUrl, content);
|
||
|
||
console.info(`成功处理 M3U8: ${targetUrl}`);
|
||
// 发送处理后的 M3U8 响应
|
||
res.status(200)
|
||
.setHeader('Content-Type', 'application/vnd.apple.mpegurl;charset=utf-8')
|
||
.setHeader('Cache-Control', `public, max-age=${CACHE_TTL}`)
|
||
// 移除可能导致问题的原始响应头
|
||
.removeHeader('content-encoding') // 很重要！node-fetch 已解压
|
||
.removeHeader('content-length') // 长度已改变
|
||
.send(processedM3u8); // 发送 M3U8 文本
|
||
|
||
} else {
|
||
// --- 如果不是 M3U8，直接返回原始内容 ---
|
||
console.info(`直接返回非 M3U8 内容: ${targetUrl}, 类型: ${contentType}`);
|
||
|
||
// 设置原始响应头，但排除有问题的头和 CORS 头（已设置）
|
||
responseHeaders.forEach((value, key) => {
|
||
const lowerKey = key.toLowerCase();
|
||
if (!lowerKey.startsWith('access-control-') &&
|
||
lowerKey !== 'content-encoding' && // 很重要！
|
||
lowerKey !== 'content-length') { // 很重要！
|
||
res.setHeader(key, value); // 设置其他原始头
|
||
}
|
||
});
|
||
// 设置我们自己的缓存策略
|
||
res.setHeader('Cache-Control', `public, max-age=${CACHE_TTL}`);
|
||
|
||
// 发送原始（已解压）内容
|
||
res.status(200).send(content);
|
||
}
|
||
|
||
// ---- 结束主处理逻辑的 try 块 ----
|
||
} catch (error) { // ---- 捕获处理过程中的任何错误 ----
|
||
// **检查这个错误是否是 "Assignment to constant variable"**
|
||
console.error(`[代理错误处理 V3] 捕获错误！目标: ${targetUrl || '解析失败'} | 错误类型: ${error.constructor.name} | 错误消息: ${error.message}`);
|
||
console.error(`[代理错误堆栈 V3] ${error.stack}`); // 记录完整的错误堆栈信息
|
||
|
||
// 特别标记 "Assignment to constant variable" 错误
|
||
if (error instanceof TypeError && error.message.includes("Assignment to constant variable")) {
|
||
console.error("!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!");
|
||
console.error("捕获到 'Assignment to constant variable' 错误!");
|
||
console.error("请再次检查函数代码及所有辅助函数中，是否有 const 声明的变量被重新赋值。");
|
||
console.error("错误堆栈指向:", error.stack);
|
||
console.error("!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!");
|
||
}
|
||
|
||
// 尝试从错误对象获取状态码，否则默认为 500
|
||
const statusCode = error.status || 500;
|
||
|
||
// 确保在发送错误响应前没有发送过响应头
|
||
if (!res.headersSent) {
|
||
res.setHeader('Content-Type', 'application/json');
|
||
// CORS 头应该已经在前面设置好了
|
||
res.status(statusCode).json({
|
||
success: false,
|
||
error: `代理处理错误: ${error.message}`, // 返回错误消息给前端
|
||
targetUrl: targetUrl // 包含目标 URL 以便调试
|
||
});
|
||
} else {
|
||
// 如果响应头已发送，无法再发送 JSON 错误
|
||
console.error("[代理错误处理 V3] 响应头已发送，无法发送 JSON 错误响应。");
|
||
// 尝试结束响应
|
||
if (!res.writableEnded) {
|
||
res.end();
|
||
}
|
||
}
|
||
} finally {
|
||
// 记录请求处理结束
|
||
console.info('--- Vercel 代理请求结束 ---');
|
||
}
|
||
}
|
||
|
||
// --- [确保所有辅助函数定义都在这里] ---
|
||
// getTargetUrlFromPath, getBaseUrl, resolveUrl, rewriteUrlToProxy, getRandomUserAgent,
|
||
// fetchContentWithType, isM3u8Content, processKeyLine, processMapLine,
|
||
// processMediaPlaylist, processM3u8Content, processMasterPlaylist
|