增加参数校验

apps/iot/src/http_handlers/container_handler.erl

@@ -63,6 +63,8 @@ handle_request("POST", "/container/push_config", _,
 handle_request("POST", "/container/deploy", _, #{<<"uuid">> := UUID, <<"task_id">> := TaskId, <<"config">> := Config})
     when is_binary(UUID), is_integer(TaskId), is_map(Config) ->
 
+    case validate_config(Config) of
+        ok ->
             case iot_host:get_pid(UUID) of
                 undefined ->
                     {ok, 200, iot_util:json_error(404, <<"host not found">>)};
@@ -79,6 +81,10 @@ handle_request("POST", "/container/deploy", _, #{<<"uuid">> := UUID, <<"task_id"
                             {ok, 200, iot_util:json_error(400, Reason)}
                     end
             end;
+        {error, Errors} ->
+            Reason = iolist_to_binary(lists:join(<<"|||">>, Errors)),
+            {ok, 200, iot_util:json_error(400, Reason)}
+    end;
 
 %% 启动服务
 handle_request("POST", "/container/start", _, #{<<"uuid">> := UUID, <<"container_name">> := ContainerName}) when is_binary(UUID), is_binary(ContainerName) ->
@@ -186,34 +192,34 @@ validate_config(Config) when is_map(Config) ->
     Required = [
         {image, binary},
         {container_name, binary},
-        {command, list},
+        {command, {list, binary}},
         {restart, binary},
         {privileged, boolean}
     ],
 
     %% 可选参数（附带默认值）
     Optional = [
-        {envs, list},
-        {ports, list},
-        {expose, list},
-        {volumes, list},
-        {networks, list},
-        {labels, map},
+        {envs, {list, binary}},
+        {ports, {list, binary}},
+        {expose, {list, binary}},
+        {volumes, {list, binary}},
+        {networks, {list, binary}},
+        {labels, {map, {binary, binary}}},
         {user, binary},
         {working_dir, binary},
         {hostname, binary},
-        {cap_add, list},
-        {cap_drop, list},
-        {devices, list},
+        {cap_add, {list, binary}},
+        {cap_drop, {list, binary}},
+        {devices, {list, binary}},
         {mem_limit, binary},
         {mem_reservation, binary},
         {cpu_shares, integer},
         {cpus, number},
-        {ulimits, map},
-        {sysctls, map},
-        {tmpfs, list},
-        {extra_hosts, list},
-        {healthcheck, map}
+        {ulimits, {map, {binary, binary}}},
+        {sysctls, {map, {binary, binary}}},
+        {tmpfs, {list, binary}},
+        {extra_hosts, {list, binary}},
+        {healthcheck, {map, {binary, any}}}
     ],
 
     Errors1 = check_required(Config, Required),
@@ -273,10 +279,27 @@ check_optional(Config, Fields) ->
 %%------------------------------------------------------------------------------
 %% 类型检查辅助函数（binary版）
 %%------------------------------------------------------------------------------
-check_type(Value, binary)  -> is_binary(Value);
-check_type(Value, integer) -> is_integer(Value);
-check_type(Value, number)  -> is_number(Value);
-check_type(Value, list)    -> is_list(Value);
-check_type(Value, map)     -> is_map(Value);
-check_type(Value, boolean) -> is_boolean(Value);
-check_type(_, _)           -> false.
+check_type(Value, binary) ->
+    is_binary(Value);
+check_type(Value, integer) ->
+    is_integer(Value);
+check_type(Value, number) ->
+    is_number(Value);
+check_type(Value, list) when is_list(Value) ->
+    true;
+check_type(Value, {list, binary}) when is_list(Value) ->
+    lists:all(fun(E) -> is_binary(E) end, Value);
+check_type(Value, {list, number}) when is_list(Value) ->
+    lists:all(fun(E) -> is_number(E) end, Value);
+check_type(Value, {list, integer}) when is_list(Value) ->
+    lists:all(fun(E) -> is_integer(E) end, Value);
+check_type(Value, map) when is_map(Value) ->
+    true;
+check_type(Value, {map, {binary, binary}}) when is_map(Value) ->
+    lists:all(fun({K, V}) -> is_binary(K) andalso is_binary(V) end, maps:to_list(Value));
+check_type(Value, {map, {binary, any}}) when is_map(Value) ->
+    lists:all(fun({K, _}) -> is_binary(K) end, maps:to_list(Value));
+check_type(Value, boolean) ->
+    is_boolean(Value);
+check_type(_, _) ->
+    false.

apps/iot/src/http_handlers/event_stream_handler.erl

@@ -23,8 +23,9 @@ init(Req0, Opts) ->
 
     lager:debug("method: ~p, path: ~p,  get: ~p", [Method, Path, GetParams]),
     Req1 = cowboy_req:stream_reply(200, #{
-        <<"content-type">> => <<"text/event-stream">>,
-        <<"cache-control">> => <<"no-cache">>
+        <<"Content-Type">> => <<"text/event-stream">>,
+        <<"Cache-Control">> => <<"no-cache">>,
+        <<"Connection">> => <<"keep-alive">>
     }, Req0),
 
     ok = iot_event_stream_observer:add_listener(self(), TaskId),