From aa907a49e8705ae0a712ffcd3325cdce8c34e386 Mon Sep 17 00:00:00 2001
From: Alexander Tim Hobelsberger
 <alexander_tim.hobelsberger@student.reutlingen-university.de>
Date: Sun, 18 Dec 2022 18:26:24 +0100
Subject: [PATCH] socket.emit

---
 docker-compose.yaml | 19 ++++++++++++++-----
 index.js            |  6 +++---
 2 files changed, 17 insertions(+), 8 deletions(-)

diff --git a/docker-compose.yaml b/docker-compose.yaml
index fd44d83..4722ecd 100644
--- a/docker-compose.yaml
+++ b/docker-compose.yaml
@@ -17,44 +17,53 @@ services:
   server-john:
     build: ./
     links:
-      - redis
+      - redis-server
     expose:
       - "3601"
     environment:
       - NAME=john
       - PORT=3601
+    depends_on:
+      - redis-server
+    
 
   server-paul:
     build: ./
     links:
-      - redis
+      - redis-server
     expose:
       - "3602"
     environment:
       - NAME=paul
       - PORT=3602
+    depends_on:
+      - redis-server
 
   server-george:
     build: ./
     links:
-      - redis
+      - redis-server
     expose:
       - "3603"
     environment:
       - NAME=george
       - PORT=3603
+    depends_on:
+      - redis-server
 
   server-ringo:
     build: ./
     links:
-      - redis
+      - redis-server
     expose:
       - "3604"
     environment:
       - NAME=ringo
       - PORT=3604
+    depends_on:
+      - redis-server
 
-  redis:
+  redis-server:
     image: redis
     ports:
       - "6379:6379"
diff --git a/index.js b/index.js
index 1cb0393..c93eefd 100644
--- a/index.js
+++ b/index.js
@@ -34,10 +34,10 @@ const { resolve } = require('path');
 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 { createAdapter } = require('@socket.io/redis-adapter');
 
-const pubClient = createClient({ url: "redis://192.168.0.230:6379" });
+const pubClient = createClient({ host: 'host.docker.internal', port: 6379});
 const subClient = pubClient.duplicate();
 
 io.adapter(createAdapter(pubClient, subClient));
@@ -298,7 +298,7 @@ io.on('connection', (socket) => {
       console.log("Received Message: " + msg);
       messageCounterOut.inc(activeUsers.size);
 
-      io.emit('chat message', {
+     socket.emit('chat message', {
         msg : msg,
         name : name,
         dateTime: dateTime
-- 
GitLab