1.0.78

package-lock.json

@@ -1,6 +1,6 @@
 {
   "name": "@pushrocks/smartuniverse",
-  "version": "1.0.75",
+  "version": "1.0.78",
   "lockfileVersion": 1,
   "requires": true,
   "dependencies": {

package.json

@@ -1,6 +1,6 @@
 {
   "name": "@pushrocks/smartuniverse",
-  "version": "1.0.75",
+  "version": "1.0.78",
   "private": false,
   "description": "messaging service for your micro services",
   "main": "dist/index.js",

ts/interfaces/socketfunctionrequests.ts

@@ -7,7 +7,7 @@ export interface ISocketRequest_SubscribeChannel {
     passphrase: string;
   };
   response: {
-    subscriptionStatus: 'subscribed' | 'unsubscribed'
+    subscriptionStatus: 'subscribed' | 'unsubscribed';
   };
 }
 
@@ -15,6 +15,6 @@ export interface ISocketRequest_ProcessMessage {
   method: 'processMessage';
   request: interfaces.IUniverseMessage;
   response: {
-    messageStatus: 'ok' | 'channel not found'
+    messageStatus: 'ok' | 'channel not found';
   };
 }

ts/interfaces/universeactions.interfaces.ts

@@ -4,7 +4,6 @@ export type IServerCallActions =
   | 'channelUnsubscribe'
   | 'terminateConnection';
 
-
 export interface IServerUnsubscribeActionPayload {
   name: string;
 }

ts/smartuniverse.classes.clientuniversechannel.ts

@@ -56,20 +56,18 @@ export class ClientUniverseChannel implements interfaces.IUniverseChannel {
   public async subscribe(observerArg?: plugins.smartrx.rxjs.Observer<any>) {
     // lets make sure the channel is connected
     if (this.status === 'unsubscribed') {
-      const response = await this.clientUniverseRef.smartsocketClient.serverCall<interfaces.ISocketRequest_SubscribeChannel>(
-        'subscribeChannel',
-        {
+      const response = await this.clientUniverseRef.smartsocketClient.serverCall<
+        interfaces.ISocketRequest_SubscribeChannel
+      >('subscribeChannel', {
         name: this.name,
         passphrase: this.passphrase
-        }
-      );
+      });
       this.status = response.subscriptionStatus;
     }
 
     if (observerArg) {
       return this.subject.subscribe(observerArg);
     }
-
   }
 
   public async emitMessageLocally(messageArg: ClientUniverseMessage) {

ts/smartuniverse.classes.reactionrequest.ts

@@ -1,5 +1,3 @@
 import * as plugins from './smartuniverse.plugins';
 
-export class ReactionRequest {
-  
-}
+export class ReactionRequest {}

ts/smartuniverse.classes.universe.ts

@@ -62,6 +62,16 @@ export class Universe {
    */
   public addChannel(nameArg: string, passphraseArg: string) {
     const newChannel = UniverseChannel.createChannel(this, nameArg, passphraseArg);
+    return newChannel;
+  }
+
+  /**
+   * returns a channel
+   */
+  public getChannelByName(channelNameArg: string) {
+    return this.universeCache.channelMap.find(channelArg => {
+      return channelArg.name === channelNameArg;
+    });
   }
 
   /**
@@ -95,13 +105,12 @@ export class Universe {
     // add the role to smartsocket
     this.smartsocket.addSocketRoles([ClientRole]);
 
-    const socketFunctionSubscription = new plugins.smartsocket.SocketFunction<interfaces.ISocketRequest_SubscribeChannel>({
+    const socketFunctionSubscription = new plugins.smartsocket.SocketFunction<
+      interfaces.ISocketRequest_SubscribeChannel
+    >({
       allowedRoles: [ClientRole], // there is only one client role, Authentication happens on another level
       funcName: 'subscribeChannel',
-      funcDef: async (
-        dataArg,
-        socketConnectionArg
-      ) => {
+      funcDef: async (dataArg, socketConnectionArg) => {
         const universeConnection = new UniverseConnection({
           socketConnection: socketConnectionArg,
           authenticationRequests: [dataArg]