config.dart 5.8 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162
  1. import 'dart:io';
  2. import 'dart:convert';
  3. import 'package:dio/dio.dart';
  4. import 'package:get/get.dart';
  5. import 'package:naiyouwl/app/bean/config.dart';
  6. import 'package:naiyouwl/app/const/const.dart';
  7. import 'package:yaml/yaml.dart';
  8. import 'package:path/path.dart' as path;
  9. import 'package:flutter_emoji/flutter_emoji.dart';
  10. final Map<String, dynamic> _defaultConfig = {
  11. 'selected': 'example.yaml',
  12. 'updateInterval': 86400,
  13. 'updateSubsAtStart': false,
  14. 'setSystemProxy': false,
  15. 'startAtLogin': false,
  16. 'breakConnections': false,
  17. 'language': 'zh_CN',
  18. 'subs': [],
  19. };
  20. class ConfigController extends GetxController {
  21. late final dio;
  22. var config = Config.fromJson(_defaultConfig).obs;
  23. var clashCoreApiAddress = '127.0.0.1:9090'.obs;
  24. var clashCoreApiSecret = ''.obs;
  25. var clashCoreDns = ''.obs;
  26. var clashCoreTunEnable = false.obs;
  27. Future<void> initConfig() async {
  28. //dio.addSentry();
  29. dio = Dio(BaseOptions(baseUrl: clashCoreApiAddress.value));
  30. if (!await Paths.config.exists()) await Paths.config.create(recursive: true);
  31. if (!await Files.configCountryMmdb.exists()) await Files.assetsCountryMmdb.copy(Files.configCountryMmdb.path);
  32. if (Platform.isWindows && !await Files.configWintun.exists()) await Files.assetsWintun.copy(Files.configWintun.path);
  33. final locale = Get.deviceLocale!;
  34. _defaultConfig['language'] = '${locale.languageCode}_${locale.countryCode}';
  35. if (await Files.configConfig.exists()) {
  36. final local = json.decode(await Files.configConfig.readAsString());
  37. config.value = Config.fromJson({..._defaultConfig, ...local});
  38. } else {
  39. config.value = Config.fromJson(_defaultConfig);
  40. }
  41. if (config.value.subs.isEmpty) {
  42. if (!await Files.configExample.exists()) await Files.assetsExample.copy(Files.configExample.path);
  43. config.value.subs.add(ConfigSub(name: 'example.yaml', url: '', updateTime: 0));
  44. config.value.selected = 'example.yaml';
  45. }
  46. await readClashCoreApi();
  47. }
  48. Future<void> save() async {
  49. await Files.configConfig.writeAsString(json.encode(config.toJson()));
  50. }
  51. Future<void> readClashCoreApi() async {
  52. final configStr = await File(path.join(Paths.config.path, config.value.selected)).readAsString();
  53. // final emoji = EmojiParser();
  54. // final b = emoji.unemojify(_config);
  55. final configJson = loadYaml(configStr.replaceAll(EmojiParser.REGEX_EMOJI, 'emoji'));
  56. // print(_json["external-controller"]);
  57. // https://github.com/dart-lang/yaml/issues/53
  58. // final _extControl = RegExp(r'''(?<!#\s*)external-controller:\s+['"]?([^'"]+?)['"]?\s''').firstMatch(_config)?.group(1);
  59. // final _secret = RegExp(r'''(?<!#\s*)secret:\s+['"]?([^'"]+?)['"]?\s''').firstMatch(_config)?.group(1);
  60. clashCoreApiAddress.value = (configJson["external-controller"] ?? '127.0.0.1:9090').replaceAll('0.0.0.0', '127.0.0.1');
  61. clashCoreApiSecret.value = (configJson["secret"] ?? '');
  62. clashCoreTunEnable.value = configJson["tun"]?["enable"] == true;
  63. clashCoreDns.value = '';
  64. if (configJson["dns"]?["enable"] == true && (configJson["dns"]["listen"] ?? '').isNotEmpty) {
  65. final dns = (configJson["dns"]["listen"] as String).split(":");
  66. final ip = dns[0];
  67. final port = dns[1];
  68. if (port == '53') {
  69. clashCoreDns.value = ip == '0.0.0.0' ? '127.0.0.1' : ip;
  70. }
  71. }
  72. }
  73. Future<void> setLanguage(String language) async {
  74. config.value.language = language;
  75. await save();
  76. config.refresh();
  77. }
  78. Future<void> setSystemProxy(bool open) async {
  79. config.value.setSystemProxy = open;
  80. await save();
  81. config.refresh();
  82. }
  83. Future<void> setUpdateInterval(int value) async {
  84. config.value.updateInterval = value;
  85. await save();
  86. config.refresh();
  87. }
  88. Future<void> setUpdateSubsAtStart(bool value) async {
  89. config.value.updateSubsAtStart = value;
  90. await save();
  91. config.refresh();
  92. }
  93. Future<void> setSelectd(String selected) async {
  94. config.value.selected = selected;
  95. await save();
  96. config.refresh();
  97. }
  98. Future<bool> updateSub(ConfigSub sub) async {
  99. if ((sub.url ?? '').isEmpty) return false;
  100. final res = await dio.get(sub.url!);
  101. final subInfo = res.headers['subscription-userinfo'];
  102. final file = File(path.join(Paths.config.path, sub.name));
  103. final oldConfig = await file.exists() ? await file.readAsString() : '';
  104. final changed = oldConfig != res.data;
  105. if (changed) await file.writeAsString(res.data);
  106. sub.updateTime = DateTime.now().millisecondsSinceEpoch ~/ 1000;
  107. sub.info = null;
  108. if (subInfo != null) {
  109. final info = Map.fromEntries(
  110. subInfo.first.split(RegExp(r';\s*')).where((s) => s.isNotEmpty).map((e) => e.split('=')).map((e) => MapEntry(e[0], int.parse(e[1]))));
  111. sub.info = ConfigSubInfo.fromJson(info);
  112. }
  113. await setSub(sub.name, sub);
  114. return changed;
  115. }
  116. Future<void> setSub(String subName, ConfigSub sub) async {
  117. final idx = config.value.subs.indexWhere((it) => it.name == subName);
  118. config.value.subs[idx] = sub;
  119. if (subName != sub.name) {
  120. final file = File(path.join(Paths.config.path, subName));
  121. if (await file.exists()) await file.rename(path.join(Paths.config.path, sub.name));
  122. }
  123. await save();
  124. config.refresh();
  125. }
  126. Future<void> addSub(ConfigSub sub) async {
  127. config.value.subs.add(sub);
  128. final file = File(path.join(Paths.config.path, sub.name));
  129. if (!await file.exists()) await file.create();
  130. await save();
  131. config.refresh();
  132. }
  133. Future<void> deleteSub(String subName) async {
  134. final file = File(path.join(Paths.config.path, subName));
  135. if (await file.exists()) await file.delete();
  136. config.value.subs.removeWhere((it) => it.name == subName);
  137. await save();
  138. config.refresh();
  139. }
  140. Future<void> setBreakConnections(bool value) async {
  141. config.value.breakConnections = value;
  142. await save();
  143. config.refresh();
  144. }
  145. }