Bus: custom URL params (queries) was added

Author: stazeworks

lib/bus.js

@@ -4,25 +4,43 @@ const { metarhia } = require('./deps.js');
 
 const prepare = (unit, application) => {
   const namespaces = application.schemas ? [application.schemas.model] : [];
-  const { parameters, returns } = unit;
+  const { parameters, query = {}, returns } = unit;
   const { Schema } = metarhia.metaschema;
   const validation = {
     parameters: parameters ? Schema.from(parameters, namespaces) : null,
+    query: query.params ? Schema.from(query.params, namespaces) : null,
     returns: returns ? Schema.from(returns, namespaces) : null,
   };
-  const method = async (args) => {
-    const { parameters, returns } = validation;
+  const method = async (args = {}) => {
+    const { parameters, query, returns } = validation;
     if (parameters) {
       const { valid, errors } = parameters.check(args);
       const problems = errors.join('; ');
       if (!valid) return new Error('Invalid parameters type: ' + problems);
     }
+    if (unit.query.params) {
+      const { valid, errors } = query.check(args);
+      const problems = errors.join('; ');
+      if (!valid) return new Error('Invalid query type: ' + problems);
+    }
     const service = method.parent['.service'];
     const verb = unit.method.get ? 'get' : 'post';
     const target = [service.url, unit.method[verb]];
     if (unit.method.path) {
       target.push(...unit.method.path.map((arg) => args[arg]));
     }
+    let url = target.join('/');
+    if (unit.query) {
+      const params = [];
+      const { prefix = '', suffix = '' } = unit.query;
+      for (const param of Object.keys(unit.query.params)) {
+        if (!args[param]) continue;
+        params.push([prefix + param + suffix, args[param]]);
+      }
+      const parsedParams = Object.fromEntries(params);
+      const stringParams = new URLSearchParams(parsedParams).toString();
+      url = params.length ? url + '?' + stringParams : url;
+    }
     const body = metarhia.metautil.serializeArguments(unit.method.body, args);
     const url = target.join('/');
     const options = { method: verb.toUpperCase(), headers: unit.headers, body };

test/bus.js

@@ -25,7 +25,7 @@ test('lib/bus - should load bus correctly', async () => {
   assert.deepStrictEqual(bus.tree, {});
 
   await bus.load();
-  assert.deepStrictEqual(Object.keys(bus.tree), ['math', 'worldTime']);
+  assert.deepStrictEqual(Object.keys(bus.tree), ['fakerapi', 'math', 'worldTime']);
   assert.strictEqual(bus.tree.math.parent, bus.tree);
   assert.strictEqual(typeof bus.tree.math, 'object');
   assert.strictEqual(typeof bus.tree.math.eval, 'function');

test/bus/fakerapi/.service.js

@@ -0,0 +1,7 @@
+({
+  url: 'https://fakerapi.it',
+  limits: [
+    { calls: 10, per: '1m' },
+    { calls: 10000, per: '1d' },
+  ],
+});

test/bus/fakerapi/books.js

@@ -0,0 +1,32 @@
+({
+  method: {
+    get: 'api/v1/books',
+  },
+
+  query: {
+    prefix: '_',
+    params: {
+      quantity: '?number',
+    },
+  },
+
+  returns: {
+    status: 'string',
+    code: 'number',
+    total: 'number',
+    data: {
+      type: 'array',
+      value: {
+        id: 'number',
+        title: 'string',
+        author: 'string',
+        genre: 'string',
+        description: 'string',
+        isbn: 'string',
+        image: 'string',
+        published: 'string',
+        publisher: 'string',
+      },
+    },
+  },
+});