diff --git a/apps/iot/src/http_handler/device_handler.erl b/apps/iot/src/http_handler/device_handler.erl index 2751bc3..0cf7567 100644 --- a/apps/iot/src/http_handler/device_handler.erl +++ b/apps/iot/src/http_handler/device_handler.erl @@ -12,7 +12,7 @@ %% API -export([handle_request/4]). --export([test/1]). +-export([test/2]). %%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%% %% helper methods @@ -94,12 +94,9 @@ handle_request(_, Path, _, _) -> {ok, 200, iot_util:json_error(-1, <<"url: ", Path1/binary, " not found">>)}. -test(DeviceUUID) when is_binary(DeviceUUID) -> +test(HostUUID, DeviceUUID) when is_binary(HostUUID), is_binary(DeviceUUID) -> Timeout = 10, - - HostUUID = <<"0356e898adc51ac449b215627b7d8e55">>, lager:debug("[device_handler] host_id: ~p, will query_edge_status uuid: ~p", [HostUUID, DeviceUUID]), - case iot_host:get_pid(HostUUID) of undefined -> {ok, 200, iot_util:json_error(404, <<"query_edge_status failed">>)}; @@ -109,7 +106,7 @@ test(DeviceUUID) when is_binary(DeviceUUID) -> iot_device_poll_task:poll_task(TaskPid, Ref, HostPid, self(), DeviceUUID, Timeout), receive {poll_task_reply, Ref, {ok, EdgeStatus}} -> - % {ok, _} = device_bo:change_edge_status(DeviceUUID, EdgeStatus), + {ok, _} = device_bo:change_edge_status(DeviceUUID, EdgeStatus), {ok, 200, iot_util:json_data(#{<<"edge_status">> => EdgeStatus})}; {poll_task_reply, Ref, {error, Reason}} -> lager:debug("[device_handler] query_edge_status device: ~p, get error: ~p", [DeviceUUID, Reason]),