File tree Expand file tree Collapse file tree 2 files changed +17
-6
lines changed Expand file tree Collapse file tree 2 files changed +17
-6
lines changed Original file line number Diff line number Diff line change @@ -5,11 +5,13 @@ const { setUpYjsSocket } = require('./websocket/collabSocket');
5
5
const app = express ( ) ;
6
6
7
7
const server = http . createServer ( app ) ;
8
- const yjsPORT = 1234
8
+
9
+ // Set up Yjs server
10
+ setUpYjsSocket ( ) ;
9
11
10
12
// Set up WebSocket server and attach to HTTP server
11
13
setupWebSocket ( server ) ;
12
- setUpYjsSocket ( yjsPORT ) ;
14
+
13
15
14
16
// Basic route to test the server
15
17
app . get ( '/' , ( req , res ) => {
Original file line number Diff line number Diff line change 1
1
const WebSocket = require ( 'ws' ) ;
2
+ const http = require ( 'http' )
3
+ const { setupWSConnection } = require ( 'y-websocket/bin/utils' ) ;
2
4
3
- function setUpYjsSocket ( port ) {
4
- const wss = new WebSocket . Server ( { port : 1234 } ) ;
5
+ function setUpYjsSocket ( ) {
5
6
6
- wss . on ( 'connection' , ( ws ) => {
7
+ const server = http . createServer ( ) ;
8
+
9
+ const wss = new WebSocket . Server ( { server } ) ;
10
+
11
+ wss . on ( 'connection' , ( ws , req ) => {
7
12
console . log ( 'New client connected' ) ;
8
13
14
+ setupWSConnection ( ws , req ) ;
15
+
9
16
ws . on ( 'close' , ( ) => {
10
17
console . log ( 'Client disconnected' ) ;
11
18
} ) ;
12
19
} ) ;
13
20
14
- console . log ( 'Websocket server is listening on ws://localhost:1234' )
21
+ server . listen ( 1234 , ( ) => {
22
+ console . log ( 'Websocket server is listening on ws://localhost:1234' )
23
+ } )
15
24
}
16
25
17
26
module . exports = { setUpYjsSocket } ;
You can’t perform that action at this time.
0 commit comments