Merge pull request #323 from caorushizi/v3.0.0

v3.0.0

.cspell/custom-words.txt

@@ -1,40 +1,62 @@
 acodec
 adblocker
 ahooks
+aliyuncs
 antd
+aplus
 behaviour
 bili
 bilibili
+bodyparser
 bodys
+buildx
 cancle
 cliqz
+clsx
 commitlint
+compat
 Conpty
 consola
 conventionalcommits
 datetime
 DDTHH
+deeplink
+esmfile
 execa
+idtype
 immer
 inversify
 KHTML
 languagedetector
 localforage
+lucide
 mediago
 metas
 nocheck
 optimizelegibility
+outdir
 pinia
+Qrcode
 redownload
 Redownload
 reduxjs
+rmvb
+shadcn
 Sider
 stylelint
+svgr
 svgz
+tailwindcss
 TDAPP
 tiptap
+tseslint
 typeorm
+vaul
+vitepress
 vuedraggable
 vuejs
+waline
 watting
 Watting
+xgplayer
+zustand

.env

@@ -1,4 +1,5 @@
+# FIXME: APP_ 开头的会暴漏给前端
 APP_NAME=mediago
 APP_ID=mediago.ziying.site
 APP_COPYRIGHT=caorushizi
-APP_VERSION=2.2.1
+APP_VERSION=3.0.0

.env.development

@@ -1,5 +1,4 @@
 APP_TD_APPID=
-APP_CLARITY_APPID=
 
 GH_TOKEN=
 LOAD_DEVTOOLS=

.env.production

@@ -1,5 +1,4 @@
 APP_TD_APPID=
-APP_CLARITY_APPID=
 
 GH_TOKEN=
 DEBUG_PLUGINS=false

.github/workflows/build.yml

@@ -8,6 +8,7 @@ on:
   push:
     branches:
       - master
+  workflow_dispatch:
 
 # Workflow's jobs
 jobs:
@@ -23,7 +24,7 @@ jobs:
     strategy:
       fail-fast: false
       matrix:
-        os: [windows-latest, macos-latest, ubuntu-latest]
+        os: [windows-latest, macos-latest, macos-13, ubuntu-latest]
 
     # create steps
     steps:
@@ -60,4 +61,4 @@ jobs:
       - uses: actions/upload-artifact@v4
         with:
           name: mediago-${{ matrix.os }}
-          path: packages/main/release/mediago-setup-*
+          path: packages/main/release/mediago-*

Dockerfile

@@ -0,0 +1,34 @@
+FROM m.daocloud.io/docker.io/library/node:20 AS builder
+
+WORKDIR /app
+
+COPY ./packages/backend/dist /app
+
+COPY ./packages/backend/package*.json ./
+
+RUN npm install --omit=dev --registry=https://registry.npmmirror.com
+
+RUN npm rebuild
+
+# FROM m.daocloud.io/docker.io/library/debian:11-slim AS deb_extractor
+
+# RUN cd /tmp && \
+#   apt-get update && apt-get download libicu-dev && \
+#   mkdir /dpkg && \
+#   for deb in *.deb; do dpkg --extract $deb /dpkg || exit 10; done
+
+# FROM gcr.io/distroless/nodejs20-debian12
+FROM m.daocloud.io/docker.io/library/node:20-bookworm-slim
+
+WORKDIR /app
+
+COPY --from=builder /app /app
+
+# COPY --from=deb_extractor /dpkg /
+RUN apt-get update && apt-get install -y libicu-dev ffmpeg
+
+RUN npm install pm2 -g
+
+EXPOSE 8899
+
+CMD ["pm2-runtime", "server/index.js"]

README.md

@@ -27,6 +27,7 @@
 - **✅  无需抓包**： 使用软件自带浏览器可以轻松嗅探网页中的视频资源，通过嗅探到的资源列表选择自己想要下载的资源，简单快速。
 - **📱  移动播放**： 可以轻松无缝的在 PC 和移动设备之前切换，下载完成后即可使用手机观看视频。
 - **⚡️  批量下载**： 支持同时下载多个视频和直播资源，高速带宽不闲置。
+- **🎉  支持 docker 部署**： 支持 docker 部署 web 端，方便快捷。
 
 ## Quickstart
 
@@ -46,53 +47,75 @@ pnpm dev
 
 # 打包运行
 pnpm release
+
+# 构建 docker 镜像
+docker buildx build -t caorushizi/mediago:latest .
+
+# docker 启动
+docker run -d --name mediago -p 8899:8899 -v /root/mediago:/root/mediago registry.cn-beijing.aliyuncs.com/caorushizi/mediago
+
 ```
 
 ## Releases
 
-**v2.2.0 (2024.5.22 发布)**
+### v3.0.0 (2024.10.7 发布)
 
-- [windows mediago v2.2.0](https://github.com/caorushizi/mediago/releases/download/v2.2.0/mediago-setup-2.2.0.exe)
-- [macos mediago v2.2.0](https://github.com/caorushizi/mediago/releases/download/v2.2.0/mediago-setup-2.2.0.dmg)
+#### 软件下载
 
-**更新日志**
+- [【mediago】 windows v2.2.3](https://github.com/caorushizi/mediago/releases/download/v2.2.3/mediago-setup-x64-2.2.3.exe)
+- [【mediago】 macos arm64 v2.2.3](https://github.com/caorushizi/mediago/releases/download/v2.2.3/mediago-setup-x64-2.2.3.dmg)
+- [【mediago】 macos x64 v2.2.3](https://github.com/caorushizi/mediago/releases/download/v2.2.3/mediago-setup-x64-2.2.3.dmg)
+- [【mediago】 linux v2.2.3](https://github.com/caorushizi/mediago/releases/download/v2.2.3/mediago-setup-arm64-2.2.3.dmg)
+- 【mediago】 docker v3.0 `docker run`
 
-- 支持下载直播流
-- 支持哔哩哔哩视频下载
-- 优化沉浸式嗅探流程
-- 支持下载控制台输出
-- 修复了一些 bug
+### 软件截图
 
-**v2.0.2（2023.7.9 发布）**
+![首页](./images/changelog4.png)
 
-- [windows mediago v2.0.2](https://github.com/caorushizi/mediago/releases/download/v2.0.2/media-downloader-setup-2.0.2.exe)
-- [macos mediago v2.0.2](https://github.com/caorushizi/mediago/releases/download/v2.0.2/media-downloader-setup-2.0.2.dmg)
+### 重要更新
 
-**更新日志**
+- 支持 docker 部署 web 端
+- 更新桌面端 UI
 
-- 暗黑模式
-- 更多下载配置
-- 支持请求标头自动带入
-- 支持开启广告过滤
-- 支持开启沉浸式嗅探
-- 支持切换手机和 PC 模式
-- 支持修改同时下载数量
-- 修复了一些 bug
+### 更新日志
+
+- 更新桌面端 UI
+- 支持 docker 部署 web 端
+- 新增视频播放，支持桌面端和移动端播放
+- 修复 mac 打开无法展示界面的问题
+- 优化了批量下载的交互
+- 添加了 windows 的便携版（免安装哦）
+- 优化了下载列表，支持页面中多个视频的嗅探
+- 支持收藏列表手动导入导出
+- 支持首页下载列表导出
+- 优化了【新建下载】表单的交互逻辑
+- 支持 UrlScheme 打开应用，并添加下载任务
+- 修复了一些 bug 并提升用户体验
 
 ## 软件截图
 
-![首页](https://static.ziying.site/v2.0.3-beta-home.png)
+![首页](https://static.ziying.site/images/home.png)
 
-![设置页面](https://static.ziying.site/v2.0.3-beta-settings.png)
+![首页-dark](https://static.ziying.site/images/home-dark.png)
 
-![资源提取](https://static.ziying.site/v2.0.3-beta-extract.png)
+![设置页面](https://static.ziying.site/images/settings.png)
+
+![资源提取](https://static.ziying.site/images/browser.png)
 
 ## 技术栈
 
+- react <https://react.dev/>
+- electron <https://www.electronjs.org>
+- koa <https://koajs.com>
 - vite <https://cn.vitejs.dev>
 - antd <https://ant.design>
-- electron <https://www.electronjs.org>
+- tailwindcss <https://tailwindcss.com>
+- shadcn <https://ui.shadcn.com/>
+- inversify <https://inversify.io>
+- typeorm <https://typeorm.io>
 
 ## 鸣谢
 
-N_m3u8DL-RE 来自于 <https://github.com/nilaoda/N_m3u8DL-RE>
+- N_m2u8DL-CLI 来自于 <https://github.com/nilaoda/N_m3u8DL-CLI>
+- N_m3u8DL-RE 来自于 <https://github.com/nilaoda/N_m3u8DL-RE>
+- mediago 来自于 <https://github.com/caorushizi/hls-downloader>

docs/.vitepress/config.ts

@@ -30,6 +30,7 @@ export default defineConfig({
     nav: [
       { text: "Home", link: "/" },
       { text: "教程", link: "/guides" },
+      { text: "更新日志", link: "/changelog" },
     ],
 
     sidebar: [
@@ -38,10 +39,11 @@ export default defineConfig({
         items: [
           { text: "快速开始", link: "/guides" },
           { text: "使用说明", link: "/documents" },
+          { text: "更新日志", link: "/changelog" },
         ],
       },
       {
-        text: "其他",
+        text: "Q&A",
         items: [
           { text: "旧版本", link: "/history" },
           { text: "意见收集", link: "/proposal" },

docs/changelog.md

@@ -0,0 +1,125 @@
+---
+layout: doc
+outline: deep
+---
+# 更新日志
+
+## v3.0.0 (2024.10.7 发布)
+
+### 软件下载
+
+- [【mediago】 windows v2.2.3](https://github.com/caorushizi/mediago/releases/download/v2.2.3/mediago-setup-x64-2.2.3.exe)
+- [【mediago】 macos arm64（apple 芯片） v2.2.3](https://github.com/caorushizi/mediago/releases/download/v2.2.3/mediago-setup-x64-2.2.3.dmg)
+- [【mediago】 macos x64（intel 芯片） v2.2.3](https://github.com/caorushizi/mediago/releases/download/v2.2.3/mediago-setup-x64-2.2.3.dmg)
+- [【mediago】 linux v2.2.3](https://github.com/caorushizi/mediago/releases/download/v2.2.3/mediago-setup-arm64-2.2.3.dmg)
+- 【mediago】 docker v3.0 `docker run`
+
+### 国内下载
+
+- [【mediago】 windows v2.2.3](https://github.com/caorushizi/mediago/releases/download/v2.2.3/mediago-setup-x64-2.2.3.exe)
+- [【mediago】 macos arm64（apple 芯片） v2.2.3](https://github.com/caorushizi/mediago/releases/download/v2.2.3/mediago-setup-x64-2.2.3.dmg)
+- [【mediago】 macos x64（intel 芯片） v2.2.3](https://github.com/caorushizi/mediago/releases/download/v2.2.3/mediago-setup-x64-2.2.3.dmg)
+- [【mediago】 linux v2.2.3](https://github.com/caorushizi/mediago/releases/download/v2.2.3/mediago-setup-arm64-2.2.3.dmg)
+
+### 软件截图
+
+![首页](./images/changelog4.png)
+
+### 重要更新
+
+- 支持 docker 部署 web 端
+- 更新桌面端 UI
+
+### 更新日志
+
+- 更新桌面端 UI
+- 支持 docker 部署 web 端
+- 新增视频播放，支持桌面端和移动端播放
+- 修复 mac 打开无法展示界面的问题
+- 优化了批量下载的交互
+- 添加了 windows 的便携版（免安装哦）
+- 优化了下载列表，支持页面中多个视频的嗅探
+- 支持收藏列表手动导入导出
+- 支持首页下载列表导出
+- 优化了【新建下载】表单的交互逻辑
+- 支持 UrlScheme 打开应用，并添加下载任务
+- 修复了一些 bug 并提升用户体验
+
+## v2.2.3 (2024.7.06 发布)
+
+### 下载链接
+
+- [windows mediago v2.2.3](https://github.com/caorushizi/mediago/releases/download/v2.2.3/mediago-setup-x64-2.2.3.exe)
+- [macos mediago v2.2.3](https://github.com/caorushizi/mediago/releases/download/v2.2.3/mediago-setup-x64-2.2.3.dmg)
+- [linux mediago v2.2.3](https://github.com/caorushizi/mediago/releases/download/v2.2.3/mediago-setup-arm64-2.2.3.dmg)
+
+### 更新日志
+
+- 设置中添加【自动更新】开关：仅更新 release 版本，beta 版本不会自动更新
+- 下载表单中增加【批量更新】
+- 新增 Linux 版本发布
+- 载时自动选择清晰度最高的视频
+- 新增【清空缓存】&【无痕模式】
+- 自定义选择安装位置
+- 修复了一些 bug
+
+## v2.2.0 (2024.5.22 发布)
+
+### 下载链接
+
+- [windows mediago v2.2.0](https://github.com/caorushizi/mediago/releases/download/v2.2.0/mediago-setup-2.2.0.exe)
+- [macos mediago v2.2.0](https://github.com/caorushizi/mediago/releases/download/v2.2.0/mediago-setup-2.2.0.dmg)
+
+### 更新日志
+
+- 支持下载直播流
+- 支持哔哩哔哩视频下载
+- 优化沉浸式嗅探流程
+- 支持下载控制台输出
+- 修复了一些 bug
+
+## v2.0.1（2023.7.1 发布）
+
+### 下载链接
+
+- [windows mediago v2.0.1](https://github.com/caorushizi/mediago/releases/download/v2.0.1/media-downloader-setup-2.0.1.exe)
+- [macos mediago v2.0.1](https://github.com/caorushizi/mediago/releases/download/v2.0.1/media-downloader-setup-2.0.1.dmg)
+
+### 软件截图
+
+![首页](./images/changelog3.png)
+
+### 更新日志
+
+- 暗黑模式
+- 更多下载配置
+- 支持请求标头自动带入
+- 支持开启广告过滤
+- 支持开启沉浸式嗅探
+- 支持切换手机和 PC 模式
+- 支持修改同时下载数量
+- 修复了一些 bug
+
+## v1.1.5（2022.2.5 发布）
+
+### 下载链接
+
+- [windows mediago v1.1.5](https://github.com/caorushizi/mediago/releases/download/1.1.5/media-downloader-setup-1.1.4.exe)
+
+### 软件截图
+
+![首页](./images/changelog2.webp)
+
+### 更新日志
+
+- 支持视频下载
+
+## v1.0.1（2021.3.1 发布）
+
+### 软件截图
+
+![首页](./images/changelog1.webp)
+
+### 更新日志
+
+- 支持视频下载

docs/documents.md

@@ -15,15 +15,37 @@ outline: deep
 下载器全局设置
 :::
 
-1. 选择文件夹： 视频下载的路径
+### 1. 选择文件夹
 
-2. 下载器主题： 支持浅色和深色模式
+视频下载的路径
 
-3. 在新窗口中打开浏览器： 开启了之后浏览器页面会独立出一个窗口。
+### 2. 下载器主题
 
-   ![step 1](./images/documents-step2.png)
+支持浅色和深色模式
 
-4. 下载完成提示： 开启之后下载完成会出现系统提示
+### 3. 显示语言、
+
+支持中文和英文
+
+### 4. 下载完成提示
+
+开启之后下载完成会出现系统提示
+
+### 5. 显示控制台
+
+开启之后会显示下载的控制台
+
+### 6. 自动更新
+
+开启之后软件会自动检查更新
+
+### 7. 允许升级测试版本
+
+开启之后软件会自动检查测试版本
+
+### 8. 关闭主窗口
+
+控制关闭主窗口后软件会【隐藏到系统托盘】还是【退出软件】
 
 ## 浏览器设置
 
@@ -31,23 +53,46 @@ outline: deep
 浏览器窗口相关的设置
 :::
 
-1. 代理设置： 填写自己的代理地址
+### 1. 在新窗口中打开浏览器
 
-2. 代理开关： 打开开关后浏览器默认会走填写的代理地址，如果代理地址这个开关是打不开的
+开启了之后浏览器页面会独立出一个窗口
 
-3. 开启广告过滤： 打开开关后会过滤页面中的广告
+   ![step 1](./images/documents-step2.png)
 
-4. 以手机模式进入： 打开后会将浏览器伪装成手机浏览器，请求移动端的站点（左侧是开启手机模式的截图）
+### 2. 代理设置
 
-   ![step 2](./images/documents-step3.png)
+填写自己的代理地址
 
-5. 使用浏览器插件
+### 3. 代理开关
 
-   - 打开状态： 从浏览器中嗅探到的资源不会自动添加到下载列表，需要手动点击页面下方的下载的链接来添加视频到下载列表 **（后面会有很强大的功能哦）**
+打开开关后 **浏览器** 默认会走填写的代理地址，如果代理地址这个开关是打不开的
 
-     ![step 3](./images/documents-step4.png)
+### 4. 开启广告过滤
 
-   - 关闭状态： 浏览器中嗅探到的资源会自动添加到下载列表
+打开开关后会过滤页面中的广告
+
+### 5. 以手机模式进入
+
+打开后会将浏览器伪装成手机浏览器，请求移动端的站点（左侧是开启手机模式的截图）
+
+  ![step 2](./images/documents-step3.png)
+
+### 6. 使用沉浸式嗅探
+
+- 打开状态： 从浏览器中嗅探到的资源不会自动添加到下载列表，需要手动点击页面中的【添加到列表】按钮
+
+  ![step 3](./images/documents-step4.png)
+
+- 关闭状态： 浏览器中嗅探到的资源会自动添加到下载列表
+
+### 7. 隐私模式： 打开后软件不会保存用户的浏览记录
+
+  ![step 4](./images/documents-step5.png)
+
+### 8. 更多操作
+
+- 清空缓存： 清空软件的缓存
+- 导出收藏【导入收藏】： 导出软件的收藏
 
 ## 下载设置
 
@@ -55,29 +100,49 @@ outline: deep
 和下载相关的设置
 :::
 
-1. 下载完成删除分片： 开启后下载完成后会将分片文件删除
-2. 最大同时下载数量： 最多同时可以下载多少视频文件，目前最大是 10，最小是 1
-3. 更多操作
-   - 配置文件目录： 软件数据库路径、日志等等路径
-   - 可执行文件目录： 下载器二进制文件的路径
-   - 本地存储路径： 下载视频的本地路径
-4. 当前版本： 当前软件版本信息
+### 1. 下载代理开关
+
+打开开关后 **下载器** 默认会走填写的代理地址，【浏览器】和【下载器】的代理是独立的
+
+### 2. 下载完成删除分片
+
+开启后下载完成后会将分片文件删除
+
+### 3. 最大同时下载数量
+
+最多同时可以下载多少视频文件，目前最大是 10，最小是 1
+
+### 4. 更多操作
+
+- 配置文件目录： 软件数据库路径、日志等等路径
+- 可执行文件目录： 下载器二进制文件的路径
+- 本地存储路径： 下载视频的本地路径
+
+### 5. 当前版本
+
+当前软件版本信息
 
 ## 其他问题
 
-**Q: 关于直播视频的下载**
+### Q: 关于直播视频的下载
 
 A: 软件支持直播下载，软件目前没有好的办法区分直播流，所以将所有的下载控制台开启。用户自行分辨下载数据源
 
-**Q: 关于 MacOS 版本**
+### Q: 关于 MacOS 版本
 
-A: 目前 MacOS 版本属于非稳定版本，2023 年 5 月发布。需要在 Mac 的安全设置中打开来自身份不明开发者的 Mac App
+A: 【Intel 芯片】需要安装 release 中的 x64 版本。
+
+安装完成后需要在 Mac 的安全设置中打开来自身份不明开发者的 Mac App
 ![QA1](./images/documents-qa1.png)
 
-**Q: 关于旧版本**
+【Apple 芯片】需要安装 release 中的 arm64 芯片
+
+安装完成后需要在控制台执行 `sudo xattr -dr com.apple.quarantine /Applications/mediago.app` 命令
+
+### Q: 关于旧版本
 
 A: 1.1.5 版本确实发布了很长时间，经过大量用户的验证，比较稳定。所以想要使用旧版软件的话请访问[此链接](/history.html)
 
-**Q: 关于 Win7 用户**
+### Q: 关于 Win7 用户
 
-A: v2.0.0 之后的版本已经放弃不支持 Win7 如果需要在 win7 上面使用同样需要下载 1.1.5 版本
+A: v2.0.0 之后的版本已经放弃不支持 Win7 如果需要在 win7 上面使用同样需要下载 1.1.5 版本。如果是 32 位系统，目前默认不支持。

docs/guides.md

@@ -5,50 +5,55 @@ outline: deep
 
 # 快速开始
 
-这篇文章是软件的简单说明，可以快速上手使用本本软件。
+这篇文章是软件的简单说明，可以快速上手使用本软件。
 
 ::: tip
-我建了一个 QQ 群，方便大家一起沟通交流： 574209001
+方便大家一起沟通交流， 可以加入反馈群：
+
+MediaGo QQ反馈群 1： 574209001
+
+MediaGo QQ反馈群 2： 921619626
+
+MediaGo 微信反馈群：[评论区查看](/guides.html#waline)
+:::
+
+::: info
+
+v3.0 是最新版本，大家的意见可以尽量在 3.0 版本中提出，我们会尽快修复。
+
 :::
 
 ## 下载安装
 
-**v2.2.0 (2024.5.22 发布)**
+### v3.0.0 (2024.10.7 发布)
 
-- [windows mediago v2.2.0](https://github.com/caorushizi/mediago/releases/download/v2.2.0/mediago-setup-2.2.0.exe)
-- [macos mediago v2.2.0](https://github.com/caorushizi/mediago/releases/download/v2.2.0/mediago-setup-2.2.0.dmg)
+#### 软件下载
 
-**更新日志**
+- [【mediago】 windows x64 v2.2.3](https://github.com/caorushizi/mediago/releases/download/v2.2.3/mediago-setup-x64-2.2.3.exe)
+- [【mediago】 macos arm64 v2.2.3](https://github.com/caorushizi/mediago/releases/download/v2.2.3/mediago-setup-x64-2.2.3.dmg)
+- [【mediago】 macos x64 v2.2.3](https://github.com/caorushizi/mediago/releases/download/v2.2.3/mediago-setup-x64-2.2.3.dmg)
+- [【mediago】 linux x64 v2.2.3](https://github.com/caorushizi/mediago/releases/download/v2.2.3/mediago-setup-arm64-2.2.3.dmg)
+- 【mediago】 docker v3.0 `docker run`
 
-- 支持下载直播流
-- 支持哔哩哔哩视频下载
-- 优化沉浸式嗅探流程
-- 支持下载控制台输出
-- 修复了一些 bug
+#### 重要更新
 
-**v2.0.1（2023.7.1 发布）**
+- 支持 docker 部署 web 端
+- 更新桌面端 UI
 
-- [windows mediago v2.0.1](https://github.com/caorushizi/mediago/releases/download/v2.0.1/media-downloader-setup-2.0.1.exe)
-- [macos mediago v2.0.1](https://github.com/caorushizi/mediago/releases/download/v2.0.1/media-downloader-setup-2.0.1.dmg)
+#### 更新日志
 
-**更新日志**
-
-- 暗黑模式
-- 更多下载配置
-- 支持请求标头自动带入
-- 支持开启广告过滤
-- 支持开启沉浸式嗅探
-- 支持切换手机和 PC 模式
-- 支持修改同时下载数量
-- 修复了一些 bug
-
-**v1.1.5（2022.2.5 发布）**
-
-- [windows mediago v1.1.5](https://github.com/caorushizi/mediago/releases/download/1.1.5/media-downloader-setup-1.1.4.exe)
-
-**更新日志**
-
-- 支持视频下载
+- 支持 docker 部署 web 端
+- 更新桌面端 UI
+- 新增视频播放，支持桌面端和移动端播放
+- 修复 mac 打开无法展示界面的问题
+- 优化了批量下载的交互
+- 添加了 windows 的便携版（免安装哦）
+- 优化了下载列表，支持页面中多个视频的嗅探
+- 支持收藏列表手动导入导出
+- 支持首页下载列表导出
+- 优化了【新建下载】表单的交互逻辑
+- 支持 UrlScheme 打开应用，并添加下载任务
+- 修复了一些 bug 并提升用户体验
 
 ## 操作说明
 
@@ -62,7 +67,7 @@ outline: deep
 
    ![step 2](./images/guides-step2.png)
 
-3. 开始下载，即可下载视频
+3. 点击【立即下载】，即可下载视频
 
    ![step 3](./images/guides-step3.png)
 
@@ -72,7 +77,7 @@ outline: deep
 
    ![step 1](./images/guides-step4.png)
 
-2. 在新建下载弹窗中填入【视频名称】和【m3u8 地址】即可
+2. 在新建下载弹窗中填入【视频名称】和【流媒体（m3u8）】或者【哔哩哔哩】即可
 
    ![step 2](./images/guides-step5.png)
 
@@ -80,25 +85,27 @@ outline: deep
 
    ![step 3](./images/guides-step3.png)
 
-## 附加功能
+### 批量下载
 
-1. 下载完成后可以在下载列表中点击转换音频按钮将视频转换为音频
+   ![step 3](./images/guides-step6.png)
 
-   ![step 1](./images/addition-step1.png)
+### 附加功能
 
-2. 下载完成后播放视频
+1. 转换为音频
 
-   - PC 播放
+   ![step 1](./images/guides-step7.png)
 
-     ![step 2](./images/addition-step2.png)
+2. 后续会增加更多功能，敬请期待~
 
-   - 移动端播放
+### 播放视频
 
-     ![step 3](./images/addition-step3.png)
+- PC 播放
 
-3. 批量下载
+     ![step 2](./images/addition-step3.png)
 
-   ![step 3](./images/addition-step4.png)
+- 移动端播放
+
+     ![step 3](./images/addition-step4.png)
 
 ## 开始你的视频下载吧
 

docs/index.md

@@ -27,4 +27,7 @@ features:
   - icon: ⚡️
     title: 支持批量下载
     details: 支持同时下载多个视频和直播资源，高速带宽不闲置。
+  - icon: 🎉
+    title: 支持 docker 部署
+    details: 支持 docker 部署 web 端，方便快捷。
 ---

docs/public/favicon.svg

@@ -1,40 +0,0 @@
-<svg t="1686326276609" class="icon" viewBox="0 0 1024 1024" version="1.1"
-    xmlns="http://www.w3.org/2000/svg" p-id="6962" xmlns:xlink="http://www.w3.org/1999/xlink"
-    width="200" height="200">
-    <path
-        d="M110.933333 42.666667h716.8A68.266667 68.266667 0 0 1 896 110.933333v802.133334a68.266667 68.266667 0 0 1-68.266667 68.266666H110.933333A68.266667 68.266667 0 0 1 42.666667 913.066667V110.933333A68.266667 68.266667 0 0 1 110.933333 42.666667z"
-        fill="#111314" fill-opacity=".72" p-id="6963"></path>
-    <path
-        d="M853.333333 42.666667h85.333334a68.266667 68.266667 0 0 1 68.266666 68.266666v802.133334A68.266667 68.266667 0 0 1 938.666667 981.333333h-85.333334a68.266667 68.266667 0 0 0 68.266667-68.266666V110.933333A68.266667 68.266667 0 0 0 853.333333 42.666667z"
-        fill="#CACBCC" p-id="6964"></path>
-    <path
-        d="M162.133333 128h614.4a34.133333 34.133333 0 0 1 34.133334 34.133333v699.733334a34.133333 34.133333 0 0 1-34.133334 34.133333H162.133333a34.133333 34.133333 0 0 1-34.133333-34.133333V162.133333a34.133333 34.133333 0 0 1 34.133333-34.133333z"
-        fill="#FFFFFF" p-id="6965"></path>
-    <path
-        d="M187.733333 170.666667h563.2c9.386667 0 17.066667 7.68 17.066667 17.066666v221.866667a17.066667 17.066667 0 0 1-17.066667 17.066667H187.733333a17.066667 17.066667 0 0 1-17.066666-17.066667V187.733333c0-9.386667 7.68-17.066667 17.066666-17.066666z"
-        fill="#EDEEF0" p-id="6966"></path>
-    <path
-        d="M256 298.666667m17.066667 0l136.533333 0q17.066667 0 17.066667 17.066666l0 136.533334q0 17.066667-17.066667 17.066666l-136.533333 0q-17.066667 0-17.066667-17.066666l0-136.533334q0-17.066667 17.066667-17.066666Z"
-        fill="#FFC13C" p-id="6967"></path>
-    <path
-        d="M341.333333 392.533333a34.133333 34.133333 0 1 1 0-68.266666 34.133333 34.133333 0 0 1 0 68.266666z m65.109334 56.192H276.224C276.224 426.666667 276.224 401.066667 341.333333 401.066667s65.109333 25.6 65.109334 47.658666z"
-        fill="#FFFFFF" p-id="6968"></path>
-    <path
-        d="M469.333333 341.333333m17.066667 0l136.533333 0q17.066667 0 17.066667 17.066667l0 8.533333q0 17.066667-17.066667 17.066667l-136.533333 0q-17.066667 0-17.066667-17.066667l0-8.533333q0-17.066667 17.066667-17.066667Z"
-        fill="#5BADFF" p-id="6969"></path>
-    <path
-        d="M512 554.666667m17.066667 0l179.2 0q17.066667 0 17.066666 17.066666l0 51.2q0 17.066667-17.066666 17.066667l-179.2 0q-17.066667 0-17.066667-17.066667l0-51.2q0-17.066667 17.066667-17.066666Z"
-        fill="#EDEEF0" p-id="6970"></path>
-    <path
-        d="M512 682.666667m17.066667 0l179.2 0q17.066667 0 17.066666 17.066666l0 51.2q0 17.066667-17.066666 17.066667l-179.2 0q-17.066667 0-17.066667-17.066667l0-51.2q0-17.066667 17.066667-17.066666Z"
-        fill="#EDEEF0" p-id="6971"></path>
-    <path
-        d="M213.333333 554.666667m17.066667 0l221.866667 0q17.066667 0 17.066666 17.066666l0 8.533334q0 17.066667-17.066666 17.066666l-221.866667 0q-17.066667 0-17.066667-17.066666l0-8.533334q0-17.066667 17.066667-17.066666Z"
-        fill="#EDEEF0" p-id="6972"></path>
-    <path
-        d="M213.333333 640m17.066667 0l221.866667 0q17.066667 0 17.066666 17.066667l0 8.533333q0 17.066667-17.066666 17.066667l-221.866667 0q-17.066667 0-17.066667-17.066667l0-8.533333q0-17.066667 17.066667-17.066667Z"
-        fill="#EDEEF0" p-id="6973"></path>
-    <path
-        d="M213.333333 725.333333m17.066667 0l221.866667 0q17.066667 0 17.066666 17.066667l0 8.533333q0 17.066667-17.066666 17.066667l-221.866667 0q-17.066667 0-17.066667-17.066667l0-8.533333q0-17.066667 17.066667-17.066667Z"
-        fill="#EDEEF0" p-id="6974"></path>
-</svg>

package.json

@@ -8,16 +8,24 @@
   "type": "module",
   "scripts": {
     "dev": "tsx scripts/dev.ts && pnpm --parallel -F \"./packages/*\" run dev",
+    "dev:web": "pnpm --parallel -F \"./packages/*\" run dev:web",
     "build": "tsx scripts/build.ts",
     "build:plugin": "pnpm -F plugin run build",
     "build:main": "pnpm -F main run build",
+    "build:web": "pnpm -F renderer run build:web",
+    "build:backend": "pnpm -F backend run build",
     "build:renderer": "pnpm -F renderer run build",
+    "build:mobile": "pnpm -F mobile run build",
+    "build:web-release": "tsx scripts/web.ts",
+    "rebuild:web": "pnpm -F backend rebuild",
+    "rebuild:electron": "pnpm -F main run rebuild",
     "beta": "pnpm run build && pnpm -F mediago run pack",
     "release": "pnpm run build && pnpm -F main run release",
     "docs:dev": "vitepress dev docs",
     "docs:build": "vitepress build docs",
     "docs:preview": "vitepress preview docs",
     "types": "pnpm -F main run types",
+    "types:renderer": "pnpm -F renderer run types",
     "types:watch": "pnpm -F main run types:watch",
     "prepare": "husky",
     "commit": "git-cz",
@@ -38,19 +46,19 @@
     "@commitlint/core": "^19.3.0",
     "@commitlint/cz-commitlint": "^19.2.0",
     "@commitlint/format": "^19.3.0",
-    "@eslint/js": "^9.3.0",
-    "@waline/client": "^3.2.0",
+    "@eslint/js": "^8.57.0",
+    "@waline/client": "^3.3.2",
     "commitizen": "^4.3.0",
     "cross-env": "^7.0.3",
     "cspell": "^8.8.3",
     "cz-git": "^1.9.2",
-    "eslint": "^9.3.0",
+    "eslint": "^8.57.0",
     "globals": "^15.3.0",
     "husky": "^9.0.11",
     "tsx": "^4.11.0",
     "typescript-eslint": "^7.10.0",
     "vitepress": "1.2.2",
-    "vue": "^3.4.27",
+    "vue": "^3.5.11",
     "zx": "^8.1.1"
   },
   "pnpm": {

packages/backend/.dockerignore

@@ -0,0 +1,2 @@
+node_modules
+npm-debug.log

packages/backend/.gitignore

@@ -0,0 +1,9 @@
+.bin
+node_modules
+build
+dist
+bin/Logs
+release
+types
+log
+bin

packages/backend/.prettierignore

@@ -0,0 +1 @@
+types/

packages/backend/.prettierrc.json

@@ -0,0 +1 @@
+{}

packages/backend/eslint.config.js

@@ -0,0 +1,16 @@
+import globals from "globals";
+import pluginJs from "@eslint/js";
+import tseslint from "typescript-eslint";
+
+export default [
+  {
+    languageOptions: { globals: globals.node },
+  },
+  pluginJs.configs.recommended,
+  ...tseslint.configs.recommended,
+  {
+    rules: {
+      "@typescript-eslint/no-explicit-any": "warn",
+    },
+  },
+];

packages/backend/gulpfile.ts

@@ -0,0 +1 @@
+export { dev, build } from "./scripts";

packages/backend/nodemon.json

@@ -0,0 +1,5 @@
+{
+  "watch": ["dist"],
+  "ext": "js",
+  "exec": "npx cross-env NODE_ENV=development node dist/server/index.js"
+}

packages/backend/package.json

@@ -0,0 +1,83 @@
+{
+  "name": "backend",
+  "version": "0.1.0",
+  "description": "在线视频下载器",
+  "type": "module",
+  "main": "dist/index.js",
+  "scripts": {
+    "start": "nodemon",
+    "dev:web": "cross-env NODE_ENV=development gulp dev",
+    "build": "cross-env NODE_ENV=production gulp build",
+    "types": "tsc",
+    "types:watch": "tsc -w",
+    "lint-staged": "lint-staged"
+  },
+  "lint-staged": {
+    "*.{js,jsx,ts,tsx}": "eslint"
+  },
+  "author": "",
+  "license": "MIT",
+  "devDependencies": {
+    "@eslint/js": "^8.57.0",
+    "@types/cors": "^2.8.17",
+    "@types/cross-spawn": "^6.0.6",
+    "@types/express": "^4.17.21",
+    "@types/fs-extra": "^11.0.4",
+    "@types/glob": "^8.1.0",
+    "@types/gulp": "^4.0.17",
+    "@types/koa": "^2.15.0",
+    "@types/koa-bodyparser": "^4.3.12",
+    "@types/koa-send": "^4.1.6",
+    "@types/koa-static": "^4.0.4",
+    "@types/koa__cors": "^5.0.0",
+    "@types/koa__router": "^12.0.4",
+    "@types/lodash": "^4.17.4",
+    "@types/mime-types": "^2.1.4",
+    "@types/node": "^20.12.12",
+    "@types/semver": "^7.5.8",
+    "@types/serve-handler": "^6.1.4",
+    "@types/undertaker": "^1.2.11",
+    "consola": "^3.2.3",
+    "cross-env": "^7.0.3",
+    "cross-spawn": "^7.0.3",
+    "del": "^7.1.0",
+    "dotenv": "^16.4.5",
+    "esbuild": "0.21.4",
+    "esbuild-register": "^3.5.0",
+    "eslint": "^8.57.0",
+    "glob": "^10.4.1",
+    "globals": "^15.3.0",
+    "gulp": "^5.0.0",
+    "lint-staged": "^15.2.5",
+    "nodemon": "^3.1.4",
+    "semver": "^7.6.2",
+    "typescript": "^5.4.5",
+    "typescript-eslint": "^7.10.0"
+  },
+  "dependencies": {
+    "@koa/cors": "^5.0.0",
+    "@koa/router": "^12.0.1",
+    "axios": "^1.7.2",
+    "better-sqlite3": "^9.3.0",
+    "cheerio": "1.0.0-rc.12",
+    "dayjs": "^1.11.11",
+    "execa": "^9.1.0",
+    "fs-extra": "^11.2.0",
+    "i18next": "^23.11.5",
+    "inversify": "^6.0.2",
+    "koa": "^2.15.3",
+    "koa-bodyparser": "^4.4.1",
+    "koa-send": "^5.0.1",
+    "koa-static": "^5.0.0",
+    "lodash": "^4.17.21",
+    "mime-types": "^2.1.35",
+    "nanoid": "^5.0.7",
+    "node-pty": "^1.0.0",
+    "reflect-metadata": "^0.2.2",
+    "socket.io": "^4.8.0",
+    "strip-ansi": "^7.1.0",
+    "typeorm": "0.3.20",
+    "winston": "^3.14.2"
+  },
+  "keywords": []
+}

packages/backend/scripts/config.ts

@@ -0,0 +1,30 @@
+import { Env, isDev, mainResolve } from "./utils";
+import esbuild from "esbuild";
+
+export function buildOptions(): esbuild.BuildOptions {
+  const getDefine = (): Record<string, string> => {
+    const vars: Record<string, string> = {
+      "process.env.NODE_ENV": isDev ? '"development"' : '"production"',
+    };
+    if (isDev) {
+      vars.__bin__ = `"${mainResolve("bin").replace(/\\/g, "\\\\")}"`;
+      Object.assign(vars, Env.getInstance().loadDotEnvDefined());
+    }
+
+    return vars;
+  };
+
+  return {
+    entryPoints: [mainResolve("src/index.ts")],
+    bundle: true,
+    sourcemap: process.env.NODE_ENV === "development",
+    define: getDefine(),
+    outdir: mainResolve("dist/server"),
+    loader: { ".png": "file" },
+    minify: process.env.NODE_ENV === "production",
+    packages: "external",
+    format: "esm",
+    target: ["node20"],
+    platform: "node",
+  };
+}

packages/backend/scripts/index.ts

@@ -0,0 +1,86 @@
+import { deleteSync } from "del";
+import { mainResolve, Env, isDev } from "./utils";
+import gulp from "gulp";
+import * as esbuild from "esbuild";
+import consola from "consola";
+import { buildOptions } from "./config";
+import fs from "fs";
+import spawn from "cross-spawn";
+
+const env = Env.getInstance();
+env.loadDotEnvRuntime();
+
+async function clean() {
+  return deleteSync([mainResolve("dist/server")]);
+}
+
+async function buildClean() {
+  return deleteSync([mainResolve("dist")]);
+}
+
+async function copyBin() {
+  const source = mainResolve(
+    "../main/bin",
+    isDev ? process.platform : "linux",
+    process.arch,
+  );
+  const target = mainResolve("dist/server/bin");
+  fs.cpSync(source, target, {
+    recursive: true,
+    filter: (src) => {
+      if (!isDev && src.endsWith("ffmpeg")) {
+        return false;
+      }
+
+      return true;
+    },
+  });
+}
+
+const copy = gulp.parallel(copyBin);
+
+async function watchTask() {
+  const main = await esbuild.context(buildOptions());
+  await main.rebuild();
+
+  const watcher = gulp.watch(["./src"]);
+  watcher
+    .on("change", async () => {
+      await main.rebuild();
+    })
+    .on("error", (error: any) => {
+      consola.error(error);
+    });
+
+  return Promise.resolve();
+}
+
+async function startNodemon() {
+  const nodemon = spawn("npm", ["start"], {
+    stdio: "pipe",
+  });
+
+  nodemon.stdout?.on("data", (data) => {
+    consola.log(data.toString());
+  });
+
+  // 监听 stderr 数据事件
+  nodemon.stderr?.on("data", (data) => {
+    consola.error(`stderr: ${data.toString()}`);
+  });
+
+  // 监听子进程的关闭事件
+  nodemon.on("close", (code) => {
+    consola.log(`子进程退出，退出码 ${code}`);
+  });
+  return Promise.resolve();
+}
+
+async function buildTask() {
+  await esbuild.build(buildOptions());
+}
+
+// 开发环境
+export const dev = gulp.series(clean, copy, watchTask, startNodemon);
+// 构建打包
+export const build = gulp.series(buildClean, copy, buildTask);

packages/backend/scripts/utils.ts

@@ -0,0 +1,70 @@
+import dotenv from "dotenv";
+import { resolve } from "path";
+import fs from "fs-extra";
+
+const baseResolve = (...r: any[]) => resolve(__dirname, ...r);
+export const mainResolve = (...r: string[]) => baseResolve("..", ...r);
+export const rootResolve = (...r: string[]) => baseResolve("../../..", ...r);
+
+export const isDev = process.env.NODE_ENV === "development";
+
+export const isLinux = process.platform === "linux";
+export const isMac = process.platform === "darwin";
+export const isWin = process.platform === "win32";
+
+export class Env {
+  env: Record<string, string> = {};
+  nodeEnv = "";
+  static instance: Env;
+
+  private constructor(nodeEnv = process.env.NODE_ENV) {
+    const env = this.parseEnv(rootResolve(".env"));
+    const modeEnv = this.parseEnv(rootResolve(`.env.${nodeEnv}`));
+    const localEnv = this.parseEnv(rootResolve(`.env.${nodeEnv}.local`));
+
+    this.nodeEnv = nodeEnv || "development";
+    this.env = { ...env, ...modeEnv, ...localEnv };
+  }
+
+  static getInstance() {
+    if (!Env.instance) {
+      Env.instance = new Env();
+    }
+
+    return Env.instance;
+  }
+
+  private parseEnv(path: string) {
+    if (!fs.existsSync(path)) {
+      return null;
+    }
+
+    const parsed = dotenv.parse(fs.readFileSync(path));
+    if (!parsed) {
+      return null;
+    }
+
+    return Object.keys(parsed).reduce((prev: any, curr) => {
+      prev[curr] = parsed[curr];
+      return prev;
+    }, {});
+  }
+
+  loadDotEnvRuntime() {
+    Object.keys(this.env).forEach((key) => {
+      if (process.env[key] != null || !this.env[key]) return;
+      process.env[key] = this.env[key];
+    });
+  }
+
+  loadDotEnvDefined() {
+    return Object.keys(this.env).reduce<Record<string, string>>((prev, cur) => {
+      prev[`process.env.${[cur]}`] = JSON.stringify(this.env[cur]);
+      return prev;
+    }, {});
+  }
+
+  get isDev() {
+    return this.nodeEnv === "development";
+  }
+}

packages/backend/src/app.ts

@@ -0,0 +1,83 @@
+import { inject, injectable } from "inversify";
+import { TYPES } from "./types.ts";
+import TypeORM from "./vendor/TypeORM.ts";
+import RouterHandlerService from "./core/router.ts";
+import Koa from "koa";
+import cors from "@koa/cors";
+import bodyParser from "koa-bodyparser";
+import Logger from "./vendor/Logger.ts";
+import http from "http";
+import SocketIO from "./vendor/SocketIO.ts";
+import VideoRepository from "./repository/VideoRepository.ts";
+import { DownloadStatus } from "./interfaces.ts";
+import serve from "koa-static";
+import { STATIC_DIR } from "./const.ts";
+import send from "koa-send";
+
+@injectable()
+export default class ElectronApp extends Koa {
+  constructor(
+    @inject(TYPES.RouterHandlerService)
+    private readonly router: RouterHandlerService,
+    @inject(TYPES.TypeORM)
+    private readonly db: TypeORM,
+    @inject(TYPES.Logger)
+    private readonly logger: Logger,
+    @inject(TYPES.SocketIO)
+    private readonly socket: SocketIO,
+    @inject(TYPES.VideoRepository)
+    private readonly videoRepository: VideoRepository,
+  ) {
+    super();
+  }
+
+  private async vendorInit() {
+    await this.db.init();
+  }
+
+  async init(): Promise<void> {
+    this.router.init();
+
+    // vendor
+    await this.vendorInit();
+
+    this.use(cors())
+      .use(bodyParser())
+      .use(this.router.routes())
+      .use(this.router.allowedMethods());
+    this.use(serve(STATIC_DIR));
+
+    // 处理静态文件和前端路由的中间件
+    this.use(async (ctx, next) => {
+      if (!ctx.path.startsWith("/api")) {
+        try {
+          await send(ctx, ctx.path, { root: STATIC_DIR });
+        } catch (err: any) {
+          if (err.status === 404) {
+            await send(ctx, "index.html", { root: STATIC_DIR });
+          }
+        }
+      }
+      await next();
+    });
+
+    const server = http.createServer(this.callback());
+
+    this.socket.initSocketIO(server);
+
+    server.listen(8899, () => {
+      this.logger.info("Server running on port 8899");
+    });
+  }
+
+  // 如果重启后还有正在下载的视频，就将状态改成下载失败
+  async resetDownloadStatus(): Promise<void> {
+    // 重启后如果还有 downloading 状态的数据， 全部重置为失败
+    const videos = await this.videoRepository.findWattingAndDownloadingVideos();
+    const videoIds = videos.map((video) => video.id);
+    await this.videoRepository.changeVideoStatus(
+      videoIds,
+      DownloadStatus.Failed,
+    );
+  }
+}

packages/backend/src/const.ts

@@ -0,0 +1,13 @@
+import os from "os";
+import { dirname, resolve } from "path";
+import { fileURLToPath } from "url";
+
+const __filename = fileURLToPath(import.meta.url);
+const __dirname = dirname(__filename);
+
+export const API_PREFIX = "/api";
+export const HOME_DIR = os.homedir();
+export const DOWNLOAD_DIR = `${HOME_DIR}/mediago`;
+export const STATIC_DIR = resolve(__dirname, "../app");
+export const BIN_DIR = resolve(__dirname, "./bin");
+export const DB_PATH = `${__dirname}/../mediago.db`;

packages/backend/src/controller/DownloadController.ts

@@ -0,0 +1,107 @@
+import { inject, injectable } from "inversify";
+import {
+  DownloadItem,
+  DownloadItemPagination,
+  type Controller,
+} from "../interfaces.ts";
+import { TYPES } from "../types.ts";
+import { get, post } from "../helper/index.ts";
+import VideoRepository from "../repository/VideoRepository.ts";
+import { Context } from "koa";
+import DownloaderService from "../services/DownloaderService.ts";
+import DownloadService from "../services/DownloadService.ts";
+import Logger from "../vendor/Logger.ts";
+
+@injectable()
+export default class DownloadController implements Controller {
+  constructor(
+    @inject(TYPES.VideoRepository)
+    private readonly videoRepository: VideoRepository,
+    @inject(TYPES.DownloaderService)
+    private readonly downloaderService: DownloaderService,
+    @inject(TYPES.DownloadService)
+    private readonly downloadService: DownloadService,
+    @inject(TYPES.Logger)
+    private readonly logger: Logger,
+  ) {}
+
+  @get("/")
+  async getFavorites() {
+    return false;
+  }
+
+  @post("add-download-item")
+  async addDownloadItem(ctx: Context) {
+    const video = ctx.request.body as DownloadItem;
+    const item = await this.videoRepository.addVideo(video);
+    return item;
+  }
+
+  @post("add-download-items")
+  async addDownloadItems(ctx: Context) {
+    const videos = ctx.request.body as DownloadItem[];
+    return this.downloaderService.addDownloadItems(videos);
+  }
+
+  @post("get-download-items")
+  async getDownloadItems(ctx: Context) {
+    const pagination = ctx.request.body as DownloadItemPagination;
+    const videos = await this.videoRepository.findVideos(pagination);
+    return videos;
+  }
+
+  @post("start-download")
+  async startDownload(ctx: Context) {
+    const { vid } = ctx.request.body as { vid: number };
+    await this.downloaderService.startDownload(vid);
+  }
+
+  @post("delete-download-item")
+  async deleteDownloadItem(ctx: Context) {
+    const { id } = ctx.request.body as { id: number };
+    await this.videoRepository.deleteDownloadItem(id);
+  }
+
+  @post("download-now")
+  async downloadNow(ctx: Context) {
+    const video = ctx.request.body as Omit<DownloadItem, "id">;
+    await this.downloaderService.downloadNow(video);
+  }
+
+  @post("download-items-now")
+  async downloadItemsNow(ctx: Context) {
+    const videos = ctx.request.body as Omit<DownloadItem, "id">[];
+    // 添加下载项
+    const items = await this.downloaderService.addDownloadItems(videos);
+    // 开始下载
+    items.forEach((item) => this.downloaderService.startDownload(item.id));
+    return items;
+  }
+
+  @post("edit-download-now")
+  async editDownloadNow(ctx: Context) {
+    const video = ctx.request.body as DownloadItem;
+    const item = await this.downloaderService.editDownloadItem(video);
+    await this.downloaderService.startDownload(item.id);
+    return item;
+  }
+
+  @post("edit-download-item")
+  async editDownloadItem(ctx: Context) {
+    const video = ctx.request.body as DownloadItem;
+    this.logger.info("editDownloadItem", video);
+    return this.downloaderService.editDownloadItem(video);
+  }
+
+  @post("stop-download")
+  async stopDownload(ctx: Context) {
+    const { id } = ctx.request.body as { id: number };
+
+    this.downloadService.stopTask(id);
+  }
+
+  @post("get-video-folders")
+  async getVideoFolders() {
+    return this.downloaderService.getVideoFolders();
+  }
+}

packages/backend/src/controller/HomeController.ts

@@ -0,0 +1,51 @@
+import { inject, injectable } from "inversify";
+import { type Controller } from "../interfaces.ts";
+import { ConfigParams, TYPES } from "../types.ts";
+import FavoriteRepository from "../repository/FavoriteRepository.ts";
+import { get, post } from "../helper/index.ts";
+import Logger from "../vendor/Logger.ts";
+import ConfigService from "../services/ConfigService.ts";
+import { Context } from "koa";
+import SocketIO from "../vendor/SocketIO.ts";
+
+@injectable()
+export default class HomeController implements Controller {
+  constructor(
+    @inject(TYPES.FavoriteRepository)
+    private readonly favoriteRepository: FavoriteRepository,
+    @inject(TYPES.Logger)
+    private readonly logger: Logger,
+    @inject(TYPES.ConfigService)
+    private readonly config: ConfigService,
+    @inject(TYPES.SocketIO)
+    private readonly socket: SocketIO,
+  ) {}
+
+  @get("/")
+  async getFavorites() {
+    return false;
+  }
+
+  @post("get-app-store")
+  async getAppStore() {
+    const store = await this.config.getConfig();
+    return store;
+  }
+
+  @post("set-app-store")
+  async setAppStore(ctx: Context) {
+    const params = ctx.request.body as ConfigParams;
+    this.config.setConfig(params);
+    this.logger.info("set app store");
+    return false;
+  }
+
+  @post("socket-test")
+  async socketTest(ctx: Context) {
+    const { message } = ctx.request.body as { message: string };
+    this.logger.info(message);
+
+    this.socket.emit("socket-test", message);
+    return message;
+  }
+}

packages/backend/src/core/router.ts

@@ -0,0 +1,72 @@
+import { inject, injectable, multiInject } from "inversify";
+import { Controller } from "../interfaces.ts";
+import { TYPES } from "../types.ts";
+import Router from "@koa/router";
+import { error, success } from "../helper/utils.ts";
+import { API_PREFIX } from "../const.ts";
+import path from "path";
+import Logger from "../vendor/Logger.ts";
+
+@injectable()
+export default class RouterHandlerService extends Router {
+  constructor(
+    @multiInject(TYPES.Controller)
+    private readonly controllers: Controller[],
+    @inject(TYPES.Logger)
+    private readonly logger: Logger,
+  ) {
+    super();
+  }
+
+  private registerIpc(
+    controller: Controller,
+    propertyKey: string | symbol,
+  ): void {
+    const property = controller[propertyKey];
+    if (typeof property !== "function") return;
+
+    const httpMethod: "get" | "post" = Reflect.getMetadata(
+      "http-method",
+      controller,
+      propertyKey,
+    );
+    if (!httpMethod) return;
+
+    const routerPath = Reflect.getMetadata(
+      "router-path",
+      controller,
+      propertyKey,
+    );
+    if (!routerPath) return;
+
+    const finalPath = path
+      .join(API_PREFIX, routerPath)
+      .replace(/\\/g, "/")
+      .replace(/\/$/, "");
+    this[httpMethod](finalPath, async (context, next) => {
+      try {
+        let res = property.call(controller, context, next);
+        if (res.then) {
+          res = await res;
+        }
+        context.body = success(res);
+      } catch (e: unknown) {
+        this.logger.error(e);
+        if (e instanceof Error) {
+          context.body = error(e.message);
+        } else {
+          context.body = error(String(e));
+        }
+      }
+    });
+  }
+
+  init(): void {
+    for (const controller of this.controllers) {
+      const Class = Object.getPrototypeOf(controller);
+      Object.getOwnPropertyNames(Class).forEach((propertyKey) =>
+        this.registerIpc(controller, propertyKey),
+      );
+    }
+  }
+}

packages/backend/src/core/vendor.ts

@@ -0,0 +1,3 @@
+export interface Vendor {
+  init(): Promise<void>;
+}

packages/backend/src/entity/Config.ts

@@ -0,0 +1,81 @@
+import {
+  Column,
+  CreateDateColumn,
+  Entity,
+  PrimaryGeneratedColumn,
+  UpdateDateColumn,
+} from "typeorm";
+import { AppLanguage, AppTheme } from "../types.ts";
+import { DOWNLOAD_DIR } from "../const.ts";
+
+@Entity({
+  name: "config",
+})
+export class Config {
+  @PrimaryGeneratedColumn()
+  id: number;
+
+  @Column({
+    type: "text",
+    nullable: false,
+    default: DOWNLOAD_DIR,
+  })
+  local: string;
+
+  @Column({
+    type: "text",
+    enum: AppTheme,
+    nullable: false,
+    default: AppTheme.System,
+  })
+  theme: AppTheme;
+
+  @Column({
+    type: "text",
+    enum: AppLanguage,
+    nullable: false,
+    default: AppLanguage.System,
+  })
+  language: AppLanguage;
+
+  @Column({
+    type: "text",
+    nullable: false,
+    default: "",
+  })
+  proxy: string;
+
+  @Column({
+    type: "boolean",
+    default: false,
+    nullable: false,
+  })
+  isLive: boolean;
+
+  @Column({
+    type: "boolean",
+    nullable: false,
+    default: false,
+  })
+  downloadProxySwitch: boolean;
+
+  @Column({
+    type: "boolean",
+    nullable: false,
+    default: true,
+  })
+  deleteSegments: boolean;
+
+  @Column({
+    type: "int",
+    nullable: false,
+    default: 2,
+  })
+  maxRunner: number;
+
+  @CreateDateColumn()
+  createdDate: Date;
+
+  @UpdateDateColumn()
+  updatedDate: Date;
+}

packages/backend/src/entity/Favorite.ts

@@ -0,0 +1,39 @@
+import {
+  Column,
+  CreateDateColumn,
+  Entity,
+  PrimaryGeneratedColumn,
+  UpdateDateColumn,
+} from "typeorm";
+
+@Entity({
+  name: "favorite",
+})
+export class Favorite {
+  @PrimaryGeneratedColumn()
+  id: number;
+
+  @Column({
+    type: "text",
+    nullable: false,
+  })
+  title: string;
+
+  @Column({
+    type: "text",
+    nullable: false,
+  })
+  url: string;
+
+  @Column({
+    type: "text",
+    nullable: true,
+  })
+  icon?: string;
+
+  @CreateDateColumn()
+  createdDate: Date;
+
+  @UpdateDateColumn()
+  updatedDate: Date;
+}

packages/backend/src/entity/Video.ts

@@ -0,0 +1,74 @@
+import { DownloadStatus, DownloadType } from "../interfaces.ts";
+import {
+  Column,
+  CreateDateColumn,
+  Entity,
+  PrimaryGeneratedColumn,
+  UpdateDateColumn,
+} from "typeorm";
+
+@Entity({
+  name: "video",
+})
+export class Video {
+  @PrimaryGeneratedColumn()
+  id: number;
+
+  @Column({
+    type: "text",
+    nullable: false,
+  })
+  name: string;
+
+  @Column({
+    type: "text",
+    nullable: true,
+  })
+  folder?: string;
+
+  @Column({
+    type: "text",
+    nullable: false,
+    default: DownloadType.m3u8,
+  })
+  type: DownloadType;
+
+  @Column({
+    type: "text",
+    nullable: false,
+  })
+  url: string;
+
+  @Column({
+    type: "text",
+    nullable: true,
+  })
+  headers?: string;
+
+  @Column({
+    type: "boolean",
+    default: false,
+    nullable: false,
+  })
+  isLive: boolean;
+
+  @Column({
+    type: "text",
+    nullable: false,
+    default: DownloadStatus.Ready,
+  })
+  status: DownloadStatus;
+
+  @Column({
+    type: "text",
+    nullable: false,
+    default: "",
+  })
+  log: string;
+
+  @CreateDateColumn()
+  createdDate: Date;
+
+  @UpdateDateColumn()
+  updatedDate: Date;
+}

packages/backend/src/global.d.ts

@@ -0,0 +1,6 @@
+/* eslint-disable no-var */
+declare global {
+  var __bin__: string;
+}
+
+export {};

packages/backend/src/helper/decorator.ts

@@ -0,0 +1,13 @@
+export const get = (route: string) => {
+  return (target: any, propertyKey: string): void => {
+    Reflect.defineMetadata("http-method", "get", target, propertyKey);
+    Reflect.defineMetadata("router-path", route, target, propertyKey);
+  };
+};
+
+export const post = (route: string) => {
+  return (target: any, propertyName: string): void => {
+    Reflect.defineMetadata("http-method", "post", target, propertyName);
+    Reflect.defineMetadata("router-path", route, target, propertyName);
+  };
+};

packages/backend/src/helper/ffmpeg.ts

@@ -0,0 +1,39 @@
+import { spawn } from "child_process";
+import { ffmpegPath } from "./variables.ts";
+
+export const convertToAudio = async (
+  input: string,
+  output: string,
+): Promise<void> => {
+  return new Promise((resolve, reject) => {
+    const ffmpeg = spawn(ffmpegPath, [
+      "-y",
+      "-v",
+      "error",
+      "-i",
+      input,
+      "-acodec",
+      "mp3",
+      "-format",
+      "mp3",
+      output,
+    ]);
+    let errData = "";
+
+    ffmpeg.stderr.on("data", (data) => {
+      errData += String(data);
+    });
+
+    ffmpeg.on("error", (err) => {
+      reject(err);
+    });
+
+    ffmpeg.on("close", (code) => {
+      if (code === 0) {
+        resolve();
+      } else {
+        reject(new Error(errData));
+      }
+    });
+  });
+};

packages/backend/src/helper/index.ts

@@ -0,0 +1,29 @@
+import os from "os";
+
+export function getLocalIP() {
+  const interfaces = os.networkInterfaces();
+  let localIP = "";
+
+  // 遍历网络接口
+  for (const key in interfaces) {
+    const iface = interfaces[key];
+    if (!iface) continue;
+
+    // 过滤出 IPv4 地址且非回环地址
+    const filteredIface = iface.filter(
+      (details) => details.family === "IPv4" && !details.internal,
+    );
+
+    if (filteredIface.length > 0) {
+      localIP = filteredIface[0].address;
+      break;
+    }
+  }
+
+  return localIP;
+}
+
+export { sleep, formatHeaders } from "./utils.ts";
+export * from "./variables.ts";
+export { get, post } from "./decorator.ts";
+export { convertToAudio } from "./ffmpeg.ts";

packages/backend/src/helper/utils.ts

@@ -0,0 +1,37 @@
+import EventEmitter from "events";
+
+export async function sleep(second = 1): Promise<void> {
+  return new Promise((resolve) => setTimeout(resolve, second * 1000));
+}
+
+export function formatHeaders(headers: Record<string, string>): string {
+  if (!headers) return "";
+  const formatted = Object.entries(headers)
+    .map(([key, value]) => `${key}:${value}`)
+    .join("\n");
+  return formatted;
+}
+
+export const event = new EventEmitter();
+
+export interface IpcResponse {
+  code: number;
+  message: string;
+  data: Record<string, any> | null;
+}
+
+export function success(data: Record<string, any>): IpcResponse {
+  return {
+    code: 0,
+    message: "success",
+    data,
+  };
+}
+
+export function error(message = "fail"): IpcResponse {
+  return {
+    code: -1,
+    message,
+    data: null,
+  };
+}

packages/backend/src/helper/variables.ts

@@ -0,0 +1,36 @@
+import { resolve } from "path";
+import { BIN_DIR } from "../const.ts";
+
+export enum Platform {
+  Windows = "win32",
+  MacOS = "darwin",
+  Linux = "linux",
+}
+
+export const isMac = process.platform === Platform.MacOS;
+export const isWin = process.platform === Platform.Windows;
+export const isLinux = process.platform === Platform.Linux;
+
+export function resolveBin(path: string) {
+  if (isWin) {
+    path += ".exe";
+  }
+  return resolve(BIN_DIR, path);
+}
+
+export const appName = process.env.APP_NAME || "mediago";
+export const defaultScheme = "mediago";
+export const PERSIST_MEDIAGO = "persist:mediago";
+export const PERSIST_WEBVIEW = "persist:webview";
+export const PRIVACY_WEBVIEW = "webview";
+
+// bin path
+export const ffmpegPath = resolveBin("ffmpeg");
+export const biliDownloaderBin = resolveBin("BBDown");
+export const m3u8DownloaderBin = resolveBin("N_m3u8DL-RE");
+
+// user agent
+export const pcUA =
+  "Mozilla/5.0 (Windows NT 10.0; Win64; x64) AppleWebKit/537.36 (KHTML, like Gecko) Chrome/114.0.0.0 Safari/537.36";
+export const mobileUA =
+  "Mozilla/5.0 (Linux; Android 8.0.0; SM-G955U Build/R16NW) AppleWebKit/537.36 (KHTML, like Gecko) Chrome/87.0.4280.141 Mobile Safari/537.36";

packages/backend/src/i18n/index.ts

@@ -0,0 +1,114 @@
+import i18n from "i18next";
+
+i18n.init({
+  debug: process.env.NODE_ENV === "development",
+  fallbackLng: "zh",
+  interpolation: {
+    escapeValue: false,
+  },
+  resources: {
+    en: {
+      translation: {
+        processIPC: "Processing ipc [{{channel}}] event exception: ",
+        open: "Open",
+        delete: "Delete",
+        noMainWindow: "No main window found",
+        copyLinkAddress: "Copy Link Address",
+        select: "Select",
+        download: "Download",
+        refresh: "Refresh",
+        openFolder: "Open Folder",
+        openFile: "Open File",
+        noFileFound: "No file found",
+        exportFavorites: "Export Favorites",
+        copy: "Copy",
+        paste: "Paste",
+        noTaskFound: "No task found",
+        urlExist: "Url already exists",
+        videoExistsPleaseChangeName:
+          "Video name already exists, please change the video name",
+        videoNotExists: "Video does not exist",
+        unknownError: "Unknown error",
+        unsupportedDownloadType: "Unsupported download type",
+        captureVideoLinkInWindow: "Capture video link in window: {{url}}",
+        browserViewNotFound: "Browser view not found",
+        currentWindowNotFound: "Current window not found",
+        proxyNotAllowEmpty: "[Proxy] Proxy cannot be empty",
+        enableProxy: "[Proxy] Enable Proxy({{proxy}})",
+        disableProxy: "[Proxy] Disable Proxy",
+        adBlockerEnableFailed: "[AdBlocker] AdBlocker enable failed",
+        enableADBlocker: "[AdBlocker] Enable AD Blocker",
+        adBlockerDisableFailed: "[AdBlocker] AdBlocker disable failed",
+        disableADBlocker: "[AdBlocker] Disable AD Blocker",
+        ua: '[UA] User-Agent: "{{ua}}"',
+        session: "[Session] {{mode}} Mode",
+        currentEnvironmentIsDevelopment:
+          "Current environment is development, start loading developer tools",
+        loadDevToolsSuccess: "Load developer tools successfully",
+        loadDevToolsFailed: "Failed to load developer tools",
+        autoUpdateSuccess: "Auto update success",
+        nextTimeWillAutoInstall: "Will be automatically installed next time",
+        downloadSuccess: "Download success",
+        videoDownloadSuccess: "{{name}} download success",
+        downloadFailed: "Download failed",
+        videoDownloadFailed: "{{name}} download failed",
+        showMainWindow: "Show main window",
+        exitApp: "Exit app",
+        updateAvailable: "Update available.",
+        updateNotAvailable: "No updates available.",
+      },
+    },
+    zh: {
+      translation: {
+        processIPC: "处理 ipc [{{channel}}] 事件时异常： ",
+        open: "打开",
+        delete: "删除",
+        noMainWindow: "未找到主窗口",
+        copyLinkAddress: "复制链接地址",
+        select: "选择",
+        download: "下载",
+        refresh: "刷新",
+        openFolder: "打开文件夹",
+        openFile: "打开文件",
+        noFileFound: "未找到文件",
+        exportFavorites: "导出收藏",
+        copy: "复制",
+        paste: "粘贴",
+        noTaskFound: "未找到任务",
+        urlExist: "链接已存在",
+        videoExistsPleaseChangeName: "视频名称已存在，请更改视频名称",
+        videoNotExists: "视频不存在",
+        unknownError: "未知错误",
+        unsupportedDownloadType: "不支持的下载类型",
+        captureVideoLinkInWindow: "在窗口中捕获视频链接: {{url}}",
+        browserViewNotFound: "未找到 BrowserView",
+        currentWindowNotFound: "未找到当前窗口",
+        proxyNotAllowEmpty: "[Proxy] 代理不能为空",
+        enableProxy: "[Proxy] 启用代理({{proxy}})",
+        disableProxy: "[Proxy] 关闭代理",
+        adBlockerEnableFailed: "[AdBlocker] AdBlocker 启用失败",
+        enableADBlocker: "[AdBlocker] 启用 AD Blocker",
+        adBlockerDisableFailed: "[AdBlocker] AdBlocker 关闭失败",
+        disableADBlocker: "[AdBlocker] 关闭 AD Blocker",
+        ua: '[UA] User-Agent: "{{ua}}"',
+        session: "[Session] {{mode}} 模式",
+        currentEnvironmentIsDevelopment:
+          "当前环境为开发环境，开始加载开发者工具",
+        loadDevToolsSuccess: "加载开发者工具成功",
+        loadDevToolsFailed: "加载开发者工具失败",
+        autoUpdateSuccess: "自动更新成功",
+        nextTimeWillAutoInstall: "下次将自动安装",
+        downloadSuccess: "下载成功",
+        videoDownloadSuccess: "{{name}} 下载成功",
+        downloadFailed: "下载失败",
+        videoDownloadFailed: "{{name}} 下载失败",
+        showMainWindow: "显示主窗口",
+        exitApp: "退出应用",
+        updateAvailable: "有可用更新。",
+        updateNotAvailable: "没有可用更新。",
+      },
+    },
+  },
+});
+
+export default i18n;

packages/backend/src/images.d.ts

@@ -0,0 +1,7 @@
+declare module "*.svg";
+declare module "*.png";
+declare module "*.jpg";
+declare module "*.jpeg";
+declare module "*.gif";
+declare module "*.bmp";
+declare module "*.tiff";

packages/backend/src/index.ts

@@ -0,0 +1,7 @@
+import "reflect-metadata";
+import { container } from "./inversify.config.ts";
+import { TYPES } from "./types.ts";
+import ElectronApp from "./app.ts";
+
+const mediago = container.get<ElectronApp>(TYPES.ElectronApp);
+mediago.init();

packages/backend/src/interfaces.ts

@@ -0,0 +1,73 @@
+export type Controller = Record<string | symbol, any>;
+
+export interface DownloadItem {
+  id: number;
+  type: DownloadType;
+  name: string;
+  url: string;
+  headers?: string;
+  status?: DownloadStatus;
+  isLive?: boolean;
+  folder?: string;
+}
+
+export enum DownloadFilter {
+  list = "list",
+  done = "done",
+}
+
+export interface DownloadItemPagination {
+  current?: number;
+  pageSize?: number;
+  filter?: DownloadFilter;
+}
+
+export interface ConversionPagination {
+  current?: number;
+  pageSize?: number;
+}
+
+export interface VideoResponse {
+  total: number;
+  list: DownloadItem[];
+}
+
+export enum DownloadStatus {
+  Ready = "ready",
+  Watting = "watting",
+  Downloading = "downloading",
+  Stopped = "stopped",
+  Success = "success",
+  Failed = "failed",
+}
+
+export type Task = {
+  id: number;
+  params: Omit<DownloadParams, "id" | "abortSignal" | "callback">;
+};
+
+export interface DownloadProgress {
+  id: number;
+  type: string;
+  percent: string;
+  speed: string;
+  isLive: boolean;
+}
+
+export enum DownloadType {
+  m3u8 = "m3u8",
+  bilibili = "bilibili",
+}
+export interface DownloadParams {
+  id: number;
+  type: DownloadType;
+  url: string;
+  local: string;
+  name: string;
+  headers?: string;
+  abortSignal: AbortController;
+  proxy?: string;
+  deleteSegments?: boolean;
+  callback: (progress: DownloadProgress) => void;
+  folder?: string;
+}

packages/backend/src/inversify.config.ts

@@ -0,0 +1,60 @@
+import HomeController from "./controller/HomeController.ts";
+import { Container } from "inversify";
+import FavoriteRepository from "./repository/FavoriteRepository.ts";
+import ElectronApp from "./app.ts";
+import { Controller } from "./interfaces.ts";
+import { TYPES } from "./types.ts";
+import TypeORM from "./vendor/TypeORM.ts";
+import RouterHandler from "./core/router.ts";
+import HomeService from "./services/HomeService.ts";
+import Logger from "./vendor/Logger.ts";
+import DownloadController from "./controller/DownloadController.ts";
+import VideoRepository from "./repository/VideoRepository.ts";
+import ConfigRepository from "./repository/ConfigRepository.ts";
+import ConfigService from "./services/ConfigService.ts";
+import DownloadService from "./services/DownloadService.ts";
+import SocketIO from "./vendor/SocketIO.ts";
+import DownloaderService from "./services/DownloaderService.ts";
+
+const container = new Container({
+  skipBaseClassChecks: true,
+  defaultScope: "Singleton",
+  autoBindInjectable: true,
+});
+
+container
+  .bind<ElectronApp>(TYPES.ElectronApp)
+  .to(ElectronApp)
+  .inSingletonScope();
+
+// services
+container.bind<HomeService>(TYPES.HomeService).to(HomeService);
+container.bind<ConfigService>(TYPES.ConfigService).to(ConfigService);
+container.bind<DownloadService>(TYPES.DownloadService).to(DownloadService);
+container
+  .bind<DownloaderService>(TYPES.DownloaderService)
+  .to(DownloaderService);
+
+// controller
+container.bind<Controller>(TYPES.Controller).to(HomeController);
+container.bind<Controller>(TYPES.Controller).to(DownloadController);
+
+// repository
+container
+  .bind<FavoriteRepository>(TYPES.FavoriteRepository)
+  .to(FavoriteRepository);
+container.bind<VideoRepository>(TYPES.VideoRepository).to(VideoRepository);
+container.bind<ConfigRepository>(TYPES.ConfigRepository).to(ConfigRepository);
+
+// vendor
+container.bind<TypeORM>(TYPES.TypeORM).to(TypeORM);
+container.bind<Logger>(TYPES.Logger).to(Logger);
+container.bind<SocketIO>(TYPES.SocketIO).to(SocketIO);
+
+// core
+container
+  .bind<RouterHandler>(TYPES.RouterHandlerService)
+  .to(RouterHandler)
+  .inSingletonScope();
+
+export { container };

packages/backend/src/main.d.ts

@@ -0,0 +1,66 @@
+import { Rectangle } from "electron";
+import { type DownloadType } from "interfaces";
+import { AppLanguage, AppTheme } from "./types";
+
+declare interface EnvPath {
+  binPath: string;
+  dbPath: string;
+  workspace: string;
+  platform: string;
+  local: string;
+}
+
+declare interface BrowserWindowInitialVal {
+  url?: string;
+  sourceList?: WebSource[];
+}
+
+declare interface WebSource {
+  url: string;
+  type: DownloadType;
+  name: string;
+  headers?: string;
+}
+
+declare interface AppStore {
+  // 本地存储地址
+  local: string;
+  // 下载完成提示音
+  promptTone: boolean;
+  // 代理地址
+  proxy: string;
+  // 是否开启代理
+  useProxy: boolean;
+  // 下载完成后删除原始文件
+  deleteSegments: boolean;
+  // 新窗口打开浏览器
+  openInNewWindow: boolean;
+  mainBounds?: Rectangle;
+  browserBounds?: Rectangle;
+  blockAds: boolean;
+  // 主题
+  theme: AppTheme;
+  // 使用浏览器插件
+  useExtension: boolean;
+  // 是否使用手机UA
+  isMobile: boolean;
+  // 最大同时下载数
+  maxRunner: number;
+  // 语言
+  language: AppLanguage;
+  // 是否显示终端
+  showTerminal: boolean;
+  // 隐私模式
+  privacy: boolean;
+  // 机器id
+  machineId: string;
+  // 下载代理设置
+  downloadProxySwitch: boolean;
+  // 自动更新
+  autoUpgrade: boolean;
+}
+
+declare interface BrowserStore {
+  url: string;
+  sourceList: WebSource[];
+}

packages/backend/src/repository/ConfigRepository.ts

@@ -0,0 +1,30 @@
+import { inject, injectable } from "inversify";
+import { ConfigParams, TYPES } from "../types.ts";
+import TypeORM from "../vendor/TypeORM.ts";
+import { Repository } from "typeorm";
+import { Config } from "../entity/Config.ts";
+
+@injectable()
+export default class ConfigRepository {
+  repository: Repository<Config>;
+
+  constructor(
+    @inject(TYPES.TypeORM)
+    private readonly db: TypeORM,
+  ) {
+    this.repository = this.db.manager.getRepository(Config);
+  }
+
+  async getConfig(): Promise<Config> {
+    const config = await this.repository.findOneBy({ id: 1 });
+    if (!config) {
+      return await this.repository.save(new Config());
+    }
+    return config;
+  }
+
+  async setConfig({ key, val }: ConfigParams) {
+    const config = await this.getConfig();
+    this.repository.update(config.id, { [key]: val });
+  }
+}

packages/backend/src/repository/FavoriteRepository.ts

@@ -0,0 +1,42 @@
+import { inject, injectable } from "inversify";
+import { TYPES } from "../types.ts";
+import { Favorite } from "../entity/Favorite.ts";
+import TypeORM from "../vendor/TypeORM.ts";
+
+@injectable()
+export default class FavoriteRepository {
+  constructor(
+    @inject(TYPES.TypeORM)
+    private readonly db: TypeORM,
+  ) {}
+
+  async findFavorites(): Promise<Favorite[]> {
+    return await this.db.manager.find(Favorite, {
+      order: {
+        createdDate: "desc",
+      },
+    });
+  }
+
+  async addFavorite(favorite: Favorite): Promise<Favorite> {
+    const exist = await this.db.manager.findOne(Favorite, {
+      where: {
+        url: favorite.url,
+      },
+    });
+
+    if (exist) {
+      throw new Error("网址已经存在");
+    }
+
+    const item = new Favorite();
+    item.title = favorite.title;
+    item.url = favorite.url;
+    item.icon = favorite.icon;
+    return await this.db.manager.save(item);
+  }
+
+  async removeFavorite(id: number): Promise<void> {
+    await this.db.manager.getRepository(Favorite).delete(id);
+  }
+}

packages/backend/src/repository/VideoRepository.ts

@@ -0,0 +1,189 @@
+import { Video } from "../entity/Video.ts";
+import { inject, injectable } from "inversify";
+import {
+  DownloadFilter,
+  DownloadItem,
+  DownloadItemPagination,
+  DownloadStatus,
+} from "../interfaces.ts";
+import { TYPES } from "../types.ts";
+import { In, Not } from "typeorm";
+import TypeORM from "../vendor/TypeORM.ts";
+import i18n from "../i18n/index.ts";
+
+@injectable()
+export default class VideoRepository {
+  constructor(
+    @inject(TYPES.TypeORM)
+    private readonly db: TypeORM,
+  ) {}
+
+  async addVideo(video: Omit<DownloadItem, "id">) {
+    // 先判断有没有同名的视频
+    const exist = await this.findVideoByName(video.name);
+    if (exist) {
+      throw new Error(i18n.t("videoExistsPleaseChangeName"));
+    }
+    const item = new Video();
+    item.name = video.name;
+    item.url = video.url;
+    item.type = video.type;
+    video.headers && (item.headers = video.headers);
+    video.folder && (item.folder = video.folder);
+    return await this.db.manager.save(item);
+  }
+
+  async addVideos(videos: Omit<DownloadItem, "id">[]) {
+    // 检查是否有同名的视频
+    const names = videos.map((item) => item.name);
+    const existItems = await this.db.appDataSource
+      .getRepository(Video)
+      .findBy({ name: In(names) });
+    if (existItems.length) {
+      const existNames = existItems.map((item) => item.name);
+      throw new Error(
+        i18n.t("videoExistsPleaseChangeName") +
+          "[" +
+          existNames.join(", ") +
+          "]",
+      );
+    }
+
+    const items = videos.map((video) => {
+      const item = new Video();
+      item.name = video.name;
+      item.url = video.url;
+      item.type = video.type;
+      video.headers && (item.headers = video.headers);
+      video.folder && (item.folder = video.folder);
+      return item;
+    });
+    return await this.db.manager.save(items);
+  }
+
+  // 编辑视频
+  async editVideo(video: DownloadItem) {
+    const item = await this.db.appDataSource
+      .getRepository(Video)
+      .findOneBy({ id: video.id });
+    if (!item) {
+      throw new Error(i18n.t("videoNotExists"));
+    }
+    item.name = video.name;
+    item.url = video.url;
+    video.headers && (item.headers = video.headers);
+    video.folder && (item.folder = video.folder);
+    return await this.db.manager.save(item);
+  }
+
+  // 查找所有视频
+  async findAllVideos() {
+    return await this.db.appDataSource.getRepository(Video).find({
+      order: {
+        createdDate: "DESC",
+      },
+    });
+  }
+
+  async findVideos(pagination: DownloadItemPagination) {
+    const {
+      current = 0,
+      pageSize = 50,
+      filter = DownloadFilter.list,
+    } = pagination;
+    const filterCondition =
+      filter === DownloadFilter.done
+        ? DownloadStatus.Success
+        : Not(DownloadStatus.Success);
+
+    const [items, count] = await this.db.appDataSource
+      .getRepository(Video)
+      .findAndCount({
+        where: {
+          status: filterCondition,
+        },
+        order: {
+          createdDate: "ASC",
+        },
+        skip: (current - 1) * pageSize,
+        take: pageSize,
+      });
+    return {
+      total: count,
+      list: items,
+    };
+  }
+
+  async findVideo(id: number) {
+    const repository = this.db.appDataSource.getRepository(Video);
+    const video = await repository.findOneBy({ id });
+
+    if (!video) {
+      throw new Error(i18n.t("videoNotExists"));
+    }
+
+    return video;
+  }
+
+  async findVideoByName(name: string) {
+    return this.db.appDataSource.getRepository(Video).findOneBy({
+      name,
+    });
+  }
+
+  async changeVideoStatus(id: number | number[], status: DownloadStatus) {
+    const ids = !Array.isArray(id) ? [id] : id;
+    const videoRepository = this.db.appDataSource.getRepository(Video);
+    const videos = await videoRepository.findBy({ id: In(ids) });
+    for (const video of videos) {
+      video.status = status;
+    }
+    await videoRepository.save(videos);
+  }
+
+  async changeVideoIsLive(id: number) {
+    const video = await this.findVideo(id);
+    video.isLive = true;
+    return this.db.manager.save(video);
+  }
+
+  async findWattingAndDownloadingVideos() {
+    return await this.db.appDataSource.getRepository(Video).find({
+      where: {
+        status: In([DownloadStatus.Downloading, DownloadStatus.Watting]),
+      },
+    });
+  }
+
+  async deleteDownloadItem(id: number) {
+    return await this.db.appDataSource.getRepository(Video).delete(id);
+  }
+
+  async findVideoByUrl(url: string) {
+    return this.db.appDataSource.getRepository(Video).findOneBy({
+      url,
+    });
+  }
+
+  async appendDownloadLog(id: number, message: string) {
+    const video = await this.findVideo(id);
+    video.log = video.log ? `${video.log}\n${message}` : message;
+    return await this.db.manager.save(video);
+  }
+
+  async getDownloadLog(id: number) {
+    const video = await this.findVideo(id);
+    return video.log;
+  }
+
+  async getVideoFolders() {
+    const videos = await this.db.appDataSource.getRepository(Video).find();
+    const folders = new Set<string>();
+    for (const video of videos) {
+      if (video.folder) {
+        folders.add(video.folder);
+      }
+    }
+    return Array.from(folders);
+  }
+}

packages/backend/src/services/ConfigService.ts

@@ -0,0 +1,19 @@
+import { inject, injectable } from "inversify";
+import { ConfigParams, TYPES } from "../types.ts";
+import ConfigRepository from "../repository/ConfigRepository.ts";
+
+@injectable()
+export default class ConfigService {
+  constructor(
+    @inject(TYPES.ConfigRepository)
+    private readonly configRepository: ConfigRepository,
+  ) {}
+
+  async getConfig() {
+    return await this.configRepository.getConfig();
+  }
+
+  async setConfig({ key, val }: ConfigParams) {
+    return await this.configRepository.setConfig({ key, val });
+  }
+}

packages/backend/src/services/DownloadService.ts

@@ -0,0 +1,421 @@
+import EventEmitter from "events";
+import { inject, injectable } from "inversify";
+import {
+  DownloadParams,
+  DownloadProgress,
+  DownloadStatus,
+  Task,
+} from "../interfaces.ts";
+import { TYPES } from "../types.ts";
+import Logger from "../vendor/Logger.ts";
+import VideoRepository from "../repository/VideoRepository.ts";
+import {
+  Platform,
+  biliDownloaderBin,
+  m3u8DownloaderBin,
+} from "../helper/index.ts";
+import * as pty from "node-pty";
+import stripAnsi from "strip-ansi";
+import i18n from "../i18n/index.ts";
+import ConfigService from "./ConfigService.ts";
+import path from "path";
+
+interface DownloadContext {
+  // 是否为直播
+  isLive: boolean;
+  // 下载进度
+  percent: string;
+  // 下载速度
+  speed: string;
+  // 是否已经 ready
+  ready: boolean;
+}
+
+export interface DownloadOptions {
+  abortSignal: AbortController;
+  encoding?: string;
+  onMessage?: (ctx: DownloadContext, message: string) => void;
+  id: number;
+}
+
+interface Schema {
+  args: Record<string, { argsName: string[] | null }>;
+  consoleReg: {
+    percent: string;
+    speed: string;
+    error: string;
+    start: string;
+    isLive: string;
+  };
+  bin: string;
+  platform: string[];
+  type: string;
+}
+
+// FIXME: 多语言正则表达式
+const processList: Schema[] = [
+  {
+    type: "m3u8",
+    platform: [Platform.MacOS, Platform.Linux, Platform.Windows],
+    bin: m3u8DownloaderBin,
+    args: {
+      url: {
+        argsName: null,
+      },
+      localDir: {
+        argsName: ["--tmp-dir", "--save-dir"],
+      },
+      name: {
+        argsName: ["--save-name"],
+      },
+      // headers: {
+      //   argsName: ["--headers"],
+      // },
+      deleteSegments: {
+        argsName: ["--del-after-done"],
+      },
+      proxy: {
+        argsName: ["--custom-proxy"],
+      },
+      __common__: {
+        argsName: [
+          "--no-log",
+          "--auto-select",
+          "--ui-language",
+          "zh-CN",
+          "--live-real-time-merge",
+        ],
+      },
+    },
+    consoleReg: {
+      percent: "([\\d.]+)%",
+      speed: "([\\d.]+[GMK]Bps)",
+      error: "ERROR",
+      start: "保存文件名:",
+      isLive: "检测到直播流",
+    },
+  },
+  {
+    type: "bilibili",
+    platform: [Platform.Linux, Platform.MacOS, Platform.Windows],
+    bin: biliDownloaderBin,
+    args: {
+      url: {
+        argsName: null,
+      },
+      localDir: {
+        argsName: ["--work-dir"],
+      },
+    },
+    consoleReg: {
+      speed: "([\\d.]+\\s[GMK]B/s)",
+      percent: "([\\d.]+)%",
+      error: "ERROR",
+      start: "开始下载",
+      isLive: "检测到直播流",
+    },
+  },
+];
+
+@injectable()
+export default class DownloadService extends EventEmitter {
+  private queue: Task[] = [];
+
+  private active: Task[] = [];
+
+  private limit: number = 2;
+
+  private signal: Record<number, AbortController> = {};
+
+  constructor(
+    @inject(TYPES.Logger)
+    private readonly logger: Logger,
+    @inject(TYPES.VideoRepository)
+    private readonly videoRepository: VideoRepository,
+    @inject(TYPES.ConfigService)
+    private readonly storeService: ConfigService,
+  ) {
+    super();
+
+    // this.storeService.getConfig().then(({ maxRunner }) => {
+    //   this.limit = maxRunner;
+    // });
+  }
+
+  async addTask(task: Task) {
+    this.queue.push(task);
+    this.runTask();
+  }
+
+  async stopTask(id: number) {
+    if (this.signal[id]) {
+      this.signal[id].abort();
+    }
+  }
+
+  async execute(task: Task) {
+    try {
+      await this.videoRepository.changeVideoStatus(
+        task.id,
+        DownloadStatus.Downloading,
+      );
+      this.emit("download-start", task.id);
+
+      this.logger.info(`taskId: ${task.id} start`);
+      const controller = new AbortController();
+      this.signal[task.id] = controller;
+
+      const callback = (progress: DownloadProgress) => {
+        if (progress.type === "progress") {
+          this.emit("download-progress", progress);
+        } else if (progress.type === "ready") {
+          this.emit("download-ready-start", progress);
+          if (progress.isLive) {
+            this.removeTask(progress.id);
+          }
+        }
+      };
+
+      const params: DownloadParams = {
+        ...task.params,
+        id: task.id,
+        abortSignal: controller,
+        callback,
+      };
+
+      const { proxy, downloadProxySwitch } =
+        await this.storeService.getConfig();
+      if (downloadProxySwitch && proxy) {
+        params.proxy = proxy;
+      }
+
+      await this.process(params);
+      delete this.signal[task.id];
+      this.logger.info(`taskId: ${task.id} success`);
+
+      await this.videoRepository.changeVideoStatus(
+        task.id,
+        DownloadStatus.Success,
+      );
+      this.emit("download-success", task.id);
+    } catch (err: any) {
+      if (err.message === "AbortError") {
+        this.logger.info(`taskId: ${task.id} stopped`);
+        // 下载暂停
+        await this.videoRepository.changeVideoStatus(
+          task.id,
+          DownloadStatus.Stopped,
+        );
+        this.emit("download-stop", task.id);
+      } else {
+        this.logger.error(`taskId: ${task.id} failed`, err);
+        // 下载失败
+        await this.videoRepository.changeVideoStatus(
+          task.id,
+          DownloadStatus.Failed,
+        );
+        this.emit("download-failed", task.id, err);
+      }
+    } finally {
+      this.removeTask(task.id);
+
+      // 传输完成
+      if (this.queue.length === 0 && this.active.length === 0) {
+        // this.emit("download-finish");
+      }
+    }
+  }
+
+  removeTask(id: number) {
+    // 处理当前正在活动的任务
+    const doneId = this.active.findIndex((i) => i.id === id);
+    this.active.splice(doneId, 1);
+    // 处理完成的任务
+    if (this.active.length < this.limit) {
+      this.runTask();
+    }
+  }
+
+  runTask() {
+    while (this.active.length < this.limit && this.queue.length > 0) {
+      const task = this.queue.shift();
+      if (task) {
+        this.active.push(task);
+        this.execute(task);
+      }
+    }
+  }
+
+  private _execa(
+    binPath: string,
+    args: string[],
+    params: DownloadOptions,
+  ): Promise<void> {
+    const { abortSignal, onMessage, id } = params;
+
+    return new Promise((resolve, reject) => {
+      const ptyProcess = pty.spawn(binPath, args, {
+        name: "xterm-color",
+        cols: 500,
+        rows: 500,
+        useConpty: false,
+      });
+
+      if (onMessage) {
+        const ctx: DownloadContext = {
+          ready: false,
+          isLive: false,
+          percent: "",
+          speed: "",
+        };
+        ptyProcess.onData((data) => {
+          try {
+            const txt = stripAnsi(data);
+            this.emit("download-message", id, data);
+            onMessage(ctx, txt);
+          } catch (err) {
+            reject(err);
+          }
+        });
+      }
+
+      abortSignal.signal.addEventListener("abort", () => {
+        ptyProcess.kill();
+        reject(new Error("AbortError"));
+      });
+
+      ptyProcess.onExit(({ exitCode }) => {
+        if (exitCode === 0) {
+          resolve();
+        } else {
+          reject(new Error(i18n.t("unknownError")));
+        }
+      });
+    });
+  }
+
+  async downloader(params: DownloadParams, schema: Schema): Promise<void> {
+    const {
+      id,
+      abortSignal,
+      url,
+      local,
+      name,
+      deleteSegments,
+      headers,
+      callback,
+      proxy,
+      folder,
+    } = params;
+
+    const spawnParams = [];
+    for (const key of Object.keys(schema.args)) {
+      const { argsName } = schema.args[key];
+      if (key === "url") {
+        argsName && spawnParams.push(...argsName);
+        spawnParams.push(url);
+      }
+      if (key === "localDir") {
+        let finalLocal = local;
+        if (folder) {
+          finalLocal = path.join(local, folder);
+        }
+        argsName && argsName.forEach((i) => spawnParams.push(i, finalLocal));
+      }
+      if (key === "name") {
+        argsName && argsName.forEach((i) => spawnParams.push(i, name));
+      }
+
+      if (key === "headers") {
+        if (headers) {
+          const h: Record<string, unknown> = JSON.parse(headers);
+          Object.entries(h).forEach(([k, v]) => {
+            spawnParams.push("--header", `${k}: ${v}`);
+          });
+        }
+      }
+
+      if (key === "deleteSegments" && deleteSegments) {
+        argsName && spawnParams.push(...argsName);
+      }
+
+      if (key === "proxy" && proxy) {
+        argsName && argsName.forEach((i) => spawnParams.push(i, proxy));
+      }
+
+      if (key === "__common__") {
+        argsName && spawnParams.push(...argsName);
+      }
+    }
+
+    const { consoleReg } = schema;
+    const isLiveReg = RegExp(consoleReg.isLive, "g");
+    const startDownloadReg = RegExp(consoleReg.start, "g");
+    const errorReg = RegExp(consoleReg.error, "g");
+    const speedReg = RegExp(consoleReg.speed, "g");
+    const percentReg = RegExp(consoleReg.percent, "g");
+
+    const onMessage = (ctx: DownloadContext, message: string) => {
+      // 解析是否为直播资源
+      if (isLiveReg.test(message)) {
+        ctx.isLive = true;
+      }
+      // 解析下载进度
+      const [, percent] = percentReg.exec(message) || [];
+      if (percent && Number(ctx.percent || 0) < Number(percent)) {
+        ctx.percent = percent;
+      }
+      // 解析下载速度
+      const [, speed] = speedReg.exec(message) || [];
+      if (speed) {
+        ctx.speed = speed;
+      }
+
+      if (startDownloadReg.test(message)) {
+        callback({
+          id,
+          type: "ready",
+          isLive: ctx.isLive,
+          speed: "",
+          percent: "",
+        });
+        ctx.ready = true;
+        return;
+      }
+
+      if (errorReg.test(message)) {
+        throw new Error(message);
+      }
+
+      if (ctx.ready && (ctx.percent || ctx.speed)) {
+        callback({
+          id,
+          type: "progress",
+          percent: ctx.percent || "",
+          speed: ctx.speed || "",
+          isLive: ctx.isLive,
+        });
+      }
+    };
+
+    this.logger.debug("download params: ", spawnParams.join(" "));
+    await this._execa(schema.bin, spawnParams, {
+      id,
+      abortSignal,
+      onMessage,
+    });
+  }
+
+  async process(params: DownloadParams): Promise<void> {
+    const program = processList
+      .filter((i) => i.platform.includes(process.platform))
+      .filter((i) => i.type === params.type);
+
+    if (program.length === 0) {
+      return Promise.reject(new Error(i18n.t("unsupportedDownloadType")));
+    }
+
+    const schema = program[0];
+    await this.downloader(params, schema);
+  }
+}

packages/backend/src/services/DownloaderService.ts

@@ -0,0 +1,66 @@
+import { inject, injectable } from "inversify";
+import VideoRepository from "../repository/VideoRepository.ts";
+import { TYPES } from "../types.ts";
+import ConfigRepository from "../repository/ConfigRepository.ts";
+import { DownloadItem, DownloadStatus, Task } from "../interfaces.ts";
+import DownloadService from "./DownloadService.ts";
+
+@injectable()
+export default class DownloaderService {
+  constructor(
+    @inject(TYPES.VideoRepository)
+    private readonly videoRepository: VideoRepository,
+    @inject(TYPES.ConfigRepository)
+    private readonly store: ConfigRepository,
+    @inject(TYPES.DownloadService)
+    private readonly downloadService: DownloadService,
+  ) {}
+
+  async startDownload(vid: number) {
+    // 查找将要下载的视频
+    const video = await this.videoRepository.findVideo(vid);
+    const { name, url, headers, type, folder } = video;
+    const { local, deleteSegments } = await this.store.getConfig();
+
+    const task: Task = {
+      id: vid,
+      params: {
+        url,
+        type,
+        local,
+        name,
+        headers,
+        deleteSegments,
+        folder,
+      },
+    };
+    await this.videoRepository.changeVideoStatus(vid, DownloadStatus.Watting);
+    this.downloadService.addTask(task);
+  }
+
+  async downloadNow(video: Omit<DownloadItem, "id">) {
+    // 添加下载项
+    const item = await this.addDownloadItem(video);
+    // 开始下载
+    await this.startDownload(item.id);
+    return item;
+  }
+
+  async addDownloadItem(video: Omit<DownloadItem, "id">) {
+    const item = await this.videoRepository.addVideo(video);
+    return item;
+  }
+
+  async addDownloadItems(videos: Omit<DownloadItem, "id">[]) {
+    const items = await this.videoRepository.addVideos(videos);
+    return items;
+  }
+
+  async editDownloadItem(video: DownloadItem) {
+    return this.videoRepository.editVideo(video);
+  }
+
+  async getVideoFolders() {
+    return this.videoRepository.getVideoFolders();
+  }
+}

packages/backend/src/services/HomeService.ts

@@ -0,0 +1,9 @@
+import EventEmitter from "events";
+import { injectable } from "inversify";
+
+@injectable()
+export default class HomeService extends EventEmitter {
+  constructor() {
+    super();
+  }
+}

packages/backend/src/types.ts

@@ -0,0 +1,46 @@
+import { Config } from "./entity/Config.ts";
+
+export const TYPES = {
+  ElectronApp: Symbol.for("ElectronApp"),
+  RouterHandlerService: Symbol.for("RouterHandlerService"),
+  Controller: Symbol.for("Controller"),
+  // repository
+  VideoRepository: Symbol.for("VideoRepository"),
+  FavoriteRepository: Symbol.for("FavoriteRepository"),
+  ConversionRepository: Symbol.for("ConversionRepository"),
+  ConfigRepository: Symbol.for("ConfigRepository"),
+  // windows
+  BrowserWindow: Symbol.for("BrowserWindow"),
+  MainWindow: Symbol.for("MainWindow"),
+  PlayerWindow: Symbol.for("PlayerWindow"),
+  // services
+  HomeService: Symbol.for("HomeService"),
+  DownloadService: Symbol.for("DownloadService"),
+  SessionService: Symbol.for("SessionService"),
+  ProtocolService: Symbol.for("ProtocolService"),
+  VideoService: Symbol.for("VideoService"),
+  SniffingHelper: Symbol.for("SniffingHelper"),
+  ConfigService: Symbol.for("ConfigService"),
+  DownloaderService: Symbol.for("DownloaderService"),
+  // vendor
+  TypeORM: Symbol.for("TypeORM"),
+  Logger: Symbol.for("Logger"),
+  SocketIO: Symbol.for("SocketIO"),
+};
+
+export enum AppTheme {
+  System = "system",
+  Light = "light",
+  Dark = "dark",
+}
+
+export enum AppLanguage {
+  System = "system",
+  ZH = "zh",
+  EN = "en",
+}
+
+export interface ConfigParams {
+  key: keyof Config;
+  val: Config[keyof Config];
+}

packages/backend/src/vendor/Logger.ts

@@ -0,0 +1,57 @@
+import { injectable } from "inversify";
+import { Vendor } from "../core/vendor.ts";
+import winston from "winston";
+
+@injectable()
+export default class Logger implements Vendor {
+  logger: winston.Logger;
+
+  constructor() {
+    this.logger = winston.createLogger({
+      level: "info",
+      format: winston.format.json(),
+      defaultMeta: { service: "user-service" },
+      transports: [
+        //
+        // - Write all logs with importance level of `error` or less to `error.log`
+        // - Write all logs with importance level of `info` or less to `combined.log`
+        //
+        new winston.transports.File({
+          filename: "./log/error.log",
+          level: "error",
+        }),
+        new winston.transports.File({ filename: "./log/combined.log" }),
+      ],
+    });
+
+    //
+    // If we're not in production then log to the `console` with the format:
+    // `${info.level}: ${info.message} JSON.stringify({ ...rest }) `
+    //
+    if (process.env.NODE_ENV !== "production") {
+      this.logger.add(
+        new winston.transports.Console({
+          format: winston.format.simple(),
+        }),
+      );
+    }
+  }
+
+  info(...args: unknown[]) {
+    return this.logger.info(args);
+  }
+
+  warn(...args: unknown[]) {
+    return this.logger.warn(args);
+  }
+
+  error(...args: unknown[]) {
+    return this.logger.error(args);
+  }
+
+  debug(...args: unknown[]) {
+    return this.logger.debug(args);
+  }
+
+  async init() {}
+}

packages/backend/src/vendor/SocketIO.ts

@@ -0,0 +1,88 @@
+import { inject, injectable } from "inversify";
+import { Vendor } from "../core/vendor.ts";
+import http from "http";
+import { Server } from "socket.io";
+import { TYPES } from "../types.ts";
+import DownloadService from "../services/DownloadService.ts";
+import { DownloadProgress } from "../interfaces.ts";
+import VideoRepository from "../repository/VideoRepository.ts";
+import Logger from "./Logger.ts";
+import ConfigService from "../services/ConfigService.ts";
+
+@injectable()
+export default class SocketIO implements Vendor {
+  io: Server;
+
+  constructor(
+    @inject(TYPES.DownloadService)
+    private readonly downloadService: DownloadService,
+    @inject(TYPES.VideoRepository)
+    private readonly videoRepository: VideoRepository,
+    @inject(TYPES.Logger)
+    private readonly logger: Logger,
+    @inject(TYPES.ConfigService)
+    private readonly store: ConfigService,
+  ) {}
+
+  async init() {}
+
+  async initSocketIO(server: http.Server) {
+    this.io = new Server(server, {
+      /* options */
+      cors: {
+        origin: "*",
+      },
+    });
+
+    this.io.engine.on("headers", (headers) => {
+      headers["Access-Control-Allow-Private-Network"] = true;
+    });
+
+    this.io.on("connection", () => {});
+
+    this.downloadService.on("download-ready-start", this.onDownloadReadyStart);
+    this.downloadService.on("download-progress", this.onDownloadProgress);
+    this.downloadService.on("download-success", this.onDownloadSuccess);
+    this.downloadService.on("download-failed", this.onDownloadFailed);
+    this.downloadService.on("download-start", this.onDownloadStart);
+    this.downloadService.on("download-stop", this.onDownloadStop);
+    this.downloadService.on("download-message", this.receiveMessage);
+  }
+
+  async emit(event: string, ...data: any[]) {
+    this.io.emit(event, {}, ...data);
+  }
+
+  onDownloadReadyStart = async ({ id, isLive }: DownloadProgress) => {
+    if (isLive) {
+      await this.videoRepository.changeVideoIsLive(id);
+      this.emit("change-video-is-live", { id });
+    }
+  };
+
+  onDownloadProgress = (progress: DownloadProgress) => {
+    this.emit("download-progress", progress);
+  };
+
+  onDownloadSuccess = async (id: number) => {
+    this.emit("download-success", id);
+  };
+
+  onDownloadFailed = async (id: number, err: unknown) => {
+    this.logger.error("download failed: ", err);
+    this.emit("download-failed", id);
+  };
+
+  onDownloadStart = async (id: number) => {
+    this.emit("download-start", id);
+  };
+
+  onDownloadStop = async (id: number) => {
+    this.emit("download-stop", id);
+  };
+
+  receiveMessage = async (id: number, message: string) => {
+    // 将日志写入数据库中
+    await this.videoRepository.appendDownloadLog(id, message);
+  };
+}

packages/backend/src/vendor/TypeORM.ts

@@ -0,0 +1,32 @@
+import { injectable } from "inversify";
+import { DataSource, EntityManager } from "typeorm";
+import { Favorite } from "../entity/Favorite.ts";
+import { Vendor } from "../core/vendor.ts";
+import { Video } from "../entity/Video.ts";
+import { Config } from "../entity/Config.ts";
+import { DB_PATH } from "../const.ts";
+
+@injectable()
+export default class DatabaseService implements Vendor {
+  appDataSource: DataSource;
+
+  constructor() {
+    this.appDataSource = new DataSource({
+      type: "better-sqlite3",
+      database: DB_PATH,
+      synchronize: true,
+      logging: false,
+      entities: [Favorite, Video, Config],
+      migrations: [],
+      subscribers: [],
+    });
+  }
+
+  async init() {
+    await this.appDataSource.initialize();
+  }
+
+  get manager(): EntityManager {
+    return this.appDataSource.manager;
+  }
+}

packages/backend/tsconfig.json

@@ -0,0 +1,27 @@
+{
+  "compilerOptions": {
+    "target": "ES2015",
+    "module": "NodeNext",
+    "esModuleInterop": true,
+    "forceConsistentCasingInFileNames": true,
+    "strict": true,
+    "skipLibCheck": true,
+    "resolveJsonModule": true,
+    "experimentalDecorators": true,
+    "emitDecoratorMetadata": true,
+    "moduleResolution": "NodeNext",
+    "strictPropertyInitialization": false,
+    "typeRoots": ["node_modules/@types"],
+    "declaration": true,
+    "emitDeclarationOnly": true,
+    "declarationDir": "./types",
+    "outDir": "app/output/build/main",
+    "allowImportingTsExtensions": true
+  },
+  "include": ["src"],
+  "references": [
+    {
+      "path": "./tsconfig.node.json"
+    }
+  ]
+}

packages/backend/tsconfig.node.json

@@ -0,0 +1,15 @@
+{
+  "compilerOptions": {
+    "strict": true,
+    "composite": true,
+    "forceConsistentCasingInFileNames": true,
+    "module": "ES2015",
+    "lib": ["ES2015"],
+    "moduleResolution": "Node",
+    "allowSyntheticDefaultImports": true,
+    "esModuleInterop": true,
+    "resolveJsonModule": true,
+    "typeRoots": ["node_modules/@types"]
+  },
+  "include": ["gulpfile.ts", "scripts"]
+}

packages/main/app/package.json

@@ -1,14 +1,14 @@
 {
   "name": "mediago",
-  "version": "2.2.1",
+  "version": "3.0.0",
   "description": "在线视频下载器",
   "main": "main/index.js",
   "author": "caorushizi",
   "homepage": "https://downloader.caorushizi.cn/",
   "license": "MIT",
   "dependencies": {
-    "@cliqz/adblocker-electron": "^1.27.3",
-    "@cliqz/adblocker-electron-preload": "^1.27.3",
+    "@cliqz/adblocker-electron": "1.27.3",
+    "@cliqz/adblocker-electron-preload": "1.27.3",
     "node-pty": "^1.0.0"
   },
   "devDependencies": {

packages/main/dev-app-update.yml

@@ -0,0 +1,3 @@
+provider: generic
+updaterCacheDirName: mediago-updater
+url: "http://127.0.0.1:9000/release"

packages/main/package.json

@@ -10,6 +10,7 @@
     "pack": "cross-env NODE_ENV=development gulp release",
     "build": "cross-env NODE_ENV=production gulp build",
     "release": "cross-env NODE_ENV=production gulp release",
+    "rebuild": "electron-rebuild -f -w",
     "types": "tsc",
     "types:watch": "tsc -w",
     "lint-staged": "lint-staged"
@@ -21,8 +22,10 @@
   "license": "MIT",
   "devDependencies": {
     "@electron/rebuild": "^3.6.0",
-    "@eslint/js": "^9.3.0",
+    "@eslint/js": "^8.57.0",
+    "@types/cors": "^2.8.17",
     "@types/electron-devtools-installer": "^2.2.5",
+    "@types/express": "^4.17.21",
     "@types/fs-extra": "^11.0.4",
     "@types/glob": "^8.1.0",
     "@types/gulp": "^4.0.17",
@@ -31,6 +34,8 @@
     "@types/node": "^20.12.12",
     "@types/node-fetch": "^2.6.11",
     "@types/semver": "^7.5.8",
+    "@types/serve-handler": "^6.1.4",
+    "@types/undertaker": "^1.2.11",
     "consola": "^3.2.3",
     "cross-env": "^7.0.3",
     "del": "^7.1.0",
@@ -40,7 +45,7 @@
     "electron-updater": "^6.1.8",
     "esbuild": "^0.21.4",
     "esbuild-register": "^3.5.0",
-    "eslint": "^9.3.0",
+    "eslint": "^8.57.0",
     "glob": "^10.4.1",
     "globals": "^15.3.0",
     "gulp": "^5.0.0",
@@ -50,25 +55,32 @@
     "typescript-eslint": "^7.10.0"
   },
   "dependencies": {
-    "@cliqz/adblocker-electron": "^1.27.3",
-    "@cliqz/adblocker-electron-preload": "^1.27.3",
+    "@cliqz/adblocker-electron": "1.27.3",
+    "@cliqz/adblocker-electron-preload": "1.27.3",
     "axios": "^1.7.2",
-    "better-sqlite3": "^10.0.0",
+    "better-sqlite3": "^9.6.0",
     "cheerio": "1.0.0-rc.12",
+    "cors": "^2.8.5",
     "dayjs": "^1.11.11",
     "electron-devtools-installer": "^3.2.0",
     "electron-is-dev": "^3.0.1",
     "electron-log": "^5.1.5",
     "electron-store": "^9.0.0",
     "execa": "^9.1.0",
+    "express": "^4.19.2",
     "fs-extra": "^11.2.0",
+    "i18next": "^23.11.5",
     "inversify": "^6.0.2",
     "lint-staged": "^15.2.5",
     "lodash": "^4.17.21",
+    "lru-cache": "^11.0.1",
     "mime-types": "^2.1.35",
+    "nanoid": "^5.0.7",
     "node-fetch": "^3.3.2",
+    "node-machine-id": "^1.1.12",
     "node-pty": "^1.0.0",
     "reflect-metadata": "^0.2.2",
+    "serve-handler": "^6.1.5",
     "strip-ansi": "^7.1.0",
     "typeorm": "0.3.20"
   }

packages/main/scripts/config.ts

@@ -63,7 +63,8 @@ export function getReleaseConfig(): Configuration {
     buildVersion: process.env.APP_VERSION,
     appId: process.env.APP_ID,
     copyright: process.env.APP_COPYRIGHT,
-    artifactName: "${productName}-setup-${arch}-${buildVersion}.${ext}",
+    artifactName:
+      "${productName}-setup-${platform}-${arch}-${buildVersion}.${ext}",
     npmRebuild: true,
     directories: {
       output: "./release",
@@ -81,7 +82,11 @@ export function getReleaseConfig(): Configuration {
         to: "plugin",
       },
       {
-        from: "./app/bin/",
+        from: "./app/mobile",
+        to: "mobile",
+      },
+      {
+        from: "./bin/${platform}/${arch}",
         to: "bin",
       },
     ],
@@ -92,8 +97,13 @@ export function getReleaseConfig(): Configuration {
           target: "nsis",
           arch: ["x64"],
         },
+        "portable",
       ],
     },
+    portable: {
+      artifactName:
+        "${productName}-portable-${platform}-${arch}-${buildVersion}.${ext}",
+    },
     dmg: {
       contents: [
         {
@@ -111,10 +121,12 @@ export function getReleaseConfig(): Configuration {
     },
     mac: {
       icon: "../assets/icon.icns",
-      target: {
-        target: "dmg",
-        arch: ["x64"],
-      },
+      target: [
+        {
+          target: "dmg",
+          arch: [process.arch === "arm64" ? "arm64" : "x64"],
+        },
+      ],
     },
     linux: {
       category: "Utility",
@@ -126,17 +138,11 @@ export function getReleaseConfig(): Configuration {
       },
     },
     nsis: {
-      oneClick: true,
+      oneClick: false,
       allowElevation: true,
-      allowToChangeInstallationDirectory: false,
-      installerIcon: "",
-      uninstallerIcon: "",
-      installerHeaderIcon: "",
+      allowToChangeInstallationDirectory: true,
       createDesktopShortcut: true,
       createStartMenuShortcut: true,
-      shortcutName: "",
-      include: "",
-      script: "",
     },
   };
 }

packages/main/scripts/index.ts

@@ -9,6 +9,7 @@ import pkg from "../app/package.json";
 import * as builder from "electron-builder";
 import { globSync } from "glob";
 import fs from "fs";
+import { exec } from "child_process";
 
 const env = Env.getInstance();
 env.loadDotEnvRuntime();
@@ -17,10 +18,25 @@ async function clean() {
   return deleteSync([
     mainResolve("app/build"),
     mainResolve("app/bin"),
+    mainResolve("app/mobile"),
+    mainResolve("app/plugin"),
     mainResolve("release"),
   ]);
 }
 
+function compileTypescript() {
+  exec("npx tsc", (error, stdout, stderr) => {
+    if (error) {
+      console.error(`Error: ${error.message}`);
+      return;
+    }
+    if (stderr) {
+      console.error(`Stderr: ${stderr}`);
+      return;
+    }
+  });
+}
+
 async function copySqlite() {
   const path = "build/Release/better_sqlite3.node";
   const source = mainResolve("node_modules/better-sqlite3", path);
@@ -29,7 +45,7 @@ async function copySqlite() {
 }
 
 async function copyBin() {
-  const source = mainResolve("bin", process.platform);
+  const source = mainResolve("bin", process.platform, process.arch);
   const target = mainResolve("app/bin");
   fs.cpSync(source, target, { recursive: true });
 }
@@ -44,7 +60,14 @@ async function chmodBin() {
   }
 }
 
-const copy = gulp.parallel(copyBin, copySqlite);
+async function copyUpdateConfig() {
+  const source = mainResolve("dev-app-update.yml");
+  const target = mainResolve("app/build/main/dev-app-update.yml");
+  fs.cpSync(source, target, { recursive: true });
+}
+
+const devCopy = gulp.parallel(copyBin, copySqlite, copyUpdateConfig);
+const buildCopy = gulp.parallel(copySqlite);
 
 async function watchTask() {
   const app = new ElectronApp();
@@ -59,6 +82,8 @@ async function watchTask() {
       app.start();
     })
     .on("change", async () => {
+      compileTypescript();
+
       await main.rebuild();
       await preload.rebuild();
       app.restart();
@@ -84,15 +109,15 @@ async function pack() {
       provider: "github",
       repo: "mediago",
       owner: "caorushizi",
-      releaseType: "prerelease",
+      releaseType: "draft",
     };
   }
   await builder.build({ config });
 }
 
 // 开发环境
-export const dev = gulp.series(clean, copy, chmodBin, watchTask);
+export const dev = gulp.series(devCopy, chmodBin, watchTask);
 // 构建打包
-export const build = gulp.series(clean, copy, chmodBin, buildTask);
+export const build = gulp.series(clean, buildCopy, chmodBin, buildTask);
 // release
 export const release = gulp.series(pack);

packages/main/scripts/utils.ts

@@ -5,7 +5,7 @@ import consola from "consola";
 import fs from "fs-extra";
 import electron from "electron";
 
-const baseResolve = (...r) => resolve(__dirname, ...r);
+const baseResolve = (...r: any[]) => resolve(__dirname, ...r);
 export const mainResolve = (...r: string[]) => baseResolve("..", ...r);
 export const rootResolve = (...r: string[]) => baseResolve("../../..", ...r);
 
@@ -81,7 +81,7 @@ export class Env {
       return null;
     }
 
-    return Object.keys(parsed).reduce((prev, curr) => {
+    return Object.keys(parsed).reduce((prev: any, curr) => {
       prev[curr] = parsed[curr];
       return prev;
     }, {});

packages/main/src/app.ts

@@ -1,8 +1,9 @@
 import { inject, injectable } from "inversify";
 import { DownloadStatus } from "./interfaces.ts";
 import { TYPES } from "./types.ts";
-import { Menu, Tray, app, nativeImage, nativeTheme } from "electron";
+import { Menu, Tray, app, nativeImage, nativeTheme, Event } from "electron";
 import TrayIcon from "./tray-icon.png";
+import TrayIconLight from "./tray-icon-light.png";
 import path from "path";
 import MainWindow from "./windows/MainWindow.ts";
 import WebviewService from "./services/WebviewService.ts";
@@ -13,6 +14,9 @@ import ElectronUpdater from "./vendor/ElectronUpdater.ts";
 import TypeORM from "./vendor/TypeORM.ts";
 import ProtocolService from "./core/protocol.ts";
 import IpcHandlerService from "./core/ipc.ts";
+import { VideoService } from "./services/VideoService.ts";
+import i18n from "./i18n/index.ts";
+import { isMac } from "./helper/variables.ts";
 
 @injectable()
 export default class ElectronApp {
@@ -35,11 +39,13 @@ export default class ElectronApp {
     private readonly devTools: ElectronDevtools,
     @inject(TYPES.ElectronStore)
     private readonly store: ElectronStore,
+    @inject(TYPES.VideoService)
+    private readonly videoService: VideoService,
   ) {}
 
   private async serviceInit(): Promise<void> {
     this.mainWindow.init();
-    this.webview.init();
+    this.videoService.init();
   }
 
   private async vendorInit() {
@@ -62,6 +68,7 @@ export default class ElectronApp {
     });
 
     this.initAppTheme();
+    this.initLanguage();
     this.resetDownloadStatus();
 
     this.initTray();
@@ -72,17 +79,28 @@ export default class ElectronApp {
     nativeTheme.themeSource = theme;
   }
 
+  initLanguage(): void {
+    const language = this.store.get("language");
+    i18n.changeLanguage(language);
+  }
+
   initTray() {
-    const iconPath = path.resolve(__dirname, TrayIcon);
+    const iconPath = path.resolve(__dirname, isMac ? TrayIconLight : TrayIcon);
     const icon = nativeImage.createFromPath(iconPath);
     const tray = new Tray(icon);
-    tray.setToolTip("在线视频下载");
+    tray.setToolTip("Media Go");
     tray.addListener("click", () => {
       this.mainWindow.init();
     });
     const contextMenu = Menu.buildFromTemplate([
-      { label: "显示主窗口", click: () => this.mainWindow.init() },
-      { label: "退出 app", role: "quit" },
+      {
+        label: i18n.t("showMainWindow"),
+        click: () => this.mainWindow.init(),
+      },
+      {
+        label: i18n.t("exitApp"),
+        role: "quit",
+      },
     ]);
     tray.setContextMenu(contextMenu);
   }
@@ -97,4 +115,9 @@ export default class ElectronApp {
       DownloadStatus.Failed,
     );
   }
+
+  secondInstance = (event: Event, commandLine: string[]) => {
+    const url = commandLine.pop() || "";
+    this.mainWindow.showWindow(url);
+  };
 }

packages/main/src/controller/DownloadController.ts

@@ -1,12 +1,14 @@
 import { IpcMainEvent } from "electron/main";
 import { inject, injectable } from "inversify";
-import { handle } from "../helper/index.ts";
+import { handle, videoPattern } from "../helper/index.ts";
 import {
   type Controller,
   DownloadItem,
   DownloadItemPagination,
   Task,
   DownloadStatus,
+  VideoStat,
+  ListPagination,
 } from "../interfaces.ts";
 import { TYPES } from "../types.ts";
 import MainWindow from "../windows/MainWindow.ts";
@@ -14,6 +16,8 @@ import ElectronStore from "../vendor/ElectronStore.ts";
 import DownloadService from "../services/DownloadService.ts";
 import VideoRepository from "../repository/VideoRepository.ts";
 import WebviewService from "../services/WebviewService.ts";
+import path from "path";
+import { glob } from "glob";
 
 @injectable()
 export default class DownloadController implements Controller {
@@ -27,7 +31,7 @@ export default class DownloadController implements Controller {
     @inject(TYPES.MainWindow)
     private readonly mainWindow: MainWindow,
     @inject(TYPES.WebviewService)
-    private readonly webviewService: WebviewService
+    private readonly webviewService: WebviewService,
   ) {}
 
   @handle("show-download-dialog")
@@ -36,7 +40,7 @@ export default class DownloadController implements Controller {
     this.webviewService.sendToWindow(
       "show-download-dialog",
       data,
-      image.toDataURL()
+      image?.toDataURL(),
     );
   }
 
@@ -88,16 +92,37 @@ export default class DownloadController implements Controller {
   }
 
   @handle("get-download-items")
-  async getDownloadItems(e: IpcMainEvent, pagination: DownloadItemPagination) {
+  async getDownloadItems(
+    e: IpcMainEvent,
+    pagination: DownloadItemPagination,
+  ): Promise<ListPagination> {
     const videos = await this.videoRepository.findVideos(pagination);
-    return videos;
+
+    const result: ListPagination = {
+      total: videos.total,
+      list: [],
+    };
+
+    const local = this.store.get("local");
+    for (const video of videos.list) {
+      const final: VideoStat = { ...video };
+      if (video.status === DownloadStatus.Success) {
+        const pattern = path.join(local, `${video.name}.{${videoPattern}}`);
+        const files = await glob(pattern);
+        final.exists = files.length > 0;
+        final.file = files[0];
+      }
+      result.list.push(final);
+    }
+
+    return result;
   }
 
   @handle("start-download")
   async startDownload(e: IpcMainEvent, vid: number) {
     // 查找将要下载的视频
     const video = await this.videoRepository.findVideo(vid);
-    const { name, url, headers, type } = video;
+    const { name, url, headers, type, folder } = video;
     const local = this.store.get("local");
 
     // 从配置中添加参数
@@ -112,6 +137,7 @@ export default class DownloadController implements Controller {
         name,
         headers,
         deleteSegments,
+        folder,
       },
     };
     await this.videoRepository.changeVideoStatus(vid, DownloadStatus.Watting);

packages/main/src/controller/HomeController.ts

@@ -9,12 +9,17 @@ import {
   clipboard,
 } from "electron";
 import { Favorite } from "../entity/Favorite.ts";
-import { convertToAudio, db, workspace } from "../helper/index.ts";
+import {
+  convertToAudio,
+  db,
+  videoPattern,
+  workspace,
+} from "../helper/index.ts";
 import { inject, injectable } from "inversify";
 import { AppStore, EnvPath } from "../main.ts";
 import path from "path";
 import { handle, getLocalIP } from "../helper/index.ts";
-import { type Controller } from "../interfaces.ts";
+import { DownloadStatus, type Controller } from "../interfaces.ts";
 import { TYPES } from "../types.ts";
 import fs from "fs-extra";
 import MainWindow from "../windows/MainWindow.ts";
@@ -24,6 +29,12 @@ import WebviewService from "../services/WebviewService.ts";
 import FavoriteRepository from "../repository/FavoriteRepository.ts";
 import VideoRepository from "../repository/VideoRepository.ts";
 import ConversionRepository from "../repository/ConversionRepository.ts";
+import { machineId } from "node-machine-id";
+import { nanoid } from "nanoid";
+import { glob } from "glob";
+import i18n from "../i18n/index.ts";
+import ElectronLogger from "../vendor/ElectronLogger.ts";
+import ElectronUpdater from "../vendor/ElectronUpdater.ts";
 
 @injectable()
 export default class HomeController implements Controller {
@@ -43,7 +54,11 @@ export default class HomeController implements Controller {
     @inject(TYPES.WebviewService)
     private readonly webviewService: WebviewService,
     @inject(TYPES.ConversionRepository)
-    private readonly conversionRepository: ConversionRepository
+    private readonly conversionRepository: ConversionRepository,
+    @inject(TYPES.ElectronLogger)
+    private readonly logger: ElectronLogger,
+    @inject(TYPES.ElectronUpdater)
+    private readonly updater: ElectronUpdater,
   ) {}
 
   @handle("get-env-path")
@@ -87,14 +102,14 @@ export default class HomeController implements Controller {
     };
     const template: Array<MenuItemConstructorOptions | MenuItem> = [
       {
-        label: "打开",
+        label: i18n.t("open"),
         click: () => {
           send("open");
         },
       },
       { type: "separator" },
       {
-        label: "删除",
+        label: i18n.t("delete"),
         click: () => {
           send("delete");
         },
@@ -108,7 +123,7 @@ export default class HomeController implements Controller {
   @handle("select-download-dir")
   async selectDownloadDir(): Promise<string> {
     const window = this.mainWindow.window;
-    if (!window) return Promise.reject("未找到主窗口");
+    if (!window) return Promise.reject(i18n.t("noMainWindow"));
 
     const result = await dialog.showOpenDialog(window, {
       properties: ["openDirectory"],
@@ -146,6 +161,18 @@ export default class HomeController implements Controller {
     if (key === "isMobile") {
       this.webviewService.setUserAgent(val);
     }
+    // privacy
+    if (key === "privacy") {
+      this.webviewService.setDefaultSession(val);
+    }
+    // language
+    if (key === "language") {
+      i18n.changeLanguage(val);
+    }
+    // allowBeta
+    if (key === "allowBeta") {
+      this.updater.changeAllowBeta(val);
+    }
 
     this.store.set(key, val);
   }
@@ -171,38 +198,63 @@ export default class HomeController implements Controller {
     const item = await this.videoRepository.findVideo(id);
     const template: Array<MenuItemConstructorOptions | MenuItem> = [
       {
-        label: "拷贝链接地址",
+        label: i18n.t("copyLinkAddress"),
         click: () => {
           clipboard.writeText(item.url || "");
         },
       },
       {
-        label: "选择",
+        label: i18n.t("select"),
         click: () => {
           send("select");
         },
       },
       {
-        label: "下载",
+        label: i18n.t("download"),
         click: () => {
           send("download");
         },
       },
       {
-        label: "刷新",
+        label: i18n.t("refresh"),
         click: () => {
           send("refresh");
         },
       },
       { type: "separator" },
       {
-        label: "删除",
+        label: i18n.t("delete"),
         click: () => {
           send("delete");
         },
       },
     ];
 
+    if (item.status === DownloadStatus.Success) {
+      const local = this.store.get("local");
+      const pattern = path.join(local, `${item.name}.{${videoPattern}}`);
+      const files = await glob(pattern);
+      const exists = files.length > 0;
+      if (exists) {
+        const file = files[0];
+        template.unshift(
+          {
+            label: i18n.t("openFolder"),
+            click: () => {
+              shell.showItemInFolder(file);
+            },
+          },
+          {
+            label: i18n.t("openFile"),
+            click: () => {
+              shell.openPath(file);
+            },
+          },
+          { type: "separator" },
+        );
+      }
+    }
+
     const menu = Menu.buildFromTemplate(template);
     menu.popup();
   }
@@ -219,7 +271,7 @@ export default class HomeController implements Controller {
     if (exist) {
       return await convertToAudio(input, output);
     } else {
-      return Promise.reject("未找到文件，可能是文件已经删除");
+      return Promise.reject(i18n.t("noFileFound"));
     }
   }
 
@@ -260,7 +312,7 @@ export default class HomeController implements Controller {
   @handle("select-file")
   async selectFile() {
     const window = this.mainWindow.window;
-    if (!window) return Promise.reject("未找到主窗口");
+    if (!window) return Promise.reject(i18n.t("noMainWindow"));
 
     const result = await dialog.showOpenDialog(window, {
       properties: ["openFile"],
@@ -271,4 +323,103 @@ export default class HomeController implements Controller {
     }
     return "";
   }
+
+  @handle("get-machine-id")
+  async getMachineId() {
+    try {
+      const id = this.store.get("machineId");
+      if (id) return id;
+      const newId = await machineId();
+      this.store.set("machineId", newId);
+      return newId;
+    } catch (e) {
+      const id = this.store.get("machineId");
+      if (id) return id;
+      const newId = nanoid();
+      this.store.set("machineId", newId);
+      return newId;
+    }
+  }
+
+  @handle("export-favorites")
+  async exportFavorites() {
+    const favorites = await this.favoriteRepository.findFavorites();
+    const json = JSON.stringify(
+      favorites.map((i) => ({
+        title: i.title,
+        url: i.url,
+        icon: i.icon,
+      })),
+      null,
+      2,
+    );
+    const window = this.mainWindow.window;
+    if (!window) return Promise.reject(i18n.t("noMainWindow"));
+
+    const result = await dialog.showSaveDialog(window, {
+      title: i18n.t("exportFavorites"),
+      defaultPath: "favorites.json",
+      filters: [{ name: "JSON", extensions: ["json"] }],
+    });
+
+    if (!result.canceled) {
+      await fs.writeFile(result.filePath, json);
+    }
+  }
+
+  @handle("import-favorites")
+  async importFavorites() {
+    const window = this.mainWindow.window;
+    if (!window) return Promise.reject(i18n.t("noMainWindow"));
+
+    const result = await dialog.showOpenDialog(window, {
+      properties: ["openFile"],
+      filters: [{ name: "JSON", extensions: ["json"] }],
+    });
+
+    if (!result.canceled) {
+      const filePath = result.filePaths[0];
+      const json = await fs.readJSON(filePath);
+      await this.favoriteRepository.importFavorites(json);
+    }
+  }
+
+  @handle("check-update")
+  async checkUpdate() {
+    this.updater.manualUpdate();
+  }
+
+  @handle("start-update")
+  async startUpdate() {
+    this.updater.startDownload();
+  }
+
+  @handle("install-update")
+  async installUpdate() {
+    this.updater.install();
+  }
+
+  @handle("export-download-list")
+  async exportDownloadList() {
+    const videos = await this.videoRepository.findAllVideos();
+
+    const txt = videos.map((video) => `${video.url} ${video.name}`).join("\n");
+    const window = this.mainWindow.window;
+    if (!window) return Promise.reject(i18n.t("noMainWindow"));
+
+    const result = await dialog.showSaveDialog(window, {
+      title: i18n.t("exportDownloadList"),
+      defaultPath: "download-list.txt",
+      filters: [{ name: "Text", extensions: ["txt"] }],
+    });
+
+    if (!result.canceled) {
+      await fs.writeFile(result.filePath, txt);
+    }
+  }
+
+  @handle("get-video-folders")
+  async getVideoFolders() {
+    return this.videoRepository.getVideoFolders();
+  }
 }

packages/main/src/controller/PlayerController.ts

@@ -0,0 +1,18 @@
+import { inject, injectable } from "inversify";
+import { handle } from "../helper/index.ts";
+import { type Controller } from "../interfaces.ts";
+import { TYPES } from "../types.ts";
+import PlayerWindow from "../windows/PlayerWindow.ts";
+
+@injectable()
+export default class PlayerController implements Controller {
+  constructor(
+    @inject(TYPES.PlayerWindow)
+    private readonly playerWindow: PlayerWindow,
+  ) {}
+
+  @handle("open-player-window")
+  async openPlayerWindow() {
+    this.playerWindow.showWindow();
+  }
+}

packages/main/src/controller/WebviewController.ts

@@ -11,6 +11,7 @@ import { TYPES } from "../types.ts";
 import WebviewService from "../services/WebviewService.ts";
 import ElectronStore from "../vendor/ElectronStore.ts";
 import { SniffingHelper } from "../services/SniffingHelperService.ts";
+import i18n from "../i18n/index.ts";
 
 @injectable()
 export default class WebviewController implements Controller {
@@ -29,7 +30,7 @@ export default class WebviewController implements Controller {
   }
 
   @handle("webview-load-url")
-  async browserViewLoadUrl(e: IpcMainEvent, url?: string): Promise<void> {
+  async browserViewLoadUrl(e: IpcMainEvent, url: string): Promise<void> {
     await this.webview.loadURL(url);
   }
 
@@ -37,11 +38,11 @@ export default class WebviewController implements Controller {
   async webviewUrlContextMenu() {
     const template: Array<MenuItemConstructorOptions | MenuItem> = [
       {
-        label: "复制",
+        label: i18n.t("copy"),
         role: "copy",
       },
       {
-        label: "粘贴",
+        label: i18n.t("paste"),
         role: "paste",
       },
     ];
@@ -85,4 +86,9 @@ export default class WebviewController implements Controller {
   async pluginReady() {
     this.sniffingHelper.pluginReady();
   }
+
+  @handle("clear-webview-cache")
+  async clearWebviewCache() {
+    return this.webview.clearCache();
+  }
 }

packages/main/src/core/ipc.ts

@@ -43,7 +43,7 @@ export default class IpcHandlerService {
         }
         return success(res);
       } catch (e: unknown) {
-        this.logger.error(`处理 ipc [${channel}] 事件时异常： `, e);
+        this.logger.error(`process ipc [${channel}] failed: `, e);
         if (e instanceof Error) {
           return error(e.message);
         } else {

packages/main/src/core/protocol.ts

@@ -1,8 +1,8 @@
-import { protocol } from "electron";
+import { app, protocol } from "electron";
 import isDev from "electron-is-dev";
 import { pathExists, readFile } from "fs-extra";
 import { injectable } from "inversify";
-import { join } from "path";
+import path, { join } from "path";
 import { URL } from "url";
 import { defaultScheme } from "../helper/index.ts";
 import mime from "mime-types";
@@ -26,5 +26,15 @@ export default class ProtocolService {
         headers: { "Content-Type": mimeType || "text/html" },
       });
     });
+
+    if (process.defaultApp) {
+      if (process.argv.length >= 2) {
+        app.setAsDefaultProtocolClient(defaultScheme, process.execPath, [
+          path.resolve(process.argv[1]),
+        ]);
+      }
+    } else {
+      app.setAsDefaultProtocolClient(defaultScheme);
+    }
   }
 }

packages/main/src/core/window.ts

@@ -34,9 +34,6 @@ export default class Window {
   windowClose = () => {
     if (!this.window) return;
 
-    // 防止 webview 同时被销毁
-    this.window.setBrowserView(null);
-
     // 销毁窗口
     this.window = null;
   };

packages/main/src/entity/Video.ts

@@ -16,7 +16,7 @@ export class Video {
 
   @Column({
     type: "text",
-    nullable: true,
+    nullable: false,
     unique: true,
   })
   name: string;
@@ -38,7 +38,13 @@ export class Video {
     type: "text",
     nullable: true,
   })
-  headers: string;
+  folder?: string;
+
+  @Column({
+    type: "text",
+    nullable: true,
+  })
+  headers?: string;
 
   @Column({
     type: "boolean",

packages/main/src/helper/cache.ts

@@ -0,0 +1,10 @@
+import { LRUCache } from "lru-cache";
+
+const options: LRUCache.OptionsMaxLimit<string, boolean, unknown> = {
+  max: 5000,
+
+  // how long to live in ms
+  ttl: 1000 * 60 * 5,
+};
+
+export const urlCache = new LRUCache(options);

packages/main/src/helper/file.ts

@@ -0,0 +1,8 @@
+import fs from "fs/promises";
+
+export function fileExists(path: string): Promise<boolean> {
+  return fs
+    .access(path, fs.constants.F_OK)
+    .then(() => true)
+    .catch(() => false);
+}

packages/main/src/helper/index.ts

@@ -34,8 +34,13 @@ function fetchWrapper(url: string) {
   return fetch(url, options);
 }
 
+export function noop() {}
+
 export { sleep, formatHeaders } from "./utils.ts";
 export * from "./variables.ts";
 export { on, handle } from "./decorator.ts";
 export { convertToAudio } from "./ffmpeg.ts";
 export { fetchWrapper as fetch };
+export { fileExists } from "./file.ts";
+export { videoPattern } from "./video.ts";
+export { urlCache } from "./cache.ts";

packages/main/src/helper/utils.ts

@@ -35,3 +35,13 @@ export function error(message = "fail"): IpcResponse {
     data: null,
   };
 }
+
+// 判断是否为 deeplink 的函数
+export function isDeeplink(url: string): boolean {
+  try {
+    const parsedUrl = new URL(url);
+    return parsedUrl.protocol !== "http:" && parsedUrl.protocol !== "https:";
+  } catch (error) {
+    return false;
+  }
+}