Add message RedirectServerAddress

pjlt · Apr 28, 2024 · 6aff288 · 6aff288
1 parent 38f44b4
commit 6aff288
Show file tree

Hide file tree

Showing 3 changed files with 15 additions and 1 deletion.
diff --git a/ltproto b/ltproto
diff --git a/ltsvr/src/main/java/cn/lanthing/svr/controller/ControlledController.java b/ltsvr/src/main/java/cn/lanthing/svr/controller/ControlledController.java
@@ -101,6 +101,13 @@ public void onConnectionUnexpectedlyClosed(long connectionID) {
     public LtMessage handleLoginDevice(long connectionID, LoginDeviceProto.LoginDevice msg) {
         //注意与ControllingController的区别
         log.info("Handle LoginDevice(connectionID:{}, deviceID:{})", connectionID, msg.getDeviceId());
+        var someCondition = false;
+        if (someCondition) {
+            var redirect = RedirectServerAddressProto.RedirectServerAddress.newBuilder();
+            redirect.setHost("somehost");
+            redirect.setPort(1234);
+            return new LtMessage(LtProto.RedirectServerAddress.ID, redirect.build());
+        }
         var ack = LoginDeviceAckProto.LoginDeviceAck.newBuilder();
         UsedID usedID = deviceIDService.getUsedDeviceID(msg.getDeviceId());
         if (usedID == null) {

diff --git a/ltsvr/src/main/java/cn/lanthing/svr/controller/ControllingController.java b/ltsvr/src/main/java/cn/lanthing/svr/controller/ControllingController.java
@@ -127,6 +127,13 @@ public LtMessage handleAllocateDeviceID(long connectionID, AllocateDeviceIDProto
     public LtMessage handleLoginDevice(long connectionID, LoginDeviceProto.LoginDevice msg) {
         //注意与ControlledController的区别
         log.info("Handle LoginDevice(connectionID:{}, deviceID:{})", connectionID, msg.getDeviceId());
+        var someCondition = false;
+        if (someCondition) {
+            var redirect = RedirectServerAddressProto.RedirectServerAddress.newBuilder();
+            redirect.setHost("somehost");
+            redirect.setPort(1234);
+            return new LtMessage(LtProto.RedirectServerAddress.ID, redirect.build());
+        }
         var ack = LoginDeviceAckProto.LoginDeviceAck.newBuilder();
         UsedID usedID = deviceIDService.getUsedDeviceID(msg.getDeviceId());
         if (usedID == null) {
+6 −0		CMakeLists.txt
+27 −0		defines.json
+18 −0		include/ltproto/ltproto.h
+11 −0		ltproto/app/file_chunk.proto
+10 −0		ltproto/app/file_chunk_ack.proto
+10 −0		ltproto/app/pull_file.proto
+6 −0		ltproto/common/clipboard.proto
+1 −0		ltproto/error_code.proto
+11 −0		ltproto/server/redirect_server_address.proto
+19 −0		ltproto/worker2service/network_changed.proto
+35 −0		src/ltproto.cpp
+2 −0		src/main/java/cn/lanthing/ltproto/LtProto.java