diff --git a/.env.example b/.env.example index ea4962d..f4b96c6 100644 --- a/.env.example +++ b/.env.example @@ -15,10 +15,18 @@ OTHER_SERVER=https://api.danmu.icu # VOD 服务器配置（支持多服务器） # 格式：名称@URL,名称@URL,... -# 示例：VOD_SERVERS=vod1@https://api1.com,vod2@https://api2.com,vod3@https://api3.com +# 示例：VOD_SERVERS=金蝉@https://zy.jinchancaiji.com,789@https://www.caiji.cyou,听风@https://gctf.tfdh.top # 如果不指定名称，会自动生成 vod-1, vod-2 等名称 -# 默认值：vod@https://www.caiji.cyou -VOD_SERVERS=vod@https://www.caiji.cyou +# 默认值：金蝉@https://zy.jinchancaiji.com,789@https://www.caiji.cyou,听风@https://gctf.tfdh.top +VOD_SERVERS=金蝉@https://zy.jinchancaiji.com,789@https://www.caiji.cyou,听风@https://gctf.tfdh.top + +# VOD 服务器返回模式 +# 可选值：all（返回所有站点结果）、fastest（只返回最快的站点结果） +# 默认值：fastest +# 说明： +# - all: 搜索时会并发查询所有配置的 VOD 站点，返回所有结果（结果较多） +# - fastest: 搜索时只返回首先响应成功的 VOD 站点结果（结果较少，避免重复） +VOD_RETURN_MODE=fastest # VOD 服务器请求超时时间（毫秒） # 默认值：5000（5秒） @@ -79,6 +87,15 @@ GROUP_MINUTE=1 # 设置为 0 表示不限流 RATE_LIMIT_MAX_REQUESTS=3 +# ==================== 集标题过滤开关 ==================== + +# 是否在手动选择接口中启用集标题过滤 +# 默认值：false（禁用） +# 说明：GET /api/v2/bangumi/{id} 和 GET /api/v2/search/anime 接口会过滤掉预告、花絮等特殊集 +# 如需启用过滤，设置为 true +# 可选值：true, false +ENABLE_EPISODE_FILTER=false + # ==================== 代理配置 ==================== # 代理地址（用于访问受限资源） @@ -86,6 +103,15 @@ RATE_LIMIT_MAX_REQUESTS=3 # 格式：http://proxy-server:port 或 https://proxy-server:port # PROXY_URL= +# ==================== 搜索结果缓存配置 ==================== + +# 搜索结果缓存时间（分钟） +# 默认值：1 +# 说明：避免短期内重复的不必要 API 请求，同时保证获取最新的结果列表 +# 可根据需要调整：Vercel/Cloudflare 建议 1-5 分钟，Docker 可设置 5-30 分钟 +# 设置为 0 表示不缓存 +SEARCH_CACHE_MINUTES=1 + # ==================== Redis 配置（Upstash）==================== # Upstash Redis REST URL（用于缓存） diff --git a/.github/workflows/docker-image.yml b/.github/workflows/docker-image.yml index bf5ac96..3b6aeef 100644 --- a/.github/workflows/docker-image.yml +++ b/.github/workflows/docker-image.yml @@ -36,10 +36,10 @@ jobs: password: ${{ secrets.DOCKER_PASSWORD }} # 构建 Docker 镜像，并指定平台为 amd64 和 arm64，推送到 Docker Hub + # 使用单条命令同时指定两个标签，避免重复构建 - name: Build and Push Docker image with version and latest tag run: | - # 构建带版本号的镜像并推送 - docker buildx build --platform linux/amd64,linux/arm64 -t ${{ secrets.DOCKER_USERNAME }}/danmu-api:${{ env.VERSION }} --push . - - # 构建带 latest 标签的镜像并推送 - docker buildx build --platform linux/amd64,linux/arm64 -t ${{ secrets.DOCKER_USERNAME }}/danmu-api:latest --push . + docker buildx build --platform linux/amd64,linux/arm64 \ + -t ${{ secrets.DOCKER_USERNAME }}/danmu-api:${{ env.VERSION }} \ + -t ${{ secrets.DOCKER_USERNAME }}/danmu-api:latest \ + --push . diff --git a/README.md b/README.md index 50b40e1..52d5026 100644 --- a/README.md +++ b/README.md @@ -6,7 +6,7 @@ LogVar 弹幕 API 服务器 -[![GitHub](https://img.shields.io/badge/-GitHub-181717?logo=github)](https://github.com/huangxd-/damnu_api) +[![GitHub](https://img.shields.io/badge/-GitHub-181717?logo=github)](https://github.com/huangxd-/danmu_api) ![GitHub forks](https://img.shields.io/github/forks/huangxd-/danmu_api) ![GitHub Repo stars](https://img.shields.io/github/stars/huangxd-/danmu_api) ![GitHub License](https://img.shields.io/github/license/huangxd-/danmu_api) @@ -37,6 +37,7 @@ LogVar 弹幕 API 服务器 - `POST /api/v2/comment/by-url`：通过视频URL直接获取弹幕。 - `GET /api/logs`：获取最近的日志（最多 500 行，格式为 `[时间戳] 级别: 消息`）。 - **日志记录**：捕获 `console.log`（info 级别）和 `console.error`（error 级别），JSON 内容格式化输出。 +- **搜索结果缓存**：支持内存缓存搜索结果和弹幕数据，避免短期内重复的不必要API请求，可通过 `SEARCH_CACHE_MINUTES` 环境变量配置缓存时间（默认1分钟）。 - **部署支持**：支持本地运行、Docker 容器化、Vercel 一键部署、Netlify 一键部署、Cloudflare 一键部署和 Docker 一键启动。 - **手动选择记忆**：支持记住之前搜索title时手动选择的anime，并在后续的match自动匹配时优选该anime【实验性】。 - **手动搜索支持输入播放链接获取弹幕**：支持手动搜索的播放器输入爱优腾芒哔播放链接可获取弹幕，如`senplayer`。 @@ -93,6 +94,7 @@ LogVar 弹幕 API 服务器 docker run -d -p 9321:9321 --name danmu-api -e TOKEN=87654321 danmu-api ``` - 使用`-e TOKEN=87654321`设置`TOKEN`环境变量，覆盖Dockerfile中的默认值。 + - 或使用 `--env-file .env` 加载 .env 文件中的所有环境变量：`docker run -d -p 9321:9321 --name danmu-api --env-file .env danmu-api` 3. **测试 API**： 使用 `http://{ip}:9321/{TOKEN}` 访问上述 API 接口。 @@ -108,7 +110,9 @@ LogVar 弹幕 API 服务器 docker run -d -p 9321:9321 --name danmu-api -e TOKEN=87654321 logvar/danmu-api:latest ``` - 使用`-e TOKEN=87654321`设置`TOKEN`环境变量。 + - 或使用 `--env-file .env` 加载 .env 文件中的所有环境变量：`docker run -d -p 9321:9321 --name danmu-api --env-file .env logvar/danmu-api:latest` + 或使用 docker compose 部署： ```yaml services: danmu-api: @@ -118,9 +122,12 @@ LogVar 弹幕 API 服务器 - "9321:9321" environment: - TOKEN=87654321 # 请将 87654321 替换为你想自定义的 Token 值 + # 如需使用 .env 文件，取消下行注释并注释掉上面的 environment 部分 + # env_file: .env restart: unless-stopped # 可选配置，容器退出时自动重启（非必需，可根据需求删除） ``` - - 或使用docker compose部署。 + + 可以使用 watchtower 监控有新版本自动更新： ```yaml services: watchtower: @@ -137,7 +144,6 @@ LogVar 弹幕 API 服务器 - "12600" # 30分钟（1800秒），适合测试 - danmu-api # 监控的目标容器名 ``` - - 可以使用watchtower监控有新版本自动更新。 3. **测试 API**： 使用 `http://{ip}:9321/{TOKEN}` 访问上述 API 接口。 @@ -154,7 +160,7 @@ LogVar 弹幕 API 服务器 1. 转到你的项目设置。 2. 在“Environment Variables”部分添加 `TOKEN` 变量，输入你的 API 令牌值。 3. 保存更改并重新部署。 -- 示例请求：`https://{your_domian}.vercel.app/87654321/api/v2/search/anime?keyword=子夜归` +- 示例请求：`https://{your_domain}.vercel.app/87654321/api/v2/search/anime?keyword=子夜归` ### 优化点 - Settings > Functions > Advanced Setting > Function Region 切换为 Hong Kong，能提高访问速度，体验更优 @@ -182,7 +188,7 @@ LogVar 弹幕 API 服务器 > 注意：部署时请在环境变量配置区域填写你的TOKEN值，该变量将用于API服务的身份验证相关功能 > -> 示例请求：`https://{your_domian}/{TOKEN}/api/v2/search/anime?keyword=子夜归`确认是否部署成功 +> 示例请求：`https://{your_domain}/{TOKEN}/api/v2/search/anime?keyword=子夜归`确认是否部署成功 > > 部署的时候项目加速区域最好设置为"全球可用区（不含中国大陆）"，不然不绑定自定义域名貌似只能生成3小时的预览链接？[相关文档](https://edgeone.cloud.tencent.com/pages/document/175191784523485184) > @@ -207,7 +213,7 @@ LogVar 弹幕 API 服务器 2. 转到“Settings” > “Variables”。 3. 添加 `TOKEN` 环境变量，输入你的 API 令牌值。 4. 保存并部署。 -- 示例请求：`https://{your_domian}.workers.dev/87654321/api/v2/search/anime?keyword=子夜归` +- 示例请求：`https://{your_domain}.workers.dev/87654321/api/v2/search/anime?keyword=子夜归` ### 手动部署 创建一个worker，将`danmu_api/worker.js`里的代码直接拷贝到你创建的`worker.js`里，然后点击部署。 @@ -244,23 +250,26 @@ LogVar 弹幕 API 服务器 | ----------- | ----------- | | TOKEN | 【可选】自定义用户token，不填默认为`87654321` | | OTHER_SERVER | 【可选】兜底第三方弹幕服务器，不填默认为`https://api.danmu.icu` | -| VOD_SERVERS | 【可选】VOD服务器列表，支持多个服务器并发查询，格式：`名称@URL,名称@URL,...`，示例：`vod@https://www.caiji.cyou,vod2@https://zy.xmm.hk`，不填默认为`vod@https://www.caiji.cyou` | +| VOD_SERVERS | 【可选】VOD服务器列表，支持多个服务器并发查询，格式：`名称@URL,名称@URL,...`，示例：`金蝉@https://zy.jinchancaiji.com,789@https://www.caiji.cyou,听风@https://gctf.tfdh.top`，不填默认为`金蝉@https://zy.jinchancaiji.com,789@https://www.caiji.cyou,听风@https://gctf.tfdh.top` | +| VOD_RETURN_MODE | 【可选】VOD返回模式，可选值：`all`（返回所有站点结果）、`fastest`（只返回最快的站点结果），默认为`fastest`。当配置多个VOD站点时，`all`模式会返回所有站点的结果（结果较多），`fastest`模式只返回首先响应成功的站点结果（结果较少，避免重复） | | VOD_REQUEST_TIMEOUT | 【可选】VOD服务器单个请求超时时间（毫秒），防止慢速或失效的采集站阻塞搜索，默认为`5000`（5秒），建议值：`3000-10000` | | BILIBILI_COOKIE | 【可选】b站cookie（填入后能抓取完整弹幕），如 `buvid3=E2BCA ... eao6; theme-avatar-tip-show=SHOWED`，请自行通过浏览器或抓包工具抓取，热心网友测试后，实际最少只需取 `SESSDATA=xxxx` 字段 | | YOUKU_CONCURRENCY | 【可选】youku弹幕请求并发数，用于加快youku弹幕请求速度，不填默认为`8`，最高`16` | | SOURCE_ORDER | 【可选】源排序，用于按源对返回资源的排序（注意：先后顺序会影响自动匹配最终的返回），默认是`360,vod,renren,hanjutv`，表示360数据排在最前，hanjutv数据排在最后，示例：`360,renren`：只返回360数据和renren数据，且360数据靠前；当前可选择的源字段有 `360,vod,tencent,renren,hanjutv,bahamut` | -| PLATFORM_ORDER | 【可选】自动匹配优选平台，按顺序优先返回指定平台弹幕，默认为空，即返回第一个满足条件的平台，示例：`bilibili1,qq`，表示如果有b站的播放源，则优先返回b站的弹幕，否则就返回腾讯的弹幕，两者都没有，则返回第一个满足条件的平台；当前可选择的平台字段有 `qiyi, bilibili1, imgo, youku, qq, tencent, renren, hanjutv, bahamut` | +| PLATFORM_ORDER | 【可选】自动匹配优选平台，按顺序优先返回指定平台弹幕，默认为空，即返回第一个满足条件的平台，示例：`bilibili1,qq`，表示如果有b站的播放源，则优先返回b站的弹幕，否则就返回腾讯的弹幕，两者都没有，则返回第一个满足条件的平台；当前可选择的平台字段有 `qiyi, bilibili1, imgo, youku, qq, renren, hanjutv, bahamut` | | EPISODE_TITLE_FILTER | 【可选】剧集标题正则过滤，按正则关键字对剧集或综艺的集标题进行过滤，适用于过滤一些预告或综艺非正式集，只支持match自动匹配，默认值如下 | +| ENABLE_EPISODE_FILTER | 【可选】是否在手动选择接口中启用集标题过滤，默认为`false`（禁用），启用后 GET /api/v2/bangumi/{id} 和 GET /api/v2/search/anime 接口会过滤掉预告、花絮等特殊集，以及名称包含特殊关键词的动漫。 | | BLOCKED_WORDS | 【可选】弹幕屏蔽词列表，默认为空，示例如下 | | GROUP_MINUTE | 【可选】合并去重分钟数，表示按n分钟分组后对弹幕合并去重，默认为1，最大值为30，0表示不去重 | | PROXY_URL | 【可选】代理地址，示例: `http://127.0.0.1:7897` ，目前只对巴哈姆特生效（注意：如果巴哈姆特请求不通，会拖慢搜索返回速度，所以除vercel/netlify/cloudflare之外默认不开启bahamut源，开启请先在SOURCE_ORDER环境变量中添加`bahamut`）如果你使用docker部署并且访问不了bahamut源，请配置代理地址；vercel/netlify/cf中理应都自然能联通，不用填写 | | RATE_LIMIT_MAX_REQUESTS | 【可选】限流配置：1分钟内同一IP最大请求次数，默认为`3`，设置为`0`表示不限流 | +| SEARCH_CACHE_MINUTES | 【可选】搜索结果缓存时间（分钟），默认为`1`，避免短期内重复的不必要API请求，同时保证获取最新的结果列表，可根据需要调整：Vercel/Cloudflare建议`1-5`分钟，Docker可设置`5-30`分钟，设置为`0`表示不缓存 | | UPSTASH_REDIS_REST_URL | 【可选】update redis url，需配合UPSTASH_REDIS_REST_TOKEN使用，用于持久化存储，不会因为冷启动而丢失过去的查询信息（在cf/eo/claw上配置后应该能更稳定点，也能解决小幻掉匹配的问题，但会稍微影响请求速度），获取方法请参考：`https://cloud.tencent.cn/developer/article/2424508` | | UPSTASH_REDIS_REST_TOKEN | 【可选】update redis token，需配合UPSTASH_REDIS_REST_URL使用，用于持久化存储，不会因为冷启动而丢失过去的查询信息（在cf/eo/claw上配置后应该能更稳定点，也能解决小幻掉匹配的问题，但会稍微影响请求速度），获取方法请参考：`https://cloud.tencent.cn/developer/article/2424508` | ```regex # EPISODE_TITLE_FILTER 默认值 -(特别|惊喜|纳凉)?企划|合伙人手记|超前|速览|vlog|reaction|纯享|加更|抢先|抢鲜|预告|花絮|特辑|彩蛋|专访|幕后|直播|未播|衍生|番外|会员|片花|精华|看点|速看|解读|影评|解说|吐槽|盘点|拍摄花絮|制作花絮|幕后花絮|未播花絮|独家花絮|花絮特辑|先导预告|终极预告|正式预告|官方预告|彩蛋片段|删减片段|未播片段|番外彩蛋|精彩片段|精彩看点|精彩回顾|精彩集锦|看点解析|看点预告|NG镜头|NG镜头|NG花絮|番外篇|番外特辑|制作特辑|拍摄特辑|幕后特辑|导演特辑|演员特辑|片尾曲|插曲|高光回顾|背景音乐|OST|音乐MV|歌曲MV|前季回顾|剧情回顾|往期回顾|内容总结|剧情盘点|精选合集|剪辑合集|混剪视频|独家专访|演员访谈|导演访谈|主创访谈|媒体采访|发布会采访|抢先看|抢先版|试看版|短剧|精编|会员版|Plus|独家版|特别版|短片|陪看|高清正片|发布会|.{2,}篇|(?!.*(入局|破冰局|做局)).{2,}局|观察室|上班那点事儿|周top|赛段|直拍|REACTION|VLOG|全纪录|开播|先导|总宣|展演|集锦|旅行日记 +(特别|惊喜|纳凉)?企划|合伙人手记|超前(营业|vlog)?|速览|vlog|reaction|纯享|加更(版|篇)?|抢先(看|版|集|篇)?|抢鲜|预告|花絮(独家)?|特辑|彩蛋|专访|幕后(故事|花絮|独家)?|直播(陪看|回顾)?|未播(片段)?|衍生|番外|会员(专享|加长|尊享|专属|版)?|片花|精华|看点|速看|解读|影评|解说|吐槽|盘点|拍摄花絮|制作花絮|幕后花絮|未播花絮|独家花絮|花絮特辑|先导预告|终极预告|正式预告|官方预告|彩蛋片段|删减片段|未播片段|番外彩蛋|精彩片段|精彩看点|精彩回顾|精彩集锦|看点解析|看点预告|NG镜头|NG花絮|番外篇|番外特辑|制作特辑|拍摄特辑|幕后特辑|导演特辑|演员特辑|片尾曲|插曲|高光回顾|背景音乐|OST|音乐MV|歌曲MV|前季回顾|剧情回顾|往期回顾|内容总结|剧情盘点|精选合集|剪辑合集|混剪视频|独家专访|演员访谈|导演访谈|主创访谈|媒体采访|发布会采访|采访|陪看(记)?|试看版|短剧|精编|Plus|独家版|特别版|短片|发布会|解忧局|走心局|火锅局|巅峰时刻|坞里都知道|福持目标坞民|.{3,}篇|(?!.*(入局|破冰局|做局)).{2,}局|观察室|上班那点事儿|周top|赛段|直拍|REACTION|VLOG|全纪录|开播|先导|总宣|展演|集锦|旅行日记|精彩分享|剧情揭秘 # 如果你想新增过滤词，请自定义EPISODE_TITLE_FILTER，示例如下，每个词用'|'隔开，增加的词都会追加到默认值后面 测试|test @@ -294,7 +303,7 @@ LogVar 弹幕 API 服务器 | ----------- | ----------- | | 360 | qiyi, bilibili1, imgo, youku, qq | | vod | qiyi, bilibili1, imgo, youku, qq | -| tencent | tencent | +| tencent | qq | | renren | renren | | hanjutv | hanjutv | | bahamut | bahamut | @@ -332,12 +341,15 @@ danmu_api/ ## 注意事项 - 日志存储在内存中，服务器重启后会清空。 - `/api/logs` 中的 JSON 日志会格式化显示，带缩进以提高可读性。 +- 搜索结果和弹幕数据存储在内存中，服务器重启后会清空，可通过配置 `UPSTASH_REDIS_REST_URL` 和 `UPSTASH_REDIS_REST_TOKEN` 启用 Redis 持久化存储。 +- 搜索结果缓存默认时间为 1 分钟，可通过环境变量 `SEARCH_CACHE_MINUTES` 调整（设置为 0 表示不缓存）。 - 确保 `package.json` 中包含 `node-fetch` 依赖。 - 一键部署需要将项目推送到公开的 Git 仓库（如 GitHub），并更新按钮中的仓库地址。 - 运行 Docker 容器时，需通过 `-e TOKEN=87654321` 传递 `TOKEN` 环境变量。 - cloudflare貌似被哔风控了。 - 如果想更换兜底第三方弹幕服务器，请添加环境变量`OTHER_SERVER`，示例`https://api.danmu.icu`。 -- 如果想更换vod站点，请添加环境变量`VOD_SERVERS`，示例`vod@https://www.caiji.cyou,vod2@https://zy.xmm.hk`（支持多个服务器并发查询）。 +- 如果想更换vod站点，请添加环境变量`VOD_SERVERS`，示例`金蝉@https://zy.jinchancaiji.com,789@https://www.caiji.cyou,听风@https://gctf.tfdh.top`（支持多个服务器并发查询）。 +- 当配置多个VOD站点时，可通过`VOD_RETURN_MODE`环境变量控制返回结果方式：`all`（返回所有站点结果）或`fastest`（默认，只返回最快的站点结果，避免结果过多）。 - 推荐vercel/netlify部署，cloudflare/edgeone/claw不稳定，当然最稳定还是自己本地docker部署最佳。 - /api/v2/comment接口默认限流：1分钟内同一IP只能请求3次，可通过环境变量`RATE_LIMIT_MAX_REQUESTS`调整（设置为0表示不限流）。 diff --git a/danmu_api/worker.js b/danmu_api/worker.js index 07910e8..5e5e6fb 100644 --- a/danmu_api/worker.js +++ b/danmu_api/worker.js @@ -1,6 +1,15 @@ +// 加载 .env 文件（仅在 Node.js 环境中有效，Cloudflare Workers 会忽略） +if (typeof process !== "undefined" && process.env && !process.env.CLOUDFLARE_ENVIRONMENT) { + try { + require('dotenv').config(); + } catch (e) { + // dotenv 未安装或加载失败，继续执行 + } +} + // 全局状态（Cloudflare 和 Vercel 都可能重用实例） // ⚠️ 不是持久化存储，每次冷启动会丢失 -const VERSION = "1.3.5"; +const VERSION = "1.4.0"; let animes = []; let episodeIds = []; let episodeNum = 10001; // 全局变量，用于自增 ID @@ -19,6 +28,10 @@ const requestHistory = new Map(); let redisValid = false; // 存储查询关键字上次选择的animeId，用于下次match自动匹配时优先选择该anime let lastSelectMap = new Map(); +// 搜索结果缓存，存储格式：{ keyword: { results, timestamp } } +const searchCache = new Map(); +// 弹幕缓存，存储格式：{ videoUrl: { comments, timestamp } } +const commentCache = new Map(); // ===================== // 环境变量处理 @@ -43,7 +56,7 @@ function resolveOtherServer(env) { return DEFAULT_OTHER_SERVER; } -const DEFAULT_VOD_SERVERS = "vod@https://www.caiji.cyou"; // 默认 vod站点配置，格式：名称@URL,名称@URL +const DEFAULT_VOD_SERVERS = "金蝉@https://zy.jinchancaiji.com,789@https://www.caiji.cyou,听风@https://gctf.tfdh.top"; // 默认 vod站点配置，格式：名称@URL,名称@URL let vodServers = []; function resolveVodServers(env) { @@ -78,6 +91,26 @@ function resolveVodServers(env) { return servers; } +const DEFAULT_VOD_RETURN_MODE = "fastest"; // 默认 vod返回模式：all（所有站点）或 fastest（最快的站点） +let vodReturnMode = DEFAULT_VOD_RETURN_MODE; + +function resolveVodReturnMode(env) { + let mode = DEFAULT_VOD_RETURN_MODE; + if (env && env.VOD_RETURN_MODE) { + mode = env.VOD_RETURN_MODE.toLowerCase(); // Cloudflare Workers + } else if (typeof process !== "undefined" && process.env?.VOD_RETURN_MODE) { + mode = process.env.VOD_RETURN_MODE.toLowerCase(); // Vercel / Node + } + + // 验证模式值 + if (mode !== "all" && mode !== "fastest") { + log("warn", `Invalid VOD_RETURN_MODE: ${mode}, using default: ${DEFAULT_VOD_RETURN_MODE}`); + return DEFAULT_VOD_RETURN_MODE; + } + + return mode; +} + const DEFAULT_BILIBILI_COOKIE = ""; // 默认 bilibili cookie let bilibliCookie = DEFAULT_BILIBILI_COOKIE; @@ -166,13 +199,13 @@ function resolvePlatformOrder(env) { return orderArr; } -const DEFAULT_EPISODE_TITLE_FILTER = "(特别|惊喜|纳凉)?企划|合伙人手记|超前|速览|vlog|reaction|纯享|加更|抢先|抢鲜|预告|花絮|" + - "特辑|彩蛋|专访|幕后|直播|未播|衍生|番外|会员|片花|精华|看点|速看|解读|影评|解说|吐槽|盘点|拍摄花絮|制作花絮|幕后花絮|未播花絮|独家花絮|" + +const DEFAULT_EPISODE_TITLE_FILTER = "(特别|惊喜|纳凉)?企划|合伙人手记|超前(营业|vlog)?|速览|vlog|reaction|纯享|加更(版|篇)?|抢先(看|版|集|篇)?|抢鲜|预告|花絮(独家)?|" + + "特辑|彩蛋|专访|幕后(故事|花絮|独家)?|直播(陪看|回顾)?|未播(片段)?|衍生|番外|会员(专享|加长|尊享|专属|版)?|片花|精华|看点|速看|解读|影评|解说|吐槽|盘点|拍摄花絮|制作花絮|幕后花絮|未播花絮|独家花絮|" + "花絮特辑|先导预告|终极预告|正式预告|官方预告|彩蛋片段|删减片段|未播片段|番外彩蛋|精彩片段|精彩看点|精彩回顾|精彩集锦|看点解析|看点预告|" + "NG镜头|NG花絮|番外篇|番外特辑|制作特辑|拍摄特辑|幕后特辑|导演特辑|演员特辑|片尾曲|插曲|高光回顾|背景音乐|OST|音乐MV|歌曲MV|前季回顾|" + - "剧情回顾|往期回顾|内容总结|剧情盘点|精选合集|剪辑合集|混剪视频|独家专访|演员访谈|导演访谈|主创访谈|媒体采访|发布会采访|抢先看|抢先版|" + - "试看版|短剧|精编|会员版|Plus|独家版|特别版|短片|陪看|高清正片|发布会|.{2,}篇|(?!.*(入局|破冰局|做局)).{2,}局|观察室|上班那点事儿|" + - "周top|赛段|直拍|REACTION|VLOG|全纪录|开播|先导|总宣|展演|集锦|旅行日记"; // 默认 剧集标题正则过滤 + "剧情回顾|往期回顾|内容总结|剧情盘点|精选合集|剪辑合集|混剪视频|独家专访|演员访谈|导演访谈|主创访谈|媒体采访|发布会采访|采访|陪看(记)?|" + + "试看版|短剧|精编|Plus|独家版|特别版|短片|发布会|解忧局|走心局|火锅局|巅峰时刻|坞里都知道|福持目标坞民|.{3,}篇|(?!.*(入局|破冰局|做局)).{2,}局|观察室|上班那点事儿|" + + "周top|赛段|直拍|REACTION|VLOG|全纪录|开播|先导|总宣|展演|集锦|旅行日记|精彩分享|剧情揭秘"; // 默认 剧集标题正则过滤 let episodeTitleFilter; // 这里既支持 Cloudflare env，也支持 Node process.env @@ -283,10 +316,120 @@ function resolveRateLimitMaxRequests(env) { return DEFAULT_RATE_LIMIT_MAX_REQUESTS; } +// 集标题过滤开关配置（默认 false，禁用过滤） +const DEFAULT_ENABLE_EPISODE_FILTER = false; +let enableEpisodeFilter = DEFAULT_ENABLE_EPISODE_FILTER; + +function resolveEnableEpisodeFilter(env) { + if (env && env.ENABLE_EPISODE_FILTER !== undefined) { + return env.ENABLE_EPISODE_FILTER.toLowerCase() === 'true'; + } + if (typeof process !== "undefined" && process.env?.ENABLE_EPISODE_FILTER !== undefined) { + return process.env.ENABLE_EPISODE_FILTER.toLowerCase() === 'true'; + } + return DEFAULT_ENABLE_EPISODE_FILTER; +} + +// 搜索结果缓存时间配置（分钟，默认 1） +const DEFAULT_SEARCH_CACHE_MINUTES = 1; +let searchCacheMinutes = DEFAULT_SEARCH_CACHE_MINUTES; + +function resolveSearchCacheMinutes(env) { + if (env && env.SEARCH_CACHE_MINUTES) { + const n = parseInt(env.SEARCH_CACHE_MINUTES, 10); + if (!Number.isNaN(n) && n > 0) return n; + } + if (typeof process !== "undefined" && process.env?.SEARCH_CACHE_MINUTES) { + const n = parseInt(process.env.SEARCH_CACHE_MINUTES, 10); + if (!Number.isNaN(n) && n > 0) return n; + } + return DEFAULT_SEARCH_CACHE_MINUTES; +} + // ===================== // 数据结构处理函数 // ===================== +// ===================== +// 搜索结果缓存管理 +// ===================== + +// 检查搜索缓存是否有效（未过期） +function isSearchCacheValid(keyword) { + if (!searchCache.has(keyword)) { + return false; + } + + const cached = searchCache.get(keyword); + const now = Date.now(); + const cacheAgeMinutes = (now - cached.timestamp) / (1000 * 60); + + if (cacheAgeMinutes > searchCacheMinutes) { + // 缓存已过期，删除它 + searchCache.delete(keyword); + log("info", `Search cache for "${keyword}" expired after ${cacheAgeMinutes.toFixed(2)} minutes`); + return false; + } + + return true; +} + +// 获取搜索缓存 +function getSearchCache(keyword) { + if (isSearchCacheValid(keyword)) { + log("info", `Using search cache for "${keyword}"`); + return searchCache.get(keyword).results; + } + return null; +} + +// 设置搜索缓存 +function setSearchCache(keyword, results) { + searchCache.set(keyword, { + results: results, + timestamp: Date.now() + }); + log("info", `Cached search results for "${keyword}" (${results.length} animes)`); +} + +// 检查弹幕缓存是否有效（未过期） +function isCommentCacheValid(videoUrl) { + if (!commentCache.has(videoUrl)) { + return false; + } + + const cached = commentCache.get(videoUrl); + const now = Date.now(); + const cacheAgeMinutes = (now - cached.timestamp) / (1000 * 60); + + if (cacheAgeMinutes > searchCacheMinutes) { + // 缓存已过期，删除它 + commentCache.delete(videoUrl); + log("info", `Comment cache for "${videoUrl}" expired after ${cacheAgeMinutes.toFixed(2)} minutes`); + return false; + } + + return true; +} + +// 获取弹幕缓存 +function getCommentCache(videoUrl) { + if (isCommentCacheValid(videoUrl)) { + log("info", `Using comment cache for "${videoUrl}"`); + return commentCache.get(videoUrl).comments; + } + return null; +} + +// 设置弹幕缓存 +function setCommentCache(videoUrl, comments) { + commentCache.set(videoUrl, { + comments: comments, + timestamp: Date.now() + }); + log("info", `Cached comments for "${videoUrl}" (${comments.length} comments)`); +} + // 添加元素到 episodeIds：检查 url 是否存在，若不存在则以自增 id 添加 function addEpisode(url, title) { // 检查是否已存在相同的 url 和 title @@ -918,7 +1061,7 @@ async function get360Zongyi(title, entId, site, year) { links.push({ "name": episodeInfo.id, "url": episodeInfo.url, - "title": `【${site}】 #${episodeInfo.name} ${episodeInfo.period}#`, + "title": `【${site}】 ${episodeInfo.name} ${episodeInfo.period}`, "sort": epNum || episodeInfo.sort || null }); } @@ -983,6 +1126,16 @@ async function getVodAnimesFromAllServers(title, servers) { return []; } + // 根据 vodReturnMode 决定查询策略 + if (vodReturnMode === "fastest") { + return await getVodAnimesFromFastestServer(title, servers); + } else { + return await getVodAnimesFromAllServersImpl(title, servers); + } +} + +// 查询所有vod站点影片信息（返回所有结果） +async function getVodAnimesFromAllServersImpl(title, servers) { // 并发查询所有服务器，使用 allSettled 确保单个服务器失败不影响其他服务器 const promises = servers.map(server => getVodAnimes(title, server.url, server.name) @@ -996,6 +1149,41 @@ async function getVodAnimesFromAllServers(title, servers) { .map(result => result.value); } +// 查询vod站点影片信息（返回最快的结果） +async function getVodAnimesFromFastestServer(title, servers) { + if (!servers || servers.length === 0) { + return []; + } + + // 使用 Promise.race 获取最快响应的服务器 + const promises = servers.map(server => + getVodAnimes(title, server.url, server.name) + ); + + try { + // race 会返回第一个成功的结果 + const result = await Promise.race(promises); + + // 检查结果是否有效（有数据） + if (result && result.list && result.list.length > 0) { + log("info", `[VOD fastest mode] 使用最快的服务器: ${result.serverName}`); + return [result]; + } + + // 如果最快的服务器没有数据，继续尝试其他服务器 + log("info", `[VOD fastest mode] 最快的服务器 ${result.serverName} 无数据，尝试其他服务器`); + const allResults = await Promise.allSettled(promises); + const validResults = allResults + .filter(r => r.status === 'fulfilled' && r.value && r.value.list && r.value.list.length > 0) + .map(r => r.value); + + return validResults.length > 0 ? [validResults[0]] : []; + } catch (error) { + log("error", `[VOD fastest mode] 所有服务器查询失败:`, error.message); + return []; + } +} + // ===================== // 工具方法 // ===================== @@ -1495,11 +1683,7 @@ const extractTitle = (title) => { return match ? match[1] : null; // 返回方括号中的内容，若没有匹配到，则返回null }; -// 提取##中的内容并进行匹配 -const extractEpTitle = (title) => { - const match = title.match(/#(.*?)#/); // 提取#号之间的内容 - return match ? match[1] : null; // 返回#号中的内容，若没有则返回null -}; + // 解析fileName，提取动漫名称和平台偏好 function parseFileName(fileName) { @@ -4038,7 +4222,7 @@ async function handleVodAnimes(animesVod, curAnimes, key) { links.push({ "name": count, "url": epInfo[1], - "title": `【${platform}】 #${epInfo[0]}#` + "title": `【${platform}】 ${epInfo[0]}` }); } } @@ -4075,7 +4259,7 @@ async function handle360Animes(animes360, curAnimes) { links.push({ "name": key, "url": anime.playlinks[key], - "title": `【${key}】${anime.titleTxt}(${anime.year})` + "title": `【${key}】 ${anime.titleTxt}(${anime.year})` }); } } @@ -4086,7 +4270,7 @@ async function handle360Animes(animes360, curAnimes) { links.push({ "name": i + 1, "url": item.url, - "title": `【${anime.seriesSite}】 #${i + 1}#` + "title": `【${anime.seriesSite}】 第${i + 1}集` }); } } @@ -4141,7 +4325,7 @@ async function handleRenrenAnimes(animesRenren, queryTitle, curAnimes) { links.push({ "name": ep.episodeIndex, "url": ep.episodeId, - "title": `【${ep.provider}】 #${ep.title}#` + "title": `【${ep.provider}】 ${ep.title}` }); } @@ -4190,7 +4374,7 @@ async function handleHanjutvAnimes(animesHanjutv, queryTitle, curAnimes) { links.push({ "name": ep.title, "url": ep.pid, - "title": `【hanjutv】 #${epTitle}#` + "title": `【hanjutv】 ${epTitle}` }); } @@ -4234,7 +4418,7 @@ async function handleBahamutAnimes(animesBahamut, queryTitle, curAnimes) { links.push({ "name": ep.episode, "url": ep.videoSn.toString(), - "title": `【bahamut】 #${epTitle}#` + "title": `【bahamut】 ${epTitle}` }); } @@ -4280,7 +4464,7 @@ async function handleTencentAnimes(animesTencent, queryTitle, curAnimes) { links.push({ "name": i + 1, "url": fullUrl, - "title": `【tencent】 #${epTitle}#` + "title": `【qq】 ${epTitle}` }); } @@ -4317,6 +4501,17 @@ async function searchAnime(url) { const queryTitle = url.searchParams.get("keyword"); log("info", `Search anime with keyword: ${queryTitle}`); + // 检查搜索缓存 + const cachedResults = getSearchCache(queryTitle); + if (cachedResults !== null) { + return jsonResponse({ + errorCode: 0, + success: true, + errorMessage: "", + animes: cachedResults, + }); + } + const curAnimes = []; // 链接弹幕解析 @@ -4353,7 +4548,7 @@ async function searchAnime(url) { const links = [{ "name": "手动解析链接弹幕", "url": queryTitle, - "title": `【${platform}】 #${pageTitle}#` + "title": `【${platform}】 ${pageTitle}` }]; curAnimes.push(tmpAnime); addAnime({...tmpAnime, links: links}); @@ -4432,11 +4627,54 @@ async function searchAnime(url) { storeAnimeIdsToMap(curAnimes, queryTitle); + // 如果启用了集标题过滤，则为每个动漫添加过滤后的 episodes + if (enableEpisodeFilter) { + const validAnimes = []; + for (const anime of curAnimes) { + // 首先检查动漫名称是否包含过滤关键词 + const animeTitle = anime.animeTitle || ''; + if (episodeTitleFilter.test(animeTitle)) { + log("info", `[searchAnime] Anime ${anime.animeId} filtered by name: ${animeTitle}`); + continue; // 跳过该动漫 + } + + const animeData = animes.find(a => a.animeId === anime.animeId); + if (animeData && animeData.links) { + let episodesList = animeData.links.map((link, index) => ({ + episodeId: link.id, + episodeTitle: link.title, + episodeNumber: index + 1 + })); + + // 应用过滤 + episodesList = episodesList.filter(episode => { + return !episodeTitleFilter.test(episode.episodeTitle); + }); + + log("info", `[searchAnime] Anime ${anime.animeId} filtered episodes: ${episodesList.length}/${animeData.links.length}`); + + // 只有当过滤后还有有效剧集时才保留该动漫 + if (episodesList.length > 0) { + anime.episodes = episodesList; + validAnimes.push(anime); + } + } + } + // 用过滤后的动漫列表替换原列表 + curAnimes.length = 0; + curAnimes.push(...validAnimes); + } + // 如果有新的anime获取到，则更新redis if (redisValid && curAnimes.length !== 0) { await updateCaches(); } + // 缓存搜索结果 + if (curAnimes.length > 0) { + setSearchCache(queryTitle, curAnimes); + } + return jsonResponse({ errorCode: 0, success: true, @@ -4447,13 +4685,9 @@ async function searchAnime(url) { function filterSameEpisodeTitle(filteredTmpEpisodes) { const filteredEpisodes = filteredTmpEpisodes.filter((episode, index, episodes) => { - const filterEp = extractEpTitle(episode.episodeTitle); - // 如果没有提取到标题，返回 true 保留该 episode - if (!filterEp) return true; // 查找当前 episode 标题是否在之前的 episodes 中出现过 return !episodes.slice(0, index).some(prevEpisode => { - const prevFilterEp = extractEpTitle(prevEpisode.episodeTitle); - return prevFilterEp === filterEp; + return prevEpisode.episodeTitle === episode.episodeTitle; }); }); return filteredEpisodes; @@ -4474,8 +4708,7 @@ async function matchAniAndEp(season, episode, searchData, title, req, platform, // 过滤集标题正则条件的 episode const filteredTmpEpisodes = bangumiData.bangumi.episodes.filter(episode => { - const filterEp = extractEpTitle(episode.episodeTitle); - return filterEp && !episodeTitleFilter.test(filterEp); // 如果##中的内容匹配正则表达式 + return !episodeTitleFilter.test(episode.episodeTitle); }); // 过滤集标题一致的 episode，且保留首次出现的集标题的 episode @@ -4546,8 +4779,7 @@ async function fallbackMatchAniAndEp(searchData, req, season, episode, resEpisod if (season && episode) { // 过滤集标题正则条件的 episode const filteredTmpEpisodes = bangumiData.bangumi.episodes.filter(episode => { - const filterEp = extractEpTitle(episode.episodeTitle); - return filterEp && !episodeTitleFilter.test(filterEp); // 如果##中的内容匹配正则表达式 + return !episodeTitleFilter.test(episode.episodeTitle); }); // 过滤集标题一致的 episode，且保留首次出现的集标题的 episode @@ -4825,17 +5057,38 @@ async function getBangumi(path) { }, }; + // 构建 episodes 列表 + let episodesList = []; for (let i = 0; i < anime.links.length; i++) { const link = anime.links[i]; - resData["bangumi"]["episodes"].push({ - seasonId: `season-${anime.animeId}`, - episodeId: link.id, - episodeTitle: `${link.title}`, - episodeNumber: `${i+1}`, - airDate: anime.startDate, - }); + episodesList.push({ + seasonId: `season-${anime.animeId}`, + episodeId: link.id, + episodeTitle: `${link.title}`, + episodeNumber: `${i+1}`, + airDate: anime.startDate, + }); } + // 如果启用了集标题过滤，则应用过滤 + if (enableEpisodeFilter) { + episodesList = episodesList.filter(episode => { + return !episodeTitleFilter.test(episode.episodeTitle); + }); + log("info", `[getBangumi] Episode filter enabled. Filtered episodes: ${episodesList.length}/${anime.links.length}`); + + // 如果过滤后没有有效剧集，返回错误 + if (episodesList.length === 0) { + log("warn", `[getBangumi] No valid episodes after filtering for anime ID ${idParam}`); + return jsonResponse( + { errorCode: 404, success: false, errorMessage: "No valid episodes after filtering", bangumi: null }, + 404 + ); + } + } + + resData["bangumi"]["episodes"] = episodesList; + return jsonResponse(resData); } @@ -4860,6 +5113,12 @@ async function getComment(path) { url = convertYoukuUrl(url); } + // 检查弹幕缓存 + const cachedComments = getCommentCache(url); + if (cachedComments !== null) { + return jsonResponse({ count: cachedComments.length, comments: cachedComments }); + } + log("info", "开始从本地请求弹幕...", url); let danmus = []; if (url.includes('.qq.com')) { @@ -4897,6 +5156,11 @@ async function getComment(path) { await setRedisKey('lastSelectMap', lastSelectMap); } + // 缓存弹幕结果 + if (danmus.length > 0) { + setCommentCache(url, danmus); + } + return jsonResponse({ count: danmus.length, comments: danmus }); } @@ -4934,6 +5198,18 @@ async function getCommentByUrl(req) { url = convertYoukuUrl(url); } + // 检查弹幕缓存 + const cachedComments = getCommentCache(url); + if (cachedComments !== null) { + return jsonResponse({ + errorCode: 0, + success: true, + errorMessage: "", + count: cachedComments.length, + comments: cachedComments + }); + } + log("info", "开始从本地请求弹幕...", url); let danmus = []; @@ -4958,6 +5234,11 @@ async function getCommentByUrl(req) { log("info", `Successfully fetched ${danmus.length} comments from URL`); + // 缓存弹幕结果 + if (danmus.length > 0) { + setCommentCache(url, danmus); + } + return jsonResponse({ errorCode: 0, success: true, @@ -4981,7 +5262,9 @@ async function handleRequest(req, env, deployPlatform, clientIp) { otherServer = resolveOtherServer(env); envs["otherServer"] = otherServer; vodServers = resolveVodServers(env); + vodReturnMode = resolveVodReturnMode(env); envs["vodServers"] = vodServers.map(s => `${s.name}@${s.url}`).join(','); + envs["vodReturnMode"] = vodReturnMode; bilibliCookie = resolveBilibiliCookie(env); envs["bilibliCookie"] = encryptStr(bilibliCookie); youkuConcurrency = resolveYoukuConcurrency(env); @@ -4998,8 +5281,12 @@ async function handleRequest(req, env, deployPlatform, clientIp) { envs["groupMinute"] = groupMinute; rateLimitMaxRequests = resolveRateLimitMaxRequests(env); envs["rateLimitMaxRequests"] = rateLimitMaxRequests; + enableEpisodeFilter = resolveEnableEpisodeFilter(env); + envs["enableEpisodeFilter"] = enableEpisodeFilter; proxyUrl = resolveProxyUrl(env); envs["proxyUrl"] = proxyUrl; + searchCacheMinutes = resolveSearchCacheMinutes(env); + envs["searchCacheMinutes"] = searchCacheMinutes; redisUrl = resolveRedisUrl(env); envs["redisUrl"] = encryptStr(redisUrl); redisToken = resolveRedisToken(env); @@ -5127,7 +5414,28 @@ async function handleRequest(req, env, deployPlatform, clientIp) { // GET /api/v2/comment/:commentId if (path.startsWith("/api/v2/comment/") && method === "GET") { - // 限流检查（如果 rateLimitMaxRequests > 0 则启用限流） + // ⚠️ 限流设计说明： + // 1. 先检查缓存，缓存命中时直接返回，不计入限流次数 + // 2. 只有缓存未命中时才执行限流检查和网络请求 + // 这样可以避免频繁访问同一弹幕时被限流，提高用户体验 + const commentId = parseInt(path.split("/").pop()); + let url = findUrlById(commentId); + + if (url) { + // 处理302场景 + if (url.includes("youku.com/video?vid")) { + url = convertYoukuUrl(url); + } + + // 检查弹幕缓存 - 缓存命中时直接返回，不计入限流 + const cachedComments = getCommentCache(url); + if (cachedComments !== null) { + log("info", `[Rate Limit] Cache hit for URL: ${url}, skipping rate limit check`); + return jsonResponse({ count: cachedComments.length, comments: cachedComments }); + } + } + + // 缓存未命中，执行限流检查（如果 rateLimitMaxRequests > 0 则启用限流） if (rateLimitMaxRequests > 0) { // 获取当前时间戳（单位：毫秒） const currentTime = Date.now(); @@ -5164,6 +5472,7 @@ async function handleRequest(req, env, deployPlatform, clientIp) { // 更新该 IP 地址的请求历史 requestHistory.set(clientIp, recentRequests); + log("info", `[Rate Limit] Request counted for IP: ${clientIp}, count: ${recentRequests.length}/${rateLimitMaxRequests}`); } return getComment(path); @@ -5254,4 +5563,5 @@ export async function netlifyHandler(event, context) { export { handleRequest, searchAnime, searchEpisodes, matchAnime, getBangumi, getComment, getCommentByUrl, fetchTencentVideo, fetchIqiyi, fetchMangoTV, fetchBilibili, fetchYouku, fetchOtherServer, httpGet, httpPost, hanjutvSearch, getHanjutvEpisodes, getHanjutvComments, getHanjutvDetail, bahamutSearch, getBahamutEpisodes, getBahamutComments, tencentSearch, getTencentEpisodes, - pingRedis, getRedisKey, setRedisKey, setRedisKeyWithExpiry}; + pingRedis, getRedisKey, setRedisKey, setRedisKeyWithExpiry, getSearchCache, setSearchCache, isSearchCacheValid, + getCommentCache, setCommentCache, isCommentCacheValid}; diff --git a/danmu_api/worker.test.js b/danmu_api/worker.test.js index a569c19..dc78a59 100644 --- a/danmu_api/worker.test.js +++ b/danmu_api/worker.test.js @@ -1,3 +1,6 @@ +// 加载 .env 文件 +require('dotenv').config(); + const test = require('node:test'); const assert = require('node:assert').strict; const { handleRequest, searchAnime, matchAnime, searchEpisode, getBangumi, getComment, fetchTencentVideo, fetchIqiyi,