import 'dart:ffi'; import 'dart:io'; import 'package:flutter/services.dart'; import 'package:flutter/widgets.dart'; import 'package:get/get.dart'; import 'package:naiyouwl/app/bean/proxie.dart'; import 'package:naiyouwl/app/common/LogHelper.dart'; import 'package:naiyouwl/app/common/SharedPreferencesUtil.dart'; import 'package:naiyouwl/app/common/constants.dart'; import 'package:naiyouwl/app/controller/controllers.dart'; import 'package:naiyouwl/app/data/model/NodeMode.dart'; import 'package:naiyouwl/app/network/api_service.dart'; import 'package:naiyouwl/app/network/dio_client.dart'; import 'package:naiyouwl/app/utils/shell.dart'; import 'package:naiyouwl/app/utils/system_proxy.dart'; import 'package:naiyouwl/app/utils/utils.dart'; import 'package:proxy_manager/proxy_manager.dart'; import 'package:shared_preferences/shared_preferences.dart'; import 'package:tray_manager/tray_manager.dart'; import 'package:window_manager/window_manager.dart'; import 'package:path/path.dart' as path; import 'package:wl_base_help/wl_base_help.dart'; import '../const/const.dart'; class GlobalController extends GetxController { final proxyManager = ProxyManager(); bool systemProxy = false; late BuildContext context; final List modes = ['rule', 'global']; final List routeModes = ['sys', 'tun']; var msgStatus = "未连接".obs; var routeModesSelect = "sys".obs; var modesSelect = "rule".obs; var nodeModes = [].obs; var isLoading = false.obs; var errorMsg = ''.obs; var statusCode = 0.obs; var selectMageNode = false.obs; var systemProxySwitchIng = false.obs; var tunProxySwitchIng = false.obs; var nodeId = 0.obs; bool allowStatusUpdate = false; final _wlBaseHelpPlugin = WlBaseHelp(); var sysInfo = ''.obs; var sysVersion = kVersion.obs; final selectedNode = Rx(null); // // 策略组 // var proxieGroups = [].obs; // // 代理集 // var proxieProviders = [].obs; // // 代理 // var proxieProxies = [].obs; // // 所有节点 // var allProxies = {}.obs; final List groupInternalTypes = ['DIRECT', 'REJECT', 'GLOBAL']; final List groupTypes = [ ProxieProxieType.selector, ProxieProxieType.urltest, ProxieProxieType.fallback, ProxieProxieType.loadbalance, ]; Future init(BuildContext context) async { this.context = context; watchExit(); // if(Platform.isWindows){ // createConsole(); // hideConsole(); // } await SharedPreferencesUtil().delete("last_successful_url"); // init plugins await controllers.tray.initTray(); controllers.window.initWindow(); } // Platform messages are asynchronous, so we initialize in an async method. Future platformState() async { String platformVersion; if(Platform.isWindows){ try { platformVersion = await _wlBaseHelpPlugin.getPlatformVersion() ?? 'Unknown platform version'; platformVersion = platformVersion + ClashName.architecture.name; } on PlatformException { platformVersion = 'Failed to get platform version.'; } sysInfo.value = platformVersion; } else { sysInfo.value = ClashName.os.name + "-" + ClashName.architecture.name; } } Future onRunAdmin() async { if(Platform.isWindows){ try { await _wlBaseHelpPlugin.runAsAdministrator(); } on PlatformException { } } } Future onIsRunAdmin() async { bool isAdmin; try { isAdmin = await _wlBaseHelpPlugin.isRunningAsAdmin() ?? false; } on PlatformException { isAdmin = false; } return isAdmin; } Future onIsProcessRunning(String passName) async { bool isRun = false; if(Platform.isWindows){ try { isRun = await _wlBaseHelpPlugin.isProcessRunning(passName) ?? false; if (isRun){ await onKillProcess(passName); } } on PlatformException { isRun = false; } } return isRun; } Future onKillProcess(String passName) async { try { await _wlBaseHelpPlugin.killProcess(passName); } on PlatformException { } } void updateMsg(String msg) { msgStatus.value = msg; } Future updateMode(String route) async { if(allowStatusUpdate){ return; } modesSelect.value = route; final coreStatus = controllers.service.coreStatus.value; if( coreStatus == RunningState.running){ controllers.core.fetchConfigUpdate({'mode': modesSelect.value}); } } Future updateRoute(String route) async { if(allowStatusUpdate){ return; } // if(route == "tun"){ // final res = await showNormalDialog( context,content: '启用网卡模式需要管理员',title: '提示', cancelText: '取消', enterText: '确认安装'); // if (res != true) return; // controllers.service.serviceModeSwitch(true); // } routeModesSelect.value = route; LogHelper().d("当前ROUTE模式${routeModesSelect.value}"); } Future fetchNodes() async { nodeModes.value = await ApiService().getNode("/api/client/v4/nodes?vless=1"); //await makeProxy(); // if(controllers.service.coreStatus.value == RunningState.stoped){ // await controllers.service.reloadClashCore(); // } // if (controllers.service.coreStatus.value != RunningState.running) return; // await controllers.core.updateVersion(); // await updateDate(); // } Future updateNode() async { NodeMode? targetNode; if (selectedNode.value == null) { targetNode = await findNodeWithMinUsers(nodeModes); } else { targetNode = selectedNode.value; } if (targetNode != null){ selectNode(targetNode); await swift(targetNode.name ?? ""); } } Future showConsole() async { await _wlBaseHelpPlugin.showConsole(); } Future hideConsole() async { await _wlBaseHelpPlugin.hideConsole(); } Future startSysMode() async { await makeProxy(); //await updateDate(); } Future startTunMode() async { await makeProxy(); } Future swift(String name) async { try{ var g = "proxy"; if(modesSelect.value == "global") { g = "GLOBAL"; } await controllers.core.fetchSetProxieGroup(g, name); final conn = await controllers.core.fetchConnection(); if(conn == null) { return; } for (final it in conn.connections) { if (it.chains.contains(name)) controllers.core.fetchCloseConnections(it.id); } }catch (e) { //LogHelper().d(e.toString()); } } Future makeProxy() async { await controllers.config.makeClashConfig(nodeModes); // await controllers.service.reloadClashCore(); } Future findNodeWithMinUsers(List nodes) async { return nodes .where((node) => node.countryCode == "hk") .reduce((a, b) => a.onlineUsers! < b.onlineUsers! ? a : b); } Future getSysProxy() async{ return await SystemProxy.instance.get(); } Future TunProxySwitch(bool open) async { tunProxySwitchIng.value = true; routeModesSelect.value = open ? "tun": "sys"; LogHelper().d("TunProxySwitch ----- 当前ROUTE模式${routeModesSelect.value}"); tunProxySwitchIng.value = false; } Future systemProxySwitch(bool open) async { systemProxySwitchIng.value = true; //await SystemProxy.instance.set(open ? controllers.core.proxyConfig : SystemProxyConfig()); await controllers.config.setSystemProxy(open); if(open) { if(Platform.isWindows){ await openProxy(); } else { await controllers.service.fetchSetProxy(); } } else { if(Platform.isWindows){ await closeProxy(); } else { await controllers.service.fetchSetProxyStop(); } } systemProxySwitchIng.value = false; } // Future _updateProxie() async { // final proxie = await controllers.core.fetchProxie(); // final global = proxie.proxies["GLOBAL"]!; // proxieGroups.value = global.all! // .where((it) => !groupInternalTypes.contains(it) && groupTypes.contains(proxie.proxies[it]!.type)) // .map((it) => proxie.proxies[it]!) // .toList(); // proxieProxies.value = global.all! // .where((it) => !groupInternalTypes.contains(it) && !groupTypes.contains(proxie.proxies[it]!.type)) // .map((it) => proxie.proxies[it]!) // .toList(); // if (controllers.core.config.value.mode == 'global') proxieGroups.insert(0, global); // } // // Future _updateProxieProvider() async { // proxieProviders.value = (await controllers.core.fetchProxieProvider()).providers.values.where((it) => it.vehicleType != 'Compatible').toList(); // for (final it in proxieProviders) { // it.proxies.sort((a, b) { // if (a.delay == 0) return 1; // if (b.delay == 0) return -1; // return a.delay - b.delay; // }); // } // } // Future updateDate() async { // //LogHelper().d('controller.proxie.updateDate()'); // try // { // await controllers.core.updateConfig(); // await _updateProxie(); // await _updateProxieProvider(); // allProxies.clear(); // for (final provide in proxieProviders) { // for (final it in provide.proxies) { // allProxies[it.name] = it; // } // } // for (final it in proxieProxies) { // allProxies[it.name] = it; // //LogHelper().d('controller.proxieProxies'); // } // for (final it in proxieGroups) { // allProxies[it.name] = it; // //LogHelper().d('controller.proxieGroups'); // } // proxieGroups.refresh(); // proxieProxies.refresh(); // proxieProviders.refresh(); // allProxies.refresh(); // } catch (e){ // LogHelper().d("updateDate -- ${e.toString()}"); // } // // } // Future handleSetProxieGroup(ProxieProxiesItem proxie, String value) async { // if (proxie.now == value) return; // await controllers.core.fetchSetProxieGroup(proxie.name, value); // await updateDate(); // if (controllers.config.config.value.breakConnections) { // final conn = await controllers.core.fetchConnection(); // for (final it in conn.connections) { // if (it.chains.contains(proxie.name)) controllers.core.fetchCloseConnections(it.id); // } // } // } // // Future handleSetSelectProxieGroup(NodeMode proxie, String value) async { // if (proxie.name == value) return; // await controllers.core.fetchSetProxieGroup(proxie.name ?? "", value); // await updateDate(); // final conn = await controllers.core.fetchConnection(); // for (final it in conn.connections) { // if (it.chains.contains(proxie.name)) controllers.core.fetchCloseConnections(it.id); // } // } void watchExit() { // watch process kill // ref https://github.com/dart-lang/sdk/issues/12170 if (Platform.isMacOS) { // windows not support https://github.com/dart-lang/sdk/issues/28603 // for macos 任务管理器退出进程 ProcessSignal.sigterm.watch().listen((_) { stdout.writeln('exit: sigterm'); handleExit(); }); } // for macos, windows ctrl+c ProcessSignal.sigint.watch().listen((_) { stdout.writeln('exit: sigint'); handleExit(); }); } void selectNode(NodeMode node) { nodeId.value = node.id ?? 0; controllers.global.selectedNode.value = node; _storeSelectedNode(node); } Future _storeSelectedNode(NodeMode node) async { final prefs = await SharedPreferences.getInstance(); // 为简化起见,我们只存储node的ID,但您可以根据需要存储更多信息 prefs.setInt('selectedNodeId', node.id ?? -1); await loadSelectedNode(); } Future loadSelectedNode() async { final prefs = await SharedPreferences.getInstance(); final selectedNodeId = prefs.getInt('selectedNodeId'); if (selectedNodeId != null) { //selectedIndex.value = nodeModes.indexWhere((item) => item.id == selectedNodeId); selectedNode.value = nodeModes.firstWhere((node) => node.id == selectedNodeId); } } void initRegularlyUpdate() { Future.delayed(const Duration(minutes: 5)).then((_) async { for (final it in controllers.config.config.value.subs) { try { if (it.url == null || it.url!.isEmpty) continue; if (((DateTime.now().millisecondsSinceEpoch ~/ 1000) - (it.updateTime ?? 0)) < controllers.config.config.value.updateInterval) continue; final chenged = await controllers.config.updateSub(it); if (!chenged) continue; if (it.name != controllers.config.config.value.selected) continue; // restart clash core await controllers.service.reloadClashCore(); await Future.delayed(const Duration(seconds: 20)); } catch (_) {} } initRegularlyUpdate(); }); } /// 打开代理 Future openProxy() async { int? port = controllers.config.mixedPort.value; if (port == 0) { port = null; } int? socksPort = controllers.config.mixedPort.value; if (socksPort == 0) { socksPort = null; } int? mixedPort = controllers.config.mixedPort.value; if (mixedPort == 0) { mixedPort = null; } port = port ?? mixedPort ?? 0; if (port != 0) { if(Platform.isWindows){ String loa = '127.*;10.*;172.16.*;172.17.*;172.18.*;172.19.*;172.20.*;172.21.*;172.22.*;172.23.*;172.24.*;172.25.*;172.26.*;172.27.*;172.28.*;172.29.*;172.30.*;172.31.*;192.168.*'; int? exitCode; // Process sysproxy = await Process.start(Files.assetsSysProxyWin.path,,mode: ProcessStartMode.inheritStdio); // sysproxy.exitCode.then((code) => exitCode = code); try { var result = await Process.run( Files.assetsSysProxyWin.path, ['global','127.0.0.1:$port',loa], runInShell: true, ); LogHelper().d(result.stderr); LogHelper().d(result.stdout); } on ProcessException catch (e) { //.e('Failed to start $coreName: ${e.message}'); throw Exception('Failed to start sysproxy: ${e.message}'); } } else { await proxyManager.setAsSystemProxy( ProxyTypes.http, "127.0.0.1", port, ); await proxyManager.setAsSystemProxy( ProxyTypes.https, "127.0.0.1", port, ); systemProxy = true; } } // // port = port ?? mixedPort ?? 0; // if (port != 0) { // } socksPort = socksPort ?? mixedPort ?? 0; if (socksPort != 0) { if (!Platform.isWindows) { await proxyManager.setAsSystemProxy( ProxyTypes.socks, "127.0.0.1", socksPort, ); } systemProxy = true; } } /// 关闭代理 Future closeProxy() async { // if (Platform.isWindows) { try { var result = await Process.run( Files.assetsSysProxyWin.path, ['set','1','','',''], runInShell: true, ); LogHelper().d(result.stderr); LogHelper().d(result.stdout); } on ProcessException catch (e) { //.e('Failed to start $coreName: ${e.message}'); throw Exception('Failed to start sysproxy: ${e.message}'); } proxyManager.cleanSystemProxy(); } systemProxy = false; } Future stopAllCore() async { await systemProxySwitch(false); if(Platform.isWindows){ await controllers.service.stopClashCore(); } else if(Platform.isMacOS) { await controllers.service.fetchStop(); } if(!controllers.service.serviceMode.value){{ if(Platform.isWindows){ await onKillProcess(path.basename(Files.assetsCCore.path)); } await killProcess(path.basename(Files.assetsCCore.path)); }} if(!controllers.service.serviceMode.value){ await killProcess(path.basename(Files.assetsClashService.path)); } } Future handleExit() async { await stopAllCore(); await trayManager.destroy(); await windowManager.destroy(); // exit(0); } void handleApiError(dynamic error) { if (error is AppException) { LogHelper().d('API error with status code: ${error.statusCode}'); statusCode.value = error.statusCode ?? -1; errorMsg.value = error.toString(); } else { LogHelper().d('Other error: $error'); errorMsg.value = error.toString(); } } @override void dispose() { controllers.tray.dispose(); controllers.window.dispose(); //controllers.protocol.dispose(); super.dispose(); } }