From 836917c7330fef12897e2a70c70d4f845320134b Mon Sep 17 00:00:00 2001
From: anlicheng <244108715@qq.com>
Date: Mon, 21 Apr 2025 14:54:31 +0800
Subject: [PATCH] fix

---
 apps/efka/src/efka.app.src   |  2 +-
 apps/efka/src/efka_agent.erl | 11 +++++++----
 config/sys.config            |  2 +-
 3 files changed, 9 insertions(+), 6 deletions(-)

diff --git a/apps/efka/src/efka.app.src b/apps/efka/src/efka.app.src
index 0c72cce..e2faafb 100644
--- a/apps/efka/src/efka.app.src
+++ b/apps/efka/src/efka.app.src
@@ -5,7 +5,7 @@
   {mod, {efka_app, []}},
   {applications,
    [
-    % sync,
+    sync,
     hackney,
     lager,
     esockd,
diff --git a/apps/efka/src/efka_agent.erl b/apps/efka/src/efka_agent.erl
index 46ba3d7..4abff1a 100644
--- a/apps/efka/src/efka_agent.erl
+++ b/apps/efka/src/efka_agent.erl
@@ -22,7 +22,7 @@
 -record(state, {
     host :: string(),
     port :: integer(),
-    socket
+    socket :: undefined | ssl:sslsocket()
 }).
 
 %%%===================================================================
@@ -84,6 +84,8 @@ handle_cast(_Request, State = #state{}) ->
 handle_info({timeout, _, create_connection}, State = #state{host = Host, port = Port}) ->
     case connect(Host, Port) of
         {ok, Socket} ->
+            ok = ssl:send(Socket, <<"hello world">>),
+            lager:debug("[efka_agent] connected success"),
             {noreply, State#state{socket = Socket}};
         {error, Reason} ->
             lager:debug("[efka_agent] create_connection get error: ~p", [Reason]),
@@ -93,7 +95,6 @@ handle_info({timeout, _, create_connection}, State = #state{host = Host, port =
 
 handle_info({ssl, Socket, Data}, State = #state{socket = Socket}) ->
     lager:debug("[efka_agent] socket get message: ~p", [Data]),
-    retry_connect(),
     {noreply, State#state{socket = undefined}};
 
 handle_info({ssl_error, Socket, Reason}, State = #state{socket = Socket}) ->
@@ -133,9 +134,11 @@ code_change(_OldVsn, State = #state{}, _Extra) ->
 retry_connect() ->
     erlang:start_timer(5000, self(), create_connection).
 
+-spec connect(Host :: string(), Port :: integer()) -> {ok, Socket :: ssl:sslsocket()} | {error, Reason :: any()}.
 connect(Host, Port) when is_list(Host), is_integer(Port) ->
     SslOptions = [
-        {verify, verify_none},
-        {active, true}
+        {packet, 4},
+        {active, true},
+        {verify, verify_none}
     ],
     ssl:connect(Host, Port, SslOptions, 5000).
\ No newline at end of file
diff --git a/config/sys.config b/config/sys.config
index 2429acb..c7cd980 100644
--- a/config/sys.config
+++ b/config/sys.config
@@ -4,7 +4,7 @@
 
     {tls_server, [
       {host, "localhost"},
-      {port, 18080}
+      {port, 443}
     ]}
   ]},