diff --git a/index.js b/index.js index 18a0ef9a07f431f8ac4deb51aefddb2616764c5f..e765e9a745fe977e8010f2b0a4563cd46efe7203 100644 --- a/index.js +++ b/index.js @@ -14,6 +14,7 @@ const server = http.createServer(app); cert: fs.readFileSync(__dirname + '/tls/cert.pem'), }, app); */ + const { Server } = require("socket.io"); const io = new Server(server); const bodyParser = require('body-parser'); @@ -27,9 +28,13 @@ const User = require('./models/user'); var port = process.env.PORT || 3000; const redis = require('socket.io-redis'); const { createAdapter } = require('@socket.io/redis-adapter'); +const { createClient } = require('redis'); + +const pubClient = createClient({ host: 'localhost', port: 6379 }); +const subClient = pubClient.duplicate(); + +io.adapter(createAdapter(pubClient, subClient)); -//Redis Adapter so every packet is sent to all matching clients connected to the current Server -io.adapter(redis({ host: 'redis', port: 6379 })); //DB Connection //mongoose.connect("mongodb://mongodb:27017/cloudComputing"); @@ -283,7 +288,7 @@ io.on('connection', (socket) => { var msg = response.msg; var name = response.name; var dateTime = new Date().toTimeString(); - + console.log("Received Message: " + msg); messageCounterOut.inc(activeUsers.size); io.emit('chat message', {