From 5d4c2c655ee610c6a608213e2cdd49f35b3e1fa9 Mon Sep 17 00:00:00 2001
From: zhouhao <zh.sqy@qq.com>
Date: Fri, 3 Feb 2023 19:06:13 +0800
Subject: [PATCH] =?UTF-8?q?=E4=BC=98=E5=8C=96?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 .../binary/BinaryMessageTypeTest.java         | 23 +++++++++++++++++--
 1 file changed, 21 insertions(+), 2 deletions(-)

diff --git a/src/test/java/org/jetlinks/protocol/official/binary/BinaryMessageTypeTest.java b/src/test/java/org/jetlinks/protocol/official/binary/BinaryMessageTypeTest.java
index 0af926b..2acf2ea 100644
--- a/src/test/java/org/jetlinks/protocol/official/binary/BinaryMessageTypeTest.java
+++ b/src/test/java/org/jetlinks/protocol/official/binary/BinaryMessageTypeTest.java
@@ -1,8 +1,10 @@
 package org.jetlinks.protocol.official.binary;
 
 import io.netty.buffer.ByteBuf;
+import io.netty.buffer.ByteBufUtil;
 import io.netty.buffer.Unpooled;
 import org.jetlinks.core.message.DeviceMessage;
+import org.jetlinks.core.message.DeviceOnlineMessage;
 import org.jetlinks.core.message.function.FunctionInvokeMessage;
 import org.jetlinks.core.message.function.FunctionInvokeMessageReply;
 import org.jetlinks.core.message.property.*;
@@ -15,6 +17,23 @@ import java.util.Collections;
 public class BinaryMessageTypeTest {
 
 
+    @Test
+    public void testOnline() {
+
+        DeviceOnlineMessage message = new DeviceOnlineMessage();
+        message.setDeviceId("1000");
+        message.addHeader(BinaryDeviceOnlineMessage.loginToken, "admin");
+
+        ByteBuf byteBuf = BinaryMessageType.write(message, Unpooled.buffer());
+
+        System.out.println(ByteBufUtil.prettyHexDump(byteBuf));
+
+        System.out.println(ByteBufUtil.prettyHexDump(Unpooled
+                                                             .buffer()
+                                                             .writeInt(byteBuf.readableBytes())
+                                                             .writeBytes(byteBuf)));
+    }
+
     @Test
     public void testReport() {
         ReportPropertyMessage message = new ReportPropertyMessage();
@@ -75,10 +94,10 @@ public class BinaryMessageTypeTest {
     }
 
     public void doTest(DeviceMessage message) {
-        ByteBuf data = Unpooled.buffer();
 
-        BinaryMessageType.write(message, data);
+        ByteBuf data = BinaryMessageType.write(message, Unpooled.buffer());
 
+        System.out.println(ByteBufUtil.prettyHexDump(data));
         DeviceMessage read = BinaryMessageType.read(data);
         if (null != read.getHeaders()) {
             read.getHeaders().forEach(message::addHeader);