FM / esm

/opt/canhelp/node_modules/engine.io-parser/build/esm/

/opt/canhelp/node_modules/engine.io-parser/build/esm

Name	Size	Mode	Actions
contrib/	-	0755	rm
commons.d.ts	486	0644	edit dl rm
commons.js	542	0644	edit dl rm
decodePacket.browser.d.ts	156	0644	edit dl rm
decodePacket.browser.js	1929	0644	edit dl rm
decodePacket.d.ts	156	0644	edit dl rm
decodePacket.js	1756	0644	edit dl rm
encodePacket.browser.d.ts	332	0644	edit dl rm
encodePacket.browser.js	2262	0644	edit dl rm
encodePacket.d.ts	298	0644	edit dl rm
encodePacket.js	1196	0644	edit dl rm
index.d.ts	670	0644	edit dl rm
index.js	6436	0644	edit dl rm
package.json	180	0644	edit dl rm

Edit: /opt/canhelp/node_modules/engine.io-parser/build/esm/decodePacket.js (1756B)

import { ERROR_PACKET, PACKET_TYPES_REVERSE, } from "./commons.js";
export 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 (!PACKET_TYPES_REVERSE[type]) {
        return ERROR_PACKET;
    }
    return encodedPacket.length > 1
        ? {
            type: PACKET_TYPES_REVERSE[type],
            data: encodedPacket.substring(1),
        }
        : {
            type: PACKET_TYPES_REVERSE[type],
        };
};
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);
            }
    }
};

import { ERROR_PACKET, PACKET_TYPES_REVERSE, } from "./commons.js"; export 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 (!PACKET_TYPES_REVERSE[type]) { return ERROR_PACKET; } return encodedPacket.length > 1 ? { type: PACKET_TYPES_REVERSE[type], data: encodedPacket.substring(1), } : { type: PACKET_TYPES_REVERSE[type], }; }; 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); } } };