零成本 VIP 视频聚合站：Cloudflare Pages Functions 多源调度架构

1
// 熔断器状态机
2
const breakerState = new Map(); // sourceId → { failures, tripped, tripUntil }
3

4
function isTripped(sourceId) {
5
  const state = breakerState.get(sourceId);
6
  if (!state) return false;
7
  // 还在熔断窗口内？跳过
8
  if (state.tripped && Date.now() < state.tripUntil) return true;
9
  // 熔断窗口过了，自动重置，允许试探
10
  if (state.tripped && Date.now() >= state.tripUntil) {
11
    state.tripped = false;
12
    state.failures = 0;
13
  }
14
  return false;
15
}

1
export async function searchVideos(keyword, page = 1) {
2
  // 并行请求 5 个源
3
  const results = await Promise.all(
4
    sources.map((s) => fetchFromSource(s, { ac: 'videolist', pg: page, wd: keyword }))
5
  );
6

7
  // 按 vod_name 归并，同一片子的多个源合并
8
  const grouped = new Map();
9
  for (const data of results) {
10
    for (const item of data.list) {
11
      const key = item.vod_name;
12
      if (!grouped.has(key)) {
13
        grouped.set(key, { ...item, _playSources: [] });
14
      }
15
      // 把播放线路合到一起
16
      grouped.get(key)._playSources.push(...parsePlaySources(item));
17
    }
18
  }
19
  return [...grouped.values()];
20
}

1
async function getCache(key) {
2
  const cache = await caches.default;
3
  const res = await cache.match(new Request('https://cache.local/' + key));
4
  if (!res) return null;
5
  const data = await res.json();
6
  // 手动 TTL，Cloudflare Cache API 不会主动过期
7
  if (Date.now() > data._expires) return null;
8
  return data;
9
}
10

11
async function setCache(key, data, ttl = 300) {
12
  const cache = await caches.default;
13
  await cache.put(
14
    new Request('https://cache.local/' + key),
15
    new Response(JSON.stringify({ ...data, _expires: Date.now() + ttl * 1000 }), {
16
      headers: { 'Cache-Control': `max-age=${ttl}` },
17
    })
18
  );
19
}

1
export function classifyPlayUrl(url) {
2
  // 官方平台 URL → 套第三方解析 API
3
  if (/v\.qq\.com|iqiyi\.com|youku\.com/.test(url)) return 'official';
4

5
  // m3u8 直链 → hls.js 直接播
6
  if (/\.m3u8(\?|$)/i.test(url)) return 'm3u8';
7

8
  // 资源站分享页（如 U酷云播、金鹰云播）
9
  // → 页面自带播放器，直接 iframe 嵌入
10
  if (/\/share\/[a-zA-Z0-9]{4,}/i.test(url)) {
11
    if (/ukzy|ukubf/i.test(host)) return 'shareDirect';
12
    return 'share'; // 其他 share 可能需要二次解析
13
  }
14

15
  return 'unknown';
16
}