feat: fix deeplink

Author: MuZhou233

l10n_arb/intl_zh_CN.arb

@@ -28,6 +28,9 @@
   "loadingFailed": "加载失败",
   "emptyContent": "无内容",
   "noMoreContent": "没有更多内容",
+  "connect": "连接",
+  "serverConnectTestSuccess": "服务器连接成功 ↑↓ {delay}ms",
+  "serverConnectTestFailed": "服务器连接失败 {reason}",
 
   "durationJustNow": "刚刚",
   "durationSeconds": "{number} 秒前",

lib/bloc/main_bloc.dart

@@ -102,6 +102,49 @@ class MainBloc extends Bloc<MainEvent, MainState> {
       }
     }, transformer: droppable());
 
+    on<MainGetServerInfoEvent>((event, emit) async {
+      emit(MainGetServerInfoState(state, EventStatus.processing));
+      try {
+        var newState = state;
+        final startTime = DateTime.now();
+        final resp = await _repo.anonymousGetServerInfo(event.server);
+        final delay = DateTime.now().difference(startTime).inMilliseconds;
+        if (resp case Ok()) {
+          final info = resp.v;
+          final knownServerInfos = {
+            event.server.serverID: ServerInformation(
+              sourceCodeAddress: info.serverBinarySummary.sourceCodeAddress,
+              buildVersion: info.serverBinarySummary.buildVersion,
+              buildDate: info.serverBinarySummary.buildDate,
+              protocolVersion: info.protocolSummary.version,
+            ),
+            ...state.knownServerInfos,
+          };
+          final knownServerFeatureSummaries = {
+            event.server.serverID: info.featureSummary,
+            ...state.knownServerFeatureSummaries,
+          };
+          final knownServerInstanceSummaries = {
+            event.server.serverID: info.serverInstanceSummary,
+            ...state.knownServerInstanceSummaries,
+          };
+          newState = newState.copyWith(
+            knownServerInfos: knownServerInfos,
+            knownServerFeatureSummaries: knownServerFeatureSummaries,
+            knownServerInstanceSummaries: knownServerInstanceSummaries,
+          );
+          emit(MainGetServerInfoState(newState, EventStatus.success,
+              delay: delay));
+        } else if (resp case Err()) {
+          emit(MainGetServerInfoState(state, EventStatus.failed, msg: resp.e));
+        }
+      } catch (e) {
+        debugPrint(e.toString());
+        emit(MainGetServerInfoState(state, EventStatus.failed,
+            msg: e.toString()));
+      }
+    }, transformer: restartable());
+
     on<MainLoginEvent>((event, emit) async {
       emit(MainLoginState(state, EventStatus.processing));
       try {
@@ -137,6 +180,7 @@ class MainBloc extends Bloc<MainEvent, MainState> {
       if (event.server == null && state.currentServer == null) {
         return;
       }
+      emit(MainRefreshServerInfoState(state, EventStatus.processing));
       try {
         final currentServer = event.server ?? state.currentServer!;
         var newState = state;
@@ -175,9 +219,10 @@ class MainBloc extends Bloc<MainEvent, MainState> {
           final user = resp2.v;
           newState = newState.copyWith(currentUser: user.user);
         }
-        emit(newState);
+        emit(MainRefreshServerInfoState(newState, EventStatus.success));
       } catch (e) {
         debugPrint(e.toString());
+        emit(MainRefreshServerInfoState(state, EventStatus.failed));
       }
     }, transformer: restartable());
 

lib/bloc/main_event.dart

@@ -12,6 +12,12 @@ class MainInitEvent extends MainEvent {
   MainInitEvent(super.context);
 }
 
+class MainGetServerInfoEvent extends MainEvent {
+  final ServerConfig server;
+
+  MainGetServerInfoEvent(super.context, {required this.server});
+}
+
 class MainLoginEvent extends MainEvent {
   final ServerConfig? serverConfig;
   final String? password;

lib/bloc/main_state.dart

@@ -72,6 +72,22 @@ class MainInitState extends MainEventState {
   MainInitState(super.state, super.statusCode, {super.msg}) : super.clone();
 }
 
+class MainGetServerInfoState extends MainEventState {
+  MainGetServerInfoState(
+    super.state,
+    super.statusCode, {
+    super.msg,
+    this.delay,
+  }) : super.clone();
+
+  final int? delay;
+}
+
+class MainRefreshServerInfoState extends MainEventState {
+  MainRefreshServerInfoState(super.state, super.statusCode, {super.msg})
+      : super.clone();
+}
+
 class MainLoginState extends MainEventState {
   MainLoginState(super.state, super.statusCode, {super.msg}) : super.clone();
 }

lib/l10n/intl/messages_zh-CN.dart

@@ -55,6 +55,10 @@ class MessageLookup extends MessageLookupByLibrary {
 
   static String m12(server) => "注册到 ${server}";
 
+  static String m16(reason) => "服务器连接失败 ${reason}";
+
+  static String m17(delay) => "服务器连接成功 ↑↓ ${delay}ms";
+
   final messages = _notInlinedMessages(_notInlinedMessages);
   static Map<String, Function> _notInlinedMessages(_) => <String, Function>{
         "ACCOUNT_PLATFORM": MessageLookupByLibrary.simpleMessage("平台"),
@@ -164,6 +168,7 @@ class MessageLookup extends MessageLookupByLibrary {
         "clientSetting": MessageLookupByLibrary.simpleMessage("客户端设置"),
         "close": MessageLookupByLibrary.simpleMessage("关闭"),
         "confirm": MessageLookupByLibrary.simpleMessage("确认"),
+        "connect": MessageLookupByLibrary.simpleMessage("连接"),
         "connectInClient": MessageLookupByLibrary.simpleMessage("使用客户端登录"),
         "continueInCurrentServer": MessageLookupByLibrary.simpleMessage("继续使用"),
         "continueInWebVersion": MessageLookupByLibrary.simpleMessage("继续使用网页版"),
@@ -252,6 +257,8 @@ class MessageLookup extends MessageLookupByLibrary {
         "safari": MessageLookupByLibrary.simpleMessage("Safari"),
         "samsung": MessageLookupByLibrary.simpleMessage("三星"),
         "scanningLocalFiles": MessageLookupByLibrary.simpleMessage("正在扫描本地文件"),
+        "serverConnectTestFailed": m16,
+        "serverConnectTestSuccess": m17,
         "serverSetup": MessageLookupByLibrary.simpleMessage("服务器设置"),
         "settings": MessageLookupByLibrary.simpleMessage("设置"),
         "showServerConfig": MessageLookupByLibrary.simpleMessage("查看服务器信息"),

lib/l10n/l10n.dart

@@ -7,6 +7,7 @@ import 'package:go_router/go_router.dart';
 
 import 'bloc/deeplink_bloc.dart';
 import 'common/platform.dart';
+import 'view/pages/settings/server_select/server_select_page.dart';
 import 'view/specialized/theme_mode_toggle.dart';
 import 'view/specialized/title_bar.dart';
 
@@ -78,9 +79,15 @@ class _DeepLinkWidget extends StatelessWidget {
   @override
   Widget build(BuildContext context) {
     return BlocConsumer<DeepLinkBloc, DeepLinkState>(
-      listener: (context, state) {
+      listener: (context, state) async {
         if (state is DeepLinkConnectState) {
-          // TODO: Implement deep link handling
+          final navigator = Navigator.of(context);
+          await showDialog(
+            context: context,
+            builder: (context) {
+              return ServerLinkAddDialog(navigator, server: state.serverConfig);
+            },
+          );
         }
       },
       builder: (context, state) {

lib/main_window.dart

@@ -98,6 +98,14 @@ class MainRepo {
     return id;
   }
 
+  Future<Result<GetServerInformationResponse, String>> anonymousGetServerInfo(
+      ServerConfig config) async {
+    final client = await LibrarianService.grpc(ServerConfig(
+        host: config.host, port: config.port, enableTLS: config.enableTLS));
+    return client.doRequest(
+        (client) => client.getServerInformation, GetServerInformationRequest());
+  }
+
   Future<Result<GetServerInformationResponse, String>> getServerInfo(
       EventContext context) async {
     return _api.get(context.sid).doRequest(

lib/repo/main_repo.dart

@@ -40,7 +40,7 @@ import 'view/pages/settings/admin/user_edit_panel.dart';
 import 'view/pages/settings/admin/user_manage_page.dart';
 import 'view/pages/settings/client/client_setting_page.dart';
 import 'view/pages/settings/porter_context_page.dart';
-import 'view/pages/settings/server_select_page.dart';
+import 'view/pages/settings/server_select/server_select_page.dart';
 import 'view/pages/settings/session/session_edit_panel.dart';
 import 'view/pages/settings/session/session_manage_page.dart';
 import 'view/pages/settings/settings_nav.dart';