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

fix: problems found by @thalesmg in code review 

Co-authored-by: Thales Macedo Garitezi <thalesmg@gmail.com>
This commit is contained in:
Kjell Winblad 2023-11-20 18:59:57 +01:00 committed by GitHub
parent edbfe090c9
commit d214ae8772
No known key found for this signature in database
GPG Key ID: 4AEE18F83AFDEB23
3 changed files with 2 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

2
apps/emqx_bridge_azure_event_hub/src/emqx_bridge_azure_event_hub_action_info.erl
View File

@ -29,4 +29,4 @@ connector_action_config_to_bridge_v1_config(ConnectorConfig, ActionConfig) ->
). ).
bridge_v1_config_to_action_config(BridgeV1Conf, ConnectorName) -> bridge_v1_config_to_action_config(BridgeV1Conf, ConnectorName) ->
bridge_v1_config_to_action_config(BridgeV1Conf, ConnectorName). emqx_bridge_kafka_action_info:bridge_v1_config_to_action_config(BridgeV1Conf, ConnectorName).

1
apps/emqx_bridge_kafka/src/emqx_bridge_kafka_action_info.erl
View File

@ -29,7 +29,6 @@ connector_action_config_to_bridge_v1_config(ConnectorConfig, ActionConfig) ->
emqx_utils_maps:rename(<<"parameters">>, <<"kafka">>, BridgeV1Config2). emqx_utils_maps:rename(<<"parameters">>, <<"kafka">>, BridgeV1Config2).
bridge_v1_config_to_action_config(BridgeV1Conf, ConnectorName) -> bridge_v1_config_to_action_config(BridgeV1Conf, ConnectorName) ->
BridgeV1Conf,
Config0 = emqx_action_info:transform_bridge_v1_config_to_action_config( Config0 = emqx_action_info:transform_bridge_v1_config_to_action_config(
BridgeV1Conf, ConnectorName, schema_module(), kafka_producer BridgeV1Conf, ConnectorName, schema_module(), kafka_producer
), ),

2
apps/emqx_connector/src/schema/emqx_connector_schema.erl
View File

@ -183,7 +183,7 @@ transform_bridge_v1_config_to_action_config(
(not maps:is_key(ConnectorFieldNameBin, TopKeysMap)) (not maps:is_key(ConnectorFieldNameBin, TopKeysMap))
of of
true -> true ->
maps:remove(to_bin(ConnectorFieldName), ToTransformSoFar); maps:remove(ConnectorFieldNameBin, ToTransformSoFar);
false -> false ->
ToTransformSoFar ToTransformSoFar
end end