Merge pull request #8 from f5devcentral/http-fetch

HTTP fetch and forwarding

Author: mstokes-f5

CHANGELOG.md

@@ -1,6 +1,8 @@
 # v0.7.0
 ## Added
 * Add jsdoc-style docs to classes mentioned in the README
+* Add option to get variable values from HTTP requests
+* Add Template.forwardHttp() to forward a rendered template result to an HTTP server
 
 ## Fixed
 * Improve guiUtils.filterExtraProperties() when using template merging

lib/http_utils.js

@@ -23,10 +23,14 @@ const makeRequest = (opts, payload) => {
             res.on('end', () => {
                 let body = buffer.join('');
                 body = body || '{}';
-                try {
-                    body = JSON.parse(body);
-                } catch (e) {
-                    return reject(new Error(`Invalid response object from ${combOpts.method} to ${combOpts.path}`));
+                if (combOpts.headers && combOpts.headers['Content-Type'] === 'application/json') {
+                    try {
+                        body = JSON.parse(body);
+                    } catch (e) {
+                        return reject(
+                            new Error(`Invalid response object from ${combOpts.method} to ${combOpts.path}`)
+                        );
+                    }
                 }
                 return resolve({
                     status: res.statusCode,

lib/template.js

@@ -9,6 +9,7 @@ const $RefParser = require('@apidevtools/json-schema-ref-parser');
 const url = require('url');
 const deepmerge = require('deepmerge');
 const path = require('path');
+const jsonpath = require('jsonpath');
 
 const httpUtils = require('./http_utils');
 
@@ -114,6 +115,7 @@ class Template {
         this._allOf = [];
         this._anyOf = [];
         this.contentType = 'text/plain';
+        this.httpForward = null;
     }
 
     _loadTypeSchemas(schemaProvider) {
@@ -431,12 +433,9 @@ class Template {
     _createParametersValidator() {
         const loadSchema = (uri) => {
             uri = url.parse(uri);
-            const opts = {
-                host: uri.host,
-                port: uri.port,
-                parth: uri.pathName,
+            const opts = Object.assign({}, url.parse(uri), {
                 method: 'GET'
-            };
+            });
             return httpUtils.makeRequest(opts)
                 .then((res) => {
                     if (res.statusCode >= 400) {
@@ -772,6 +771,80 @@ class Template {
             return acc;
         });
     }
+
+    fetchHttp() {
+        const promises = [];
+        const view = {};
+        Object.entries(this.definitions).forEach(([def, defProp]) => {
+            if (!defProp.url) {
+                return;
+            }
+
+            const defaultOpts = {
+                method: 'GET',
+                host: null,
+                port: null,
+                headers: {
+                }
+            };
+            const urlOpts = (typeof defProp.url === 'string') ? url.parse(defProp.url) : defProp.url;
+            const opts = Object.assign({}, defaultOpts, urlOpts);
+            promises.push(Promise.resolve()
+                .then(() => httpUtils.makeRequest(opts))
+                .then((res) => {
+                    if (res.statusCode >= 400) {
+                        return Promise.reject(new Error(`error loading ${defProp.url}: ${res.statusCode}`));
+                    }
+                    try {
+                        view[def] = JSON.parse(res.body);
+                    } catch (e) {
+                        view[def] = res.body;
+                    }
+                    if (defProp.pathQuery) {
+                        const results = jsonpath.query(view[def], defProp.pathQuery, 1);
+                        view[def] = results[0];
+                    }
+                    return Promise.resolve();
+                }));
+        });
+        return Promise.all(promises)
+            .then(() => view);
+    }
+
+    fetchAndRender(parameters) {
+        return Promise.resolve()
+            .then(() => this.fetchHttp())
+            .then(httpView => Object.assign({}, parameters, httpView))
+            .then(combParams => this.render(combParams));
+    }
+
+    forwardHttp(parameters) {
+        if (!this.httpForward) {
+            return Promise.reject(
+                new Error('httpForward was not defined for this template')
+            );
+        }
+
+        const defaultOpts = {
+            method: 'POST',
+            host: null,
+            port: null,
+            headers: {
+                'Content-Type': this.contentType
+            }
+        };
+        const urlOpts = (typeof this.httpForward.url === 'string') ? url.parse(this.httpForward.url) : this.httpForward.url;
+        const opts = Object.assign({}, defaultOpts, urlOpts);
+        return Promise.resolve()
+            .then(() => this.fetchAndRender(parameters))
+            .then(() => httpUtils.makeRequest(opts))
+            .then((res) => {
+                if (res.statusCode >= 400) {
+                    return Promise.reject(new Error(`error forwarding to ${this.httpForward.url}: ${res.statusCode}`));
+                }
+                return Promise.resolve(res);
+            });
+    }
 }
 
 module.exports = {

package-lock.json

@@ -56,6 +56,7 @@
     "deepmerge": "^4.2.2",
     "js-yaml": "^3.14.0",
     "json-schema-merge-allof": "^0.7.0",
+    "jsonpath": "^1.0.2",
     "mustache": "^4.0.1",
     "uuid": "^7.0.3",
     "yargs": "^15.4.1"