📦 socketio / engine.io-parser

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47import { PACKET_TYPES, Packet, RawData } from "./commons.js";

export const encodePacket = (
  { type, data }: Packet,
  supportsBinary: boolean,
  callback: (encodedPacket: RawData) => void,
) => {
  if (data instanceof ArrayBuffer || ArrayBuffer.isView(data)) {
    return callback(
      supportsBinary ? data : "b" + toBuffer(data, true).toString("base64"),
    );
  }
  // plain string
  return callback(PACKET_TYPES[type] + (data || ""));
};

const toBuffer = (data: BufferSource, forceBufferConversion: boolean) => {
  if (
    Buffer.isBuffer(data) ||
    (data instanceof Uint8Array && !forceBufferConversion)
  ) {
    return data;
  } else if (data instanceof ArrayBuffer) {
    return Buffer.from(data);
  } else {
    return Buffer.from(data.buffer, data.byteOffset, data.byteLength);
  }
};

let TEXT_ENCODER;

export function encodePacketToBinary(
  packet: Packet,
  callback: (encodedPacket: RawData) => void,
) {
  if (packet.data instanceof ArrayBuffer || ArrayBuffer.isView(packet.data)) {
    return callback(toBuffer(packet.data, false));
  }
  encodePacket(packet, true, (encoded) => {
    if (!TEXT_ENCODER) {
      // lazily created for compatibility with Node.js 10
      TEXT_ENCODER = new TextEncoder();
    }
    callback(TEXT_ENCODER.encode(encoded));
  });
}