[feature] Transform the 'divide,' 'grpc,' and 'websocket' plugins for discovery

src/locales/en-US.json

@@ -405,12 +405,19 @@
   "SHENYU.DISCOVERY.SELECTOR.CONFIGURATION": "Discovery Configuration",
   "SHENYU.DISCOVERY.SELECTOR.UPSTREAM": "Discovery Upstreams",
   "SHENYU.DISCOVERY.SELECTOR.UPSTREAM.ADD": "Add Discovery Upstream",
-  "SHENYU.DISCOVERY.SELECTOR.UPSTREAM.DELETE": "Sure to delete?",
+  "SHENYU.DISCOVERY.SELECTOR.UPSTREAM.DELETE.CONFIRM": "Sure to delete?",
+  "SHENYU.DISCOVERY.SELECTOR.UPSTREAM.CANCEL.CONFIRM": "Sure to cancel?",
   "SHENYU.DISCOVERY.SELECTOR.UPSTREAM.OPERATION": "operation",
+  "SHENYU.DISCOVERY.SELECTOR.UPSTREAM.CANCEL": "Cancel",
+  "SHENYU.DISCOVERY.SELECTOR.UPSTREAM.SAVE": "Save",
+  "SHENYU.DISCOVERY.SELECTOR.UPSTREAM.EDIT": "Edit",
   "SHENYU.DISCOVERY.SELECTOR.UPSTREAM.DateCreated": "DateCreated",
   "SHENYU.DISCOVERY.SELECTOR.UPSTREAM.DateUpdated": "DateUpdated",
   "SHENYU.DISCOVERY.SELECTOR.CONFIG.BASIC": "Basic Config",
   "SHENYU.DISCOVERY.SELECTOR.CONFIG.DISCOVERY": "Discovery Config",
+  "SHENYU.DISCOVERY.SELECTOR.CONFIG.IMPORT": "Import Background Discovery Config",
+  "SHENYU.DISCOVERY.SELECTOR.CONFIG.IMPORT.CONFIRM": "Configuration Import Confirmation",
   "SHENYU.DISCOVERY.SELECTOR.DELETE.CONFIRM": "Are you sure to delete this selector?",
+  "SHENYU.DISCOVERY.SELECTOR.CONFIG.IMPORT.SURE": "Import",
   "SHENYU.COMMON.REFRESH": "Refresh"
-}
+}

src/locales/zh-CN.json

@@ -408,12 +408,19 @@
   "SHENYU.DISCOVERY.SELECTOR.CONFIGURATION": "服务发现配置",
   "SHENYU.DISCOVERY.SELECTOR.UPSTREAM": "服务下游列表",
   "SHENYU.DISCOVERY.SELECTOR.UPSTREAM.ADD": "添加下游服务",
-  "SHENYU.DISCOVERY.SELECTOR.UPSTREAM.DELETE": "确定删除吗",
+  "SHENYU.DISCOVERY.SELECTOR.UPSTREAM.DELETE.CONFIRM": "确定删除吗",
+  "SHENYU.DISCOVERY.SELECTOR.UPSTREAM.CANCEL.CONFIRM": "确定取消吗",
   "SHENYU.DISCOVERY.SELECTOR.UPSTREAM.OPERATION": "操作",
+  "SHENYU.DISCOVERY.SELECTOR.UPSTREAM.CANCEL": "取消",
+  "SHENYU.DISCOVERY.SELECTOR.UPSTREAM.SAVE": "保存",
+  "SHENYU.DISCOVERY.SELECTOR.UPSTREAM.EDIT": "编辑",
   "SHENYU.DISCOVERY.SELECTOR.UPSTREAM.DateCreated": "创建时间",
   "SHENYU.DISCOVERY.SELECTOR.UPSTREAM.DateUpdated": "更新时间",
   "SHENYU.DISCOVERY.SELECTOR.CONFIG.BASIC": "基本配置",
   "SHENYU.DISCOVERY.SELECTOR.CONFIG.DISCOVERY": "服务发现",
+  "SHENYU.DISCOVERY.SELECTOR.CONFIG.IMPORT": "导入后台服务发现配置",
+  "SHENYU.DISCOVERY.SELECTOR.CONFIG.IMPORT.CONFIRM": "后台配置导入确认",
+  "SHENYU.DISCOVERY.SELECTOR.CONFIG.IMPORT.SURE": "导入",
   "SHENYU.DISCOVERY.SELECTOR.DELETE.CONFIRM": "确定删除该选择器吗?",
   "SHENYU.COMMON.REFRESH": "刷新"
 }

src/models/common.js

@@ -109,7 +109,8 @@ export default {
       const json = yield call(addSelector, payload);
       if (json.code === 200) {
         message.success(getIntlContent('SHENYU.COMMON.RESPONSE.ADD.SUCCESS'));
-        callback();
+        const selectorId = json.data;
+        callback(selectorId);
         yield put({ type: "reload", fetchValue });
       } else {
         message.warn(json.message);

src/models/discovery.js

@@ -25,8 +25,9 @@ import {
   updateProxySelector,
   getDiscovery,
   refreshProxySelector,
-  deleteDiscovery
-
+  deleteDiscovery,
+  bindingSelector,
+  updateDiscoveryUpstream
 } from "../services/api";
 import {getIntlContent} from "../utils/IntlUtils";
 
@@ -35,15 +36,15 @@ export default {
 
   state: {
     typeEnums: [],
-    selectorList: [],
+    proxySelectorList: [],
     chosenType: '',
     totalPage: 0,
     currentPage: 1,
     pageSize: 6
   },
 
   effects: {
-    * fetchSelector(params, {call, put}) {
+    * fetchProxySelectors(params, {call, put}) {
       const {payload} = params;
       const json = yield call(fetchProxySelector, payload);
       if (json.code === 200) {
@@ -80,6 +81,7 @@ export default {
         message.warn(json.message);
       }
     },
+
     * delete(params, {call, put}) {
       const {payload, fetchValue} = params;
       const { list } = payload;
@@ -92,6 +94,7 @@ export default {
         message.warn(json.message);
       }
     },
+
     * update(params, {call, put}) {
       const {payload, callback, fetchValue} = params;
       const json = yield call(updateProxySelector, payload);
@@ -103,11 +106,12 @@ export default {
         message.warn(json.message);
       }
     },
+
     * reload(params, {put}) {
       const {fetchValue} = params;
       const {name = '', currentPage, pageSize} = fetchValue;
       const payload = {name, currentPage, pageSize};
-      yield put({type: "fetchSelector", payload});
+      yield put({type: "fetchProxySelectors", payload});
     },
 
 
@@ -116,9 +120,9 @@ export default {
       const json = yield call(postDiscoveryInsertOrUpdate, payload);
       if (json.code === 200) {
         message.success(getIntlContent('SHENYU.COMMON.RESPONSE.CONFIGURATION.SUCCESS'));
-        const { data } = json;
+        const discoveryConfigData = json.data;
         if (callback) {
-          callback(data);
+          callback(discoveryConfigData);
         }
       } else {
         message.warn(json.message);
@@ -162,14 +166,35 @@ export default {
       }
     },
 
+    * bindSelector(params, {call}) {
+      const {payload} = params;
+      const json = yield call(bindingSelector, payload);
+      if (json.code === 200) {
+        // message.success(getIntlContent('SHENYU.COMMON.RESPONSE.ADD.SUCCESS'));
+        // callback();
+      } else {
+        message.warn(json.message);
+      }
+    },
+
+    * updateDiscoveryUpstream(params, {call}) {
+      const { discoveryHandlerId, upstreams } = params.payload;
+      const json = yield call(updateDiscoveryUpstream, discoveryHandlerId, upstreams);
+      if (json.code === 200) {
+        // message.success(getIntlContent('SHENYU.COMMON.RESPONSE.UPDATE.SUCCESS'));
+      } else {
+        message.warn(json.message);
+      }
+    },
+
   },
 
   reducers: {
     saveProxySelectors(state, {payload}) {
       return {
         ...state,
         totalPage: payload.total,
-        selectorList: payload.dataList,
+        proxySelectorList: payload.dataList,
       };
     },