service.dart 13 KB

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