Dev2alpha

packages/shared/IpcChannel.ts

@@ -126,6 +126,7 @@ export enum IpcChannel {
   MediaServer_GetInfo = 'media-server:get-info',
   MediaServer_GetPort = 'media-server:get-port',
   MediaServer_CheckHealth = 'media-server:check-health',
+  MediaServer_CleanupCachesForFile = 'media-server:cleanup-caches-for-file',
   MediaServer_PortChanged = 'media-server:port-changed', // 端口变更事件
 
   // MediaInfo 相关 IPC 通道 / MediaInfo related IPC channels

src/main/ipc.ts

@@ -651,6 +651,9 @@ export function registerIpc(mainWindow: BrowserWindow, app: Electron.App) {
   ipcMain.handle(IpcChannel.MediaServer_GetPort, async () => {
     return mediaServerService.getPort()
   })
+  ipcMain.handle(IpcChannel.MediaServer_CleanupCachesForFile, async (_, filePath: string) => {
+    return await mediaServerService.cleanupCachesForFile(filePath)
+  })
 
   // MediaParser (Remotion)
   ipcMain.handle(IpcChannel.MediaInfo_CheckExists, async () => {

src/main/services/MediaServerService.ts

@@ -1,3 +1,6 @@
+import { createHash } from 'node:crypto'
+import { open, rm, stat } from 'node:fs/promises'
+
 import { IpcChannel } from '@shared/IpcChannel'
 import type { MediaServerInfo, MediaServerStatus } from '@shared/types'
 import { ChildProcess, spawn } from 'child_process'
@@ -54,6 +57,20 @@ export interface MediaServerConfig {
   audioTrackTtlHours?: number // 音频轨道 TTL（小时）
 }
 
+export interface TranscodeCacheCleanupResult {
+  assetHash: string
+  hls: {
+    path: string
+    removed: boolean
+    error?: string
+  }
+  audio: {
+    path: string
+    removed: boolean
+    error?: string
+  }
+}
+
 /**
  * Media Server 管理服务
  * 负责启动、停止和监控 Media Server 进程
@@ -513,6 +530,99 @@ export class MediaServerService {
     return this.port
   }
 
+  /**
+   * 清理指定文件对应的转码缓存
+   * @param filePath 原始视频文件路径
+   */
+  public async cleanupCachesForFile(filePath: string): Promise<TranscodeCacheCleanupResult> {
+    const resolvedPath = path.resolve(filePath)
+    try {
+      await stat(resolvedPath)
+    } catch (err) {
+      const code = (err as NodeJS.ErrnoException).code
+      if (code === 'ENOENT') {
+        throw new Error(`文件不存在: ${resolvedPath}`)
+      }
+      throw err
+    }
+
+    const assetHash = await this.calculateAssetHash(resolvedPath)
+    const dataPath = getDataPath()
+    const mediaServerCachePath = path.join(dataPath, 'MediaServerCache')
+    const hlsDir = path.join(mediaServerCachePath, 'hls-segments', assetHash)
+    const audioDir = path.join(mediaServerCachePath, 'audio-cache', assetHash)
+
+    logger.info('清理转码缓存', {
+      filePath: resolvedPath,
+      assetHash,
+      hlsDir,
+      audioDir
+    })
+
+    const hlsResult = await this.removeDirectoryIfExists(hlsDir)
+    const audioResult = await this.removeDirectoryIfExists(audioDir)
+
+    return {
+      assetHash,
+      hls: {
+        path: hlsDir,
+        ...hlsResult
+      },
+      audio: {
+        path: audioDir,
+        ...audioResult
+      }
+    }
+  }
+
+  private async calculateAssetHash(filePath: string): Promise<string> {
+    const resolvedPath = path.resolve(filePath)
+    const fileStat = await stat(resolvedPath)
+    const hash = createHash('sha256')
+
+    hash.update(resolvedPath)
+    hash.update(fileStat.size.toString())
+    hash.update(Math.floor(fileStat.mtimeMs / 1000).toString())
+
+    const sampleSize = 8 * 1024 * 1024
+    const fileSize = Number(fileStat.size)
+    const fileHandle = await open(resolvedPath, 'r')
+
+    try {
+      if (fileSize <= sampleSize * 2) {
+        const buffer = Buffer.alloc(fileSize)
+        const { bytesRead } = await fileHandle.read(buffer, 0, buffer.length, 0)
+        hash.update(buffer.subarray(0, bytesRead))
+      } else {
+        const headBuffer = Buffer.alloc(sampleSize)
+        await fileHandle.read(headBuffer, 0, sampleSize, 0)
+        hash.update(headBuffer)
+
+        const tailBuffer = Buffer.alloc(sampleSize)
+        await fileHandle.read(tailBuffer, 0, sampleSize, fileSize - sampleSize)
+        hash.update(tailBuffer)
+      }
+    } finally {
+      await fileHandle.close()
+    }
+
+    return hash.digest('hex').slice(0, 16)
+  }
+
+  private async removeDirectoryIfExists(
+    dirPath: string
+  ): Promise<{ removed: boolean; error?: string }> {
+    try {
+      await rm(dirPath, { recursive: true, force: true })
+      logger.info('已删除转码缓存目录', { dirPath })
+      return { removed: true }
+    } catch (error) {
+      const message = error instanceof Error ? error.message : String(error)
+      logger.warn('删除转码缓存目录失败', { dirPath, error: message })
+      return { removed: false, error: message }
+    }
+  }
+
   /**
    * 等待服务器启动
    */

src/main/services/UvBootstrapperService.ts

@@ -413,15 +413,24 @@ export class UvBootstrapperService {
   ): Promise<boolean> {
     const key = `${platform}-${arch}`
 
-    // 检查是否已存在
-    const installation = await this.checkUvInstallation()
-    if (installation.exists && installation.isDownloaded) {
-      logger.info('uv 已存在，跳过下载', { platform, arch, path: installation.path })
+    // 检查目标平台的缓存二进制
+    const downloadedPath = this.getDownloadedUvPath(platform, arch)
+    if (downloadedPath) {
+      logger.info('uv 已存在，跳过下载', { platform, arch, path: downloadedPath })
       return true
     }
 
+    // 仅当请求的平台与当前进程一致时，才额外使用缓存的系统检测结果
+    if (platform === process.platform && arch === process.arch) {
+      const installation = await this.checkUvInstallation()
+      if (installation.exists && installation.isDownloaded) {
+        logger.info('uv 已存在，跳过下载', { platform, arch, path: installation.path })
+        return true
+      }
+    }
+
     // 检查是否正在下载
-    if (this.downloadProgress.has(key)) {
+    if (this.downloadProgress.has(key) || this.downloadController.has(key)) {
       logger.warn('uv 正在下载中', { platform, arch })
       return false
     }
@@ -466,12 +475,12 @@ export class UvBootstrapperService {
 
     this.downloadProgress.set(key, progress)
 
+    const platformDir = `${version.version}-${platform}-${arch}`
+    const targetDir = path.join(this.binariesDir, platformDir)
+    const tempDir = path.join(this.binariesDir, '.temp', key)
+
     try {
       // 创建目标目录
-      const platformDir = `${version.version}-${platform}-${arch}`
-      const targetDir = path.join(this.binariesDir, platformDir)
-      const tempDir = path.join(this.binariesDir, '.temp', key)
-
       this.ensureDir(targetDir)
       this.ensureDir(tempDir)
 
@@ -550,9 +559,6 @@ export class UvBootstrapperService {
 
       logger.info('uv 下载完成', { platform, arch, finalPath })
 
-      // 清理临时文件
-      this.cleanupTempDir(tempDir)
-
       // 清除缓存以便重新检测
       UvBootstrapperService.clearUvCache(platform, arch)
 
@@ -571,6 +577,7 @@ export class UvBootstrapperService {
     } finally {
       this.downloadProgress.delete(key)
       this.downloadController.delete(key)
+      this.cleanupTempDir(tempDir)
     }
   }
 

src/preload/index.ts

@@ -332,7 +332,9 @@ const api = {
       uptime?: number
       error?: string
     }> => ipcRenderer.invoke(IpcChannel.MediaServer_GetInfo),
-    getPort: (): Promise<number | null> => ipcRenderer.invoke(IpcChannel.MediaServer_GetPort)
+    getPort: (): Promise<number | null> => ipcRenderer.invoke(IpcChannel.MediaServer_GetPort),
+    cleanupCachesForFile: (filePath: string) =>
+      ipcRenderer.invoke(IpcChannel.MediaServer_CleanupCachesForFile, filePath)
   },
   fs: {
     checkFileExists: (filePath: string): Promise<boolean> =>

src/renderer/src/pages/home/HomePage.tsx

@@ -1,5 +1,6 @@
 import { loggerService } from '@logger'
 import FFmpegDownloadPrompt from '@renderer/components/FFmpegDownloadPrompt'
+import FileManager from '@renderer/services/FileManager'
 import HomePageVideoService, { type HomePageVideoItem } from '@renderer/services/HomePageVideos'
 import { VideoLibraryService } from '@renderer/services/VideoLibrary'
 import { useSettingsStore } from '@renderer/state/stores/settings.store'
@@ -164,6 +165,21 @@ export function HomePage(): React.JSX.Element {
         onOk: async () => {
           try {
             const videoLibraryService = new VideoLibraryService()
+            let filePath: string | null = null
+
+            try {
+              const record = await videoLibraryService.getRecordById(video.id)
+              if (record?.fileId) {
+                const fileInfo = await FileManager.getFile(record.fileId)
+                filePath = fileInfo?.path ?? null
+              }
+            } catch (lookupError) {
+              logger.warn('获取视频文件信息失败，跳过转码缓存清理', {
+                error: lookupError,
+                videoId: video.id
+              })
+            }
+
             await videoLibraryService.deleteRecord(video.id)
 
             // 从本地状态中移除该视频
@@ -173,6 +189,22 @@ export function HomePage(): React.JSX.Element {
             setCachedVideos(cachedVideos.filter((v) => v.id !== video.id))
 
             message.success(t('home.delete.success_message'))
+
+            if (filePath) {
+              void window.api.mediaServer
+                .cleanupCachesForFile(filePath)
+                .then((result) => {
+                  logger.info('已清理转码缓存', { result, videoId: video.id })
+                })
+                .catch((cleanupError) => {
+                  logger.warn('清理转码缓存失败', {
+                    error:
+                      cleanupError instanceof Error ? cleanupError.message : String(cleanupError),
+                    filePath,
+                    videoId: video.id
+                  })
+                })
+            }
           } catch (error) {
             logger.error('删除视频记录失败', { error })
             message.error(t('home.delete.error_message'))