feat: uniform throw errors

Author: yugasun

.eslintignore

@@ -2,4 +2,3 @@ coverage
 dist
 node_modules
 example
-*.test.js

src/baas/apigw/index.js

@@ -1,5 +1,6 @@
 const { apigw } = require('tencent-cloud-sdk');
 const { uniqueArray } = require('../../utils/index');
+const { TypeError } = require('../../utils/error');
 
 class Apigw {
   constructor(credentials = {}, region) {
@@ -19,11 +20,19 @@ class Apigw {
 
   async request(inputs) {
     inputs.Region = this.region;
-    const result = await this.apigwClient.request(inputs);
-    if (result.code != 0) {
-      throw new Error(`Request API ${inputs.Action} failed: ${result.message}`);
-    } else {
-      return result;
+    try {
+      const result = await this.apigwClient.request(inputs);
+
+      if (result.code != 0) {
+        throw new TypeError(
+          `API_APIGW_${inputs.Action}`,
+          `Request API ${inputs.Action} failed: ${result.message}`,
+        );
+      } else {
+        return result;
+      }
+    } catch (e) {
+      throw new TypeError(`API_APIGW_${inputs.Action}`, e.message, e.stack);
     }
   }
 
@@ -122,7 +131,10 @@ class Apigw {
 
     if (endpoint.protocol === 'WEBSOCKET') {
       if (!endpoint.function.transportFunctionName) {
-        throw new Error('"endpoints.function.transportFunctionName" is required');
+        throw new TypeError(
+          `PARAMETER_APIGW`,
+          '"endpoints.function.transportFunctionName" is required',
+        );
       }
       apiInputs.serviceWebsocketTransportFunctionName = endpoint.function.transportFunctionName;
       apiInputs.serviceWebsocketTransportFunctionQualifier = funcQualifier;
@@ -137,7 +149,7 @@ class Apigw {
       apiInputs.serviceWebsocketCleanupFunctionNamespace = funcNamespace;
     } else {
       if (!funcName) {
-        throw new Error('"endpoints.function.functionName" is required');
+        throw new TypeError(`PARAMETER_APIGW`, '"endpoints.function.functionName" is required');
       }
       apiInputs.serviceScfFunctionName = funcName;
       apiInputs.serviceScfFunctionNamespace = funcNamespace;

src/baas/apigw/index.test.js

@@ -1,32 +1,32 @@
-const Apigw = require('./index')
+const Apigw = require('./index');
 
 async function runTest() {
   const credentials = {
     SecretId: '',
-    SecretKey: ''
-  }
+    SecretKey: '',
+  };
 
   const inputs = {
     region: 'ap-guangzhou',
     serviceId: 'service-7i9kk5a8',
     protocols: ['http', 'https'],
     serviceName: 'serverless',
     environment: 'release',
-    customDomains: [
-      {
-        domain: 'fullstack.yugasun.com',
-        // TODO: change to your certId
-        certificateId: '123456',
-        isDefaultMapping: 'FALSE',
-        pathMappingSet: [
-          {
-            path: '/',
-            environment: 'release'
-          }
-        ],
-        protocols: ['http', 'https']
-      }
-    ],
+    // customDomains: [
+    //   {
+    //     domain: 'fullstack.yugasun.com',
+    //     // TODO: change to your certId
+    //     certificateId: '123456',
+    //     isDefaultMapping: 'FALSE',
+    //     pathMappingSet: [
+    //       {
+    //         path: '/',
+    //         environment: 'release',
+    //       },
+    //     ],
+    //     protocols: ['http', 'https'],
+    //   },
+    // ],
     endpoints: [
       {
         apiId: 'api-a05zvycu',
@@ -35,7 +35,7 @@ async function runTest() {
         method: 'GET',
         apiName: 'index',
         function: {
-          functionName: 'egg-function'
+          functionName: 'egg-function',
         },
         usagePlan: {
           usagePlanName: 'slscmp',
@@ -45,17 +45,21 @@ async function runTest() {
         auth: {
           serviceTimeout: 15,
           secretName: 'secret',
-        }
+        },
 
-      }
-    ]
-  }
-  const apigw = new Apigw(credentials, inputs.region)
-  const outputs = await apigw.deploy(inputs)
+      },
+    ],
+  };
+  const apigw = new Apigw(credentials, inputs.region);
+  const outputs = await apigw.deploy(inputs);
   console.log('outputs', JSON.stringify(outputs));
 
 
-  await apigw.remove(outputs)
+  await apigw.remove(outputs);
 }
 
-runTest()
+runTest();
+
+process.on('unhandledRejection', (e) => {
+  throw e;
+});

src/baas/cam/index.js

@@ -1,4 +1,5 @@
 const { cam } = require('tencent-cloud-sdk');
+const { TypeError } = require('../../utils/error');
 
 class Cam {
   constructor(credentials = {}, region) {
@@ -7,10 +8,21 @@ class Cam {
     this.camClient = new cam(this.credentials);
   }
 
-  async sleep(ms) {
-    return new Promise((resolve) => {
-      setTimeout(resolve, ms);
-    });
+  async request(data) {
+    try {
+      const res = await this.camClient.request(data);
+
+      if (res.Response && res.Response.Error) {
+        throw new TypeError(
+          `API_CAM_${data.Action}`,
+          JSON.stringify(res.Response),
+          res.Response.RequestId,
+        );
+      }
+      return res;
+    } catch (e) {
+      throw new TypeError(`API_CAM_${data.Action}`, e.message, e.stack);
+    }
   }
 
   async DescribeRoleList(page, limit) {
@@ -20,7 +32,7 @@ class Cam {
       Page: page,
       Rp: limit,
     };
-    return await this.camClient.request(reqParams);
+    return this.request(reqParams);
   }
 
   async ListRolePoliciesByRoleId(roleId, page, limit) {
@@ -31,7 +43,7 @@ class Cam {
       Rp: limit,
       RoleId: roleId,
     };
-    return await this.camClient.request(reqParams);
+    return this.request(reqParams);
   }
 
   async CreateRole(roleName, policiesDocument) {
@@ -42,7 +54,7 @@ class Cam {
       PolicyDocument: policiesDocument,
       Description: 'Serverless Framework',
     };
-    return await this.camClient.request(reqParams);
+    return this.request(reqParams);
   }
 
   // api limit qps 3/s
@@ -53,16 +65,13 @@ class Cam {
       AttachRoleId: roleId,
       PolicyName: policyName,
     };
-    return await this.camClient.request(reqParams);
+    return this.request(reqParams);
   }
 
   async CheckSCFExcuteRole() {
     const ScfExcuteRoleName = 'QCS_SCFExcuteRole';
 
     const roles = await this.DescribeRoleList(1, 200);
-    if (roles.Response.Error) {
-      throw new Error(roles.Response.Error.Message);
-    }
 
     const len = roles.Response.List.length;
     for (var i = 0; i < len; i++) {

src/baas/cam/index.test.js

@@ -1,15 +1,18 @@
-const secret = require('../../../../secret')
-const CamUtils = require('./index')
+const CamUtils = require('./index');
 
 class ClientTest {
 	async camTest() {
 		const cam = new CamUtils({
-			SecretId: secret.SecretId,
-			SecretKey: secret.SecretKey
-		})
-		const ret = await cam.CheckSCFExcuteRole()
-		console.log(ret)
+			SecretId: '',
+			SecretKey: '',
+		});
+		const ret = await cam.CheckSCFExcuteRole();
+		console.log(ret);
 	}
 }
 
-new ClientTest().camTest()
+new ClientTest().camTest();
+
+process.on('unhandledRejection', (e) => {
+  throw e;
+});

src/baas/cdn/apis.js

@@ -1,9 +1,4 @@
-function HttpError(code, message, reqId) {
-  this.code = code || 0;
-  this.message = reqId ? `${reqId}, ${message || ''}` : message || '';
-}
-
-HttpError.prototype = Error.prototype;
+const { TypeError } = require('../../utils/error');
 
 function isEmpty(val) {
   return val === undefined || val === null || (typeof val === 'number' && isNaN(val));
@@ -41,11 +36,16 @@ function apiFactory(actions) {
           },
         );
         if (Response && Response.Error && Response.Error.Code) {
-          throw new HttpError(Response.Error.Code, Response.Error.Message, Response.RequestId);
+          throw new TypeError(
+            `API_CDN_${action}`,
+            Response.Error.Message,
+            null,
+            Response.RequestId,
+          );
         }
         return Response;
       } catch (e) {
-        throw new HttpError(500, e.message);
+        throw new TypeError(`API_CDN_${action}`, JSON.stringify(e), e.stack);
       }
     };
   });

src/baas/cdn/index.js

@@ -1,5 +1,6 @@
 const { Capi } = require('@tencent-sdk/capi');
 const { sleep, waitResponse } = require('@ygkit/request');
+const { TypeError } = require('../../utils/error');
 const {
   AddCdnDomain,
   UpdateDomainConfig,
@@ -240,7 +241,7 @@ class Cdn {
   async remove(inputs = {}) {
     const { domain } = inputs;
     if (!domain) {
-      throw new Error('domain is required');
+      throw new TypeError(`PARAMETER_CDN`, 'domain is required');
     }
 
     // need circle for deleting, after domain status is 6, then we can delete it

src/baas/cdn/index.test.js

@@ -1,10 +1,10 @@
-const Cdn = require('./index')
+const Cdn = require('./index');
 
 async function runTest() {
   const credentials = {
     SecretId: '',
-    SecretKey: ''
-  }
+    SecretKey: '',
+  };
 
   // const inputs = {
   //   async: true,
@@ -49,28 +49,27 @@ async function runTest() {
       switch: 'on',
       http2: 'on',
       certInfo: {
-        certId: 'xxx'
-      }
+        certId: 'xxx',
+      },
     },
     forceRedirect: {
       switch: 'on',
       redirectType: 'https',
-      redirectStatusCode: 301
-    }
-  }
-  const cdn = new Cdn(credentials, inputs.region)
-  const outputs = await cdn.deploy(inputs)
-  console.log(outputs)
+      redirectStatusCode: 301,
+    },
+  };
+  const cdn = new Cdn(credentials, inputs.region);
+  const outputs = await cdn.deploy(inputs);
+  console.log(outputs);
 
-  // await cdn.remove({
-  //   domain: 'fullstack.yugasun.com'
-  // })
+  await cdn.remove({
+    domain: 'fullstack.yugasun.com',
+  });
 }
 
-runTest()
+runTest();
 
 
 process.on('unhandledRejection', (e) => {
   console.log(e);
-
-})
+});