core.dart 4.4 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143
  1. import 'package:dio/dio.dart';
  2. import 'package:get/get.dart';
  3. import 'package:naiyouwl/app/bean/clash_core.dart';
  4. import 'package:naiyouwl/app/bean/connect.dart';
  5. import 'package:naiyouwl/app/bean/proxie.dart';
  6. import 'package:naiyouwl/app/bean/rule.dart';
  7. import 'package:naiyouwl/app/utils/system_proxy.dart';
  8. import 'package:web_socket_channel/io.dart';
  9. class CoreController extends GetxController {
  10. final dio = Dio(BaseOptions(baseUrl: 'http://127.0.0.1:9090'));
  11. var version = ClashCoreVersion(premium: true, version: '').obs;
  12. var address = ''.obs;
  13. var secret = ''.obs;
  14. var config = ClashCoreConfig(
  15. port: 0,
  16. socksPort: 0,
  17. redirPort: 0,
  18. tproxyPort: 0,
  19. mixedPort: 0,
  20. authentication: [],
  21. allowLan: false,
  22. bindAddress: '',
  23. mode: '',
  24. logLevel: '',
  25. ipv6: false,
  26. ).obs;
  27. var ruleProvider = RuleProvider(providers: {}).obs;
  28. var rule = Rule(rules: []).obs;
  29. CoreController() {
  30. //dio.addSentry();
  31. }
  32. SystemProxyConfig get proxyConfig {
  33. final mixedPort = config.value.mixedPort == 0 ? null : config.value.mixedPort;
  34. final httpPort = mixedPort ?? config.value.port;
  35. final httpsPort = mixedPort ?? config.value.port;
  36. final socksPort = mixedPort ?? config.value.socksPort;
  37. return SystemProxyConfig(
  38. http: httpPort == 0 ? null : '127.0.0.1:$httpPort',
  39. https: httpsPort == 0 ? null : '127.0.0.1:$httpsPort',
  40. socks: socksPort == 0 ? null : '127.0.0.1:$socksPort',
  41. );
  42. }
  43. setApi(String apiAddress, String apiSecret) {
  44. address.value = apiAddress;
  45. secret.value = apiSecret;
  46. dio.options.baseUrl = 'http://${address.value}';
  47. dio.options.headers['Authorization'] = 'Bearer ${secret.value}';
  48. }
  49. Future<dynamic> fetchHello() async {
  50. return await dio.get('/');
  51. }
  52. Future<void> updateVersion() async {
  53. final res = await dio.get('/version');
  54. version.value = ClashCoreVersion.fromJson(res.data);
  55. }
  56. Future<void> updateConfig() async {
  57. final res = await dio.get('/configs');
  58. config.value = ClashCoreConfig.fromJson(res.data);
  59. }
  60. Future<void> fetchConfigUpdate(Map<String, dynamic> config) async {
  61. await dio.patch('/configs', data: config);
  62. await updateConfig();
  63. }
  64. // type updateConfigRequest struct {
  65. // Path string `json:"path"`
  66. // Payload string `json:"payload"`
  67. // }
  68. // https://github.com/Dreamacro/clash/blob/c231fd14666d6ea05d6a75eaba6db69f9eee5ae9/hub/route/configs.go#L95
  69. Future<void> fetchReloadConfig(Map<String, String> config) async {
  70. await dio.put('/configs', data: config);
  71. }
  72. Future<void> fetchCloseConnections(String id) async {
  73. await dio.delete('/connections/${Uri.encodeComponent(id)}');
  74. }
  75. IOWebSocketChannel fetchConnectionsWs() {
  76. return IOWebSocketChannel.connect(
  77. Uri.parse('ws://${address.value}/connections'),
  78. headers: {"Authorization": dio.options.headers["Authorization"]},
  79. );
  80. }
  81. Future updateRuleProvider() async {
  82. final res = await dio.get('/providers/rules');
  83. ruleProvider.value = RuleProvider.fromJson(res.data);
  84. ruleProvider.refresh();
  85. }
  86. Future updateRule() async {
  87. final res = await dio.get('/rules');
  88. rule.value = Rule.fromJson(res.data);
  89. rule.refresh();
  90. }
  91. Future<void> fetchRuleProviderUpdate(String name) async {
  92. await dio.put('/providers/rules/${Uri.encodeComponent(name)}');
  93. }
  94. Future<Proxie> fetchProxie() async {
  95. final res = await dio.get('/proxies');
  96. return Proxie.fromJson(res.data);
  97. }
  98. Future<ProxieProvider> fetchProxieProvider() async {
  99. final res = await dio.get('/providers/proxies');
  100. return ProxieProvider.fromJson(res.data);
  101. }
  102. Future<void> fetchProxieProviderHealthCheck(String provider) async {
  103. await dio.get('/providers/proxies/${Uri.encodeComponent(provider)}/healthcheck');
  104. }
  105. Future<void> fetchSetProxieGroup(String group, String value) async {
  106. await dio.put('/proxies/${Uri.encodeComponent(group)}', data: {'name': value});
  107. }
  108. Future<void> fetchProxieProviderUpdate(String name) async {
  109. await dio.put('/providers/proxies/${Uri.encodeComponent(name)}');
  110. }
  111. Future<int> fetchProxieDelay(String name) async {
  112. final query = {'timeout': 5000, 'url': 'http://www.gstatic.com/generate_204'};
  113. final res = await dio.get('/proxies/${Uri.encodeComponent(name)}/delay', queryParameters: query);
  114. return res.data['delay'] ?? 0;
  115. }
  116. Future<Connect> fetchConnection() async {
  117. final res = await dio.get('/connections');
  118. return Connect.fromJson(res.data);
  119. }
  120. }