refactor: extract createBackupZip to reduce duplication in backup.ts

package.json

@@ -31,7 +31,7 @@
   },
   "dependencies": {
     "@electron-toolkit/utils": "^4.0.0",
-    "@mihomo-party/sysproxy": "^2.0.8",
+    "sysproxy-rs": "file:src/native/sysproxy",
     "adm-zip": "^0.5.16",
     "axios": "^1.13.2",
     "chokidar": "^5.0.0",

pnpm-lock.yaml

@@ -11,9 +11,6 @@ importers:
       '@electron-toolkit/utils':
         specifier: ^4.0.0
         version: 4.0.0(electron@37.10.0)
-      '@mihomo-party/sysproxy':
-        specifier: ^2.0.8
-        version: 2.0.8
       adm-zip:
         specifier: ^0.5.16
         version: 0.5.16
@@ -38,6 +35,9 @@ importers:
       iconv-lite:
         specifier: ^0.7.1
         version: 0.7.1
+      sysproxy-rs:
+        specifier: file:src/native/sysproxy
+        version: file:src/native/sysproxy
       webdav:
         specifier: ^5.8.0
         version: 5.8.0
@@ -1405,54 +1405,6 @@ packages:
     resolution: {integrity: sha512-9QOtNffcOF/c1seMCDnjckb3R9WHcG34tky+FHpNKKCW0wc/scYLwMtO+ptyGUfMW0/b/n4qRiALlaFHc9Oj7Q==}
     engines: {node: '>= 10.0.0'}
 
-  '@mihomo-party/sysproxy-darwin-arm64@2.0.8':
-    resolution: {integrity: sha512-4bSqsjEkmtXzgr8zrSUiNmOdlfRDnkFoXICfJqH7ZlM+4L6n74zrm6perFP0NHPpn/oZO97QXGxIJUQSNhFDrw==}
-    engines: {node: '>= 10'}
-    cpu: [arm64]
-    os: [darwin]
-
-  '@mihomo-party/sysproxy-darwin-x64@2.0.8':
-    resolution: {integrity: sha512-sIDzG7yyQZu+DKQ8X1MeYubdEqXSDjzYjVi+5rVZG/jfLlucS9QZNNiXyoTTDUD5cGRcqv1gYNRynd2Csewesg==}
-    engines: {node: '>= 10'}
-    cpu: [x64]
-    os: [darwin]
-
-  '@mihomo-party/sysproxy-linux-arm64-gnu@2.0.8':
-    resolution: {integrity: sha512-weKk+KcB4lghEj3z15x9FSyla3PT3uLIEU4l4LE4RqhzxgkbJmOt7Wu+ofx4/1k8g8OwwGXIucNgYsV0qpnZQg==}
-    engines: {node: '>= 10'}
-    cpu: [arm64]
-    os: [linux]
-    libc: [glibc]
-
-  '@mihomo-party/sysproxy-linux-x64-gnu@2.0.8':
-    resolution: {integrity: sha512-wLt63mztsnZoGFUKxzizRRRd5qAtINg+tB2zdhOnr+0E9TaKLGxZnhYm+Nk8tAB1EBvqjmTWsJG9MDHikh2agg==}
-    engines: {node: '>= 10'}
-    cpu: [x64]
-    os: [linux]
-    libc: [glibc]
-
-  '@mihomo-party/sysproxy-win32-arm64-msvc@2.0.8':
-    resolution: {integrity: sha512-+Mxkw8d3rD6sbFZjjZ18kfx1/WrWXOVlpKd8k3Gdf4LUg7nW8vr64Eaxvjxwcw9AQ1Bu61SHEtvNZfu7woCc1w==}
-    engines: {node: '>= 10'}
-    cpu: [arm64]
-    os: [win32]
-
-  '@mihomo-party/sysproxy-win32-ia32-msvc@2.0.8':
-    resolution: {integrity: sha512-xOVagbGu21MGzEMidpgMoQGRHY0V1EFdDKb+ZhPPnoIbFhECBRR9fQK7lENV6e7S41ppNbg1Rja4J94VpXdvZA==}
-    engines: {node: '>= 10'}
-    cpu: [ia32]
-    os: [win32]
-
-  '@mihomo-party/sysproxy-win32-x64-msvc@2.0.8':
-    resolution: {integrity: sha512-AIgCFoExX36BgXN8sQyf0G99wrObFO0LGBzEFs9OsS2cg8bPkpt63XkAkNcGVxlqJD4WLzsS1GhbsL3qzo64DQ==}
-    engines: {node: '>= 10'}
-    cpu: [x64]
-    os: [win32]
-
-  '@mihomo-party/sysproxy@2.0.8':
-    resolution: {integrity: sha512-tCnkDL4UjbUPvFvFubswmWxz56f+gTsYDpv1ULke1YDEZN7aTSREgC3K+Ge7JjZj2jUZYU1lEYuhFgeFz6+W6w==}
-    engines: {node: '>= 10'}
-
   '@npmcli/fs@2.1.2':
     resolution: {integrity: sha512-yOJKRvohFOaLqipNtwYB9WugyZKhC/DZC4VYPmpaCzDBrA8YpK3qHZ8/HGscMnE4GqbkLNuVcCnxkeQEdGt6LQ==}
     engines: {node: ^12.13.0 || ^14.15.0 || >=16.0.0}
@@ -4746,6 +4698,9 @@ packages:
     resolution: {integrity: sha512-MeQTA1r0litLUf0Rp/iisCaL8761lKAZHaimlbGK4j0HysC4PLfqygQj9srcs0m2RdtDYnF8UuYyKpbjHYp7Jw==}
     engines: {node: ^14.18.0 || >=16.0.0}
 
+  sysproxy-rs@file:src/native/sysproxy:
+    resolution: {directory: src/native/sysproxy, type: directory}
+
   tailwind-merge@3.4.0:
     resolution: {integrity: sha512-uSaO4gnW+b3Y2aWoWfFpX62vn2sR3skfhbjsEnaBI81WD1wBLlHZe5sWf0AqjksNdYTbGBEd0UasQMT3SNV15g==}
 
@@ -6769,37 +6724,6 @@ snapshots:
     transitivePeerDependencies:
       - supports-color
 
-  '@mihomo-party/sysproxy-darwin-arm64@2.0.8':
-    optional: true
-
-  '@mihomo-party/sysproxy-darwin-x64@2.0.8':
-    optional: true
-
-  '@mihomo-party/sysproxy-linux-arm64-gnu@2.0.8':
-    optional: true
-
-  '@mihomo-party/sysproxy-linux-x64-gnu@2.0.8':
-    optional: true
-
-  '@mihomo-party/sysproxy-win32-arm64-msvc@2.0.8':
-    optional: true
-
-  '@mihomo-party/sysproxy-win32-ia32-msvc@2.0.8':
-    optional: true
-
-  '@mihomo-party/sysproxy-win32-x64-msvc@2.0.8':
-    optional: true
-
-  '@mihomo-party/sysproxy@2.0.8':
-    optionalDependencies:
-      '@mihomo-party/sysproxy-darwin-arm64': 2.0.8
-      '@mihomo-party/sysproxy-darwin-x64': 2.0.8
-      '@mihomo-party/sysproxy-linux-arm64-gnu': 2.0.8
-      '@mihomo-party/sysproxy-linux-x64-gnu': 2.0.8
-      '@mihomo-party/sysproxy-win32-arm64-msvc': 2.0.8
-      '@mihomo-party/sysproxy-win32-ia32-msvc': 2.0.8
-      '@mihomo-party/sysproxy-win32-x64-msvc': 2.0.8
-
   '@npmcli/fs@2.1.2':
     dependencies:
       '@gar/promisify': 1.1.3
@@ -10935,6 +10859,8 @@ snapshots:
     dependencies:
       '@pkgr/core': 0.2.9
 
+  sysproxy-rs@file:src/native/sysproxy: {}
+
   tailwind-merge@3.4.0: {}
 
   tailwind-variants@3.2.2(tailwind-merge@3.4.0)(tailwindcss@4.1.18):

src/main/resolve/backup.ts

@@ -55,37 +55,42 @@ async function getWebDAVClient(): Promise<WebDAVContext> {
   return { client, webdavDir, webdavMaxBackups }
 }
 
-export async function webdavBackup(): Promise<boolean> {
-  const { client, webdavDir, webdavMaxBackups } = await getWebDAVClient()
+function createBackupZip(): AdmZip {
   const zip = new AdmZip()
 
-  if (existsSync(appConfigPath())) {
-    zip.addLocalFile(appConfigPath())
+  const files = [
+    appConfigPath(),
+    controledMihomoConfigPath(),
+    profileConfigPath(),
+    overrideConfigPath()
+  ]
+
+  const folders = [
+    { path: themesDir(), name: 'themes' },
+    { path: profilesDir(), name: 'profiles' },
+    { path: overrideDir(), name: 'override' },
+    { path: rulesDir(), name: 'rules' },
+    { path: subStoreDir(), name: 'substore' }
+  ]
+
+  for (const file of files) {
+    if (existsSync(file)) {
+      zip.addLocalFile(file)
     }
-  if (existsSync(controledMihomoConfigPath())) {
-    zip.addLocalFile(controledMihomoConfigPath())
   }
-  if (existsSync(profileConfigPath())) {
-    zip.addLocalFile(profileConfigPath())
+
+  for (const { path, name } of folders) {
+    if (existsSync(path)) {
+      zip.addLocalFolder(path, name)
     }
-  if (existsSync(overrideConfigPath())) {
-    zip.addLocalFile(overrideConfigPath())
-  }
-  if (existsSync(themesDir())) {
-    zip.addLocalFolder(themesDir(), 'themes')
-  }
-  if (existsSync(profilesDir())) {
-    zip.addLocalFolder(profilesDir(), 'profiles')
-  }
-  if (existsSync(overrideDir())) {
-    zip.addLocalFolder(overrideDir(), 'override')
-  }
-  if (existsSync(rulesDir())) {
-    zip.addLocalFolder(rulesDir(), 'rules')
-  }
-  if (existsSync(subStoreDir())) {
-    zip.addLocalFolder(subStoreDir(), 'substore')
   }
+
+  return zip
+}
+
+export async function webdavBackup(): Promise<boolean> {
+  const { client, webdavDir, webdavMaxBackups } = await getWebDAVClient()
+  const zip = createBackupZip()
   const date = new Date()
   const zipFileName = `${process.platform}_${dayjs(date).format('YYYY-MM-DD_HH-mm-ss')}.zip`
 
@@ -214,34 +219,7 @@ export async function reinitScheduler(): Promise<void> {
  * 导出本地备份
  */
 export async function exportLocalBackup(): Promise<boolean> {
-  const zip = new AdmZip()
-  if (existsSync(appConfigPath())) {
-    zip.addLocalFile(appConfigPath())
-  }
-  if (existsSync(controledMihomoConfigPath())) {
-    zip.addLocalFile(controledMihomoConfigPath())
-  }
-  if (existsSync(profileConfigPath())) {
-    zip.addLocalFile(profileConfigPath())
-  }
-  if (existsSync(overrideConfigPath())) {
-    zip.addLocalFile(overrideConfigPath())
-  }
-  if (existsSync(themesDir())) {
-    zip.addLocalFolder(themesDir(), 'themes')
-  }
-  if (existsSync(profilesDir())) {
-    zip.addLocalFolder(profilesDir(), 'profiles')
-  }
-  if (existsSync(overrideDir())) {
-    zip.addLocalFolder(overrideDir(), 'override')
-  }
-  if (existsSync(subStoreDir())) {
-    zip.addLocalFolder(subStoreDir(), 'substore')
-  }
-  if (existsSync(rulesDir())) {
-    zip.addLocalFolder(rulesDir(), 'rules')
-  }
+  const zip = createBackupZip()
 
   const date = new Date()
   const zipFileName = `clash-party-backup-${dayjs(date).format('YYYY-MM-DD_HH-mm-ss')}.zip`

src/main/sys/sysproxy.ts

@@ -1,10 +1,8 @@
-import { triggerAutoProxy, triggerManualProxy } from '@mihomo-party/sysproxy'
+import { triggerAutoProxy, triggerManualProxy } from 'sysproxy-rs'
 import { getAppConfig, getControledMihomoConfig } from '../config'
 import { pacPort, startPacServer, stopPacServer } from '../resolve/server'
 import { promisify } from 'util'
-import { exec, execFile } from 'child_process'
-import path from 'path'
-import { resourcesFilesDir } from '../utils/dirs'
+import { exec } from 'child_process'
 import { net } from 'electron'
 import axios from 'axios'
 import fs from 'fs'
@@ -76,87 +74,51 @@ async function enableSysProxy(): Promise<void> {
   const { sysProxy } = await getAppConfig()
   const { mode, host, bypass = defaultBypass } = sysProxy
   const { 'mixed-port': port = 7890 } = await getControledMihomoConfig()
-  const execFilePromise = promisify(execFile)
-  switch (mode || 'manual') {
-    case 'auto': {
-      if (process.platform === 'win32') {
-        try {
-          await execFilePromise(path.join(resourcesFilesDir(), 'sysproxy.exe'), [
-            'pac',
-            `http://${host || '127.0.0.1'}:${pacPort}/pac`
-          ])
-        } catch {
-          triggerAutoProxy(true, `http://${host || '127.0.0.1'}:${pacPort}/pac`)
-        }
-      } else if (process.platform === 'darwin') {
+  const proxyHost = host || '127.0.0.1'
+
+  if (process.platform === 'darwin') {
+    // macOS 需要 helper 提权
+    if (mode === 'auto') {
       await helperRequest(() =>
         axios.post(
           'http://localhost/pac',
-            { url: `http://${host || '127.0.0.1'}:${pacPort}/pac` },
-            {
-              socketPath: helperSocketPath
-            }
+          { url: `http://${proxyHost}:${pacPort}/pac` },
+          { socketPath: helperSocketPath }
         )
       )
     } else {
-        triggerAutoProxy(true, `http://${host || '127.0.0.1'}:${pacPort}/pac`)
-      }
-
-      break
-    }
-
-    case 'manual': {
-      if (process.platform === 'win32') {
-        try {
-          await execFilePromise(path.join(resourcesFilesDir(), 'sysproxy.exe'), [
-            'global',
-            `${host || '127.0.0.1'}:${port}`,
-            bypass.join(';')
-          ])
-        } catch {
-          triggerManualProxy(true, host || '127.0.0.1', port, bypass.join(','))
-        }
-      } else if (process.platform === 'darwin') {
       await helperRequest(() =>
         axios.post(
           'http://localhost/global',
-            { host: host || '127.0.0.1', port: port.toString(), bypass: bypass.join(',') },
-            {
-              socketPath: helperSocketPath
+          { host: proxyHost, port: port.toString(), bypass: bypass.join(',') },
+          { socketPath: helperSocketPath }
+        )
+      )
     }
-          )
-        )
   } else {
-        triggerManualProxy(true, host || '127.0.0.1', port, bypass.join(','))
-      }
-      break
+    // Windows / Linux 直接使用 sysproxy-rs
+    if (mode === 'auto') {
+      triggerAutoProxy(true, `http://${proxyHost}:${pacPort}/pac`)
+    } else {
+      triggerManualProxy(true, proxyHost, port, bypass.join(','))
     }
   }
 }
 
 async function disableSysProxy(): Promise<void> {
   await stopPacServer()
-  const execFilePromise = promisify(execFile)
-  if (process.platform === 'win32') {
-    try {
-      await execFilePromise(path.join(resourcesFilesDir(), 'sysproxy.exe'), ['set', '1'])
-    } catch {
-      triggerAutoProxy(false, '')
-      triggerManualProxy(false, '', 0, '')
-    }
-  } else if (process.platform === 'darwin') {
+
+  if (process.platform === 'darwin') {
     await helperRequest(() =>
-      axios.get('http://localhost/off', {
-        socketPath: helperSocketPath
-      })
+      axios.get('http://localhost/off', { socketPath: helperSocketPath })
     )
   } else {
+    // Windows / Linux 直接使用 sysproxy-rs
     triggerAutoProxy(false, '')
     triggerManualProxy(false, '', 0, '')
   }
 }
 
-// Helper function to check if socket file exists
 function isSocketFileExists(): boolean {
   try {
     return fs.existsSync(helperSocketPath)
@@ -165,7 +127,6 @@ function isSocketFileExists(): boolean {
   }
 }
 
-// Check if helper process is running (no admin privileges needed)
 async function isHelperRunning(): Promise<boolean> {
   try {
     const execPromise = promisify(exec)
@@ -176,7 +137,6 @@ async function isHelperRunning(): Promise<boolean> {
   }
 }
 
-// Start or restart helper service via launchctl
 async function startHelperService(): Promise<void> {
   const execPromise = promisify(exec)
   const shell = `launchctl kickstart -k system/party.mihomo.helper`
@@ -185,7 +145,6 @@ async function startHelperService(): Promise<void> {
   await new Promise((resolve) => setTimeout(resolve, 1500))
 }
 
-// Send signal to recreate socket (only if process is running)
 async function requestSocketRecreation(): Promise<void> {
   try {
     const execPromise = promisify(exec)
@@ -199,7 +158,6 @@ async function requestSocketRecreation(): Promise<void> {
   }
 }
 
-// Wrapper function for helper requests with auto-retry on socket issues
 async function helperRequest(requestFn: () => Promise<unknown>, maxRetries = 2): Promise<unknown> {
   let lastError: Error | null = null
 

src/main/utils/init.ts

@@ -47,7 +47,6 @@ import { initLogger } from './logger'
 
 let isInitBasicCompleted = false
 
-// 安全错误处理
 export function safeShowErrorBox(titleKey: string, message: string): void {
   let title: string
   try {
@@ -84,12 +83,9 @@ async function fixDataDirPermissions(): Promise<void> {
   }
 }
 
-// 比较修改 geodata 文件修改时间
 async function isSourceNewer(sourcePath: string, targetPath: string): Promise<boolean> {
   try {
-    const sourceStats = await stat(sourcePath)
-    const targetStats = await stat(targetPath)
-
+    const [sourceStats, targetStats] = await Promise.all([stat(sourcePath), stat(targetPath)])
     return sourceStats.mtime > targetStats.mtime
   } catch {
     return true
@@ -99,7 +95,6 @@ async function isSourceNewer(sourcePath: string, targetPath: string): Promise<bo
 async function initDirs(): Promise<void> {
   await fixDataDirPermissions()
 
-  // 按依赖顺序创建目录
   const dirsToCreate = [
     dataDir(),
     themesDir(),
@@ -112,16 +107,13 @@ async function initDirs(): Promise<void> {
     subStoreDir()
   ]
 
-  for (const dir of dirsToCreate) {
-    try {
+  await Promise.all(
+    dirsToCreate.map(async (dir) => {
       if (!existsSync(dir)) {
         await mkdir(dir, { recursive: true })
       }
-    } catch (error) {
-      await initLogger.error(`Failed to create directory ${dir}`, error)
-      throw new Error(`Failed to create directory ${dir}: ${error}`)
-    }
-  }
+    })
+  )
 }
 
 async function initConfig(): Promise<void> {
@@ -137,97 +129,120 @@ async function initConfig(): Promise<void> {
     }
   ]
 
-  for (const config of configs) {
-    try {
+  await Promise.all(
+    configs.map(async (config) => {
       if (!existsSync(config.path)) {
         await writeFile(config.path, stringify(config.content))
       }
-    } catch (error) {
-      await initLogger.error(`Failed to create ${config.name} at ${config.path}`, error)
-      throw new Error(`Failed to create ${config.name}: ${error}`)
+    })
+  )
+}
+
+async function killOldMihomoProcesses(): Promise<void> {
+  if (process.platform !== 'win32') return
+
+  const execPromise = promisify(exec)
+  try {
+    const { stdout } = await execPromise(
+      'powershell -NoProfile -Command "Get-Process | Where-Object {$_.ProcessName -like \'*mihomo*\'} | Select-Object Id | ConvertTo-Json"',
+      { encoding: 'utf8' }
+    )
+
+    if (!stdout.trim()) return
+
+    const processes = JSON.parse(stdout)
+    const processArray = Array.isArray(processes) ? processes : [processes]
+
+    for (const proc of processArray) {
+      const pid = proc.Id
+      if (pid && pid !== process.pid) {
+        try {
+          process.kill(pid, 'SIGTERM')
+          await initLogger.info(`Terminated old mihomo process ${pid}`)
+        } catch {
+          // 进程可能退出
         }
       }
+    }
+
+    await new Promise((resolve) => setTimeout(resolve, 500))
+  } catch {
+    // 忽略错误
+  }
 }
 
 async function initFiles(): Promise<void> {
-  const copy = async (file: string): Promise<void> => {
-    const targetPath = path.join(mihomoWorkDir(), file)
-    const testTargetPath = path.join(mihomoTestDir(), file)
-    const sourcePath = path.join(resourcesFilesDir(), file)
+  await killOldMihomoProcesses()
 
-    try {
-      // 检查是否需要复制
-      if (existsSync(sourcePath)) {
-        const shouldCopyToWork =
-          !existsSync(targetPath) || (await isSourceNewer(sourcePath, targetPath))
-        if (shouldCopyToWork) {
+  const copyFile = async (file: string): Promise<void> => {
+    const sourcePath = path.join(resourcesFilesDir(), file)
+    if (!existsSync(sourcePath)) return
+
+    const targets = [
+      path.join(mihomoWorkDir(), file),
+      path.join(mihomoTestDir(), file)
+    ]
+
+    await Promise.all(
+      targets.map(async (targetPath) => {
+        const shouldCopy = !existsSync(targetPath) || (await isSourceNewer(sourcePath, targetPath))
+        if (shouldCopy) {
           await cp(sourcePath, targetPath, { recursive: true, force: true })
         }
-      }
-      if (existsSync(sourcePath)) {
-        const shouldCopyToTest =
-          !existsSync(testTargetPath) || (await isSourceNewer(sourcePath, testTargetPath))
-        if (shouldCopyToTest) {
-          await cp(sourcePath, testTargetPath, { recursive: true, force: true })
-        }
-      }
-    } catch (error) {
-      await initLogger.error(`Failed to copy ${file}`, error)
-      if (['country.mmdb', 'geoip.dat', 'geosite.dat'].includes(file)) {
-        throw new Error(`Failed to copy critical file ${file}: ${error}`)
-      }
-    }
+      })
+    )
   }
 
-  // 确保工作目录存在
-  if (!existsSync(mihomoWorkDir())) {
-    await mkdir(mihomoWorkDir(), { recursive: true })
-  }
-  if (!existsSync(mihomoTestDir())) {
-    await mkdir(mihomoTestDir(), { recursive: true })
-  }
+  const files = [
+    'country.mmdb',
+    'geoip.metadb',
+    'geoip.dat',
+    'geosite.dat',
+    'ASN.mmdb',
+    'sub-store.bundle.cjs',
+    'sub-store-frontend'
+  ]
 
-  await Promise.all([
-    copy('country.mmdb'),
-    copy('geoip.metadb'),
-    copy('geoip.dat'),
-    copy('geosite.dat'),
-    copy('ASN.mmdb'),
-    copy('sub-store.bundle.cjs'),
-    copy('sub-store-frontend')
-  ])
+  const criticalFiles = ['country.mmdb', 'geoip.dat', 'geosite.dat']
+
+  const results = await Promise.allSettled(files.map(copyFile))
+
+  for (let i = 0; i < results.length; i++) {
+    const result = results[i]
+    if (result.status === 'rejected') {
+      const file = files[i]
+      await initLogger.error(`Failed to copy ${file}`, result.reason)
+      if (criticalFiles.includes(file)) {
+        throw new Error(`Failed to copy critical file ${file}: ${result.reason}`)
+      }
+    }
+  }
 }
 
 async function cleanup(): Promise<void> {
-  // update cache
-  const files = await readdir(dataDir())
-  for (const file of files) {
-    if (file.endsWith('.exe') || file.endsWith('.pkg') || file.endsWith('.7z')) {
-      try {
-        await rm(path.join(dataDir(), file))
-      } catch {
-        // ignore
-      }
-    }
-  }
-  // logs
+  const [dataFiles, logFiles] = await Promise.all([readdir(dataDir()), readdir(logDir())])
+
+  // 清理更新缓存
+  const cacheExtensions = ['.exe', '.pkg', '.7z']
+  const cacheCleanup = dataFiles
+    .filter((file) => cacheExtensions.some((ext) => file.endsWith(ext)))
+    .map((file) => rm(path.join(dataDir(), file)).catch(() => {}))
+
+  // 清理过期日志
   const { maxLogDays = 7 } = await getAppConfig()
-  const logs = await readdir(logDir())
+  const maxAge = maxLogDays * 24 * 60 * 60 * 1000
   const datePattern = /^\d{4}-\d{2}-\d{2}/
-  for (const log of logs) {
+
+  const logCleanup = logFiles
+    .filter((log) => {
       const match = log.match(datePattern)
-    if (!match) continue
+      if (!match) return false
       const date = new Date(match[0])
-    if (isNaN(date.getTime())) continue
-    const diff = Date.now() - date.getTime()
-    if (diff > maxLogDays * 24 * 60 * 60 * 1000) {
-      try {
-        await rm(path.join(logDir(), log))
-      } catch {
-        // ignore
-      }
-    }
-  }
+      return !isNaN(date.getTime()) && Date.now() - date.getTime() > maxAge
+    })
+    .map((log) => rm(path.join(logDir(), log)).catch(() => {}))
+
+  await Promise.all([...cacheCleanup, ...logCleanup])
 }
 
 async function migrateSubStoreFiles(): Promise<void> {
@@ -243,111 +258,97 @@ async function migrateSubStoreFiles(): Promise<void> {
   }
 }
 
-async function migration(): Promise<void> {
-  const {
-    siderOrder = [
-      'sysproxy',
-      'tun',
-      'profile',
-      'proxy',
-      'rule',
-      'resource',
-      'override',
-      'connection',
-      'mihomo',
-      'dns',
-      'sniff',
-      'log',
-      'substore'
-    ],
-    appTheme = 'system',
-    envType = [process.platform === 'win32' ? 'powershell' : 'bash'],
-    useSubStore = true,
-    showFloatingWindow = false,
-    disableTray = false,
-    encryptedPassword
-  } = await getAppConfig()
-  const {
-    'external-controller-pipe': externalControllerPipe,
-    'external-controller-unix': externalControllerUnix,
-    'external-controller': externalController,
-    'skip-auth-prefixes': skipAuthPrefixes,
-    authentication,
-    'bind-address': bindAddress,
-    'lan-allowed-ips': lanAllowedIps,
-    'lan-disallowed-ips': lanDisallowedIps,
-    tun
-  } = await getControledMihomoConfig()
-  // add substore sider card
+// 迁移：添加 substore 到侧边栏
+async function migrateSiderOrder(): Promise<void> {
+  const { siderOrder = [], useSubStore = true } = await getAppConfig()
   if (useSubStore && !siderOrder.includes('substore')) {
     await patchAppConfig({ siderOrder: [...siderOrder, 'substore'] })
   }
-  // add default skip auth prefix
-  if (!skipAuthPrefixes) {
-    await patchControledMihomoConfig({ 'skip-auth-prefixes': ['127.0.0.1/32', '::1/128'] })
-  } else if (skipAuthPrefixes.length >= 1 && skipAuthPrefixes[0] === '127.0.0.1/32') {
-    const filteredPrefixes = skipAuthPrefixes.filter((ip) => ip !== '::1/128')
-    const newPrefixes = [filteredPrefixes[0], '::1/128', ...filteredPrefixes.slice(1)]
-    if (JSON.stringify(newPrefixes) !== JSON.stringify(skipAuthPrefixes)) {
-      await patchControledMihomoConfig({ 'skip-auth-prefixes': newPrefixes })
-    }
-  }
-  // add default authentication
-  if (!authentication) {
-    await patchControledMihomoConfig({ authentication: [] })
-  }
-  // add default bind address
-  if (!bindAddress) {
-    await patchControledMihomoConfig({ 'bind-address': '*' })
-  }
-  // add default lan allowed ips
-  if (!lanAllowedIps) {
-    await patchControledMihomoConfig({ 'lan-allowed-ips': ['0.0.0.0/0', '::/0'] })
-  }
-  // add default lan disallowed ips
-  if (!lanDisallowedIps) {
-    await patchControledMihomoConfig({ 'lan-disallowed-ips': [] })
-  }
-  // default tun device
-  if (!tun?.device || (process.platform === 'darwin' && tun.device === 'Mihomo')) {
-    const defaultDevice = process.platform === 'darwin' ? 'utun1500' : 'Mihomo'
-    await patchControledMihomoConfig({
-      tun: {
-        ...tun,
-        device: defaultDevice
-      }
-    })
-  }
-  // remove custom app theme
+}
+
+// 迁移：修复 appTheme
+async function migrateAppTheme(): Promise<void> {
+  const { appTheme = 'system' } = await getAppConfig()
   if (!['system', 'light', 'dark'].includes(appTheme)) {
     await patchAppConfig({ appTheme: 'system' })
   }
-  // change env type
+}
+
+// 迁移：envType 字符串转数组
+async function migrateEnvType(): Promise<void> {
+  const { envType } = await getAppConfig()
   if (typeof envType === 'string') {
     await patchAppConfig({ envType: [envType] })
   }
-  // use unix socket
-  if (externalControllerUnix) {
-    await patchControledMihomoConfig({ 'external-controller-unix': undefined })
-  }
-  // use named pipe
-  if (externalControllerPipe) {
-    await patchControledMihomoConfig({
-      'external-controller-pipe': undefined
-    })
-  }
-  if (externalController === undefined) {
-    await patchControledMihomoConfig({ 'external-controller': '' })
-  }
+}
+
+// 迁移：禁用托盘时必须显示悬浮窗
+async function migrateTraySettings(): Promise<void> {
+  const { showFloatingWindow = false, disableTray = false } = await getAppConfig()
   if (!showFloatingWindow && disableTray) {
     await patchAppConfig({ disableTray: false })
   }
-  // remove password
+}
+
+// 迁移：移除加密密码
+async function migrateRemovePassword(): Promise<void> {
+  const { encryptedPassword } = await getAppConfig()
   if (encryptedPassword) {
     await patchAppConfig({ encryptedPassword: undefined })
   }
 }
 
+// 迁移：mihomo 配置默认值
+async function migrateMihomoConfig(): Promise<void> {
+  const config = await getControledMihomoConfig()
+  const patches: Partial<IMihomoConfig> = {}
+
+  // skip-auth-prefixes
+  if (!config['skip-auth-prefixes']) {
+    patches['skip-auth-prefixes'] = ['127.0.0.1/32', '::1/128']
+  } else if (
+    config['skip-auth-prefixes'].length >= 1 &&
+    config['skip-auth-prefixes'][0] === '127.0.0.1/32' &&
+    !config['skip-auth-prefixes'].includes('::1/128')
+  ) {
+    patches['skip-auth-prefixes'] = ['127.0.0.1/32', '::1/128', ...config['skip-auth-prefixes'].slice(1)]
+  }
+
+  // 其他默认值
+  if (!config.authentication) patches.authentication = []
+  if (!config['bind-address']) patches['bind-address'] = '*'
+  if (!config['lan-allowed-ips']) patches['lan-allowed-ips'] = ['0.0.0.0/0', '::/0']
+  if (!config['lan-disallowed-ips']) patches['lan-disallowed-ips'] = []
+
+  // tun device
+  if (!config.tun?.device || (process.platform === 'darwin' && config.tun.device === 'Mihomo')) {
+    patches.tun = {
+      ...config.tun,
+      device: process.platform === 'darwin' ? 'utun1500' : 'Mihomo'
+    }
+  }
+
+  // 移除废弃配置
+  if (config['external-controller-unix']) patches['external-controller-unix'] = undefined
+  if (config['external-controller-pipe']) patches['external-controller-pipe'] = undefined
+  if (config['external-controller'] === undefined) patches['external-controller'] = ''
+
+  if (Object.keys(patches).length > 0) {
+    await patchControledMihomoConfig(patches)
+  }
+}
+
+async function migration(): Promise<void> {
+  await Promise.all([
+    migrateSiderOrder(),
+    migrateAppTheme(),
+    migrateEnvType(),
+    migrateTraySettings(),
+    migrateRemovePassword(),
+    migrateMihomoConfig()
+  ])
+}
+
 function initDeeplink(): void {
   if (process.defaultApp) {
     if (process.argv.length >= 2) {
@@ -360,11 +361,8 @@ function initDeeplink(): void {
   }
 }
 
-// 基础初始化
 export async function initBasic(): Promise<void> {
-  if (isInitBasicCompleted) {
-    return
-  }
+  if (isInitBasicCompleted) return
 
   await initDirs()
   await initConfig()
@@ -379,6 +377,7 @@ export async function initBasic(): Promise<void> {
 export async function init(): Promise<void> {
   await startSubStoreFrontendServer()
   await startSubStoreBackendServer()
+
   const { sysProxy } = await getAppConfig()
   try {
     if (sysProxy.enable) {
@@ -388,7 +387,7 @@ export async function init(): Promise<void> {
   } catch {
     // ignore
   }
-  await startSSIDCheck()
 
+  await startSSIDCheck()
   initDeeplink()
 }

src/native/sysproxy/index.d.ts

@@ -0,0 +1,24 @@
+export interface SysproxyInfo {
+  enable: boolean
+  host: string
+  port: number
+  bypass: string
+}
+
+export interface AutoproxyInfo {
+  enable: boolean
+  url: string
+}
+
+export function triggerManualProxy(
+  enable: boolean,
+  host: string,
+  port: number,
+  bypass: string
+): void
+
+export function triggerAutoProxy(enable: boolean, url: string): void
+
+export function getSystemProxy(): SysproxyInfo
+
+export function getAutoProxy(): AutoproxyInfo

src/native/sysproxy/index.js

@@ -0,0 +1,75 @@
+const { existsSync, readFileSync } = require('fs')
+const { join } = require('path')
+
+const { platform, arch } = process
+
+let nativeBinding = null
+let loadError = null
+
+function isMusl() {
+  if (!process.report || typeof process.report.getReport !== 'function') {
+    try {
+      const lddPath = require('child_process').execSync('which ldd').toString().trim()
+      return readFileSync(lddPath, 'utf8').includes('musl')
+    } catch {
+      return true
+    }
+  } else {
+    const { glibcVersionRuntime } = process.report.getReport().header
+    return !glibcVersionRuntime
+  }
+}
+
+function getBindingName() {
+  switch (platform) {
+    case 'win32':
+      if (arch === 'x64') return 'sysproxy.win32-x64-msvc.node'
+      if (arch === 'arm64') return 'sysproxy.win32-arm64-msvc.node'
+      break
+    case 'darwin':
+      if (arch === 'x64') return 'sysproxy.darwin-x64.node'
+      if (arch === 'arm64') return 'sysproxy.darwin-arm64.node'
+      break
+    case 'linux':
+      if (isMusl()) {
+        if (arch === 'x64') return 'sysproxy.linux-x64-musl.node'
+        if (arch === 'arm64') return 'sysproxy.linux-arm64-musl.node'
+      } else {
+        if (arch === 'x64') return 'sysproxy.linux-x64-gnu.node'
+        if (arch === 'arm64') return 'sysproxy.linux-arm64-gnu.node'
+      }
+      break
+  }
+  throw new Error(`Unsupported platform: ${platform}-${arch}`)
+}
+
+function loadBinding() {
+  const bindingName = getBindingName()
+
+  // 查找项目根目录的 extra/sidecar
+  let currentDir = __dirname
+  while (currentDir !== require('path').dirname(currentDir)) {
+    const sidecarPath = join(currentDir, 'extra', 'sidecar', bindingName)
+    if (existsSync(sidecarPath)) {
+      try {
+        nativeBinding = require(sidecarPath)
+        return nativeBinding
+      } catch (e) {
+        loadError = e
+      }
+    }
+    currentDir = require('path').dirname(currentDir)
+  }
+
+  if (loadError) {
+    throw loadError
+  }
+  throw new Error(`Native binding not found: ${bindingName}`)
+}
+
+const binding = loadBinding()
+
+module.exports.triggerManualProxy = binding.triggerManualProxy
+module.exports.triggerAutoProxy = binding.triggerAutoProxy
+module.exports.getSystemProxy = binding.getSystemProxy
+module.exports.getAutoProxy = binding.getAutoProxy

src/native/sysproxy/package.json

@@ -0,0 +1,8 @@
+{
+  "name": "sysproxy-rs",
+  "version": "0.4.0",
+  "description": "System proxy library for Node.js",
+  "main": "index.js",
+  "types": "index.d.ts",
+  "license": "MIT"
+}

src/renderer/src/hooks/create-config-context.tsx

@@ -0,0 +1,72 @@
+import React, { createContext, useContext, ReactNode, useCallback, useEffect } from 'react'
+import { useTranslation } from 'react-i18next'
+import { showError } from '@renderer/utils/error-display'
+import useSWR, { KeyedMutator } from 'swr'
+
+interface ConfigContextValue<T> {
+  config: T | undefined
+  mutate: KeyedMutator<T>
+}
+
+interface CreateConfigContextOptions<T> {
+  swrKey: string
+  fetcher: () => Promise<T>
+  ipcEvent: string
+}
+
+export function createConfigContext<T>(options: CreateConfigContextOptions<T>) {
+  const { swrKey, fetcher, ipcEvent } = options
+  const Context = createContext<ConfigContextValue<T> | undefined>(undefined)
+
+  const Provider: React.FC<{ children: ReactNode }> = ({ children }) => {
+    const { data: config, mutate } = useSWR(swrKey, fetcher)
+
+    useEffect(() => {
+      const handler = (): void => {
+        mutate()
+      }
+      window.electron.ipcRenderer.on(ipcEvent, handler)
+      return () => {
+        window.electron.ipcRenderer.removeListener(ipcEvent, handler)
+      }
+    }, [mutate])
+
+    return <Context.Provider value={{ config, mutate }}>{children}</Context.Provider>
+  }
+
+  const useConfig = (): ConfigContextValue<T> => {
+    const context = useContext(Context)
+    if (!context) {
+      throw new Error(`useConfig must be used within Provider`)
+    }
+    return context
+  }
+
+  return { Provider, useConfig, Context }
+}
+
+interface ActionOptions {
+  errorKey: string
+  updateTray?: boolean
+}
+
+export function useConfigAction<T>(
+  mutate: KeyedMutator<T>,
+  action: () => Promise<void>,
+  options: ActionOptions
+): () => Promise<void> {
+  const { t } = useTranslation()
+
+  return useCallback(async () => {
+    try {
+      await action()
+    } catch (e) {
+      await showError(e, t(options.errorKey))
+    } finally {
+      mutate()
+      if (options.updateTray) {
+        window.electron.ipcRenderer.send('updateTrayMenu')
+      }
+    }
+  }, [mutate, action, t, options.errorKey, options.updateTray])
+}

src/renderer/src/hooks/use-app-config.tsx

@@ -1,51 +1,60 @@
-import React, { createContext, useContext, ReactNode } from 'react'
+import React, { ReactNode, useCallback } from 'react'
 import { useTranslation } from 'react-i18next'
 import { showError } from '@renderer/utils/error-display'
-import useSWR from 'swr'
+import { createConfigContext } from './create-config-context'
 import { getAppConfig, patchAppConfig as patch } from '@renderer/utils/ipc'
 
+const { Provider, useConfig } = createConfigContext<IAppConfig>({
+  swrKey: 'getAppConfig',
+  fetcher: getAppConfig,
+  ipcEvent: 'appConfigUpdated'
+})
+
 interface AppConfigContextType {
   appConfig: IAppConfig | undefined
   mutateAppConfig: () => void
   patchAppConfig: (value: Partial<IAppConfig>) => Promise<void>
 }
 
-const AppConfigContext = createContext<AppConfigContextType | undefined>(undefined)
-
 export const AppConfigProvider: React.FC<{ children: ReactNode }> = ({ children }) => {
-  const { t } = useTranslation()
-  const { data: appConfig, mutate: mutateAppConfig } = useSWR('getConfig', () => getAppConfig())
+  return (
+    <Provider>
+      <AppConfigContextWrapper>{children}</AppConfigContextWrapper>
+    </Provider>
+  )
+}
 
-  const patchAppConfig = async (value: Partial<IAppConfig>): Promise<void> => {
+const AppConfigContextWrapper: React.FC<{ children: ReactNode }> = ({ children }) => {
+  const { config, mutate } = useConfig()
+  const { t } = useTranslation()
+
+  const patchAppConfig = useCallback(
+    async (value: Partial<IAppConfig>): Promise<void> => {
       try {
         await patch(value)
       } catch (e) {
         await showError(e, t('common.error.updateAppConfigFailed'))
       } finally {
-      mutateAppConfig()
+        mutate()
       }
-  }
-
-  React.useEffect(() => {
-    const handler = (): void => {
-      mutateAppConfig()
-    }
-    window.electron.ipcRenderer.on('appConfigUpdated', handler)
-    return (): void => {
-      window.electron.ipcRenderer.removeListener('appConfigUpdated', handler)
-    }
-  }, [])
+    },
+    [mutate, t]
+  )
 
   return (
-    <AppConfigContext.Provider value={{ appConfig, mutateAppConfig, patchAppConfig }}>
+    <AppConfigContext.Provider
+      value={{ appConfig: config, mutateAppConfig: mutate, patchAppConfig }}
+    >
       {children}
     </AppConfigContext.Provider>
   )
 }
 
+const AppConfigContext = React.createContext<AppConfigContextType | undefined>(undefined)
+
 export const useAppConfig = (): AppConfigContextType => {
-  const context = useContext(AppConfigContext)
-  if (context === undefined) {
+  const context = React.useContext(AppConfigContext)
+  if (!context) {
     throw new Error('useAppConfig must be used within an AppConfigProvider')
   }
   return context

src/renderer/src/hooks/use-override-config.tsx

@@ -1,7 +1,7 @@
-import React, { createContext, useContext, ReactNode } from 'react'
+import React, { ReactNode, useCallback } from 'react'
 import { useTranslation } from 'react-i18next'
 import { showError } from '@renderer/utils/error-display'
-import useSWR from 'swr'
+import { createConfigContext } from './create-config-context'
 import {
   getOverrideConfig,
   setOverrideConfig as set,
@@ -10,6 +10,12 @@ import {
   updateOverrideItem as update
 } from '@renderer/utils/ipc'
 
+const { Provider, useConfig } = createConfigContext<IOverrideConfig>({
+  swrKey: 'getOverrideConfig',
+  fetcher: getOverrideConfig,
+  ipcEvent: 'overrideConfigUpdated'
+})
+
 interface OverrideConfigContextType {
   overrideConfig: IOverrideConfig | undefined
   setOverrideConfig: (config: IOverrideConfig) => Promise<void>
@@ -19,60 +25,59 @@ interface OverrideConfigContextType {
   removeOverrideItem: (id: string) => Promise<void>
 }
 
-const OverrideConfigContext = createContext<OverrideConfigContextType | undefined>(undefined)
+const OverrideConfigContext = React.createContext<OverrideConfigContextType | undefined>(undefined)
 
 export const OverrideConfigProvider: React.FC<{ children: ReactNode }> = ({ children }) => {
+  return (
+    <Provider>
+      <OverrideConfigContextWrapper>{children}</OverrideConfigContextWrapper>
+    </Provider>
+  )
+}
+
+const OverrideConfigContextWrapper: React.FC<{ children: ReactNode }> = ({ children }) => {
+  const { config, mutate } = useConfig()
   const { t } = useTranslation()
-  const { data: overrideConfig, mutate: mutateOverrideConfig } = useSWR('getOverrideConfig', () =>
-    getOverrideConfig()
+
+  const withErrorHandling = useCallback(
+    (action: () => Promise<void>, errorKey: string) => async () => {
+      try {
+        await action()
+      } catch (e) {
+        await showError(e, t(errorKey))
+      } finally {
+        mutate()
+      }
+    },
+    [mutate, t]
   )
 
-  const setOverrideConfig = async (config: IOverrideConfig): Promise<void> => {
-    try {
-      await set(config)
-    } catch (e) {
-      await showError(e, t('common.error.saveOverrideConfigFailed'))
-    } finally {
-      mutateOverrideConfig()
-    }
-  }
+  const setOverrideConfig = useCallback(
+    (cfg: IOverrideConfig) => withErrorHandling(() => set(cfg), 'common.error.saveOverrideConfigFailed')(),
+    [withErrorHandling]
+  )
 
-  const addOverrideItem = async (item: Partial<IOverrideItem>): Promise<void> => {
-    try {
-      await add(item)
-    } catch (e) {
-      await showError(e, t('common.error.addOverrideFailed'))
-    } finally {
-      mutateOverrideConfig()
-    }
-  }
+  const addOverrideItem = useCallback(
+    (item: Partial<IOverrideItem>) => withErrorHandling(() => add(item), 'common.error.addOverrideFailed')(),
+    [withErrorHandling]
+  )
 
-  const removeOverrideItem = async (id: string): Promise<void> => {
-    try {
-      await remove(id)
-    } catch (e) {
-      await showError(e, t('common.error.deleteOverrideFailed'))
-    } finally {
-      mutateOverrideConfig()
-    }
-  }
+  const removeOverrideItem = useCallback(
+    (id: string) => withErrorHandling(() => remove(id), 'common.error.deleteOverrideFailed')(),
+    [withErrorHandling]
+  )
 
-  const updateOverrideItem = async (item: IOverrideItem): Promise<void> => {
-    try {
-      await update(item)
-    } catch (e) {
-      await showError(e, t('common.error.updateOverrideFailed'))
-    } finally {
-      mutateOverrideConfig()
-    }
-  }
+  const updateOverrideItem = useCallback(
+    (item: IOverrideItem) => withErrorHandling(() => update(item), 'common.error.updateOverrideFailed')(),
+    [withErrorHandling]
+  )
 
   return (
     <OverrideConfigContext.Provider
       value={{
-        overrideConfig,
+        overrideConfig: config,
         setOverrideConfig,
-        mutateOverrideConfig,
+        mutateOverrideConfig: mutate,
         addOverrideItem,
         removeOverrideItem,
         updateOverrideItem
@@ -84,8 +89,8 @@ export const OverrideConfigProvider: React.FC<{ children: ReactNode }> = ({ chil
 }
 
 export const useOverrideConfig = (): OverrideConfigContextType => {
-  const context = useContext(OverrideConfigContext)
-  if (context === undefined) {
+  const context = React.useContext(OverrideConfigContext)
+  if (!context) {
     throw new Error('useOverrideConfig must be used within an OverrideConfigProvider')
   }
   return context

src/renderer/src/hooks/use-profile-config.tsx

@@ -1,7 +1,7 @@
-import React, { createContext, ReactNode, useContext } from 'react'
+import React, { ReactNode, useCallback, useRef } from 'react'
 import { useTranslation } from 'react-i18next'
 import { showError } from '@renderer/utils/error-display'
-import useSWR from 'swr'
+import { createConfigContext } from './create-config-context'
 import {
   addProfileItem as add,
   changeCurrentProfile as change,
@@ -11,6 +11,12 @@ import {
   updateProfileItem as update
 } from '@renderer/utils/ipc'
 
+const { Provider, useConfig } = createConfigContext<IProfileConfig>({
+  swrKey: 'getProfileConfig',
+  fetcher: getProfileConfig,
+  ipcEvent: 'profileConfigUpdated'
+})
+
 interface ProfileConfigContextType {
   profileConfig: IProfileConfig | undefined
   setProfileConfig: (config: IProfileConfig) => Promise<void>
@@ -21,80 +27,64 @@ interface ProfileConfigContextType {
   changeCurrentProfile: (id: string) => Promise<void>
 }
 
-const ProfileConfigContext = createContext<ProfileConfigContextType | undefined>(undefined)
+const ProfileConfigContext = React.createContext<ProfileConfigContextType | undefined>(undefined)
 
 export const ProfileConfigProvider: React.FC<{ children: ReactNode }> = ({ children }) => {
-  const { t } = useTranslation()
-  const { data: profileConfig, mutate: mutateProfileConfig } = useSWR('getProfileConfig', () =>
-    getProfileConfig()
+  return (
+    <Provider>
+      <ProfileConfigContextWrapper>{children}</ProfileConfigContextWrapper>
+    </Provider>
   )
-  const targetProfileId = React.useRef<string | null>(null)
-  const pendingTask = React.useRef<Promise<void> | null>(null)
+}
 
-  const setProfileConfig = async (config: IProfileConfig): Promise<void> => {
+const ProfileConfigContextWrapper: React.FC<{ children: ReactNode }> = ({ children }) => {
+  const { config, mutate } = useConfig()
+  const { t } = useTranslation()
+  const targetProfileId = useRef<string | null>(null)
+  const pendingTask = useRef<Promise<void> | null>(null)
+
+  const withErrorHandling = useCallback(
+    (action: () => Promise<void>, errorKey: string, updateTray = true) =>
+      async () => {
         try {
-      await set(config)
+          await action()
         } catch (e) {
-      await showError(e, t('common.error.saveProfileConfigFailed'))
+          await showError(e, t(errorKey))
         } finally {
-      mutateProfileConfig()
+          mutate()
+          if (updateTray) {
             window.electron.ipcRenderer.send('updateTrayMenu')
           }
         }
+      },
+    [mutate, t]
+  )
 
-  const addProfileItem = async (item: Partial<IProfileItem>): Promise<void> => {
-    try {
-      await add(item)
-    } catch (e) {
-      await showError(e, t('common.error.addProfileFailed'))
-    } finally {
-      mutateProfileConfig()
-      window.electron.ipcRenderer.send('updateTrayMenu')
-    }
-  }
+  const setProfileConfig = useCallback(
+    (cfg: IProfileConfig) =>
+      withErrorHandling(() => set(cfg), 'common.error.saveProfileConfigFailed')(),
+    [withErrorHandling]
+  )
 
-  const removeProfileItem = async (id: string): Promise<void> => {
-    try {
-      await remove(id)
-    } catch (e) {
-      await showError(e, t('common.error.deleteProfileFailed'))
-    } finally {
-      mutateProfileConfig()
-      window.electron.ipcRenderer.send('updateTrayMenu')
-    }
-  }
+  const addProfileItem = useCallback(
+    (item: Partial<IProfileItem>) =>
+      withErrorHandling(() => add(item), 'common.error.addProfileFailed')(),
+    [withErrorHandling]
+  )
 
-  const updateProfileItem = async (item: IProfileItem): Promise<void> => {
-    try {
-      await update(item)
-    } catch (e) {
-      await showError(e, t('common.error.updateProfileFailed'))
-    } finally {
-      mutateProfileConfig()
-      window.electron.ipcRenderer.send('updateTrayMenu')
-    }
-  }
+  const removeProfileItem = useCallback(
+    (id: string) => withErrorHandling(() => remove(id), 'common.error.deleteProfileFailed')(),
+    [withErrorHandling]
+  )
 
-  const changeCurrentProfile = async (id: string): Promise<void> => {
-    if (targetProfileId.current === id) {
-      return
-    }
+  const updateProfileItem = useCallback(
+    (item: IProfileItem) =>
+      withErrorHandling(() => update(item), 'common.error.updateProfileFailed')(),
+    [withErrorHandling]
+  )
 
-    // 立即更新 UI 状态和托盘菜单，提供即时反馈
-    if (profileConfig) {
-      const optimisticUpdate = { ...profileConfig, current: id }
-      mutateProfileConfig(optimisticUpdate, false)
-      window.electron.ipcRenderer.send('updateTrayMenu')
-    }
-
-    targetProfileId.current = id
-    await processChange()
-  }
-
-  const processChange = async () => {
-    if (pendingTask.current) {
-      return
-    }
+  const processChange = useCallback(async () => {
+    if (pendingTask.current) return
 
     while (targetProfileId.current) {
       const targetId = targetProfileId.current
@@ -102,41 +92,48 @@ export const ProfileConfigProvider: React.FC<{ children: ReactNode }> = ({ child
 
       pendingTask.current = change(targetId)
       try {
-        // 异步执行后台切换，不阻塞 UI
         await pendingTask.current
       } catch (e) {
         const errorMsg = (e as { message?: string })?.message || String(e)
-        // 处理 IPC 超时错误
         if (errorMsg.includes('reply was never sent')) {
-          setTimeout(() => mutateProfileConfig(), 1000)
+          setTimeout(() => mutate(), 1000)
         } else {
           await showError(errorMsg, t('common.error.switchProfileFailed'))
-          mutateProfileConfig()
+          mutate()
         }
       } finally {
         pendingTask.current = null
       }
     }
+  }, [mutate, t])
+
+  const changeCurrentProfile = useCallback(
+    async (id: string) => {
+      if (targetProfileId.current === id) return
+
+      if (config) {
+        mutate({ ...config, current: id }, false)
+        window.electron.ipcRenderer.send('updateTrayMenu')
       }
 
+      targetProfileId.current = id
+      await processChange()
+    },
+    [config, mutate, processChange]
+  )
+
   React.useEffect(() => {
-    const handler = (): void => {
-      mutateProfileConfig()
-    }
-    window.electron.ipcRenderer.on('profileConfigUpdated', handler)
-    return (): void => {
-      // 清理待处理任务，防止内存泄漏
+    return () => {
       targetProfileId.current = null
-      window.electron.ipcRenderer.removeListener('profileConfigUpdated', handler)
     }
   }, [])
 
   return (
     <ProfileConfigContext.Provider
       value={{
-        profileConfig,
+        profileConfig: config,
         setProfileConfig,
-        mutateProfileConfig,
+        mutateProfileConfig: mutate,
         addProfileItem,
         removeProfileItem,
         updateProfileItem,
@@ -149,8 +146,8 @@ export const ProfileConfigProvider: React.FC<{ children: ReactNode }> = ({ child
 }
 
 export const useProfileConfig = (): ProfileConfigContextType => {
-  const context = useContext(ProfileConfigContext)
-  if (context === undefined) {
+  const context = React.useContext(ProfileConfigContext)
+  if (!context) {
     throw new Error('useProfileConfig must be used within a ProfileConfigProvider')
   }
   return context