feature: bodyArgs

Author: zhaoxuxu

src/fake-services/example/__param1__/map

@@ -18,6 +18,12 @@
 #                        to match value
 #                    e.g. _pa1={.*}&pa2={.*}
 #
+#     +bodyArgs    : optional
+#                    starts with +
+#                    urlencoded, braces to include a regular expression
+#                        to match value
+#                    e.g. +arg1={.*}&arg2={.*}
+#
 #     responsePath : required
 #                    search response file by this field based on current
 #                        directory
@@ -27,8 +33,10 @@
 # ], divided with space(s), e.g:
 # GET ?qu1={.*}&qu2={.*} _pa1={.*}&pa2={.*} ./response
 # @2019-5-29 created by @zhaoxuxu
+# @2021-3-17 updated by @zhaoxuxu
 
 GET ?range={.*}&n={.*} _param1={.*} ./response
 GET _param1={.*} ./response
 GET ?range={.*}&n={.*} ./response
+POST +username={xyz}&password={.*} ./response
 GET ./response

src/fake-services/example/off renamed to src/fake-services/example/offf

@@ -1,4 +1,5 @@
 # https://nodejs.org
 
 baidu https://baidu.com
-node https://nodejs.org
+bing https://bing.com
+https://nodejs.org

src/fake-services/proxy404

@@ -36,6 +36,8 @@ if (fs.existsSync(proxy404CfgFile)
     });
 }
 
+const REQUEST_MAX_SIZE = '10mb';
+app.use(express.json({limit: REQUEST_MAX_SIZE}));
 app.use(mapToRes);
 
 function tillListen(tryPort) {

src/index.js

@@ -39,6 +39,7 @@ function matchOneLine(line, req){
         method: fields[0],
         querys: parseQueryStr(fields.find(fld => fld[0] === '?')),
         pathParams: parseQueryStr(fields.find(fld => fld[0] === '_')),
+        bodyArgs: parseQueryStr(fields.find(fld => fld[0] === '+')),
         responsePath: fields[fields.length - 1],
     };
 
@@ -86,6 +87,26 @@ function matchOneLine(line, req){
     if (!pathParamsOk)
         return false;
 
+    let bodyArgsOk = false;
+    if (_.isObject(cfg.bodyArgs)) {
+        bodyArgsOk = true;
+        const keys = Object.keys(cfg.bodyArgs);
+        for (let i = 0; i < keys.length; i++) {
+            const key = keys[i];
+            const rule = cfg.bodyArgs[key];
+            if(!isRuleMatch(rule, req.body[key])) {
+                bodyArgsOk = false;
+                break;
+            }
+        }
+    } else if (cfg.bodyArgs === false){
+        bodyArgsOk = true;
+    } else {
+        return new Error('Abnormal condition.');
+    }
+    if (!bodyArgsOk)
+        return false;
+
     return cfg.responsePath;
 }
 
@@ -102,15 +123,19 @@ function walkMapFileLines(mapFilePath, req) {
                 const tmp = matchOneLine(line, req);
                 if (tmp) {
                    responsePath = tmp;
-                   lineReader.close();
                    resolve(responsePath);
+                   lineReader.close();
                 }
             }
             catch (err) {
                 err.message = `Bad rule for matching: ${line}. ${err.message}`;
                 reject(err.message);
             }
         });
+        lineReader.on('close', () => {
+            // handle only EOF situation
+            reject('No match.');
+        });
     });
 }
 
@@ -124,7 +149,10 @@ function match(req) {
             if (fs.existsSync(mapFilePath)) {
                 walkMapFileLines(mapFilePath, req).then(
                     responsePath => resolve(pathUtil.resolve(resource.path, responsePath)),
-                    reason => reject(reason),
+                    reason => {
+                        console.error(reason);
+                        resolve(null);
+                    },
                 );
             } else if (fs.existsSync(defaultResponsePath)) {
                 resolve(defaultResponsePath);

src/middlewares/mapToRes/matchAResponse.js

@@ -1,2 +1,5 @@
 curl localhost:3000/example/sdfd?sdsd=223 -v
 curl localhost:3000/404/sdfd?sdsd=223 -v
+curl localhost:3000/example/sdfd?sdsd=223 -v \
+  -H 'content-type: application/json' \
+  --data '{"username":"xyz","password":"xyz"}'

src/test/curl

@@ -1,7 +1,7 @@
 module.exports = function(str) {
     if (!str) return false;
     let ret = {};
-    if (str[0] === '?' || str[0] === '_')
+    if (str[0] === '?' || str[0] === '_' || str[0] === '+')
         str = str.slice(1);
     str.split('&')
         .filter(one => one.length > 0)