commit bd5d61d6faf080781e096e96115c4ae363d6d32a · gmstn.systems/shard

+27
src/lib/utils/ws.ts
···

       1
       1
       +
       import type { RawData } from "ws";

     

       2
       2
       +
       

     

       3
       3
       +
       export const wsSyncHandler = (

     

       4
       4
       +
           data: RawData,

     

       5
       5
       +
           handler: (jsonData: unknown) => void,

     

       6
       6
       +
       ) => {

     

       7
       7
       +
           const jsonText = rawDataToString(data);

     

       8
       8
       +
           const jsonData: unknown = JSON.parse(jsonText);

     

       9
       9
       +
           try {

     

       10
       10
       +
               handler(jsonData);

     

       11
       11
       +
           } catch (err: unknown) {

     

       12
       12
       +
               console.error(

     

       13
       13
       +
                   `Something went wrong while executing the WebSocket handler ${handler.name}`,

     

       14
       14
       +
               );

     

       15
       15
       +
               console.error(err);

     

       16
       16
       +
           }

     

       17
       17
       +
       };

     

       18
       18
       +
       

     

       19
       19
       +
       export const rawDataToString = (data: RawData): string => {

     

       20
       20
       +
           if (Buffer.isBuffer(data)) {

     

       21
       21
       +
               return data.toString("utf-8");

     

       22
       22
       +
           }

     

       23
       23
       +
           if (Array.isArray(data)) {

     

       24
       24
       +
               return Buffer.concat(data).toString("utf-8");

     

       25
       25
       +
           }

     

       26
       26
       +
           return new TextDecoder().decode(data);

     

       27
       27
       +
       };