From 9c6ed236d0518f58e5b22d319a54a92971295291 Mon Sep 17 00:00:00 2001
From: anlicheng <244108715@qq.com>
Date: Sun, 26 Apr 2026 16:08:20 +0800
Subject: [PATCH] fix

---
 src/transport/efka_client.erl | 16 ++++++++--------
 1 file changed, 8 insertions(+), 8 deletions(-)

diff --git a/src/transport/efka_client.erl b/src/transport/efka_client.erl
index 16b7aa1..5aea791 100644
--- a/src/transport/efka_client.erl
+++ b/src/transport/efka_client.erl
@@ -181,7 +181,7 @@ handle_event(internal, {request, PacketId, {container_request, #{action := list}
     ?STATE_ACTIVATED, State = #state{socket = Socket}) ->
     case docker_commands:get_containers() of
         {ok, Containers} ->
-            send_result_reply(Socket, PacketId, iolist_to_binary(json:encode(Containers)));
+            send_result_reply(Socket, PacketId, Containers);
         {error, Reason} ->
             send_error_reply(Socket, PacketId, Reason)
     end,
@@ -249,16 +249,16 @@ handle_event(internal, {request, PacketId, _Body},
     send_error_reply(Socket, PacketId, <<"agent state invalid">>),
     {keep_state, State};
 
-handle_event(internal, {response, AuthPacketId, {ok, Message}},
+handle_event(internal, {response, AuthPacketId, {auth_response, {ok, Message}}},
     ?STATE_AUTH, State = #state{auth_packet_id = AuthPacketId}) ->
 
     logger:debug("[efka_client] auth success, message: ~p", [Message]),
     {next_state, ?STATE_ACTIVATED, State, [{next_event, info, flush_cache}]};
-handle_event(internal, {response, AuthPacketId, {error, 1, Message}},
+handle_event(internal, {response, AuthPacketId, {auth_response, {error, 1, Message}}},
     ?STATE_AUTH, State = #state{auth_packet_id = AuthPacketId}) ->
     logger:debug("[efka_client] auth denied, message: ~p", [Message]),
     {next_state, ?STATE_RESTRICTED, State};
-handle_event(internal, {response, AuthPacketId, {error, _Code, Message}},
+handle_event(internal, {response, AuthPacketId, {auth_response, {error, _Code, Message}}},
     ?STATE_AUTH, State = #state{socket = Socket, auth_packet_id = AuthPacketId}) ->
     logger:debug("[efka_client] auth failed, message: ~p", [Message]),
     disconnect(Socket),
@@ -441,14 +441,14 @@ delete_oldest_cache_entry() ->
             dets:delete(?CACHE_TAB, Key)
     end.
 
--spec send_result_reply(ssl:sslsocket(), integer(), binary()) -> ok.
-send_result_reply(Socket, PacketId, Payload) when is_binary(Payload) ->
-    Packet = term_to_binary({response, PacketId, {ok, Payload}}),
+-spec send_result_reply(ssl:sslsocket(), integer(), term()) -> ok.
+send_result_reply(Socket, PacketId, Payload) ->
+    Packet = term_to_binary({response, PacketId, {container_response, {ok, Payload}}}),
     send_packet(Socket, Packet).
 
 -spec send_error_reply(ssl:sslsocket(), integer(), binary()) -> ok.
 send_error_reply(Socket, PacketId, Reason) when is_binary(Reason) ->
-    Packet = term_to_binary({response, PacketId, {error, -1, Reason}}),
+    Packet = term_to_binary({response, PacketId, {container_response, {error, -1, Reason}}}),
     send_packet(Socket, Packet).
 
 -spec container_target(map()) -> binary().