123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338339340341342343344345346347348349350351352353354355356357358359360361362363364365366367368369370371372373374375376377378379380381382383384385386387388389390391392393394395396397398399400401402403404405406407408409410411412413414415416417418419420421422423424425426427428429430431432433434435436437438439440441442443444445446447448449450451452453454455456457458459460461462463464465466467468469470471472473474475476477478479480481482483484485486487488489490 |
- import 'dart:async';
- import 'dart:io';
- import 'package:dart_json_mapper/dart_json_mapper.dart';
- import 'package:get/get.dart';
- import 'package:naiyouwl/app/common/constants.dart';
- import 'package:naiyouwl/app/const/const.dart';
- import 'package:naiyouwl/app/controller/GlobalController.dart';
- import 'package:naiyouwl/app/controller/controllers.dart';
- import 'package:naiyouwl/app/utils/shell.dart';
- import 'package:naiyouwl/app/utils/utils.dart';
- import 'package:url_launcher/url_launcher.dart';
- import '../../../common/LogHelper.dart';
- import '../../../common/SharedPreferencesUtil.dart';
- import '../../../component/connection_status.dart';
- import '../../../data/model/LocalUser.dart';
- import '../../../data/model/NodeMode.dart';
- import '../../../data/model/SysConfig.dart';
- import '../../../data/model/UserMode.dart';
- import '../../../network/api_service.dart';
- import '../../../routes/app_pages.dart';
- import 'package:path/path.dart' as path;
- enum ImageType {
- CUSTOMER,
- PROMOTION,
- TUTORIAL,
- RENEWAL,
- }
- class HomeController extends GetxController {
- //TODO: Implement HomeController
- var isLoading = false.obs;
- var sysConfig = SysConfig().obs;
- var localUsers = LocalUser().obs;
- var userMode = User().obs;
- var UsersysConfig = SysConfig().obs;
- var serviceStuatus = false.obs;
- var coreStuatus = false.obs;
- var connectStatus = Rx<ConnectionStatus>(ConnectionStatus.disconnected);
- var nodeModes = <NodeMode>[];
- var isConnect = false.obs;
- var errAdminMsg = false.obs;
- var errAdmin = ''.obs;
- var isInit = false.obs;
- var isServiceInstall = false.obs;
- bool get isRunning => connectStatus.value == ConnectionStatus.stopped && controllers.global.allowStatusUpdate;
- late final GlobalController globalController = controllers.global;
- StreamSubscription<RunningState>? _statusSubscription;
- final Map<ImageType, String> imageMap = {
- ImageType.CUSTOMER: "assets/images/main/customer.png",
- ImageType.PROMOTION: "assets/images/main/promotion.png",
- ImageType.TUTORIAL: "assets/images/main/tutorial.png",
- ImageType.RENEWAL: "assets/images/main/renewal.png",
- };
- void onImageTap(ImageType type) async {
- if(type == ImageType.CUSTOMER){
- await launchUrl(Uri.parse(UsersysConfig.value.userTicket ?? ""));
- } else if (type == ImageType.PROMOTION){
- await launchUrl(Uri.parse(UsersysConfig.value.affUrl ?? ""));
- } else if (type == ImageType.TUTORIAL){
- await launchUrl(Uri.parse(UsersysConfig.value.userDownload ?? ""));
- } else if (type == ImageType.RENEWAL){
- await launchUrl(Uri.parse(UsersysConfig.value.userBuy ?? ""));
- }
- LogHelper().d("${imageMap[type]} tapped as ${type.toString().split('.').last}");
- }
- void updateStatus(ConnectionStatus newStatus) {
- connectStatus.value = newStatus;
- }
- void _handleStateChange([dynamic _]) async {
- final coreStatus = controllers.service.coreStatus.value;
- final isVisible = controllers.window.isVisible.value;
- final serviceStatus = controllers.service.serviceStatus.value;
- // if(serviceStatus != RunningState.running){
- // updateStatus(ConnectionStatus.disconnected);
- // return;
- // }
- if (coreStatus == RunningState.running && isVisible && controllers.global.allowStatusUpdate) {
- // if(connectStatus.value == ConnectionStatus.connecting){
- // controllers.global.updateMsg("连接完成...");
- // }
- }
- }
- Future<void> handleButtonClick() async {
- if(userMode.value.enable != 1){
- controllers.global.handleApiError("账号禁用,刷新账号状态,或者重启软件");
- return;
- }
- if(connectStatus.value == ConnectionStatus.connecting ){
- return;
- }
- // 如果当前状态是已连接或正在连接,则停止服务
- if (connectStatus.value == ConnectionStatus.stopped) {
- controllers.global.allowStatusUpdate = false;
- await controllers.config.setBreakConnections(true);
- // // 停止服务
- if(Platform.isWindows)
- {
- await controllers.service.stopClash();
- }
- else
- {
- await controllers.service.fetchStartInit();
- }
- await controllers.global.systemProxySwitch(false);
- updateStatus(ConnectionStatus.disconnected);
- return;
- } else {
- controllers.config.config.value.selected = 'proxy.yaml';
- controllers.global.updateMsg("开始连接...");
- await controllers.config.setBreakConnections(true);
- controllers.global.allowStatusUpdate = true;
- var routeModes = controllers.global.routeModesSelect.value;
- if(routeModes == "tun"){
- controllers.global.updateMsg("正在启动网卡模式...");
- controllers.config.clashCoreTunEnable.value = true;
- controllers.global.startTunMode();
- if(controllers.service.serviceMode.value == false){
- if(Platform.isWindows)
- {
- if(!await isRunningAsAdmin()){
- controllers.global.updateMsg("网卡模式需要管理模式运行...");
- return;
- }
- } else {
- if(controllers.service.serviceMode.value == false){
- controllers.global.updateMsg("需要开启服务,才能使用...");
- return;
- }
- }
- //await controllers.service.serviceModeSwitch(true);
- serviceStuatus.value = true;
- }
- final coreStatus = controllers.service.coreStatus.value;
- final serverStatus = controllers.service.serviceStatus.value;
- if (coreStatus == RunningState.running){
- await controllers.service.reloadClashCore();
- }
- else{
- if(serverStatus == RunningState.running){
- await controllers.service.reloadClashCore();
- }
- }
- } else {
- controllers.global.updateMsg("正在启动系统模式...");
- controllers.config.clashCoreTunEnable.value = false;
- controllers.global.startSysMode();
- final coreStatus = controllers.service.coreStatus.value;
- final serverStatus = controllers.service.serviceStatus.value;
- if(Platform.isWindows){
- if (coreStatus == RunningState.running){
- controllers.global.updateMsg("正在重启内核...");
- await controllers.service.reloadClashCore();
- }
- }
- else{
- controllers.global.updateMsg("正在启动内核...");
- if(serverStatus == RunningState.running){
- await controllers.service.reloadClashCore();
- }
- }
- }
- updateStatus(ConnectionStatus.connecting);
- Future.delayed(const Duration(seconds: 5), () async {
- updateStatus(ConnectionStatus.stopped);
- await controllers.global.updateNode();
- //
- await controllers.tray.updateTray();
- if(routeModes == "tun"){
- if(Platform.isMacOS){
- await controllers.service.fetchSetDnsProxy();
- }
- controllers.global.updateMsg("启动tun模式完成...");
- }
- else{
- await controllers.global.systemProxySwitch(true);
- controllers.global.updateMsg("设置系统代理完成...");
- }
- isConnect.value = true;
- });
- }
- }
- void SetSysProxy() async{
- }
- Future<void> stopVpn() async {
- controllers.global.updateMsg("正在停止...");
- await controllers.global.systemProxySwitch(false);
- await controllers.config.setBreakConnections(true);
- await controllers.tray.updateTray();
- // // 停止服务
- await controllers.service.stopClash();
- //controllers.global.updateMsg("正在停止....");
- Future.delayed(const Duration(seconds: 1), () async {
- controllers.global.allowStatusUpdate = false;
- isConnect.value = false;
- updateStatus(ConnectionStatus.disconnected);
- controllers.global.updateMsg("停止完成,点击立即加速");
- });
- }
- Future<void> fetchAuthUser() async {
- try {
- if(Platform.isWindows)
- {
- if (!controllers.service.coreIsRuning){
- controllers.global.updateMsg("内核没有启动...");
- return;
- }
- }
- if(Platform.isMacOS){
- if(!controllers.service.serviceIsRuning)
- {
- controllers.global.updateMsg("服务内核没有启动...");
- return;
- }
- }
- if(controllers.global.routeModesSelect.value == "tun")
- {
- if(Platform.isWindows)
- {
- if(!await isRunningAsAdmin()){
- controllers.global.updateMsg("网卡模式需要管理模式运行...");
- errAdminMsg.value = true;
- errAdmin.value = "网卡模式需要用户管理员模式去运行,点击确定管理员模式重启如果无法重启,手动重启。";
- return;
- }
- } else {
- if(controllers.service.serviceMode.value == false){
- controllers.global.updateMsg("需要开启服务,才能使用,记得卸载服务才能卸载软件...");
- return;
- }
- }
- }
- if(Platform.isMacOS){
- if(!controllers.service.serviceMode.value)
- {
- if(!await controllers.global.onIsRunAdmin()){
- errAdminMsg.value = true;
- errAdmin.value = "当前用户没有管理员权限。系统代理,可能无法使用,可以安装服务来解决这个问题,或者开启用户的管理员许可";
- return;
- }
- }
- }
- if (controllers.global.allowStatusUpdate && connectStatus.value == ConnectionStatus.stopped || connectStatus.value == ConnectionStatus.connecting) {
- controllers.global.updateMsg("当前连接状态未停止,不要多次启动...");
- return;
- }
- if(isConnect.value == true){
- controllers.global.updateMsg("当前连接状态未停止,不要多次启动...");
- return;
- }
- controllers.global.updateMsg("正在身份验证...");
- final ret = await ApiService().fetchAuthUser(KAuthUser);
- if(controllers.global.selectMageNode.value == false){
- controllers.global.selectedNode.value = ret;
- controllers.global.selectNode(ret);
- controllers.global.updateMsg("获取自动节点完成...");
- }
- await handleButtonClick();
- } catch (e) {
- controllers.global.handleApiError(e);
- } finally {
- }
- }
- Future<void> fetchSysConfig() async {
- try {
- String? data = await SharedPreferencesUtil().getString("sysconfig");
- if(data != null){
- sysConfig.value =JsonMapper.deserialize<SysConfig>(data)!;
- }
- } catch (e) {
- controllers.global.handleApiError(e);
- } finally {
- }
- }
-
- Future<void> fetchUserinfo() async {
- try {
- isLoading.value = true;
- userMode.value = await ApiService().userinfo("/api/client/v4/userinfo");
- await globalController.fetchNodes();
- await fetchlUserUrl(localUsers.value.email ?? "",localUsers.value.password ?? "");
- //await controllers.global.makeProxy();
- //await controllers.global.initService();
- // //生成配置
- // await controllers.global.makeProxy();
- // // 开始重启服务
- // await controllers.service.reloadClashCore();
- } catch (e) {
- controllers.global.handleApiError(e);
- } finally {
- isLoading.value = false;
- }
- }
- Future<void> fetchNode() async {
- try {
- isLoading.value = true;
- await globalController.fetchNodes();
- } catch (e) {
- controllers.global.handleApiError(e);
- } finally {
- isLoading.value = false;
- }
- }
- Future<void> outlogin() async {
- if(connectStatus.value == ConnectionStatus.connecting || connectStatus.value == ConnectionStatus.stopped){
- controllers.global.handleApiError("当前连接状态无法退出(先停止加速)");
- return ;
- }
- await SharedPreferencesUtil().delete("token");
- try {
- //isLoading.value = true;
- await ApiService().fetchLogout(KLogout);
- } catch (e) {
- //errorMsg.value = e.toString();
- } finally {
- //isLoading.value = false;
- }
- Get.offNamed(Routes.LOGIN);
- }
- //await SharedPreferencesUtil().setObject("localUser", userModes.toJson());
- Future<void> fetchlUserUrl(String username,String password) async {
- try {
- isLoading.value = true;
- UsersysConfig.value = await ApiService().fetchUserSysConfig(kSysConfig,{"email":username,"password":password});
- } catch (e) {
- controllers.global.handleApiError(e);
- } finally {
- isLoading.value = false;
- }
- }
- Future<void> fetchLocalUser() async {
- try {
- String? userdata = await SharedPreferencesUtil().getString("localUser");
- if(userdata != null){
- localUsers.value = JsonMapper.deserialize<LocalUser>(userdata)!;
- }
- await fetchSysConfig();
- } catch (e) {
- controllers.global.handleApiError(e);
- } finally {
- }
- }
- Future<void> installService() async{
- if(serviceStuatus.value == false){
- controllers.global.updateMsg("正在安装服务");
- await controllers.service.serviceModeSwitch(true);
- serviceStuatus.value = true;
- }
- }
- Future<void> UninstallService() async{
- if(serviceStuatus.value){
- controllers.global.updateMsg("正在卸载服务");
- await controllers.service.serviceModeSwitch(false);
- serviceStuatus.value = false;
- }
- }
- Future<void> coreRestart() async{
- await controllers.service.reloadClashCore();
- }
- Future<void> coreInit() async{
- controllers.global.updateMsg("正在初始化内核");
- isInit.value = true;
- //controllers.protocol.initProtocol();
- await controllers.config.portDetection();
- // init clash config
- // init config
- await controllers.config.initConfig();
- await controllers.service.initConfig();
- await controllers.global.platformState();
- //判断clash 程序是否在启动中,如果是可以先停止
- if (Platform.isWindows){
- await controllers.global.onIsProcessRunning(path.basename(Files.assetsCCore.path));
- }
- if(Platform.isWindows){
- await controllers.service.initClashCoreConfig();
- if (controllers.service.coreStatus.value != RunningState.running) return;
- await controllers.core.updateVersion();
- final hello = await controllers.core.fetchHello();
- print(hello);
- } else {
- await controllers.service.startService();
- if (controllers.service.serviceStatus.value != RunningState.running) return;
- if(Platform.isMacOS){
- if(!await controllers.global.onIsRunAdmin()){
- isServiceInstall.value = true;
- }
- }
- }
- controllers.global.updateMsg("初始化内核完成");
- isInit.value = false;
- }
- void init(){
- Future.delayed(Duration.zero, () async {
- await fetchSysConfig();
- await fetchLocalUser();
- await fetchUserinfo();
- //controllers.global.initService();
- await coreInit();
- });
- }
- final count = 0.obs;
- @override
- void onInit() {
- super.onInit();
- _statusSubscription = controllers.service.coreStatus.stream.listen(_handleStateChange);
- init();
- }
- @override
- void onReady() {
- super.onReady();
- }
- @override
- void onClose() {
- _statusSubscription?.cancel();
- super.onClose();
- }
- bool GetEnable() => userMode.value.enable == 1;
- String GetUserName() => localUsers.value.email.toString();
- String GetExpiredAt() => "到期时间:${userMode.value.expiredAt}";
- String GetTraffic() => "用户流量:${userMode.value.unusedTraffic}";
- String GetNode() => controllers.global.selectedNode.value?.name ?? "未选择节点";
- String getHttp() => "http 127.0.0.1:${controllers.config.mixedPort.value}";
- String getSocket() => "sock 127.0.0.1:${controllers.config.mixedPort.value}";
- String getSerivce() => "${controllers.config.servicePort.value}";
- void RouteNode() => Get.toNamed(Routes.NODE);
- }
|