anlicheng/iot_cloud
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

fix endpoint handler

Browse Source
This commit is contained in:
anlicheng 2025-11-14 23:15:26 +08:00
parent c5f246d453
commit a3425ffc12
1 changed files with 7 additions and 7 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

14
apps/iot/src/http_handlers/endpoint_handler.erl
View File

@ -133,23 +133,23 @@ handle_request("POST", "/endpoint/test", _, #{<<"protocol">> := <<"mqtt">>, <<"c
case emqtt:start_link(Opts) of case emqtt:start_link(Opts) of
{ok, ConnPid} -> {ok, ConnPid} ->
lager:debug("[endpoint_mqtt] start connect, options: ~p", [Opts]), lager:debug("[endpint_handler] start connect, options: ~p", [Opts]),
case catch emqtt:connect(ConnPid, 5000) of case catch emqtt:connect(ConnPid, 5000) of
{ok, _} -> {ok, _} ->
lager:debug("[endpoint_mqtt] connect success, pid: ~p", [ConnPid]), lager:debug("[endpint_handler] connect success, pid: ~p", [ConnPid]),
emqtt:stop(ConnPid), emqtt:stop(ConnPid),
{ok, 200, iot_util:json_data(<<"ok">>)}; {ok, 200, iot_util:json_data(<<"ok">>)};
{error, Reason} -> {error, Reason} ->
lager:warning("[endpoint_mqtt] connect get error: ~p", [Reason]), lager:warning("[endpint_handler] connect get error: ~p", [Reason]),
emqtt:stop(ConnPid), emqtt:stop(ConnPid),
{ok, 200, iot_util:json_error(-1, <<"connect mqtt server failed">>)}; {ok, 200, iot_util:json_error(-1, <<"connect mqtt server failed">>)};
Error -> Error ->
lager:warning("[endpoint_mqtt] connect get error: ~p", [Error]), lager:warning("[endpint_handler] connect get error: ~p", [Error]),
emqtt:stop(ConnPid), emqtt:stop(ConnPid),
{ok, 200, iot_util:json_error(-1, <<"connect mqtt server failed">>)} {ok, 200, iot_util:json_error(-1, <<"connect mqtt server failed">>)}
end; end;
Other -> Other ->
lager:warning("[endpoint_handler] test connect mqtt with options: ~p, get error: ~p", [Opts, Other]), lager:warning("[endpint_handler] test connect mqtt with options: ~p, get error: ~p", [Opts, Other]),
{ok, 200, iot_util:json_error(-1, <<"connect mqtt server failed">>)} {ok, 200, iot_util:json_error(-1, <<"connect mqtt server failed">>)}
end; end;
{error, Errors} -> {error, Errors} ->
@ -180,11 +180,11 @@ handle_request("POST", "/endpoint/test", _, #{<<"protocol">> := <<"kafka">>, <<"
ok = brod:stop_client(ClientId), ok = brod:stop_client(ClientId),
{ok, 200, iot_util:json_data(<<"ok">>)}; {ok, 200, iot_util:json_data(<<"ok">>)};
{error, Reason} -> {error, Reason} ->
lager:debug("[endpoint_kafka] start_producer: ~p, get error: ~p", [ClientId, Reason]), lager:debug("[endpint_handler] start_producer: ~p, get error: ~p", [ClientId, Reason]),
{ok, 200, iot_util:json_error(-1, <<"config kafka server failed">>)} {ok, 200, iot_util:json_error(-1, <<"config kafka server failed">>)}
end; end;
Error -> Error ->
lager:debug("[endpoint_kafka] start_client: ~p, get error: ~p", [ClientId, Error]), lager:debug("[endpint_handler] start_client: ~p, get error: ~p", [ClientId, Error]),
{ok, 200, iot_util:json_error(-1, <<"config kafka server failed">>)} {ok, 200, iot_util:json_error(-1, <<"config kafka server failed">>)}
end; end;
{error, Errors} -> {error, Errors} ->