rustdesk/lib/pages/server_page.dart

import 'dart:async';
import 'package:flutter/material.dart';
import 'package:flutter_hbb/main.dart';
import 'package:flutter_hbb/models/model.dart';
import 'package:provider/provider.dart';

import '../common.dart';
import 'home_page.dart';
import '../models/model.dart';

class ServerPage extends StatelessWidget implements PageShape {
  @override
  final title = "Share Screen";

  @override
  final icon = Icon(Icons.mobile_screen_share);

  @override
  final appBarActions = [
    PopupMenuButton<String>(
        itemBuilder: (context) {
          return [
            PopupMenuItem(
              child: Text(translate("Change ID")),
              value: "changeID",
              enabled: false,
            ),
            PopupMenuItem(
              child: Text("Set your own password"),
              value: "changePW",
              enabled: false,
            )
          ];
        },
        onSelected: (value) => debugPrint("PopupMenuItem onSelected:$value"))
  ];

  @override
  Widget build(BuildContext context) {
    checkService();
    return ChangeNotifierProvider.value(
      value: FFI.serverModel,
      child: SingleChildScrollView(
        child: Center(
          child: Column(
            mainAxisAlignment: MainAxisAlignment.start,
            children: [
              ServerInfo(),
              PermissionChecker(),
              ConnectionManager(),
              SizedBox.fromSize(size: Size(0, 15.0)), // Bottom padding
            ],
          ),
        ),
      ),
    );
  }
}

void checkService() {
  // 检测当前服务状态，若已存在服务则异步更新数据回来
  FFI.invokeMethod("check_service"); // jvm
  FFI.serverModel.updateClientState();
}

class ServerInfo extends StatefulWidget {
  @override
  _ServerInfoState createState() => _ServerInfoState();
}

class _ServerInfoState extends State<ServerInfo> {
  var _passwdShow = false;

  // TODO set ID / PASSWORD
  var _serverId = TextEditingController(text: "");
  var _serverPasswd = TextEditingController(text: "");
  var _emptyIdShow = translate("connecting_status");

  @override
  void initState() {
    super.initState();
    var id = FFI.getByName("server_id");
    _serverId.text = id == "" ? _emptyIdShow : id;
    _serverPasswd.text = FFI.getByName("server_password");
    if (_serverId.text == _emptyIdShow || _serverPasswd.text == "") {
      fetchConfigAgain();
    }
  }

  @override
  Widget build(BuildContext context) {
    return myCard(Column(
      mainAxisSize: MainAxisSize.min,
      children: [
        TextFormField(
          readOnly: true,
          style: TextStyle(
              fontSize: 25.0,
              fontWeight: FontWeight.bold,
              color: MyTheme.accent),
          controller: _serverId,
          decoration: InputDecoration(
            icon: const Icon(Icons.perm_identity),
            labelText: translate("ID"),
            labelStyle:
                TextStyle(fontWeight: FontWeight.bold, color: MyTheme.accent50),
          ),
          onSaved: (String? value) {},
        ),
        TextFormField(
          readOnly: true,
          obscureText: !_passwdShow,
          style: TextStyle(
              fontSize: 25.0,
              fontWeight: FontWeight.bold,
              color: MyTheme.accent),
          controller: _serverPasswd,
          decoration: InputDecoration(
              icon: const Icon(Icons.lock),
              labelText: translate("Password"),
              labelStyle: TextStyle(
                  fontWeight: FontWeight.bold, color: MyTheme.accent50),
              suffix: IconButton(
                  icon: Icon(Icons.visibility),
                  onPressed: () {
                    setState(() {
                      _passwdShow = !_passwdShow;
                    });
                  })),
          onSaved: (String? value) {},
        ),
      ],
    ));
  }

  fetchConfigAgain() async {
    FFI.setByName("start_service");
    var count = 0;
    const maxCount = 10;
    while (count < maxCount) {
      if (_serverId.text != _emptyIdShow && _serverPasswd.text != "") {
        break;
      }
      await Future.delayed(Duration(seconds: 2));
      var id = FFI.getByName("server_id");
      _serverId.text = id == "" ? _emptyIdShow : id;
      _serverPasswd.text = FFI.getByName("server_password");
      debugPrint(
          "fetch id & passwd again at $count:id:${_serverId.text},passwd:${_serverPasswd.text}");
      count++;
    }
    FFI.setByName("stop_service");
  }
}

class PermissionChecker extends StatefulWidget {
  @override
  _PermissionCheckerState createState() => _PermissionCheckerState();
}

class _PermissionCheckerState extends State<PermissionChecker> {
  @override
  Widget build(BuildContext context) {
    final serverModel = Provider.of<ServerModel>(context);

    return myCard(Column(
      crossAxisAlignment: CrossAxisAlignment.start,
      children: [
        cardTitle(translate("Configuration Permissions")),
        PermissionRow(
            translate("Media"), serverModel.mediaOk, _toAndroidInitService),
        const Divider(height: 0),
        PermissionRow(
            translate("Input"), serverModel.inputOk, showInputWarnAlert),
        const Divider(),
        serverModel.mediaOk
            ? ElevatedButton.icon(
                style: ButtonStyle(
                    backgroundColor: MaterialStateProperty.all(Colors.red)),
                icon: Icon(Icons.stop),
                onPressed: _toAndroidStopService,
                label: Text(translate("Stop service")))
            : ElevatedButton.icon(
                icon: Icon(Icons.play_arrow),
                onPressed: _toAndroidInitService,
                label: Text(translate("Start Service"))),
      ],
    ));
  }
}

Widget getConnInfo(String name, String peerID) {
  return Row(
    children: [
      CircleAvatar(child: Text(name[0]), backgroundColor: MyTheme.border),
      SizedBox(width: 12),
      Text(name, style: TextStyle(color: MyTheme.idColor)),
      SizedBox(width: 8),
      Text(peerID, style: TextStyle(color: MyTheme.idColor))
    ],
  );
}

void showLoginReqAlert(String peerID, String name) async {
  if (globalKey.currentContext == null) return;
  await showDialog(
      barrierDismissible: false,
      context: globalKey.currentContext!,
      builder: (alertContext) {
        DialogManager.reset();
        DialogManager.register(alertContext);
        return AlertDialog(
          title: Text("Control Request"),
          content: Container(
              height: 100,
              child: Column(
                mainAxisAlignment: MainAxisAlignment.center,
                crossAxisAlignment: CrossAxisAlignment.start,
                children: [
                  Text(translate("Do you accept?")),
                  SizedBox(height: 20),
                  getConnInfo(name, peerID),
                ],
              )),
          actions: [
            TextButton(
                child: Text(translate("Dismiss")),
                onPressed: () {
                  FFI.setByName("login_res", "false");
                  DialogManager.reset();
                }),
            ElevatedButton(
                child: Text(translate("Accept")),
                onPressed: () {
                  FFI.setByName("login_res", "true");
                  if (!FFI.serverModel.isFileTransfer) {
                    _toAndroidStartCapture();
                  }
                  FFI.serverModel.setPeer(true);
                  DialogManager.reset();
                }),
          ],
        );
      });
  DialogManager.reset();
}

class PermissionRow extends StatelessWidget {
  PermissionRow(this.name, this.isOk, this.onPressed);

  final String name;
  final bool isOk;
  final VoidCallback onPressed;

  @override
  Widget build(BuildContext context) {
    return Row(
      mainAxisAlignment: MainAxisAlignment.spaceBetween,
      children: [
        Row(
          children: [
            SizedBox(
                width: 60,
                child: Text(name + ":",
                    style: TextStyle(fontSize: 16.0, color: MyTheme.accent50))),
            SizedBox(
              width: 50,
              child: Text(isOk ? translate("ON") : translate("OFF"),
                  style: TextStyle(
                      fontSize: 16.0,
                      color: isOk ? Colors.green : Colors.grey)),
            )
          ],
        ),
        TextButton(
            onPressed: isOk ? null : onPressed,
            child: Text(
              translate("OPEN"),
              style: TextStyle(fontWeight: FontWeight.bold),
            )),
      ],
    );
  }
}

class ConnectionManager extends StatelessWidget {
  @override
  Widget build(BuildContext context) {
    final serverModel = Provider.of<ServerModel>(context);
    return serverModel.isPeerStart
        ? myCard(Column(
            crossAxisAlignment: CrossAxisAlignment.start,
            children: [
              cardTitle(translate("Connection")), // TODO t
              Padding(
                padding: EdgeInsets.symmetric(vertical: 5.0),
                child: getConnInfo(serverModel.peerName, serverModel.peerID),
              ),
              ElevatedButton.icon(
                  style: ButtonStyle(
                      backgroundColor: MaterialStateProperty.all(Colors.red)),
                  icon: Icon(Icons.close),
                  onPressed: () {
                    FFI.setByName("close_conn");
                    // _toAndroidStopCapture();
                    serverModel.setPeer(false);
                  },
                  label: Text(translate("Close")))
            ],
          ))
        : SizedBox.shrink();
  }
}

Widget cardTitle(String text) {
  return Padding(
      padding: EdgeInsets.symmetric(vertical: 5.0),
      child: Text(
        text,
        style: TextStyle(
          fontFamily: 'WorkSans',
          fontWeight: FontWeight.bold,
          fontSize: 22,
          color: MyTheme.accent80,
        ),
      ));
}

Widget myCard(Widget child) {
  return Container(
      width: double.maxFinite,
      child: Card(
        margin: EdgeInsets.fromLTRB(15.0, 15.0, 15.0, 0),
        child: Padding(
          padding: EdgeInsets.symmetric(vertical: 15.0, horizontal: 30.0),
          child: child,
        ),
      ));
}

Future<Null> _toAndroidInitService() async {
  bool res = await FFI.invokeMethod("init_service");
  FFI.setByName("start_service");
  debugPrint("_toAndroidInitService:$res");
}

Future<Null> _toAndroidStartCapture() async {
  bool res = await FFI.invokeMethod("start_capture");
  debugPrint("_toAndroidStartCapture:$res");
}

// Future<Null> _toAndroidStopCapture() async {
//   bool res = await FFI.invokeMethod("stop_capture");
//   debugPrint("_toAndroidStopCapture:$res");
// }

Future<Null> _toAndroidStopService() async {
  FFI.setByName("close_conn");
  FFI.serverModel.setPeer(false);

  bool res = await FFI.invokeMethod("stop_service");
  FFI.setByName("stop_service");
  debugPrint("_toAndroidStopSer:$res");
}

Future<Null> _toAndroidInitInput() async {
  bool res = await FFI.invokeMethod("init_input");
  debugPrint("_toAndroidInitInput:$res");
}

showInputWarnAlert() async {
  if (globalKey.currentContext == null) return;
  DialogManager.reset();
  await showDialog<bool>(
      context: globalKey.currentContext!,
      builder: (alertContext) {
        // TODO t
        DialogManager.register(alertContext);
        return AlertDialog(
          title: Text("获取输入权限引导"),
          // content: Text("请在接下来的系统设置页面 \n进入 [服务] 配置页面\n将[RustDesk Input]服务开启"),
          content: Text.rich(TextSpan(style: TextStyle(), children: [
            TextSpan(text: "请在接下来的系统设置页\n进入"),
            TextSpan(text: " [服务] ", style: TextStyle(color: MyTheme.accent)),
            TextSpan(text: "配置页面\n将"),
            TextSpan(
                text: " [RustDesk Input] ",
                style: TextStyle(color: MyTheme.accent)),
            TextSpan(text: "服务开启")
          ])),
          actions: [
            TextButton(
                child: Text(translate("Do nothing")),
                onPressed: () {
                  DialogManager.reset();
                }),
            ElevatedButton(
                child: Text(translate("Go System Setting")),
                onPressed: () {
                  _toAndroidInitInput();
                  DialogManager.reset();
                }),
          ],
        );
      });
  DialogManager.reset();
}

void toAndroidChannelInit() {
  FFI.setMethodCallHandler((method, arguments) {
    debugPrint("flutter got android msg,$method,$arguments");
    try {
      switch (method) {
        case "try_start_without_auth":
          {
            FFI.serverModel.updateClientState();
            debugPrint(
                "pre show loginAlert:${FFI.serverModel.isFileTransfer.toString()}");
            showLoginReqAlert(FFI.serverModel.peerID, FFI.serverModel.peerName);
            debugPrint("from jvm:try_start_without_auth done");
            break;
          }
        case "start_capture":
          {
            DialogManager.reset();
            FFI.serverModel.updateClientState();
            break;
          }
        case "stop_capture":
          {
            DialogManager.reset();
            FFI.serverModel.setPeer(false);
            break;
          }
        case "on_permission_changed":
          {
            var name = arguments["name"] as String;
            var value = arguments["value"] as String == "true";
            debugPrint("from jvm:on_permission_changed,$name:$value");
            FFI.serverModel.changeStatue(name, value);
            break;
          }
      }
    } catch (e) {
      debugPrint("MethodCallHandler err:$e");
    }
    return "";
  });
}