@@ -3,6 +3,7 @@ import express from "express";
3
3
import { Server } from "socket.io" ;
4
4
import { createServer } from "http" ;
5
5
import cors from 'cors' ;
6
+ import { YSocketIO } from "y-socket.io/dist/server" ;
6
7
7
8
const app = express ( ) ;
8
9
const server = createServer ( app ) ;
@@ -11,20 +12,41 @@ const io = new Server(server, {
11
12
} ) ;
12
13
const PORT = 8000 ;
13
14
15
+ const ysocketio = new YSocketIO ( io , { gcEnabled : true } ) ;
16
+
17
+ ysocketio . initialize ( ) ;
18
+
14
19
app . use ( cors ( { origin : '*' } ) )
15
20
16
21
app . get ( '/' , ( req , res ) => {
17
22
console . log ( 'running' )
18
23
} )
19
24
20
- io . on ( 'connection' , ( socket ) => {
25
+ app . get ( '/test' , ( req , res ) => {
26
+ res . send ( JSON . stringify ( { ok : true } ) ) ;
27
+ } )
28
+
29
+ io . on ( 'connection' , ( socket ) => {
21
30
console . log ( 'user connected socket' )
22
31
socket . on ( 'draw' , ( data ) => {
23
32
socket . broadcast . emit ( 'draw' , data ) ;
24
33
} )
25
- socket . on ( 'clear' , ( ) => {
34
+
35
+ socket . on ( 'clear' , ( ) => {
26
36
io . emit ( 'clear' ) ;
27
37
} )
38
+
39
+ socket . on ( 'open-text-editor' , data => {
40
+ socket . broadcast . emit ( "open-text-editor" , data ) ;
41
+ } )
42
+
43
+ socket . on ( 'close-text-editor' , data => {
44
+ socket . broadcast . emit ( "close-text-editor" , data ) ;
45
+ } )
46
+
47
+ socket . on ( "text-updated" , ( data ) => {
48
+ socket . broadcast . emit ( "text-updated" , data ) ;
49
+ } ) ;
28
50
} )
29
51
30
52
server . listen ( PORT , ( ) => {
0 commit comments