Added Socket event class

Author: grishabh1992

app/config/socket.ts

@@ -1,27 +1,42 @@
+import { AuthUtil } from "../utils/auth.util";
+
 const io = require('socket.io')();
-export const Socket: any = {};
-export const socketInit = (server) => {
- Socket.io = io.listen(server, {
- log: true
- });
- Socket.io.use(function (socket, next) {
- console.log(socket.handshake.query, 'socket.handshake.query');
- if (socket.handshake.query && socket.handshake.query.token) {
- // Authentiation code should be here
- next();
- }
- else {
- next(new Error('Authentication error'));
- }
- })
- Socket.io.on('connect', socket => {
- console.log('Client Connectted');
- socket.send('Hello!');
- });
+export const SocketConf: any = {};
+export class Socket {
+ private auth: AuthUtil;
+ constructor() {
+ this.auth = new AuthUtil();
+ }
+ init(server) {
+ SocketConf.io = io.listen(server, {
+ log: true
+ });
+ this.setupEvent();
+ }
 
- Socket.io.on('join', socket => {
- console.log('Client Connectted');
- socket.send('Hello!');
- });
-}
+ setupEvent() {
+ SocketConf.io.use((socket, next) => {
+ console.log(socket.handshake.query, 'socket.handshake.query');
+ if (socket.handshake.query) {
+ let token = this.auth.authenticate(socket.handshake.query.token);
+ if (token) {
+ next();
+ } else {
+ next(new Error('Authentication error'));
+ }
+ }
+ else {
+ next(new Error('Authentication error'));
+ }
+ })
+ SocketConf.io.on('connect', socket => {
+ console.log('Client Connectted');
 
+ socket.on('join', room => {
+ console.log('Client join', room);
+ socket.join(room.roomName);
+ io.to(room.roomName).emit('New User Connected...');
+ });
+ });
+ }
+}

server.ts

@@ -2,13 +2,14 @@ import * as express from 'express';
 import { ClusterConfig } from './cluster';
 const port = 3001;
 const app: express.Application = require('./app/app');
-import { socketInit } from './app/config/socket';
+import { Socket } from './app/config/socket';
 
 const clusterConfig = new ClusterConfig();
 
 clusterConfig.initaliseCLuster(false, (isReady: boolean) => {
  const server = app.listen(port, () => {
  console.log("Node app is running at localhost:" + port);
  });
- socketInit(server);
+ const socket = new Socket();
+ socket.init(server); 
 });