Merge pull request #12481 from lafirest/fix/action_info

fix(tdengine): remove redundant codes

apps/emqx_bridge_tdengine/src/emqx_bridge_tdengine_action_info.erl

@@ -5,67 +5,24 @@
 
 -behaviour(emqx_action_info).
 
--elvis([{elvis_style, invalid_dynamic_call, disable}]).
-
-%% behaviour callbacks
 -export([
-    action_type_name/0,
-    bridge_v1_config_to_action_config/2,
-    bridge_v1_config_to_connector_config/1,
     bridge_v1_type_name/0,
-    connector_action_config_to_bridge_v1_config/2,
+    action_type_name/0,
     connector_type_name/0,
     schema_module/0
 ]).
 
--import(emqx_utils_conv, [bin/1]).
-
 -define(ACTION_TYPE, tdengine).
 -define(SCHEMA_MODULE, emqx_bridge_tdengine).
 
-action_type_name() -> ?ACTION_TYPE.
+bridge_v1_type_name() ->
-bridge_v1_type_name() -> ?ACTION_TYPE.
+    ?ACTION_TYPE.
-connector_type_name() -> ?ACTION_TYPE.
 
-schema_module() -> ?SCHEMA_MODULE.
+action_type_name() ->
+    ?ACTION_TYPE.
 
-connector_action_config_to_bridge_v1_config(ConnectorConfig, ActionConfig) ->
+connector_type_name() ->
-    MergedConfig =
+    ?ACTION_TYPE.
-        emqx_utils_maps:deep_merge(
-            maps:without(
-                [<<"description">>, <<"local_topic">>, <<"connector">>, <<"data">>],
-                emqx_utils_maps:unindent(<<"parameters">>, ActionConfig)
-            ),
-            ConnectorConfig
-        ),
-    BridgeV1Keys = schema_keys("config"),
-    maps:with(BridgeV1Keys, MergedConfig).
 
-bridge_v1_config_to_action_config(BridgeV1Config, ConnectorName) ->
+schema_module() ->
-    ActionTopLevelKeys = schema_keys(action_config),
+    ?SCHEMA_MODULE.
-    ActionParametersKeys = schema_keys(action_parameters),
-    ActionKeys = ActionTopLevelKeys ++ ActionParametersKeys,
-    ActionConfig = make_config_map(ActionKeys, ActionParametersKeys, BridgeV1Config),
-    emqx_utils_maps:update_if_present(
-        <<"resource_opts">>,
-        fun emqx_bridge_v2_schema:project_to_actions_resource_opts/1,
-        ActionConfig#{<<"connector">> => ConnectorName}
-    ).
-
-bridge_v1_config_to_connector_config(BridgeV1Config) ->
-    ConnectorKeys = schema_keys(emqx_bridge_tdengine_connector, "config_connector"),
-    emqx_utils_maps:update_if_present(
-        <<"resource_opts">>,
-        fun emqx_connector_schema:project_to_connector_resource_opts/1,
-        maps:with(ConnectorKeys, BridgeV1Config)
-    ).
-
-make_config_map(PickKeys, IndentKeys, Config) ->
-    Conf0 = maps:with(PickKeys, Config),
-    emqx_utils_maps:indent(<<"parameters">>, IndentKeys, Conf0).
-
-schema_keys(Name) ->
-    schema_keys(?SCHEMA_MODULE, Name).
-
-schema_keys(Mod, Name) ->
-    [bin(Key) || Key <- proplists:get_keys(Mod:fields(Name))].