yuanbiao
/
emqx
1
0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

fix(tdengine): keep the bridge schema still compatible with v1

This commit is contained in:
firest 2024-02-05 10:21:06 +08:00
parent 06684e5f73
commit 4a2c5a3161
1 changed files with 10 additions and 7 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

17
apps/emqx_bridge_tdengine/src/emqx_bridge_tdengine_connector.erl
View File

@ -47,16 +47,13 @@ roots() ->
[{config, #{type => hoconsc:ref(?MODULE, config)}}].
fields(config) ->
[
{server, server()}
| adjust_fields(emqx_connector_schema_lib:relational_db_fields())
];
base_config(true);
%%=====================================================================
%% V2 Hocon schema
fields("config_connector") ->
emqx_connector_schema:common_fields() ++
fields(config) ++
base_config(false) ++
emqx_connector_schema:resource_opts_ref(?MODULE, connector_resource_opts);
fields(connector_resource_opts) ->
emqx_connector_schema:resource_opts_fields();
@ -67,6 +64,12 @@ fields("put") ->
fields("get") ->
emqx_bridge_schema:status_fields() ++ fields("post").
base_config(HasDatabase) ->
[
{server, server()}
| adjust_fields(emqx_connector_schema_lib:relational_db_fields(), HasDatabase)
].
desc(config) ->
?DESC("desc_config");
desc(connector_resource_opts) ->
@ -78,7 +81,7 @@ desc(Method) when Method =:= "get"; Method =:= "put"; Method =:= "post" ->
desc(_) ->
undefined.
adjust_fields(Fields) ->
adjust_fields(Fields, HasDatabase) ->
lists:filtermap(
fun
({username, OrigUsernameFn}) ->
@ -86,7 +89,7 @@ adjust_fields(Fields) ->
({password, _}) ->
{true, {password, emqx_connector_schema_lib:password_field(#{required => true})}};
({database, _}) ->
false;
HasDatabase;
(_Field) ->
true
end,