Merge pull request #16 from myDevicesIoT/refactor/auth

refactor: authentication

Author: hugocortes

.env.example

@@ -0,0 +1,20 @@
+CAYENNE_BASE_URL=
+CAYENNE_TOKEN=
+
+DELOREAN_ES_BASE_URL=
+DELOREAN_ES_TOKEN=
+
+EXECUTOR_BASE_URL=
+EXECUTOR_TOKEN=
+
+HERMES_BASE_URL=
+HERMES_TOKEN=
+
+PROMETHEUS_BASE_URL=
+PROMETHEUS_TOKEN=
+
+STREAMING_BASE_URL=
+STREAMING_TOKEN=
+
+TIMEKEEPER_BASE_URL=
+TIMEKEEPER_TOKEN=

lib/Auth/token.js

@@ -0,0 +1,42 @@
+const classes = {
+  Cayenne: require('./Services/cayenne'),
+  DeloreanES: require('./Services/delorean-es'),
+  Executor: require('./Services/executor'),
+  Hermes: require('./Services/hermes'),
+  Prometheus: require('./Services/prometheus'),
+  Streaming: require('./Services/streaming'),
+  Timekeeper: require('./Services/timekeeper')
+};
+
+/**
+ * @typedef ServiceOpts
+ *
+ * @property {string} name
+ * @property {string} url
+ * @property {string} token
+ */
+
+class Core {
+  /**
+   * @param {Object}      coreOpts
+   * @param {ServiceOpts} coreOpts.cayenne
+   * @param {ServiceOpts} coreOpts.deloreanES
+   * @param {ServiceOpts} coreOpts.executor
+   * @param {ServiceOpts} coreOpts.hermes
+   * @param {ServiceOpts} coreOpts.prometheus
+   * @param {ServiceOpts} coreOpts.starbase
+   * @param {ServiceOpts} coreOpts.streaming
+   * @param {ServiceOpts} coreOpts.timekeeper
+   * @param {Object}     [opts={}]
+   */
+  constructor(coreOpts, opts = {}) {
+    Object.entries(coreOpts).forEach(([key, { name, url, token }]) => {
+      if (!classes[name]) {
+        return;
+      }
+      this[key] = new classes[name](url, token, opts);
+    });
+  }
+}
+
+module.exports = Core;

lib/Core.js

@@ -39,23 +39,16 @@ class CoreError extends Boom {
     return this;
   }
 
-  static InvalidApplicationCredentials() {
-    return this.unauthorized(this.InvalidApplicationCredentials.name, {
-      ctr: this.InvalidApplicationCredentials,
+  static InvalidConfiguration() {
+    return this.badRequest(this.InvalidConfiguration.name, {
+      ctr: this.InvalidConfiguration,
       isInternal: true
     });
   }
 
-  static MaxAuthenticationRequestsReached() {
-    return this.unauthorized(this.MaxAuthenticationRequestsReached.name, {
-      ctr: this.MaxAuthenticationRequestsReached,
-      isInternal: true
-    });
-  }
-
-  static MaxAuthenticatedRequestsReached() {
-    return this.unauthorized(this.MaxAuthenticatedRequestsReached.name, {
-      ctr: this.MaxAuthenticatedRequestsReached,
+  static InvalidCredentials() {
+    return this.unauthorized(this.InvalidCredentials.name, {
+      ctr: this.InvalidCredentials,
       isInternal: true
     });
   }