simonmcconnell / msgpax_serializer Goto Github PK

import {encode, decode} from '@msgpack/msgpack'

// Still that old saying, pay attention to the same order!
const serialize = ({join_ref, ref, topic, event, payload}, callback) => callback(encode([join_ref, ref, topic, event, payload]))

const deserialize = (rawMessage, callback) => {
  // Don't I repeat it?
  const [join_ref, ref, topic, event, payload] = decode(rawMessage)
  return callback({join_ref, ref, topic, event, payload})
}

let socket = new Socket("/socket", {
  ...,
  encode: serialize,  // Overwrite the original ws serialization mode
  decode: deserialize  // Overwrite the original ws deserialization mode
})