@@ -3,6 +3,7 @@ import express from "express";
33import { Server } from "socket.io" ;
44import { createServer } from "http" ;
55import cors from 'cors' ;
6+ import { YSocketIO } from "y-socket.io/dist/server" ;
67
78const app = express ( ) ;
89const server = createServer ( app ) ;
@@ -11,20 +12,41 @@ const io = new Server(server, {
1112} ) ;
1213const PORT = 8000 ;
1314
15+ const ysocketio = new YSocketIO ( io , { gcEnabled : true } ) ;
16+
17+ ysocketio . initialize ( ) ;
18+
1419app . use ( cors ( { origin : '*' } ) )
1520
1621app . get ( '/' , ( req , res ) => {
1722 console . log ( 'running' )
1823} )
1924
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 ) => {
2130 console . log ( 'user connected socket' )
2231 socket . on ( 'draw' , ( data ) => {
2332 socket . broadcast . emit ( 'draw' , data ) ;
2433 } )
25- socket . on ( 'clear' , ( ) => {
34+
35+ socket . on ( 'clear' , ( ) => {
2636 io . emit ( 'clear' ) ;
2737 } )
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+ } ) ;
2850} )
2951
3052server . listen ( PORT , ( ) => {
0 commit comments