import 'dart:io'; 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/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/system_proxy.dart'; import 'package:naiyouwl/app/utils/utils.dart'; import 'package:shared_preferences/shared_preferences.dart'; import 'package:tray_manager/tray_manager.dart'; import 'package:window_manager/window_manager.dart'; class GlobalController extends GetxController { 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 systemProxySwitchIng = false.obs; bool allowStatusUpdate = false; 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(); await SharedPreferencesUtil().delete("last_successful_url"); // init plugins await controllers.tray.initTray(); controllers.window.initWindow(); //controllers.protocol.initProtocol(); await controllers.config.portDetection(); // init clash config // init config await controllers.config.initConfig(); await controllers.service.initConfig(); // init service await controllers.service.startService(); if (controllers.service.serviceStatus.value != RunningState.running) return; // await controllers.service.serviceModeSwitch(true); // init clash core await controllers.service.initClashCoreConfig(); if (controllers.service.coreStatus.value != RunningState.running) return; await controllers.core.updateVersion(); //initRegularlyUpdate(); } 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; } 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 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); await updateDate(); final conn = await controllers.core.fetchConnection(); for (final it in conn.connections) { if (it.chains.contains(name)) controllers.core.fetchCloseConnections(it.id); } }catch (e) { LogHelper().d(e.toString()); } } // Future findProxieByName(String name) async { // return proxieGroups.firstWhere((proxie) => proxie['name'] == name, orElse: () => null); // } Future findProxieByName(String name) async { ProxieProxiesItem? result; try { result = proxieGroups.firstWhere((proxie) => proxie.all!.contains(name)); } catch (e) { // 在这里可以处理异常,或者只是简单地返回 null return null; } return result; } 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 systemProxySwitch(bool open) async { systemProxySwitchIng.value = true; await SystemProxy.instance.set(open ? controllers.core.proxyConfig : SystemProxyConfig()); await controllers.config.setSystemProxy(open); 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) { 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 handleExit() async { await systemProxySwitch(false); await controllers.service.stopService(); 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(); } }