Refactor, added Error exception assert

Installed chai-as-promised (again)

Author: nuxy

package-lock.json

@@ -30,6 +30,7 @@
     "@lambda-lambda-lambda/router": "latest",
     "@types/aws-lambda": "^8.10.111",
     "chai": "^4.3.7",
+    "chai-as-promised": "^7.1.1",
     "clone": "^2.1.2",
     "cookie": "^0.5.0",
     "eslint": "^7.32.0",

package.json

@@ -2,60 +2,56 @@
 
 const https = require('https');
 
+const {RouterError} = require('@lambda-lambda-lambda/router/src/router/Error');
+
 /**
  * Middleware to validate Google ReCAPTCHA invisible responses.
  *
  * @requires AppConfigPlugin
  */
 module.exports = async (req, res, next) => {
-  return new Promise(function(resolve) {
-    const {google} = req.plugin('config');
-
-    const secretKey = google?.reCaptcha?.secretKey;
-
-    if (!secretKey) {
-      /* istanbul ignore next */
-      throw new Error('Missing Google API secret key');
-    }
-
-    if (req.method() === 'POST') {
-      const captchaResponse = req.param('g-recaptcha-response');
-
-      const options = {
-        hostname: 'www.google.com',
-        port: 443,
-        path: '/recaptcha/api/siteverify',
-        method: 'POST',
-        headers: {
-          'Content-Type': 'application/x-www-form-urlencoded'
-        }
-      };
-
-      const httpRequest = https.request(options, hr => {
-
-        /* istanbul ignore next */
-        if (hr.statusCode === 200) {
-          hr.on('data', buffer => {
-            const {success} = JSON.parse(buffer.toString());
-
-            if (success !== true) {
-
-              // Return error response.
-              res.status(400).send('Bad Request');
-            }
-
-            resolve();
-          });
-        } else {
-          console.warn(`Google API error: ${hr.statusMessage}`);
-
-          // Return error response.
-          res.status(500).send('Internal Server Error');
-        }
-      });
-
-      httpRequest.write(`secret=${secretKey}&response=${captchaResponse}`);
-      httpRequest.end();
-    }
-  });
+  const {google} = req.plugin('config');
+
+  const secretKey = google?.reCaptcha?.secretKey;
+
+  if (!secretKey) {
+    throw new RouterError('Missing Google API secret key');
+  }
+
+  /* istanbul ignore next */
+  if (req.method() === 'POST') {
+    const captchaResponse = req.param('g-recaptcha-response');
+
+    const options = {
+      hostname: 'www.google.com',
+      port: 443,
+      path: '/recaptcha/api/siteverify',
+      method: 'POST',
+      headers: {
+        'Content-Type': 'application/x-www-form-urlencoded'
+      }
+    };
+
+    const httpRequest = https.request(options, hr => {
+      if (hr.statusCode === 200) {
+        hr.on('data', buffer => {
+          const {success} = JSON.parse(buffer.toString());
+
+          if (success !== true) {
+
+            // Return error response.
+            res.status(400).send('Bad Request');
+          }
+        });
+      } else {
+        console.warn(`Google API error: ${hr.statusMessage}`);
+
+        // Return error response.
+        res.status(500).send('Internal Server Error');
+      }
+    });
+
+    httpRequest.write(`secret=${secretKey}&response=${captchaResponse}`);
+    httpRequest.end();
+  }
 };

plugins/GoogleRecaptchaHandler/src/plugin.js

@@ -1,16 +1,26 @@
 'use strict';
 
-const event = require(`${PACKAGE_ROOT}/event.json`);
-const chai  = require('chai');
+const event          = require(`${PACKAGE_ROOT}/event.json`);
+const chai           = require('chai');
+const chaiAsPromised = require('chai-as-promised');
+const sinon          = require('sinon');
+const https          = require('https');
+
+chai.use(chaiAsPromised);
 
 const expect = chai.expect;
 
 // Load modules.
-const Request    = require('@lambda-lambda-lambda/router/src/router/Request.js');
-const Response   = require('@lambda-lambda-lambda/router/src/router/Response.js');
-const Stack      = require('@lambda-lambda-lambda/router/src/router/Stack.js');
-const Utils      = require('@lambda-lambda-lambda/router/src/router/Utils.js');
-const middleware = require(PLUGIN_ROOT);
+const {RouterError} = require('@lambda-lambda-lambda/router/src/router/Error');
+const Request       = require('@lambda-lambda-lambda/router/src/router/Request.js');
+const Response      = require('@lambda-lambda-lambda/router/src/router/Response.js');
+const Stack         = require('@lambda-lambda-lambda/router/src/router/Stack.js');
+const Utils         = require('@lambda-lambda-lambda/router/src/router/Utils.js');
+const middleware    = require(PLUGIN_ROOT);
+
+afterEach(() => {
+  sinon.restore();
+});
 
 describe('GoogleReCaptchaHandler', function() {
   describe('success', function() {
@@ -33,7 +43,7 @@ describe('GoogleReCaptchaHandler', function() {
     Utils.setFuncName(dependency, 'middleware');
     Utils.setFuncName(middleware, 'middleware');
 
-    const route = function(req, res) {
+    const route = async function(req, res, next) {
       res.status(200).send();
     };
 
@@ -69,4 +79,50 @@ describe('GoogleReCaptchaHandler', function() {
       expect(result.body).to.be.undefined;
     });
   });
+
+  describe('error', function() {
+    const stack = new Stack();
+
+    const dependency = function(req, res, next) {
+      const config = {
+        google: {
+          reCaptcha: {
+            secretKey: ''
+          }
+        }
+      };
+
+      req.plugin('config', config);
+      next();
+    };
+
+    Utils.setFuncName(dependency, 'middleware');
+    Utils.setFuncName(middleware, 'middleware');
+
+    const route = async function(req, res, next) {
+      res.status(200).send();
+    };
+
+    Utils.setFuncName(route, 'route:index');
+
+    stack.middleware = [dependency, middleware];
+    stack.routes     = route;
+
+    // Define form POST parameters.
+    event.Records[0].cf.request.method = 'POST';
+    event.Records[0].cf.request.uri    = '/path/to/resource';
+    event.Records[0].cf.request.body   = {
+      data: Buffer.from('g-recaptcha-response=GOOGLE_RESPONSE')
+        .toString('base64')
+    };
+
+    const req = new Request(event.Records[0].cf.request, {});
+    const res = new Response({});
+
+    it('should throw RouterError', function() {
+      const result = stack.exec(req, res);
+
+      return expect(result).to.be.rejectedWith(RouterError, /Missing Google API secret key/);
+    });
+  });
 });