feat: ORT Local Translate

lib/provider/aria2c.dart

@@ -8,11 +8,11 @@ import 'package:flutter/foundation.dart';
 import 'package:hive_ce/hive.dart';
 import 'package:starcitizen_doctor/api/api.dart';
 import 'package:starcitizen_doctor/common/helper/system_helper.dart';
-import 'package:starcitizen_doctor/common/rust/api/rs_process.dart'
-    as rs_process;
+import 'package:starcitizen_doctor/common/rust/api/rs_process.dart' as rs_process;
 
 import 'package:starcitizen_doctor/common/utils/log.dart';
 import 'package:starcitizen_doctor/common/utils/provider.dart';
+import 'package:starcitizen_doctor/ui/home/downloader/home_downloader_ui_model.dart';
 
 part 'aria2c.g.dart';
 
@@ -20,11 +20,8 @@ part 'aria2c.freezed.dart';
 
 @freezed
 abstract class Aria2cModelState with _$Aria2cModelState {
-  const factory Aria2cModelState({
-    required String aria2cDir,
-    Aria2c? aria2c,
-    Aria2GlobalStat? aria2globalStat,
-  }) = _Aria2cModelState;
+  const factory Aria2cModelState({required String aria2cDir, Aria2c? aria2c, Aria2GlobalStat? aria2globalStat}) =
+      _Aria2cModelState;
 }
 
 extension Aria2cModelExt on Aria2cModelState {
@@ -32,10 +29,8 @@ extension Aria2cModelExt on Aria2cModelState {
 
   bool get hasDownloadTask => aria2globalStat != null && aria2TotalTaskNum > 0;
 
-  int get aria2TotalTaskNum => aria2globalStat == null
-      ? 0
-      : ((aria2globalStat!.numActive ?? 0) +
-          (aria2globalStat!.numWaiting ?? 0));
+  int get aria2TotalTaskNum =>
+      aria2globalStat == null ? 0 : ((aria2globalStat!.numActive ?? 0) + (aria2globalStat!.numWaiting ?? 0));
 }
 
 @riverpod
@@ -57,8 +52,7 @@ class Aria2cModel extends _$Aria2cModel {
       try {
         final sessionFile = File("$aria2cDir\\aria2.session");
         // 有下载任务则第一时间初始化
-        if (await sessionFile.exists() &&
-            (await sessionFile.readAsString()).trim().isNotEmpty) {
+        if (await sessionFile.exists() && (await sessionFile.readAsString()).trim().isNotEmpty) {
           dPrint("launch Aria2c daemon");
           await launchDaemon(appGlobalState.applicationBinaryModuleDir!);
         } else {
@@ -74,8 +68,7 @@ class Aria2cModel extends _$Aria2cModel {
 
   Future launchDaemon(String applicationBinaryModuleDir) async {
     if (state.aria2c != null) return;
-    await BinaryModuleConf.extractModule(
-        ["aria2c"], applicationBinaryModuleDir);
+    await BinaryModuleConf.extractModule(["aria2c"], applicationBinaryModuleDir);
 
     /// skip for debug hot reload
     if (kDebugMode) {
@@ -99,30 +92,30 @@ class Aria2cModel extends _$Aria2cModel {
     dPrint("Aria2cManager .-----  aria2c start $port------");
 
     final stream = rs_process.start(
-        executable: exePath,
-        arguments: [
-          "-V",
-          "-c",
-          "-x 16",
-          "--dir=${state.aria2cDir}\\downloads",
-          "--disable-ipv6",
-          "--enable-rpc",
-          "--pause",
-          "--rpc-listen-port=$port",
-          "--rpc-secret=$pwd",
-          "--input-file=${sessionFile.absolute.path.trim()}",
-          "--save-session=${sessionFile.absolute.path.trim()}",
-          "--save-session-interval=60",
-          "--file-allocation=trunc",
-          "--seed-time=0",
-        ],
-        workingDirectory: state.aria2cDir);
+      executable: exePath,
+      arguments: [
+        "-V",
+        "-c",
+        "-x 16",
+        "--dir=${state.aria2cDir}\\downloads",
+        "--disable-ipv6",
+        "--enable-rpc",
+        "--pause",
+        "--rpc-listen-port=$port",
+        "--rpc-secret=$pwd",
+        "--input-file=${sessionFile.absolute.path.trim()}",
+        "--save-session=${sessionFile.absolute.path.trim()}",
+        "--save-session-interval=60",
+        "--file-allocation=trunc",
+        "--seed-time=0",
+      ],
+      workingDirectory: state.aria2cDir,
+    );
 
     String launchError = "";
 
     stream.listen((event) {
-      dPrint(
-          "Aria2cManager.rs_process event === [${event.rsPid}] ${event.dataType} >> ${event.data}");
+      dPrint("Aria2cManager.rs_process event === [${event.rsPid}] ${event.dataType} >> ${event.data}");
       switch (event.dataType) {
         case rs_process.RsProcessStreamDataType.output:
           if (event.data.contains("IPv4 RPC: listening on TCP port")) {
@@ -155,8 +148,7 @@ class Aria2cModel extends _$Aria2cModel {
   }
 
   String generateRandomPassword(int length) {
-    const String charset =
-        "abcdefghijklmnopqrstuvwxyzABCDEFGHIJKLMNOPQRSTUVWXYZ0123456789";
+    const String charset = "abcdefghijklmnopqrstuvwxyzABCDEFGHIJKLMNOPQRSTUVWXYZ0123456789";
     Random random = Random();
     StringBuffer buffer = StringBuffer();
     for (int i = 0; i < length; i++) {
@@ -190,12 +182,12 @@ class Aria2cModel extends _$Aria2cModel {
       _listenState(aria2c);
     });
     final box = await Hive.openBox("app_conf");
-    aria2c.changeGlobalOption(Aria2Option()
-      ..maxOverallUploadLimit =
-          textToByte(box.get("downloader_up_limit", defaultValue: "0"))
-      ..maxOverallDownloadLimit =
-          textToByte(box.get("downloader_down_limit", defaultValue: "0"))
-      ..btTracker = trackerList);
+    aria2c.changeGlobalOption(
+      Aria2Option()
+        ..maxOverallUploadLimit = textToByte(box.get("downloader_up_limit", defaultValue: "0"))
+        ..maxOverallDownloadLimit = textToByte(box.get("downloader_down_limit", defaultValue: "0"))
+        ..btTracker = trackerList,
+    );
   }
 
   Future<void> _listenState(Aria2c aria2c) async {
@@ -214,4 +206,14 @@ class Aria2cModel extends _$Aria2cModel {
       await Future.delayed(const Duration(seconds: 1));
     }
   }
+
+  Future<bool> isNameInTask(String name) async {
+    final aria2c = state.aria2c;
+    if (aria2c == null) return false;
+    for (var value in [...await aria2c.tellActive(), ...await aria2c.tellWaiting(0, 100000)]) {
+      final t = HomeDownloaderUIModel.getTaskTypeAndName(value);
+      return (t.key == "torrent" && t.value.contains(name));
+    }
+    return false;
+  }
 }

lib/provider/aria2c.g.dart

@@ -41,7 +41,7 @@ final class Aria2cModelProvider
   }
 }
 
-String _$aria2cModelHash() => r'3d51aeefd92e5291dca1f01db961f9c5496ec24f';
+String _$aria2cModelHash() => r'eb45d6aa9fc641abceb34ad5685aab57aa7a870b';
 
 abstract class _$Aria2cModel extends $Notifier<Aria2cModelState> {
   Aria2cModelState build();