flutter_nayou/lib/app/modules/home/controllers/home_controller.dart

import 'dart:async';
import 'dart:io';

import 'package:dart_json_mapper/dart_json_mapper.dart';
import 'package:flutter/cupertino.dart';
import 'package:get/get.dart';
import 'package:naiyouwl/app/common/constants.dart';
import 'package:naiyouwl/app/component/dialogs.dart';
import 'package:naiyouwl/app/controller/GlobalController.dart';
import 'package:naiyouwl/app/controller/controllers.dart';
import 'package:naiyouwl/app/controller/service.dart';
import 'package:naiyouwl/app/modules/login/views/login_view.dart';
import 'package:naiyouwl/app/utils/system_proxy.dart';
import 'package:naiyouwl/app/utils/utils.dart';
import 'package:tray_manager/tray_manager.dart';
import 'package:url_launcher/url_launcher.dart';
import 'package:window_manager/window_manager.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';

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 errorMsg = ''.obs;
  var UsersysConfig = SysConfig().obs;
  var connectStatus = Rx<ConnectionStatus>(ConnectionStatus.disconnected);
  var nodeModes = <NodeMode>[];
  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.userLoginUrlKe ?? ""));
    } else if (type == ImageType.PROMOTION){
      await launchUrl(Uri.parse(UsersysConfig.value.affUrl ?? ""));
    } else if (type == ImageType.TUTORIAL){
      await launchUrl(Uri.parse(UsersysConfig.value.userTicket ?? ""));
    } 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) {
    //   updateStatus(ConnectionStatus.connecting);
    //   await Future.delayed(const Duration(seconds: 3));
    //   updateStatus(ConnectionStatus.stopped);
    // } else {
    //   LogHelper().d("stop coreStatus serivce");
    //   // var routeModes = controllers.global.routeModesSelect.value;
    //   // if(routeModes != "tun"){
    //   //   controllers.config.clashCoreTunEnable.value = false;
    //   // }
    //   // await controllers.global.systemProxySwitch(false);
    //   updateStatus(ConnectionStatus.disconnected);
    // }
  }

  Future<void> handleButtonClick() async {
    if(userMode.value.enable != 1){
      errorMsg.value = "用户是禁用的，无法连接";
      return;
    }


    if(connectStatus.value == ConnectionStatus.connecting ){
      return;
    }
    // 如果当前状态是已连接或正在连接，则停止服务
    if (connectStatus.value == ConnectionStatus.stopped) {
      controllers.global.allowStatusUpdate = false;
      await controllers.config.setBreakConnections(true);
      // // 停止服务
      await controllers.service.stopClash();
      await controllers.global.systemProxySwitch(false);
      updateStatus(ConnectionStatus.disconnected);
      return;
    } else {
      await controllers.config.setBreakConnections(true);
      controllers.global.allowStatusUpdate = true;
      var routeModes = controllers.global.routeModesSelect.value;
      if(routeModes == "tun"){
        controllers.config.clashCoreTunEnable.value = true;
        controllers.global.startTunMode();
        await controllers.service.startTunService();
        final coreStatus = controllers.service.coreStatus.value;
        if (coreStatus == RunningState.running){
          await controllers.service.reloadClashCore();
        }
        else{
          await controllers.service.startClashCore();
        }

      } else {

        controllers.config.clashCoreTunEnable.value = false;
        controllers.global.startSysMode();
        final coreStatus = controllers.service.coreStatus.value;
        if (coreStatus == RunningState.running){
          await controllers.service.reloadClashCore();
        }
        else{
          await controllers.service.startClashCore();
        }
        await controllers.global.systemProxySwitch(true);
      }

      updateStatus(ConnectionStatus.connecting);
      await Future.delayed(const Duration(seconds: 3));
      await controllers.global.updateNode();
      await controllers.global.updateDate();
      await controllers.tray.updateTray();
      updateStatus(ConnectionStatus.stopped);
    }
  }


  void SetSysProxy() async{

  }

  dynamic showError(BuildContext context) async {
    await showNormalDialog(context,
        title: '提示',
        content: errorMsg.value,
        enterText: '确认', cancelText: '',
        );
  }



  Future<void> stopVpn() async {
    controllers.global.allowStatusUpdate = false;
    await controllers.config.setBreakConnections(true);
    // // 停止服务
    await controllers.service.stopClashCore();
    await controllers.global.systemProxySwitch(false);
    updateStatus(ConnectionStatus.disconnected);
  }
  Future<void> fetchAuthUser() async {
    try {

      final ret  = await ApiService().fetchAuthUser(KAuthUser);
      controllers.global.selectedNode.value = ret;
      controllers.global.selectNode(ret);
      await handleButtonClick();
    } catch (e) {
      errorMsg.value = e.toString();
    } finally {
    }
  }

  Future<void> fetchSysConfig() async {
    try {
      String? data  = await SharedPreferencesUtil().getString("sysconfig");
      if(data  != null){
        sysConfig.value =JsonMapper.deserialize<SysConfig>(data)!;
      }

    } catch (e) {
      errorMsg.value = e.toString();
    } 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) {
      errorMsg.value = e.toString();
    } finally {
      isLoading.value = false;
    }
  }

  Future<void> fetchNode() async {
    try {
      isLoading.value = true;
      await globalController.fetchNodes();

    } catch (e) {
      errorMsg.value = e.toString();
    } finally {
      isLoading.value = false;
    }
  }

  Future<void> outlogin() async {
    if(connectStatus.value == ConnectionStatus.connecting || connectStatus.value == ConnectionStatus.stopped){
      errorMsg.value = "先断开，在退出登录";
      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) {
      errorMsg.value = e.toString();
    } 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) {
      errorMsg.value = e.toString();
    } finally {
    }
  }



  final count = 0.obs;
  @override
  void onInit() {
    super.onInit();
    _statusSubscription = controllers.service.coreStatus.stream.listen(_handleStateChange);

    fetchSysConfig();
    fetchLocalUser();
    fetchUserinfo();
    //controllers.global.initService();
  }

  @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.core.config.value.mixedPort}";
  String getSocket() => "socks 127.0.0.1:${controllers.core.config.value.mixedPort}";

  void RouteNode() =>  Get.toNamed(Routes.NODE);
}