Fix android tile service

Optimize Windows service mode

Update core

.github/workflows/build.yaml

@@ -27,9 +27,9 @@ jobs:
           - platform: macos
             os: macos-latest
             arch: arm64
-          - platform: windows
-            os: windows-11-arm
-            arch: arm64
+          #          - platform: windows
+          #            os: windows-11-arm
+          #            arch: arm64
           - platform: linux
             os: ubuntu-24.04-arm
             arch: arm64

.gitignore

@@ -45,11 +45,19 @@ app.*.map.json
 /android/app/debug
 /android/app/profile
 /android/app/release
+/android/**/.cxx
+/android/**/build
+/android/common/**/.**/
+/android/common/local.*
+/android/core/**/includes/
+/android/core/**/cmake-build-*/
+/android/core/**/jniLibs/
 
 
-
-#libclash
+#FlClash
 /libclash/
-
-#jniLibs
 /android/app/src/main/jniLibs/
+/services/helper/target
+/macos/**/Package.resolved
+devtools_options.yaml
+

CHANGELOG.md

@@ -1,3 +1,13 @@
+## v0.8.89
+
+- Fix some issues
+
+- Optimize Windows service mode
+
+- Update core
+
+- Update changelog
+
 ## v0.8.88
 
 - Add android separates the core process

android/app/src/main/AndroidManifest.xml

@@ -66,6 +66,7 @@
 
         <activity
             android:name=".TempActivity"
+            android:excludeFromRecents="true"
             android:exported="true"
             android:theme="@style/TransparentTheme">
             <intent-filter>

android/app/src/main/kotlin/com/follow/clash/State.kt

@@ -92,6 +92,7 @@ object State {
 
     suspend fun destroyServiceEngine() {
         runLock.withLock {
+            GlobalState.log("Destroy service engine")
             withContext(Dispatchers.Main) {
                 runCatching {
                     serviceFlutterEngine?.destroy()
@@ -103,10 +104,12 @@ object State {
 
     suspend fun startServiceWithEngine() {
         runLock.withLock {
-            if (serviceFlutterEngine != null || runStateFlow.value == RunState.PENDING || runStateFlow.value == RunState.START) {
+            if (runStateFlow.value == RunState.PENDING || runStateFlow.value == RunState.START) {
                 return
             }
+            GlobalState.log("Create service engine")
             withContext(Dispatchers.Main) {
+                serviceFlutterEngine?.destroy()
                 serviceFlutterEngine = FlutterEngine(GlobalState.application)
                 serviceFlutterEngine?.plugins?.add(ServicePlugin())
                 serviceFlutterEngine?.plugins?.add(AppPlugin())

android/app/src/main/kotlin/com/follow/clash/TempActivity.kt

@@ -30,6 +30,6 @@ class TempActivity : Activity(),
                 }
             }
         }
-        finishAndRemoveTask()
+        finish()
     }
 }

core/hub.go

@@ -33,6 +33,8 @@ var (
 )
 
 func handleInitClash(paramsString string) bool {
+	runLock.Lock()
+	defer runLock.Unlock()
 	var params = InitParams{}
 	err := json.Unmarshal([]byte(paramsString), &params)
 	if err != nil {

lib/common/function.dart

@@ -1,5 +1,6 @@
 import 'dart:async';
 
+import 'package:fl_clash/common/common.dart';
 import 'package:fl_clash/enum/enum.dart';
 
 class Debouncer {
@@ -68,7 +69,7 @@ Future<T> retry<T>({
   required Future<T> Function() task,
   int maxAttempts = 3,
   required bool Function(T res) retryIf,
-  Duration delay = Duration.zero,
+  Duration delay = midDuration,
 }) async {
   int attempts = 0;
   while (attempts < maxAttempts) {
@@ -78,7 +79,7 @@ Future<T> retry<T>({
     }
     attempts++;
   }
-  throw 'unknown error';
+  throw 'retry error';
 }
 
 final debouncer = Debouncer();

lib/common/system.dart

@@ -186,26 +186,26 @@ class Windows {
       logLevel: LogLevel.warning,
     );
 
-    if (result < 42) {
+    if (result <= 32) {
       return false;
     }
     return true;
   }
 
-  Future<void> _killProcess(int port) async {
-    final result = await Process.run('netstat', ['-ano']);
-    final lines = result.stdout.toString().trim().split('\n');
-    for (final line in lines) {
-      if (!line.contains(':$port') || !line.contains('LISTENING')) {
-        continue;
-      }
-      final parts = line.trim().split(RegExp(r'\s+'));
-      final pid = int.tryParse(parts.last);
-      if (pid != null) {
-        await Process.run('taskkill', ['/PID', pid.toString(), '/F']);
-      }
-    }
-  }
+  // Future<void> _killProcess(int port) async {
+  //   final result = await Process.run('netstat', ['-ano']);
+  //   final lines = result.stdout.toString().trim().split('\n');
+  //   for (final line in lines) {
+  //     if (!line.contains(':$port') || !line.contains('LISTENING')) {
+  //       continue;
+  //     }
+  //     final parts = line.trim().split(RegExp(r'\s+'));
+  //     final pid = int.tryParse(parts.last);
+  //     if (pid != null) {
+  //      await Process.run('taskkill', ['/PID', pid.toString(), '/F']);
+  //     }
+  //   }
+  // }
 
   Future<WindowsHelperServiceStatus> checkService() async {
     // final qcResult = await Process.run('sc', ['qc', appHelperService]);
@@ -231,16 +231,18 @@ class Windows {
       return true;
     }
 
-    await _killProcess(helperPort);
-
     final command = [
       '/c',
       if (status == WindowsHelperServiceStatus.presence) ...[
-        'sc',
+        'taskkill',
+        '/F',
+        '/IM',
+        '$appHelperService.exe'
+            ' & '
+            'sc',
         'delete',
         appHelperService,
-        '/force',
-        '&&',
+        '&',
       ],
       'sc',
       'create',
@@ -256,8 +258,12 @@ class Windows {
     final res = runas('cmd.exe', command);
 
     await Future.delayed(Duration(milliseconds: 300));
-
-    return res;
+    final retryStatus = await retry(
+      task: checkService,
+      retryIf: (status) => status == WindowsHelperServiceStatus.running,
+      delay: commonDuration,
+    );
+    return res && retryStatus == WindowsHelperServiceStatus.running;
   }
 
   Future<bool> registerTask(String appName) async {

lib/common/utils.dart

@@ -322,12 +322,15 @@ class Utils {
     return SingleActivator(trigger, control: control, meta: !control);
   }
 
-  FutureOr<T> handleWatch<T>(Function function) async {
+  FutureOr<T> handleWatch<T>({
+    required Function function,
+    required void Function(T data, int elapsedMilliseconds) onWatch,
+  }) async {
     if (kDebugMode) {
       final stopwatch = Stopwatch()..start();
       final res = await function();
       stopwatch.stop();
-      commonPrint.log('耗时：${stopwatch.elapsedMilliseconds} ms');
+      onWatch(res, stopwatch.elapsedMilliseconds);
       return res;
     }
     return await function();

lib/controller.dart

@@ -962,7 +962,7 @@ class AppController {
       final res = await futureFunction();
       return res;
     } catch (e) {
-      commonPrint.log('$futureFunction ===> $e', logLevel: LogLevel.warning);
+      commonPrint.log('$title===> $e', logLevel: LogLevel.warning);
       if (realSilence) {
         globalState.showNotifier(e.toString());
       } else {

lib/core/interface.dart

@@ -5,6 +5,7 @@ import 'dart:isolate';
 import 'package:fl_clash/common/common.dart';
 import 'package:fl_clash/enum/enum.dart';
 import 'package:fl_clash/models/models.dart';
+import 'package:flutter/foundation.dart';
 
 mixin CoreInterface {
   Future<bool> init(InitParams params);
@@ -86,7 +87,18 @@ abstract class CoreHandlerInterface with CoreInterface {
     Duration? timeout,
   }) async {
     await connected;
-    return invoke(method: method, data: data, timeout: timeout);
+    if (kDebugMode) {
+      commonPrint.log('Invoke ${method.name} ${DateTime.now()} $data');
+    }
+
+    return utils.handleWatch(
+      function: () async {
+        return await invoke(method: method, data: data, timeout: timeout);
+      },
+      onWatch: (data, elapsedMilliseconds) {
+        commonPrint.log('Invoke ${method.name} ${elapsedMilliseconds}ms');
+      },
+    );
   }
 
   Future<T?> invoke<T>({
@@ -145,7 +157,7 @@ abstract class CoreHandlerInterface with CoreInterface {
   @override
   Future<Result> getConfig(String path) async {
     return await _invoke<Result>(method: ActionMethod.getConfig, data: path) ??
-        Result<Map<String, dynamic>>.success({});
+        Result.success({});
   }
 
   @override

lib/core/service.dart

@@ -38,23 +38,29 @@ class CoreService extends CoreHandlerInterface {
     completer?.complete(data);
   }
 
-  void _initServer() {
-    runZonedGuarded(
-      () async {
-        final address = !system.isWindows
-            ? InternetAddress(unixSocketPath, type: InternetAddressType.unix)
-            : InternetAddress(localhost, type: InternetAddressType.IPv4);
-        await _deleteSocketFile();
-        final server = await ServerSocket.bind(address, 0, shared: true);
-        _serverCompleter.complete(server);
-        await for (final socket in server) {
-          await _attachSocket(socket);
+  Future<void> _initServer() async {
+    final server = await retry(
+      task: () async {
+        try {
+          final address = !system.isWindows
+              ? InternetAddress(unixSocketPath, type: InternetAddressType.unix)
+              : InternetAddress(localhost, type: InternetAddressType.IPv4);
+          await _deleteSocketFile();
+          final server = await ServerSocket.bind(address, 0, shared: true);
+          server.listen((socket) async {
+            await _attachSocket(socket);
+          });
+          return server;
+        } catch (_) {
+          return null;
         }
       },
-      (error, stack) async {
-        commonPrint.log('Service error: $error', logLevel: LogLevel.warning);
-      },
+      retryIf: (server) => server == null,
     );
+    if (server == null) {
+      exit(0);
+    }
+    _serverCompleter.complete(server);
   }
 
   Future<void> _attachSocket(Socket socket) async {

lib/main.dart

@@ -33,15 +33,14 @@ Future<void> _service(List<String> flags) async {
       },
     ),
   );
-  Future(() async {
-    app?.tip(appLocalizations.startVpn);
-    final version = await system.version;
-    await coreController.init(version);
-    final clashConfig = globalState.config.patchClashConfig.copyWith.tun(
-      enable: false,
-    );
+  app?.tip(appLocalizations.startVpn);
+  final version = await system.version;
+  await coreController.init(version);
+  final clashConfig = globalState.config.patchClashConfig.copyWith.tun(
+    enable: false,
+  );
+  coreController.setupConfig(clashConfig).then((_) async {
     await globalState.handleStart();
-    await coreController.setupConfig(clashConfig);
   });
 }
 

lib/models/core.dart

@@ -192,7 +192,7 @@ extension ActionResultExt on ActionResult {
     if (code == ResultType.success) {
       return Result.success(data);
     } else {
-      return Result.error(data);
+      return Result.error('$data');
     }
   }
 }

lib/state.dart

@@ -304,7 +304,13 @@ class GlobalState {
 
   Future<void> genConfigFile(ClashConfig pathConfig) async {
     final configFilePath = await appPath.configFilePath;
-    final config = await patchRawConfig(patchConfig: pathConfig);
+    var config = {};
+    try {
+      config = await patchRawConfig(patchConfig: pathConfig);
+    } catch (e) {
+      globalState.showNotifier(e.toString());
+      config = {};
+    }
     final res = await Isolate.run<String>(() async {
       try {
         final res = json.encode(config);

lib/views/proxies/providers.dart

@@ -147,7 +147,8 @@ class ProviderItem extends StatelessWidget {
         crossAxisAlignment: CrossAxisAlignment.start,
         children: [
           const SizedBox(height: 4),
-          Text(_buildProviderDesc()),
+          if (provider.updateAt.microsecondsSinceEpoch > 0)
+            Text(_buildProviderDesc()),
           const SizedBox(height: 4),
           if (provider.subscriptionInfo != null)
             SubscriptionInfoView(subscriptionInfo: provider.subscriptionInfo),

pubspec.yaml

@@ -1,7 +1,7 @@
 name: fl_clash
 description: A multi-platform proxy client based on ClashMeta, simple and easy to use, open-source and ad-free.
 publish_to: 'none'
-version: 0.8.89+2025092402
+version: 0.8.90+2025100101
 environment:
   sdk: '>=3.8.0 <4.0.0'
 

windows/packaging/exe/inno_setup.iss

@@ -15,8 +15,8 @@ SolidCompression=yes
 SetupIconFile={{SETUP_ICON_FILE}}
 WizardStyle=modern
 PrivilegesRequired={{PRIVILEGES_REQUIRED}}
-ArchitecturesAllowed={{ARCH}}
-ArchitecturesInstallIn64BitMode={{ARCH}}
+ArchitecturesAllowed=x64 arm64
+ArchitecturesInstallIn64BitMode=x64 arm64
 
 [Code]
 procedure KillProcesses;