/opt/canhelp/node_modules/engine.io-parser/build/cjs
NameSizeModeActions
contrib/-0755rm
commons.d.ts4860644editdlrm
commons.js7700644editdlrm
decodePacket.browser.d.ts1560644editdlrm
decodePacket.browser.js21440644editdlrm
decodePacket.d.ts1560644editdlrm
decodePacket.js19240644editdlrm
encodePacket.browser.d.ts3320644editdlrm
encodePacket.browser.js24420644editdlrm
encodePacket.d.ts2980644editdlrm
encodePacket.js14070644editdlrm
index.d.ts6700644editdlrm
index.js71190644editdlrm
package.json1820644editdlrm
Edit: /opt/canhelp/node_modules/engine.io-parser/build/cjs/decodePacket.js (1924B)
"use strict"; Object.defineProperty(exports, "__esModule", { value: true }); exports.decodePacket = void 0; const commons_js_1 = require("./commons.js"); const decodePacket = (encodedPacket, binaryType) => { if (typeof encodedPacket !== "string") { return { type: "message", data: mapBinary(encodedPacket, binaryType), }; } const type = encodedPacket.charAt(0); if (type === "b") { const buffer = Buffer.from(encodedPacket.substring(1), "base64"); return { type: "message", data: mapBinary(buffer, binaryType), }; } if (!commons_js_1.PACKET_TYPES_REVERSE[type]) { return commons_js_1.ERROR_PACKET; } return encodedPacket.length > 1 ? { type: commons_js_1.PACKET_TYPES_REVERSE[type], data: encodedPacket.substring(1), } : { type: commons_js_1.PACKET_TYPES_REVERSE[type], }; }; exports.decodePacket = decodePacket; const mapBinary = (data, binaryType) => { switch (binaryType) { case "arraybuffer": if (data instanceof ArrayBuffer) { // from WebSocket & binaryType "arraybuffer" return data; } else if (Buffer.isBuffer(data)) { // from HTTP long-polling return data.buffer.slice(data.byteOffset, data.byteOffset + data.byteLength); } else { // from WebTransport (Uint8Array) return data.buffer; } case "nodebuffer": default: if (Buffer.isBuffer(data)) { // from HTTP long-polling or WebSocket & binaryType "nodebuffer" (default) return data; } else { // from WebTransport (Uint8Array) return Buffer.from(data); } } };