From 5d7530b756fad083c052aa7ff3f91ea6f215eed3 Mon Sep 17 00:00:00 2001
From: anlicheng <244108715@qq.com>
Date: Thu, 13 Nov 2025 18:07:22 +0800
Subject: [PATCH] fix message

---
 apps/efka/src/message/message_codec.erl | 12 +++++++++---
 1 file changed, 9 insertions(+), 3 deletions(-)

diff --git a/apps/efka/src/message/message_codec.erl b/apps/efka/src/message/message_codec.erl
index 085d63e..643242c 100644
--- a/apps/efka/src/message/message_codec.erl
+++ b/apps/efka/src/message/message_codec.erl
@@ -35,10 +35,14 @@ encode0(#auth_reply{code = Code, payload = Payload}) ->
     ]);
 encode0(#jsonrpc_reply{result = Result, error = undefined}) ->
     ResultBin = erlang:term_to_binary(#{<<"result">> => Result}),
-    iolist_to_binary([marshal(?Bytes, ResultBin)]);
+    iolist_to_binary([
+        marshal(?Bytes, ResultBin)
+    ]);
 encode0(#jsonrpc_reply{result = undefined, error = Error}) ->
     ResultBin = erlang:term_to_binary(#{<<"error">> => Error}),
-    iolist_to_binary([marshal(?Bytes, ResultBin)]);
+    iolist_to_binary([
+        marshal(?Bytes, ResultBin)
+    ]);
 encode0(#pub{topic = Topic, content = Content}) ->
     iolist_to_binary([
         marshal(?Bytes, Topic),
@@ -52,7 +56,9 @@ encode0(#command{command_type = CommandType, command = Command}) ->
 
 encode0(#jsonrpc_request{method = Method, params = Params}) ->
     ReqBody = erlang:term_to_binary(#{<<"method">> => Method, <<"params">> => Params}),
-    marshal(?Bytes, ReqBody);
+    iolist_to_binary([
+        marshal(?Bytes, ReqBody)
+    ]);
 encode0(#data{service_id = ServiceId, device_uuid = DeviceUUID, route_key = RouteKey, metric = Metric}) ->
     iolist_to_binary([
         marshal(?Bytes, ServiceId),