feat: add soar protocol super class

Take tag/branch/commitref as constructor arg
and retrieve schema from gitlab

dist/protocol.esm.js

+import axios from 'axios';
 import Validator from 'swagger-model-validator';
 
 /**
@@ -25,8 +26,17 @@ import Validator from 'swagger-model-validator';
 class GenericProtocol {
   constructor(schema, services) {
     this.schema = schema;
-    this.validator = new Validator(schema);
     this.services = services;
+    this.validator = this.createValidator(schema);
+  }
+
+  /**
+   * Create a Validator from the provided JSONSchema
+   * @param {object} schema 
+   * @returns {Validator}
+   */
+  createValidator(schema) {
+    return new Validator(schema);
   }
 
   /**
@@ -84,4 +94,69 @@ class GenericProtocol {
   }
 }
 
-export { GenericProtocol };
+
+/**
+ * GenericSoarProtocol defines a simple passthru handler for messages
+ * 
+ * This provides the same as above but loads a version of the 
+ * SoAR message protocol  
+ */
+class GenericSoarProtocol extends GenericProtocol {
+  constructor(schema, services) {
+    super(schema, services);
+  }
+
+  /**
+   * Create a Validator from the provided JSONSchema
+   * 
+   * If schema is a string build a URL and retrieve the 
+   * schema from gitlab 
+   * @param {string|object} schema 
+   * @returns {object}
+   */
+  async createValidator(schema) {
+    if (typeof schema === 'string' && schema.match(/^[\w\.]+$/)) {
+      return await this.loadSchema(schema)
+      .then((schema) => {
+        return new Validator(schema);
+      });
+    } else {
+      return new Validator(schema);
+    } 
+  }
+
+  
+  /**
+   * Load schema from gitlab by tag/branch/commitref 
+   * @param {string} version
+   * @returns {object} 
+   */
+  loadSchema(version) {
+    this.axios = axios;
+    let repository = "https://git.noc.ac.uk/communications-backbone-system/backbone-message-format";
+    // TODO check this path resolves for tags
+    let url = `${repository}/-/raw/${version}/project/soar/swagger.json`;
+    this.schema = this.axios.get(url)
+    .then((response) => {
+      return response.data;
+    });
+    return this.schema;
+  }
+
+  /**
+   * Validate that a message meets the reqiured schema 
+   * @param {object} message 
+   * @returns {object}
+   */
+  validate(message) {
+    return this.validator.validate(
+      message,
+      this.schema.components.schemas.MESSAGE,
+      this.schema.components.schemas,
+      false,
+      true
+    );
+  }
+}
+
+export { GenericProtocol, GenericSoarProtocol };

dist/protocol.js

 'use strict';
 
+var axios = require('axios');
 var Validator = require('swagger-model-validator');
 
 /**
@@ -27,8 +28,17 @@ var Validator = require('swagger-model-validator');
 class GenericProtocol {
   constructor(schema, services) {
     this.schema = schema;
-    this.validator = new Validator(schema);
     this.services = services;
+    this.validator = this.createValidator(schema);
+  }
+
+  /**
+   * Create a Validator from the provided JSONSchema
+   * @param {object} schema 
+   * @returns {Validator}
+   */
+  createValidator(schema) {
+    return new Validator(schema);
   }
 
   /**
@@ -86,4 +96,70 @@ class GenericProtocol {
   }
 }
 
+
+/**
+ * GenericSoarProtocol defines a simple passthru handler for messages
+ * 
+ * This provides the same as above but loads a version of the 
+ * SoAR message protocol  
+ */
+class GenericSoarProtocol extends GenericProtocol {
+  constructor(schema, services) {
+    super(schema, services);
+  }
+
+  /**
+   * Create a Validator from the provided JSONSchema
+   * 
+   * If schema is a string build a URL and retrieve the 
+   * schema from gitlab 
+   * @param {string|object} schema 
+   * @returns {object}
+   */
+  async createValidator(schema) {
+    if (typeof schema === 'string' && schema.match(/^[\w\.]+$/)) {
+      return await this.loadSchema(schema)
+      .then((schema) => {
+        return new Validator(schema);
+      });
+    } else {
+      return new Validator(schema);
+    } 
+  }
+
+  
+  /**
+   * Load schema from gitlab by tag/branch/commitref 
+   * @param {string} version
+   * @returns {object} 
+   */
+  loadSchema(version) {
+    this.axios = axios;
+    let repository = "https://git.noc.ac.uk/communications-backbone-system/backbone-message-format";
+    // TODO check this path resolves for tags
+    let url = `${repository}/-/raw/${version}/project/soar/swagger.json`;
+    this.schema = this.axios.get(url)
+    .then((response) => {
+      return response.data;
+    });
+    return this.schema;
+  }
+
+  /**
+   * Validate that a message meets the reqiured schema 
+   * @param {object} message 
+   * @returns {object}
+   */
+  validate(message) {
+    return this.validator.validate(
+      message,
+      this.schema.components.schemas.MESSAGE,
+      this.schema.components.schemas,
+      false,
+      true
+    );
+  }
+}
+
 exports.GenericProtocol = GenericProtocol;
+exports.GenericSoarProtocol = GenericSoarProtocol;

src/protocol/index.js

+import axios from 'axios';
 import Validator from 'swagger-model-validator';
 
 /**
@@ -25,8 +26,17 @@ import Validator from 'swagger-model-validator';
 export class GenericProtocol {
   constructor(schema, services) {
     this.schema = schema;
-    this.validator = new Validator(schema);
     this.services = services;
+    this.validator = this.createValidator(schema);
+  }
+
+  /**
+   * Create a Validator from the provided JSONSchema
+   * @param {object} schema 
+   * @returns {Validator}
+   */
+  createValidator(schema) {
+    return new Validator(schema);
   }
 
   /**
@@ -83,3 +93,67 @@ export class GenericProtocol {
     return message;
   }
 }
+
+
+/**
+ * GenericSoarProtocol defines a simple passthru handler for messages
+ * 
+ * This provides the same as above but loads a version of the 
+ * SoAR message protocol  
+ */
+export class GenericSoarProtocol extends GenericProtocol {
+  constructor(schema, services) {
+    super(schema, services);
+  }
+
+  /**
+   * Create a Validator from the provided JSONSchema
+   * 
+   * If schema is a string build a URL and retrieve the 
+   * schema from gitlab 
+   * @param {string|object} schema 
+   * @returns {object}
+   */
+  async createValidator(schema) {
+    if (typeof schema === 'string' && schema.match(/^[\w\.]+$/)) {
+      return await this.loadSchema(schema)
+      .then((schema) => {
+        return new Validator(schema);
+      });
+    } else {
+      return new Validator(schema);
+    } 
+  }
+
+  /**
+   * Load schema from gitlab by tag/branch/commitref 
+   * @param {string} version
+   * @returns {object} 
+   */
+  loadSchema(version) {
+    this.axios = axios;
+    let repository = "https://git.noc.ac.uk/communications-backbone-system/backbone-message-format";
+    // TODO check this path resolves for tags
+    let url = `${repository}/-/raw/${version}/project/soar/swagger.json`;
+    this.schema = this.axios.get(url)
+    .then((response) => {
+      return response.data;
+    });
+    return this.schema;
+  }
+
+  /**
+   * Validate that a message meets the reqiured schema 
+   * @param {object} message 
+   * @returns {object}
+   */
+  validate(message) {
+    return this.validator.validate(
+      message,
+      this.schema.components.schemas.MESSAGE,
+      this.schema.components.schemas,
+      false,
+      true
+    );
+  }
+}
\ No newline at end of file