Merge pull request #76 from macacajs/feat-global-proxy

Feat global proxy

Author: zhangyuheng

app/controller/api/interface.js

@@ -50,6 +50,13 @@ class InterfaceController extends Controller {
     ctx.success(res);
   }
 
+  async updateAllProxy() {
+    const ctx = this.ctx;
+    const { projectUniqId, enabled } = ctx.request.body;
+    const res = await ctx.service.interface.updateAllProxy({ projectUniqId, enabled });
+    ctx.success(res);
+  }
+
   async delete() {
     const ctx = this.ctx;
     const { uniqId } = ctx.params;

app/router.js

@@ -48,6 +48,7 @@ module.exports = app => {
   router.post('/api/sdk/switch_scene', controller.api.sdk.switchScene);
   router.post('/api/sdk/switch_multi_scenes', controller.api.sdk.switchMultiScenes);
   router.post('/api/sdk/switch_all_scenes', controller.api.sdk.switchAllScenes);
+  router.post('/api/sdk/switch_all_proxy', controller.api.interface.updateAllProxy);
 
   router.all('/data/:projectName/:pathname+', contextMiddleWare, controller.data.index);
 };

app/service/interface.js

@@ -90,6 +90,28 @@ class InterfaceService extends Service {
     );
   }
 
+  async updateAllProxy({ projectUniqId, enabled }) {
+    const interfaces = await this.ctx.model.Interface.findAll({
+      where: {
+        projectUniqId,
+      },
+    });
+
+    await Promise.all(interfaces.map(async item => {
+      const proxyConfig = Object.assign(item.proxyConfig, {
+        enabled,
+      });
+      return await this.updateInterface({
+        uniqId: item.dataValues.uniqId,
+        payload: {
+          proxyConfig,
+        },
+      });
+    }));
+
+    return null;
+  }
+
   async deleteInterfaceByUniqId({ uniqId }) {
     return await this.ctx.model.Interface.destroy({
       where: {

package.json

@@ -1,6 +1,6 @@
 {
   "name": "macaca-datahub",
-  "version": "2.1.8",
+  "version": "2.1.9",
   "description": "Continuous data provider for development, testing, staging and production.",
   "bin": {
     "datahub": "./bin/datahub.js",