mongo store servers users, and logs

Author: AdSegura

laravel-echo-server.json

@@ -20,7 +20,7 @@
         "mongo": {
             "host": "127.0.0.1",
             "port": "27017",
-            "dbName": "presence",
+            "dbName": "echo",
             "user": null,
             "password": null
         }

src/channels/baseAuthChannel.ts

@@ -1,4 +1,5 @@
 import {Log} from "../log";
+import {Logger} from "../log/logger";
 
 let url = require('url');
 const request = require('request');
@@ -22,7 +23,7 @@ export class BaseAuthChannel {
      * @param options
      * @param log
      */
-    constructor(protected options: any, protected log: any) {
+    constructor(protected options: any, protected log: Logger) {
 
         this.request = request;
     }

src/channels/channel.ts

@@ -2,6 +2,8 @@ import {PresenceChannel} from './presence-channel';
 import {PrivateChannel} from './private-channel';
 import {Log} from './../log';
 import {RootChannel} from "./rootChannel";
+import {Database} from "../database";
+import {Logger} from "../log/logger";
 
 export class Channel {
     /**
@@ -32,11 +34,11 @@ export class Channel {
     /**
      * Create a new channel instance.
      */
-    constructor(private io, private options, protected log) {
+    constructor(private io: any, private options: any, protected log: Logger, protected db: Database) {
 
-        this.private = new PrivateChannel(options, this.log);
-        this.rootChannel = new RootChannel(options, this.log);
-        this.presence = new PresenceChannel(io, options, this.log);
+        this.private = new PrivateChannel(this.options, this.log);
+        this.rootChannel = new RootChannel(this.options, this.log);
+        this.presence = new PresenceChannel(this.io, this.options, this.log, this.db);
 
         Log.success('Channels are ready.');
 

src/channels/commandChannel.ts

@@ -1,9 +1,10 @@
 import {IoUtils} from "../utils/ioUtils";
 import {Log} from "../log";
+import {Logger} from "../log/logger";
 
 export class CommandChannel {
 
-    constructor(private options: any, protected io: any, protected log: any){
+    constructor(private options: any, protected io: any, protected log: Logger){
 
     }
 

src/channels/presence-channel.ts

@@ -1,19 +1,16 @@
+import {Logger} from "../log/logger";
+
 var _ = require('lodash');
 import { Channel } from './channel';
 import { Database } from './../database';
 import { Log } from './../log';
 
 export class PresenceChannel {
-    /**
-     * Database instance.
-     */
-    db: Database;
 
     /**
      * Create a new Presence channel instance.
      */
-    constructor(private io, private options: any, protected log: any) {
-        this.db = new Database(this.options);
+    constructor(private io, private options: any, protected log: Logger, protected db: Database) {
     }
 
     /**

src/channels/private-channel.ts

@@ -1,11 +1,12 @@
 import {BaseAuthChannel} from "./baseAuthChannel";
+import {Logger} from "../log/logger";
 
 export class PrivateChannel extends BaseAuthChannel {
 
     /**
      * Create a new private channel instance.
      */
-    constructor(protected options: any, protected log: any) {
+    constructor(protected options: any, protected log: Logger) {
         super(options, log)
     }
 }

src/channels/rootChannel.ts

@@ -1,11 +1,12 @@
 import {BaseAuthChannel} from "./baseAuthChannel";
+import {Logger} from "../log/logger";
 
 export class RootChannel extends BaseAuthChannel {
 
     /**
      * Create a new private channel instance.
      */
-    constructor(options: any, log: any) {
+    constructor(options: any, log: Logger) {
         super(options, log);
     }
 

src/database/database-driver.ts

@@ -3,6 +3,19 @@
  */
 export interface DatabaseDriver {
 
+    /**
+     * set user on new Root channel Auth connection
+     */
+    setUserInServer(key: string, value: any): void;
+
+    /**
+     * Delete user from DB base on socket_id
+     *
+     * @param collection
+     * @param socket_id
+     */
+    delUserInServerBySocketId(collection: string, socket_id: any): void;
+
     /**
      * get all members in channel
      */
@@ -45,4 +58,12 @@ export interface DatabaseDriver {
      * @param sockets array, active array socketsId on Io Channel
      */
     removeInactive(channel: string, sockets: any): Promise<any>;
+
+    /**
+     * Remove inactive sockets from this Io server
+     *
+     * @param collection
+     * @param sockets
+     */
+    removeInactiveSocketsInThisServer(collection: string, sockets: any): Promise<any>;
 }

src/database/database.ts

@@ -1,5 +1,6 @@
 import { DatabaseDriver } from './database-driver';
 import {MongoDatabase} from "./mongo";
+import {Logger} from "../log/logger";
 
 /**
  * Class that controls the key/value data store.
@@ -13,8 +14,8 @@ export class Database implements DatabaseDriver {
     /**
      * Create a new Mongo database instance.
      */
-    constructor(private options: any) {
-        this.driver = new MongoDatabase(this.options);
+    constructor(private options: any, protected log: Logger) {
+        this.driver = new MongoDatabase(this.options, this.log);
     }
 
 
@@ -45,4 +46,16 @@ export class Database implements DatabaseDriver {
     removeInactive(channel: string, member: any): Promise<any>{
         return this.driver.removeInactive(channel, member);
     }
+
+    removeInactiveSocketsInThisServer(collection: string, sockets: any): Promise<any>{
+        return this.driver.removeInactiveSocketsInThisServer(collection, sockets);
+    }
+
+    setUserInServer(collection: string, user: any): void{
+        return this.driver.setUserInServer(collection, user);
+    };
+
+    delUserInServerBySocketId(collection: string, socket_id: any): void {
+        return this.driver.delUserInServerBySocketId(collection, socket_id);
+    }
 }