service.dart 8.6 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260
  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/const/const.dart';
  8. import 'package:naiyouwl/app/controller/controllers.dart';
  9. import 'package:naiyouwl/app/utils/logger.dart';
  10. import 'package:naiyouwl/app/utils/shell.dart';
  11. import 'package:naiyouwl/app/utils/system_dns.dart';
  12. import 'package:naiyouwl/app/utils/system_proxy.dart';
  13. import 'package:naiyouwl/app/utils/utils.dart';
  14. import 'package:path/path.dart' as path;
  15. import 'package:flutter/foundation.dart';
  16. import 'package:bot_toast/bot_toast.dart';
  17. import 'package:web_socket_channel/io.dart';
  18. final headers = {"User-Agent": "ccore-for-flutter/0.0.1"};
  19. class ServiceController extends GetxController {
  20. late final _dio = Dio(BaseOptions(baseUrl: 'http://127.0.0.1:9899', headers: headers));
  21. var serviceMode = false.obs;
  22. var coreStatus = RunningState.stoped.obs;
  23. var serviceStatus = RunningState.stoped.obs;
  24. Process? clashServiceProcess;
  25. bool get isRunning => serviceStatus.value == RunningState.running && coreStatus.value == RunningState.running;
  26. bool get isCanOperationService =>
  27. ![RunningState.starting, RunningState.stopping].contains(serviceStatus.value) &&
  28. ![RunningState.starting, RunningState.stopping].contains(coreStatus.value);
  29. bool get isCanOperationCore =>
  30. serviceStatus.value == RunningState.running && ![RunningState.starting, RunningState.stopping].contains(coreStatus.value);
  31. ServiceController(
  32. );
  33. Future<void> initConfig() async{
  34. _dio.options.baseUrl = 'http://127.0.0.1:${controllers.config.config.value.servicePort}';
  35. }
  36. Future<void> startService() async {
  37. serviceStatus.value = RunningState.starting;
  38. if (Platform.isLinux) {
  39. await fixBinaryExecutePermissions(Files.assetsClashService);
  40. await fixBinaryExecutePermissions(Files.assetsClashCore);
  41. }
  42. try {
  43. final data = await fetchInfo();
  44. serviceMode.value = data.mode == 'service-mode';
  45. } catch (e) {
  46. await startUserModeService();
  47. if (serviceStatus.value == RunningState.error) return;
  48. }
  49. serviceStatus.value = RunningState.running;
  50. }
  51. Future<void> fixBinaryExecutePermissions(File file) async {
  52. final stat = await file.stat();
  53. // 0b001000000
  54. final has = (stat.mode & 64) == 64;
  55. if (has) return;
  56. await Process.run('chmod', ['+x', file.path]);
  57. }
  58. Future<void> startUserModeService() async {
  59. serviceMode.value = false;
  60. try {
  61. int? exitCode;
  62. clashServiceProcess = await Process.start(Files.assetsClashService.path, ['user-mode'], mode: ProcessStartMode.inheritStdio);
  63. clashServiceProcess!.exitCode.then((code) => exitCode = code);
  64. while (true) {
  65. await Future.delayed(const Duration(milliseconds: 200));
  66. if (exitCode == 101) {
  67. BotToast.showText(text: 'clash-service exit with code: $exitCode,After 10 seconds, try to restart');
  68. log.error('After 10 seconds, try to restart');
  69. await Future.delayed(const Duration(seconds: 10));
  70. await startUserModeService();
  71. break;
  72. } else if (exitCode != null) {
  73. serviceStatus.value = RunningState.error;
  74. break;
  75. }
  76. try {
  77. await _dio.post('/info');
  78. break;
  79. } catch (_) {}
  80. }
  81. } catch (e) {
  82. serviceStatus.value = RunningState.error;
  83. BotToast.showText(text: e.toString());
  84. }
  85. }
  86. Future<void> stopService() async {
  87. serviceStatus.value = RunningState.stopping;
  88. if (coreStatus.value == RunningState.running) await stopClashCore();
  89. if (!serviceMode.value) {
  90. if (clashServiceProcess != null) {
  91. clashServiceProcess!.kill();
  92. clashServiceProcess = null;
  93. } else if (kDebugMode) {
  94. await killProcess(path.basename(Files.assetsClashService.path));
  95. }
  96. }
  97. serviceStatus.value = RunningState.stoped;
  98. }
  99. // for macos
  100. Future<void> waitServiceStart() async {
  101. while (true) {
  102. await Future.delayed(const Duration(milliseconds: 100));
  103. try {
  104. await _dio.post('/info');
  105. break;
  106. } catch (_) {}
  107. }
  108. }
  109. // for windows
  110. Future<void> waitServiceStop() async {
  111. while (true) {
  112. await Future.delayed(const Duration(milliseconds: 100));
  113. try {
  114. await _dio.post('/info');
  115. } catch (e) {
  116. break;
  117. }
  118. }
  119. }
  120. Future<ClashServiceInfo> fetchInfo() async {
  121. final res = await _dio.post('/info');
  122. return ClashServiceInfo.fromJson(res.data);
  123. }
  124. IOWebSocketChannel fetchLogWs() {
  125. return IOWebSocketChannel.connect(Uri.parse('ws://127.0.0.1:${controllers.config.config.value.servicePort}/logs'), headers: headers);
  126. }
  127. Future<void> fetchStart(String name) async {
  128. await fetchStop();
  129. final res = await _dio.post<String>('/start', data: {
  130. "args": ['-d', Paths.config.path, '-f', path.join(Paths.config.path, name)]
  131. });
  132. if (json.decode(res.data!)["code"] != 0) throw json.decode(res.data!)["msg"];
  133. }
  134. Future<void> fetchStop() async {
  135. try {
  136. await _dio.post('/stop');
  137. } catch (e) {
  138. return;
  139. }
  140. }
  141. Future<void> install() async {
  142. final res = await runAsAdmin(Files.assetsClashService.path, ["stop", "uninstall", "install", "start"]);
  143. await initConfig();
  144. log.debug('install', res.stdout, res.stderr);
  145. if (res.exitCode != 0) throw res.stderr;
  146. await waitServiceStart();
  147. }
  148. Future<void> uninstall() async {
  149. final res = await runAsAdmin(Files.assetsClashService.path, ["stop", "uninstall"]);
  150. log.debug('uninstall', res.stdout, res.stderr);
  151. if (res.exitCode != 0) throw res.stderr;
  152. await waitServiceStop();
  153. }
  154. Future<void> serviceModeSwitch(bool open) async {
  155. if (serviceStatus.value == RunningState.running) await stopService();
  156. try {
  157. open ? await install() : await uninstall();
  158. var data = _dio.post("/info");
  159. print(data);
  160. } catch (e) {
  161. BotToast.showText(text: e.toString());
  162. }
  163. await startService();
  164. await startClashCore();
  165. }
  166. Future<void> startClashCore() async {
  167. try {
  168. coreStatus.value = RunningState.starting;
  169. await fetchStart(controllers.config.config.value.selected);
  170. controllers.core.setApi(controllers.config.clashCoreApiAddress.value, controllers.config.clashCoreApiSecret.value);
  171. while (true) {
  172. await Future.delayed(const Duration(milliseconds: 200));
  173. final info = await fetchInfo();
  174. print("core --- info $info");
  175. if (info.status == 'running') {
  176. try {
  177. await controllers.core.fetchHello();
  178. break;
  179. } catch (_) {}
  180. } else {
  181. throw 'clash-core start error';
  182. }
  183. }
  184. await controllers.core.updateConfig();
  185. if (Platform.isMacOS &&
  186. controllers.service.serviceMode.value &&
  187. controllers.config.clashCoreTunEnable.value &&
  188. controllers.config.clashCoreDns.isNotEmpty) {
  189. await MacSystemDns.instance.set([controllers.config.clashCoreDns.value]);
  190. }
  191. if (controllers.config.config.value.setSystemProxy) await SystemProxy.instance.set(controllers.core.proxyConfig);
  192. coreStatus.value = RunningState.running;
  193. } catch (e) {
  194. log.error("core -- $e");
  195. BotToast.showText(text: e.toString());
  196. coreStatus.value = RunningState.error;
  197. }
  198. }
  199. Future<void> stopClashCore() async {
  200. coreStatus.value = RunningState.stopping;
  201. if (Platform.isMacOS &&
  202. controllers.service.serviceMode.value &&
  203. controllers.config.clashCoreTunEnable.value &&
  204. controllers.config.clashCoreDns.isNotEmpty) {
  205. await MacSystemDns.instance.set([]);
  206. }
  207. if (controllers.config.config.value.setSystemProxy) await SystemProxy.instance.set(SystemProxyConfig());
  208. await fetchStop();
  209. coreStatus.value = RunningState.stoped;
  210. }
  211. Future<void> reloadClashCore() async {
  212. BotToast.showText(text: '正在重启 Core ……');
  213. await stopClashCore();
  214. await controllers.config.readClashCoreApi();
  215. await startClashCore();
  216. if (coreStatus.value == RunningState.error) {
  217. BotToast.showText(text: '重启失败');
  218. } else {
  219. await controllers.core.updateVersion();
  220. BotToast.showText(text: '重启成功');
  221. }
  222. }
  223. Future<int> getFreePort() async {
  224. var server = await HttpServer.bind(InternetAddress.loopbackIPv4, 0);
  225. int port = server.port;
  226. await server.close();
  227. return port;
  228. }
  229. }