service.dart 11 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324
  1. import 'dart:io';
  2. import 'dart:async';
  3. import 'dart:convert';
  4. import 'package:dio/dio.dart';
  5. import 'package:get/get.dart';
  6. import 'package:naiyouwl/app/bean/ClashServiceInfo.dart';
  7. import 'package:naiyouwl/app/common/LogHelper.dart';
  8. import 'package:naiyouwl/app/const/const.dart';
  9. import 'package:naiyouwl/app/controller/controllers.dart';
  10. import 'package:naiyouwl/app/utils/logger.dart';
  11. import 'package:naiyouwl/app/utils/shell.dart';
  12. import 'package:naiyouwl/app/utils/system_dns.dart';
  13. import 'package:naiyouwl/app/utils/system_proxy.dart';
  14. import 'package:naiyouwl/app/utils/utils.dart';
  15. import 'package:path/path.dart' as path;
  16. import 'package:flutter/foundation.dart';
  17. import 'package:bot_toast/bot_toast.dart';
  18. import 'package:web_socket_channel/io.dart';
  19. final headers = {"User-Agent": "ccore-for-flutter/0.0.1"};
  20. class ServiceController extends GetxController {
  21. late final _dio = Dio(BaseOptions(baseUrl: 'http://127.0.0.1:9899', headers: headers));
  22. var serviceMode = false.obs;
  23. var coreStatus = RunningState.stoped.obs;
  24. var serviceStatus = RunningState.stoped.obs;
  25. Process? clashServiceProcess;
  26. bool get isRunning => serviceStatus.value == RunningState.running && coreStatus.value == RunningState.running;
  27. bool get isCanOperationService =>
  28. ![RunningState.starting, RunningState.stopping].contains(serviceStatus.value) &&
  29. ![RunningState.starting, RunningState.stopping].contains(coreStatus.value);
  30. bool get isCanOperationCore =>
  31. serviceStatus.value == RunningState.running && ![RunningState.starting, RunningState.stopping].contains(coreStatus.value);
  32. ServiceController(
  33. );
  34. Future<void> initConfig() async{
  35. _dio.options.baseUrl = 'http://127.0.0.1:${controllers.config.config.value.servicePort}';
  36. }
  37. Future<void> startTunService() async {
  38. try {
  39. while (true) {
  40. final data = await fetchInfo();
  41. if( data.mode != 'service-mode')
  42. {
  43. if (serviceStatus.value == RunningState.running) {
  44. await stopService();
  45. }
  46. await install();
  47. } else {
  48. break;
  49. }
  50. }
  51. } catch (e) {
  52. serviceStatus.value = RunningState.error;
  53. log.debug(e.toString());
  54. // BotToast.showText(text: e.toString());
  55. }
  56. }
  57. Future<void> startService() async {
  58. controllers.global.updateMsg("开启服务");
  59. serviceStatus.value = RunningState.starting;
  60. if (Platform.isLinux) {
  61. await fixBinaryExecutePermissions(Files.assetsClashService);
  62. await fixBinaryExecutePermissions(Files.assetsClashCore);
  63. }
  64. try {
  65. final data = await fetchInfo();
  66. serviceMode.value = data.mode == 'service-mode';
  67. controllers.global.updateMsg("服务模式");
  68. } catch (e) {
  69. await startUserModeService();
  70. controllers.global.updateMsg("开启用户服务");
  71. if (serviceStatus.value == RunningState.error) return;
  72. }
  73. serviceStatus.value = RunningState.running;
  74. }
  75. Future<void> fixBinaryExecutePermissions(File file) async {
  76. final stat = await file.stat();
  77. // 0b001000000
  78. final has = (stat.mode & 64) == 64;
  79. if (has) return;
  80. await Process.run('chmod', ['+x', file.path]);
  81. }
  82. Future<void> startUserModeService() async {
  83. serviceMode.value = false;
  84. try {
  85. int? exitCode;
  86. clashServiceProcess = await Process.start(Files.assetsClashService.path, ['-port','${controllers.config.config.value.servicePort}','user-mode'], mode: ProcessStartMode.inheritStdio);
  87. clashServiceProcess!.exitCode.then((code) => exitCode = code);
  88. while (true) {
  89. await Future.delayed(const Duration(milliseconds: 200));
  90. if (exitCode == 101) {
  91. BotToast.showText(text: 'clash-service exit with code: $exitCode,After 10 seconds, try to restart');
  92. log.error('After 10 seconds, try to restart');
  93. await Future.delayed(const Duration(seconds: 10));
  94. await startUserModeService();
  95. break;
  96. } else if (exitCode != null) {
  97. serviceStatus.value = RunningState.error;
  98. break;
  99. }
  100. try {
  101. await _dio.post('/info');
  102. break;
  103. } catch (_) {}
  104. }
  105. } catch (e) {
  106. serviceStatus.value = RunningState.error;
  107. BotToast.showText(text: e.toString());
  108. }
  109. }
  110. Future<void> stopService() async {
  111. serviceStatus.value = RunningState.stopping;
  112. if (coreStatus.value == RunningState.running) await stopClashCore();
  113. if (!serviceMode.value) {
  114. if (clashServiceProcess != null) {
  115. clashServiceProcess!.kill();
  116. clashServiceProcess = null;
  117. } else if (kDebugMode) {
  118. await killProcess(path.basename(Files.assetsClashService.path));
  119. }
  120. }
  121. serviceStatus.value = RunningState.stoped;
  122. }
  123. // for macos
  124. Future<void> waitServiceStart() async {
  125. while (true) {
  126. await Future.delayed(const Duration(milliseconds: 100));
  127. try {
  128. await _dio.post('/info');
  129. break;
  130. } catch (_) {}
  131. }
  132. }
  133. // for windows
  134. Future<void> waitServiceStop() async {
  135. while (true) {
  136. await Future.delayed(const Duration(milliseconds: 100));
  137. try {
  138. await _dio.post('/info');
  139. } catch (e) {
  140. break;
  141. }
  142. }
  143. }
  144. Future<ClashServiceInfo> fetchInfo() async {
  145. final res = await _dio.post('/info');
  146. return ClashServiceInfo.fromJson(res.data);
  147. }
  148. IOWebSocketChannel fetchLogWs() {
  149. return IOWebSocketChannel.connect(Uri.parse('ws://127.0.0.1:${controllers.config.config.value.servicePort}/logs'), headers: headers);
  150. }
  151. Future<void> fetchStart(String name) async {
  152. await fetchStop();
  153. final res = await _dio.post<String>('/start', data: {
  154. "args": ['-d', Paths.config.path, '-f', path.join(Paths.config.path, name)]
  155. });
  156. if (json.decode(res.data!)["code"] != 0) throw json.decode(res.data!)["msg"];
  157. }
  158. Future<void> fetchStop() async {
  159. try {
  160. await _dio.post('/stop');
  161. } catch (e) {
  162. return;
  163. }
  164. }
  165. Future<void> install() async {
  166. final res = await runAsAdmin(Files.assetsClashService.path, ["-port","${controllers.config.config.value.servicePort}","stop", "uninstall", "install", "start"]);
  167. await initConfig();
  168. log.debug('install', res.stdout, res.stderr);
  169. if (res.exitCode != 0) throw res.stderr;
  170. await waitServiceStart();
  171. }
  172. Future<void> uninstall() async {
  173. final res = await runAsAdmin(Files.assetsClashService.path, ["stop", "uninstall"]);
  174. log.debug('uninstall', res.stdout, res.stderr);
  175. if (res.exitCode != 0) throw res.stderr;
  176. await waitServiceStop();
  177. }
  178. Future<void> serviceModeSwitch(bool open) async {
  179. if (serviceStatus.value == RunningState.running) await stopService();
  180. try {
  181. controllers.global.updateMsg(open ? "安装服务" : "卸载服务");
  182. open ? await install() : await uninstall();
  183. } catch (e) {
  184. BotToast.showText(text: e.toString());
  185. }
  186. await startService();
  187. //await startClashCore();
  188. }
  189. Future<void> startClashCore() async {
  190. try {
  191. //controllers.global.updateMsg("启动内核");
  192. if( controllers.config.config.value.selected == 'init_proxy.yaml'){
  193. controllers.global.updateMsg("启动内核初始化");
  194. } else {
  195. controllers.global.updateMsg("启动内核");
  196. }
  197. coreStatus.value = RunningState.starting;
  198. await fetchStart(controllers.config.config.value.selected);
  199. log.debug("api${controllers.config.clashCoreApiAddress.value}");
  200. controllers.core.setApi(controllers.config.clashCoreApiAddress.value, controllers.config.clashCoreApiSecret.value);
  201. while (true) {
  202. await Future.delayed(const Duration(milliseconds: 200));
  203. final info = await fetchInfo();
  204. print("core --- info $info");
  205. if (info.status == 'running') {
  206. try {
  207. final ret = await controllers.core.fetchHello();
  208. log.debug("请求内核结果$ret---服务器状态${info.status}...");
  209. // controllers.global.updateMsg("请求内核结果$ret---服务器状态${info.status}...");
  210. break;
  211. } catch (_) {
  212. //controllers.global.updateMsg("请求内核错误${e.toString()}---服务器状态${info.status}...");
  213. }
  214. } else {
  215. controllers.global.updateMsg("启动内核错误---等待中...");
  216. throw 'clash-core start error';
  217. }
  218. }
  219. await controllers.core.updateConfig();
  220. if (Platform.isMacOS &&
  221. controllers.service.serviceMode.value &&
  222. controllers.config.clashCoreTunEnable.value &&
  223. controllers.config.clashCoreDns.isNotEmpty) {
  224. await MacSystemDns.instance.set([controllers.config.clashCoreDns.value]);
  225. }
  226. if (controllers.config.config.value.setSystemProxy) await SystemProxy.instance.set(controllers.core.proxyConfig);
  227. coreStatus.value = RunningState.running;
  228. controllers.global.updateMsg("内核状态:${coreStatus.value == RunningState.running} ");
  229. controllers.global.updateDate();
  230. } catch (e) {
  231. log.error("core -- $e");
  232. controllers.global.updateMsg("启动内核错误");
  233. controllers.global.handleApiError(e);
  234. // BotToast.showText(text: e.toString());
  235. coreStatus.value = RunningState.error;
  236. }
  237. }
  238. Future<void> stopClashCore() async {
  239. coreStatus.value = RunningState.stopping;
  240. if (Platform.isMacOS &&
  241. controllers.service.serviceMode.value &&
  242. controllers.config.clashCoreTunEnable.value &&
  243. controllers.config.clashCoreDns.isNotEmpty) {
  244. await MacSystemDns.instance.set([]);
  245. }
  246. if (controllers.config.config.value.setSystemProxy) await SystemProxy.instance.set(SystemProxyConfig());
  247. await fetchStop();
  248. coreStatus.value = RunningState.stoped;
  249. }
  250. Future<void> initClashCoreConfig() async {
  251. //await stopClashCore();
  252. await startClashCore();
  253. if (coreStatus.value == RunningState.error) {
  254. //BotToast.showText(text: '重启失败');
  255. } else {
  256. await controllers.core.updateVersion();
  257. //BotToast.showText(text: '重启成功');
  258. }
  259. }
  260. Future<void> stopClash() async {
  261. controllers.config.config.value.selected = 'init_proxy.yaml';
  262. if( coreStatus.value == RunningState.running){
  263. await controllers.core.fetchReloadConfig({"path": path.join(Paths.config.path, controllers.config.config.value.selected),"payload": ""});
  264. }
  265. }
  266. Future<void> reloadClashCore() async {
  267. controllers.config.config.value.selected = 'proxy.yaml';
  268. // if( coreStatus.value == RunningState.running){
  269. // await controllers.core.fetchReloadConfig({"path": path.join(Paths.config.path, controllers.config.config.value.selected),"payload":""});
  270. // }
  271. //BotToast.showText(text: '正在重启 Core ……');
  272. controllers.global.updateMsg("停止内核...");
  273. await stopClashCore();
  274. await controllers.config.readClashCoreApi();
  275. await startClashCore();
  276. if (coreStatus.value == RunningState.error) {
  277. controllers.global.updateMsg("启动内核失败...");
  278. } else {
  279. await controllers.core.updateVersion();
  280. controllers.global.updateMsg("启动内核成功...");
  281. }
  282. }
  283. Future<int> getFreePort() async {
  284. var server = await HttpServer.bind(InternetAddress.loopbackIPv4, 0);
  285. int port = server.port;
  286. await server.close();
  287. return port;
  288. }
  289. }