add remote update but not finished

server/src/UdpClientPool.cs

@@ -1,6 +1,8 @@
 using System.Net;
 using System.Net.Sockets;
 using System.Text;
+using DotNext;
+using WebProtocol;
 
 /// <summary>
 /// UDP客户端发送池
@@ -161,4 +163,90 @@ public class UDPClientPool
 
         return isSuccessful;
     }
+
+    /// <summary>
+    /// [TODO:description]
+    /// </summary>
+    /// <param name="endPoint">[TODO:parameter]</param>
+    /// <param name="devAddr">[TODO:parameter]</param>
+    /// <param name="timeout">[TODO:parameter]</param>
+    /// <returns>[TODO:return]</returns>
+    public static async ValueTask<Result<RecvDataPackage>> ReadAddr(
+            IPEndPoint endPoint, uint devAddr, int timeout = 1000)
+    {
+        var ret = false;
+        var opts = new SendAddrPackOptions();
+
+        opts.BurstType = BurstType.FixedBurst;
+        opts.BurstLength = 0;
+        opts.CommandID = 0;
+        opts.Address = devAddr;
+
+        // Read Jtag State Register
+        opts.IsWrite = false;
+        ret = await UDPClientPool.SendAddrPackAsync(endPoint, new SendAddrPackage(opts));
+        if (!ret) return new(new Exception("Send Address Package Failed!"));
+
+        // Wait for Read Ack
+        if (!MsgBus.IsRunning)
+            return new(new Exception("Message Bus not Working!"));
+
+        var retPack = await MsgBus.UDPServer.WaitForDataAsync(
+                endPoint.Address.ToString(), endPoint.Port, timeout);
+        if (!retPack.IsSuccessful) return new(retPack.Error);
+        else if (!retPack.Value.IsSuccessful)
+            return new(new Exception("Send address package failed"));
+
+        var retPackOpts = retPack.Value.Options;
+        if (retPackOpts.Data is null)
+            return new(new Exception($"Data is Null, package: {retPackOpts.ToString()}"));
+
+        return retPack;
+    }
+
+    public static async ValueTask<Result<RecvDataPackage>> ReadAddrWithCheck(
+            IPEndPoint endPoint, uint devAddr, int timeout = 1000)
+    {
+    }
+
+
+    /// <summary>
+    /// [TODO:description]
+    /// </summary>
+    /// <param name="endPoint">[TODO:parameter]</param>
+    /// <param name="devAddr">[TODO:parameter]</param>
+    /// <param name="data">[TODO:parameter]</param>
+    /// <param name="timeout">[TODO:parameter]</param>
+    /// <returns>[TODO:return]</returns>
+    public static async ValueTask<Result<bool>> WriteAddr(
+            IPEndPoint endPoint, UInt32 devAddr, UInt32 data, int timeout = 1000)
+    {
+        var ret = false;
+        var opts = new SendAddrPackOptions();
+
+        opts.BurstType = BurstType.FixedBurst;
+        opts.BurstLength = 0;
+        opts.CommandID = 0;
+        opts.Address = devAddr;
+
+        // Write Jtag State Register
+        opts.IsWrite = true;
+        ret = await UDPClientPool.SendAddrPackAsync(endPoint, new SendAddrPackage(opts));
+        if (!ret) return new(new Exception("Send 1st address package failed!"));
+        // Send Data Package
+        ret = await UDPClientPool.SendDataPackAsync(endPoint,
+                new SendDataPackage(Common.Number.NumberToBytes(data, 4).Value));
+        if (!ret) return new(new Exception("Send data package failed!"));
+
+        // Check Msg Bus
+        if (!MsgBus.IsRunning)
+            return new(new Exception("Message bus not working!"));
+
+        // Wait for Write Ack
+        var udpWriteAck = await MsgBus.UDPServer.WaitForAckAsync(
+                endPoint.Address.ToString(), endPoint.Port, timeout);
+        if (!udpWriteAck.IsSuccessful) return new(udpWriteAck.Error);
+
+        return udpWriteAck.Value.IsSuccessful;
+    }
 }