1.0.18

package.json

@@ -1,6 +1,7 @@
 {
   "name": "@pushrocks/smartuniverse",
-  "version": "1.0.15",
+  "version": "1.0.18",
+  "private": true,
   "description": "messaging service for your micro services",
   "main": "dist/index.js",
   "typings": "dist/index.d.ts",
@@ -13,12 +14,16 @@
   },
   "devDependencies": {
     "@types/node": "^9.6.0",
-    "tapbundle": "^2.0.0"
+    "tapbundle": "^2.0.0",
+    "ts-node": "^6.0.3",
+    "typescript": "^2.8.3"
   },
   "dependencies": {
     "lik": "^2.0.5",
+    "nodehash": "^1.0.4",
     "rxjs": "^5.5.8",
     "smartcli": "^2.0.12",
+    "smartdelay": "^1.0.4",
     "smartexpress": "^1.0.21",
     "smartfile": "^4.2.28",
     "smartq": "^1.1.8",

ts/smartuniverse.classes.manager.ts

@@ -1,20 +0,0 @@
-import * as plugins from './smartuniverse.plugins';
-
-import { Objectmap } from 'lik';
-import { UniverseChannel } from './smartuniverse.classes.universechannel';
-
-export class UniverseManager {
-  public channelStore = new Objectmap<UniverseChannel>();
-
-  /**
-   * register a new member
-   */
-  public async registerMember() {}
-
-  /**
-   * register a new channel within the universe
-   * @param channelName the name of the channel
-   * @param authSecret the secret against which to verify members of the channel
-   */
-  public async registerChannel(channelName: string, authSecret: string) {}
-}

ts/smartuniverse.classes.universe.ts

@@ -1,8 +1,6 @@
 import * as plugins from './smartuniverse.plugins';
 
 import { Handler, Route, Server } from 'smartexpress';
-
-import { UniverseManager } from './smartuniverse.classes.manager';
 import { UniverseChannel } from './smartuniverse.classes.universechannel';
 import { UniverseMessage } from './smartuniverse.classes.universemessage';
 import { UniverseStore } from './smartuniverse.classes.universestore';
@@ -19,15 +17,22 @@ export interface IServerGetMessagesRequestBody {
   youngerThan: number;
 }
 
+/**
+ * the interface for a standard request
+ */
 export interface IServerPutMessageRequestBody {
+  channel: string;
+  passphrase: string;
   message: string;
   payload: any;
 }
 
+/**
+ * main class that setsup a Universe
+ */
 export class Universe {
   // subinstances
   public universeStore: UniverseStore;
-  public universeManager: UniverseManager;
 
   // options
   private options: ISmartUniverseConstructorOptions;
@@ -50,7 +55,6 @@ export class Universe {
   constructor(optionsArg: ISmartUniverseConstructorOptions) {
     this.options = optionsArg;
     this.universeStore = new UniverseStore(this.options.messageExpiryInMilliseconds);
-    this.universeManager = new UniverseManager();
   }
 
   /**
@@ -67,8 +71,9 @@ export class Universe {
     // message handling
     // adds messages
     const addMessageHandler = new Handler('PUT', request => {
-      const requestBody = request.body;
+      const requestBody: IServerPutMessageRequestBody = request.body;
-      this.universeStore.addMessage(requestBody.message, requestBody.payload);
+      const message = new UniverseMessage(requestBody.message, requestBody.channel, requestBody.passphrase, requestBody.payload);
+      this.universeStore.addMessage(message);
       console.log(requestBody);
       return true;
     });

ts/smartuniverse.classes.universechannel.ts

@@ -9,27 +9,55 @@ export class UniverseChannel {
   /**
    * stores the channels that are available within the universe
    */
-  public static channelStore = new Objectmap();
+  public static channelStore = new Objectmap<UniverseChannel>();
 
   /**
-   * the credentials for the channel
+   * allows messages to be processed in a blacklist mode for further analysis
    */
-  private credentials: {
+  public static blackListChannel = new UniverseChannel('blacklist', 'nada');
-    user: string;
-    password: string;
-  };
 
   /**
    * creates new channels
    * @param channelArg the name of the topic
-   * @param secretArg the secret thats used for a certain topic.
+   * @param passphraseArg the secret thats used for a certain topic.
    */
-  public static createChannel = (channelArg: string, secretArg: string) => {
+  public static createChannel (channelNameArg: string, passphraseArg: string) {
-
+    const newChannel = new UniverseChannel(channelNameArg, passphraseArg);
+    return newChannel;
   };
 
+  public static authorizeForChannel (channelNameArg: string, passphraseArg: string) {
+    const foundChannel = this.channelStore.find(universeChannel => {
+       const result = universeChannel.authenticate(channelNameArg, passphraseArg);
+       return result;
+    });
+    if(foundChannel) {
+      return foundChannel;
+    } else {
+      return this.blackListChannel;
+    }
+  };
+
+  /**
+   * the name of the channel
+   */
+  public name: string;
+
+  /**
+   * the passphrase for the channel
+   */
+  public passphrase: string;
+
+  constructor(channelNameArg: string, passphraseArg: string) {
+    this.name = channelNameArg;
+    this.passphrase = passphraseArg;
+    UniverseChannel.channelStore.add(this);
+  }
+
   /**
    * authenticates a client on the server side
    */
-  async authenticateClient() {}
+  public authenticate(channelNameArg: string, passphraseArg: string): boolean {
+    return (this.name === channelNameArg &&  this.passphrase === passphraseArg);
+  }
 }

ts/smartuniverse.classes.universemessage.ts

@@ -1,7 +1,9 @@
 import * as plugins from './smartuniverse.plugins';
 
 import { Timer, TimeStamp } from 'smarttime';
+import { UniverseChannel } from './smartuniverse.classes.universechannel';
 import { UniverseStore } from './smartuniverse.classes.universestore';
+import { Universe } from './smartuniverse.classes.universe';
 
 /**
  * represents a message within a universe
@@ -19,6 +21,10 @@ export class UniverseMessage {
    * the universe store the message is attached to
    */
   public universeStore: UniverseStore;
+  /**
+   * enables unprotected grouping of messages for efficiency purposes.
+   */
+  public universeChannel: UniverseChannel;
 
   /**
    * time of creation
@@ -26,36 +32,55 @@ export class UniverseMessage {
   public timestamp: TimeStamp;
 
   /**
-   * enables unprotected grouping of messages for efficiency purposes.
+   * the actual message
    */
-  public universeChannel: string;
+  public message: string;
-  public message: string; // the actual message
+
-  public attachedPayload: any; // any attached payloads. Can be of binary format.
+  /**
+   * any attached payloads. Can be of binary format.
+   */
+  public attachedPayload: any;
   public destructionTimer: Timer; // a timer to take care of message destruction
 
   /**
    * the constructor to create a universe message
-   * @param parentUniverseStore
    * @param messageArg
    * @param attachedPayloadArg
-   * @param selfdestructAfterArg
    */
-  constructor(
+  constructor(messageArg: string, channelNameArg: string, passphraseArg: string,  attachedPayloadArg: any) {
-    parentUniverseStore: UniverseStore,
-    messageArg: string,
-    attachedPayloadArg: any,
-    selfdestructAfterArg: number
-  ) {
-    this.universeStore = parentUniverseStore;
     this.timestamp = new TimeStamp();
     this.message = messageArg;
+    this.universeChannel = UniverseChannel.authorizeForChannel(channelNameArg, passphraseArg); 
     this.attachedPayload = attachedPayloadArg;
-    this.destructionTimer = new Timer(selfdestructAfterArg);
+    this.fallBackDestruction();
-    this.destructionTimer.start();
+  }
 
-    // set up self destruction by removing this from the parent messageStore
+  public setUniverseStore(universeStoreArg: UniverseStore) {
-    this.destructionTimer.completed.then(async () => {
+    this.universeStore = universeStoreArg;
-      this.universeStore.messageStore.remove(this);
+  }
+
+  public setDestructionTimer(selfdestructAfterArg: number) {
+    if (selfdestructAfterArg) {
+      this.destructionTimer = new Timer(selfdestructAfterArg);
+      this.destructionTimer.start();
+
+      // set up self destruction by removing this from the parent messageStore
+      this.destructionTimer.completed.then(async () => {
+        this.universeStore.messageStore.remove(this);
+      });
+    } else {
+      this.fallBackDestruction();
+    }
+  }
+
+  /**
+   * prevents memory leaks if channels have no default
+   */
+  private fallBackDestruction() {
+    plugins.smartdelay.delayFor(1000).then(() => {
+      if (!this.destructionTimer) {
+        this.setDestructionTimer(6000);
+      }
     });
   }
 }

ts/smartuniverse.classes.universestore.ts

@@ -25,10 +25,8 @@ export class UniverseStore {
    * @param messageArg
    * @param attachedPayloadArg
    */
-  public addMessage(messageArg, attachedPayloadArg) {
+  public addMessage(messageArg: UniverseMessage) {
-    this.messageStore.add(
+    this.messageStore.add(messageArg);
-      new UniverseMessage(this, messageArg, attachedPayloadArg, this.destructionTime)
-    );
   }
 
   /**

ts/smartuniverse.plugins.ts

@@ -1,6 +1,8 @@
 import * as lik from 'lik';
+import * as nodehash from 'nodehash';
 import * as path from 'path';
 import * as smartcli from 'smartcli';
+import * as smartdelay from 'smartdelay';
 import * as smartexpress from 'smartexpress';
 import * as smartfile from 'smartfile';
 import * as smartq from 'smartq';
@@ -11,8 +13,10 @@ import * as smarttime from 'smarttime';
 
 export {
   lik,
+  nodehash,
   path,
   smartcli,
+  smartdelay,
   smartexpress,
   smartfile,
   smartq,