Skip to content

Commit a28aff0

Browse files
committed
Fix connection error for code collaboration PORT 1234
1 parent 0deef37 commit a28aff0

File tree

4 files changed

+46
-31
lines changed

4 files changed

+46
-31
lines changed

Backend/CollabService/app.js

Lines changed: 6 additions & 7 deletions
Original file line numberDiff line numberDiff line change
@@ -1,22 +1,21 @@
11
const express = require('express');
22
const http = require('http');
3-
const { setupWebSocket } = require('./websocket/collabSocket');
4-
// const { WebsocketServer } = require('y-websockets-server');
5-
3+
const { setupWebSocket } = require('./websocket/roomManagerSocket');
4+
const { setUpYjsSocket } = require('./websocket/collabSocket');
65
const app = express();
7-
//const PORT = 1234;
86

97
const server = http.createServer(app);
8+
const yjsPORT = 1234
109

1110
// Set up WebSocket server and attach to HTTP server
1211
setupWebSocket(server);
13-
14-
//const wss = new WebsocketServer(PORT);
15-
//console.log(`Yjs WebSocket server is running on ws://localhost:${PORT}`)
12+
setUpYjsSocket(yjsPORT);
1613

1714
// Basic route to test the server
1815
app.get('/', (req, res) => {
1916
res.send('CollabService using Yjs is running');
2017
});
2118

19+
20+
2221
module.exports = { server };
Lines changed: 6 additions & 23 deletions
Original file line numberDiff line numberDiff line change
@@ -1,34 +1,17 @@
11
const WebSocket = require('ws');
2-
const { manageRoom } = require('../utils/roomManager');
32

4-
function setupWebSocket(server) {
5-
const wss = new WebSocket.Server({ server });
3+
function setUpYjsSocket(port) {
4+
const wss = new WebSocket.Server({ port: 1234 });
65

76
wss.on('connection', (ws) => {
8-
console.log('User connected to the collaboration space');
9-
10-
ws.on('message', (message) => {
11-
const data = JSON.parse(message);
12-
13-
switch (data.type) {
14-
case 'joinRoom':
15-
// add user into room with roomId
16-
manageRoom(ws, data.roomId, data.userId, "join");
17-
break;
18-
case 'leaveRoom':
19-
// remove user from room with roomId
20-
manageRoom(ws, data.roomId, data.userId, "leave");
21-
break;
22-
default:
23-
console.error('Unknown message type');
24-
}
25-
});
7+
console.log('New client connected');
268

279
ws.on('close', () => {
28-
console.log('User disconnected from collaboration space');
10+
console.log('Client disconnected');
2911
});
3012
});
3113

14+
console.log('Websocket server is listening on ws://localhost:1234')
3215
}
3316

34-
module.exports = { setupWebSocket };
17+
module.exports = { setUpYjsSocket };
Lines changed: 34 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -0,0 +1,34 @@
1+
const WebSocket = require('ws');
2+
const { manageRoom } = require('../utils/roomManager');
3+
4+
function setupWebSocket(server) {
5+
const wss = new WebSocket.Server({ server });
6+
7+
wss.on('connection', (ws) => {
8+
console.log('User connected to the collaboration space');
9+
10+
ws.on('message', (message) => {
11+
const data = JSON.parse(message);
12+
13+
switch (data.type) {
14+
case 'joinRoom':
15+
// add user into room with roomId
16+
manageRoom(ws, data.roomId, data.userId, "join");
17+
break;
18+
case 'leaveRoom':
19+
// remove user from room with roomId
20+
manageRoom(ws, data.roomId, data.userId, "leave");
21+
break;
22+
default:
23+
console.error('Unknown message type');
24+
}
25+
});
26+
27+
ws.on('close', () => {
28+
console.log('User disconnected from collaboration space');
29+
});
30+
});
31+
32+
}
33+
34+
module.exports = { setupWebSocket };

Frontend/src/components/collab/CollaborationSpace.jsx

Lines changed: 0 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -76,7 +76,6 @@ const CollaborationSpace = () => {
7676
const wsProvider = new WebsocketProvider("ws://localhost:1234", roomId, doc);
7777
setProvider(wsProvider);
7878

79-
8079
// Create a shared type in Yjs for collaborative code editing
8180
const yText = doc.getText('monacoEditor');
8281

0 commit comments

Comments
 (0)