From 33a604dcaa1d0b3d4e50ee4a6b8def72ecc399e6 Mon Sep 17 00:00:00 2001
From: JimMoen <LnJimMoen@outlook.com>
Date: Thu, 4 Aug 2022 13:40:00 +0800
Subject: [PATCH] fix: refine influxdb connector api type name

---
 .../src/emqx_ee_connector.erl                 |  6 +--
 .../src/emqx_ee_connector_influxdb.erl        | 42 +++++++++----------
 2 files changed, 24 insertions(+), 24 deletions(-)

diff --git a/lib-ee/emqx_ee_connector/src/emqx_ee_connector.erl b/lib-ee/emqx_ee_connector/src/emqx_ee_connector.erl
index 0971e1a06..6846ea740 100644
--- a/lib-ee/emqx_ee_connector/src/emqx_ee_connector.erl
+++ b/lib-ee/emqx_ee_connector/src/emqx_ee_connector.erl
@@ -14,9 +14,9 @@
 api_schemas(Method) ->
     [
         ref(emqx_ee_connector_hstreamdb, Method),
-        ref(emqx_ee_connector_influxdb, Method ++ "_udp"),
-        ref(emqx_ee_connector_influxdb, Method ++ "_api_v1"),
-        ref(emqx_ee_connector_influxdb, Method ++ "_api_v2")
+        ref(emqx_ee_connector_influxdb, "udp_" ++ Method),
+        ref(emqx_ee_connector_influxdb, "api_v1_" ++ Method),
+        ref(emqx_ee_connector_influxdb, "api_v2_" ++ Method)
     ].
 
 fields(connectors) ->
diff --git a/lib-ee/emqx_ee_connector/src/emqx_ee_connector_influxdb.erl b/lib-ee/emqx_ee_connector/src/emqx_ee_connector_influxdb.erl
index 8ba8478b3..c9971607e 100644
--- a/lib-ee/emqx_ee_connector/src/emqx_ee_connector_influxdb.erl
+++ b/lib-ee/emqx_ee_connector/src/emqx_ee_connector_influxdb.erl
@@ -49,30 +49,30 @@ on_get_status(_InstId, #{client := Client}) ->
 %% schema
 namespace() -> connector_influxdb.
 
-fields("put_udp") ->
+fields("udp_get") ->
+    Key = influxdb_udp,
+    fields(Key) ++ type_name_field(Key);
+fields("udp_post") ->
+    Key = influxdb_udp,
+    fields(Key) ++ type_name_field(Key);
+fields("udp_put") ->
     fields(influxdb_udp);
-fields("put_api_v1") ->
+fields("api_v1_get") ->
+    Key = influxdb_api_v1,
+    fields(Key) ++ type_name_field(Key);
+fields("api_v1_post") ->
+    Key = influxdb_api_v1,
+    fields(Key) ++ type_name_field(Key);
+fields("api_v1_put") ->
     fields(influxdb_api_v1);
-fields("put_api_v2") ->
+fields("api_v2_get") ->
+    Key = influxdb_api_v2,
+    fields(Key) ++ type_name_field(Key);
+fields("api_v2_post") ->
+    Key = influxdb_api_v2,
+    fields(Key) ++ type_name_field(Key);
+fields("api_v2_put") ->
     fields(influxdb_api_v2);
-fields("get_udp") ->
-    Key = influxdb_udp,
-    fields(Key) ++ type_name_field(Key);
-fields("get_api_v1") ->
-    Key = influxdb_api_v1,
-    fields(Key) ++ type_name_field(Key);
-fields("get_api_v2") ->
-    Key = influxdb_api_v2,
-    fields(Key) ++ type_name_field(Key);
-fields("post_udp") ->
-    Key = influxdb_udp,
-    fields(Key) ++ type_name_field(Key);
-fields("post_api_v1") ->
-    Key = influxdb_api_v1,
-    fields(Key) ++ type_name_field(Key);
-fields("post_api_v2") ->
-    Key = influxdb_api_v2,
-    fields(Key) ++ type_name_field(Key);
 fields(basic) ->
     [
         {host,