···

       
15
       
 
       
export const shardMessageSchema = websocketMessageSchema

     

       
16
       
 
       
    .safeExtend({

     

       
17
       
 
       
        type: z.literal("shard/message"),

     

       
18
       
-
       
        sessionToken: z.string(),

     

       
19
       
 
       
        channel: z.string(),

     

       
20
       
 
       
        content: z.string(),

     

       
21
       
 
       
        sentBy: didSchema,

     

       
0
       
 
       

     

       
22
       
 
       
        sentAt: z.coerce.date(),

     

       
23
       
 
       
    })

     

       
24
       
 
       
    .strict();

     

···

       
15
       
 
       
export const shardMessageSchema = websocketMessageSchema

     

       
16
       
 
       
    .safeExtend({

     

       
17
       
 
       
        type: z.literal("shard/message"),

     

       
0
       
 
       

     

       
18
       
 
       
        channel: z.string(),

     

       
19
       
 
       
        content: z.string(),

     

       
20
       
 
       
        sentBy: didSchema,

     

       
21
       
+
       
        routedThrough: didSchema,

     

       
22
       
 
       
        sentAt: z.coerce.date(),

     

       
23
       
 
       
    })

     

       
24
       
 
       
    .strict();

     

···

       
50
       
 
       
    }

     

       
51
       
 
       
    const messageToSendToShard = {

     

       
52
       
 
       
        ...message,

     

       
53
       
-
       
        sessionToken: shardSessionInfo.token,

     

       
54
       
 
       
    };

     

       
55
       
 
       
    if (shardSocket.readyState === WebSocket.OPEN)

     

       
56
       
 
       
        shardSocket.send(JSON.stringify(messageToSendToShard));

     

···

       
50
       
 
       
    }

     

       
51
       
 
       
    const messageToSendToShard = {

     

       
52
       
 
       
        ...message,

     

       
0
       
 
       

     

       
53
       
 
       
    };

     

       
54
       
 
       
    if (shardSocket.readyState === WebSocket.OPEN)

     

       
55
       
 
       
        shardSocket.send(JSON.stringify(messageToSendToShard));