File tree Expand file tree Collapse file tree
Expand file tree Collapse file tree Original file line number Diff line number Diff line change @@ -26,15 +26,14 @@ export const messages = new Elysia({ prefix: "/messages" })
2626 timestamp : Date . now ( ) ,
2727 roomId,
2828 } ;
29-
30- await redis . rpush ( `messages:${ roomId } ` , {
31- ...message ,
32- token : auth . token ,
33- } ) ;
34- await realtime . channel ( roomId ) . emit ( "chat.message" , message ) ;
35-
3629 const remaining = await redis . ttl ( `meta:${ roomId } ` ) ;
30+
3731 await Promise . all ( [
32+ redis . rpush ( `messages:${ roomId } ` , {
33+ ...message ,
34+ token : auth . token ,
35+ } ) ,
36+ realtime . channel ( roomId ) . emit ( "chat.message" , message ) ,
3837 redis . expire ( `messages:${ roomId } ` , remaining ) ,
3938 redis . expire ( `history:${ roomId } ` , remaining ) ,
4039 redis . expire ( roomId , remaining ) ,
Original file line number Diff line number Diff line change @@ -10,12 +10,13 @@ export const rooms = new Elysia({ prefix: "/room" })
1010 . post ( "/create" , async ( ) => {
1111 const roomId = nanoid ( ) ;
1212
13- await redis . hset ( `meta:${ roomId } ` , {
14- connected : [ ] ,
15- createdAt : new Date ( ) ,
16- } ) ;
17-
18- await redis . expire ( `meta:${ roomId } ` , ROOM_TTL_SECONDS ) ;
13+ await Promise . all ( [
14+ redis . hset ( `meta:${ roomId } ` , {
15+ connected : [ ] ,
16+ createdAt : new Date ( ) ,
17+ } ) ,
18+ redis . expire ( `meta:${ roomId } ` , ROOM_TTL_SECONDS ) ,
19+ ] ) ;
1920
2021 return { roomId } ;
2122 } )
You can’t perform that action at this time.
0 commit comments