From 9716b051d9be5f3bb083998ab112d33493d42141 Mon Sep 17 00:00:00 2001 From: JianBo He Date: Tue, 21 Nov 2023 11:24:23 +0800 Subject: [PATCH] fix(ocpp): fix bad webscoket schema for HTTP API --- apps/emqx_gateway/src/emqx_gateway_schema.erl | 12 ++++++++++-- apps/emqx_gateway_ocpp/src/emqx_ocpp_conf.erl | 2 +- apps/emqx_gateway_ocpp/src/emqx_ocpp_schemas.erl | 2 +- 3 files changed, 12 insertions(+), 4 deletions(-) diff --git a/apps/emqx_gateway/src/emqx_gateway_schema.erl b/apps/emqx_gateway/src/emqx_gateway_schema.erl index c84cf086b..c0abb48ce 100644 --- a/apps/emqx_gateway/src/emqx_gateway_schema.erl +++ b/apps/emqx_gateway/src/emqx_gateway_schema.erl @@ -127,9 +127,15 @@ fields(ssl_listener) -> )} ]; fields(ws_listener) -> - ws_listener() ++ ws_opts(<<>>, <<>>); + emqx_gateway_schema:ws_listener() ++ + [{websocket, sc(ref(websocket), #{})}]; fields(wss_listener) -> - wss_listener() ++ ws_opts(<<>>, <<>>); + emqx_gateway_schema:wss_listener() ++ + [{websocket, sc(ref(websocket), #{})}]; +fields(websocket) -> + DefaultPath = <<>>, + SubProtocols = <<>>, + emqx_gateway_schema:ws_opts(DefaultPath, SubProtocols); fields(udp_listener) -> [ %% some special configs for udp listener @@ -193,6 +199,8 @@ desc(udp_opts) -> "Settings for UDP sockets."; desc(dtls_opts) -> "Settings for DTLS protocol."; +desc(websocket) -> + "Websocket options"; desc(_) -> undefined. diff --git a/apps/emqx_gateway_ocpp/src/emqx_ocpp_conf.erl b/apps/emqx_gateway_ocpp/src/emqx_ocpp_conf.erl index 1151e1dbb..00d1aca6c 100644 --- a/apps/emqx_gateway_ocpp/src/emqx_ocpp_conf.erl +++ b/apps/emqx_gateway_ocpp/src/emqx_ocpp_conf.erl @@ -63,7 +63,7 @@ max_mqueue_len() -> | dnstream_only | disable. message_format_checking() -> - conf(message_format_checking, all). + conf(message_format_checking, disable). uptopic(Action) -> Topic = upstream(topic), diff --git a/apps/emqx_gateway_ocpp/src/emqx_ocpp_schemas.erl b/apps/emqx_gateway_ocpp/src/emqx_ocpp_schemas.erl index e2bd00d0e..99003763f 100644 --- a/apps/emqx_gateway_ocpp/src/emqx_ocpp_schemas.erl +++ b/apps/emqx_gateway_ocpp/src/emqx_ocpp_schemas.erl @@ -32,7 +32,7 @@ load() -> disable -> ok; _ -> - case feedvar(emqx_config:get([gateway, ocpp, json_schema_dir])) of + case feedvar(emqx_config:get([gateway, ocpp, json_schema_dir], undefined)) of undefined -> ok; Dir ->