Files
Alex Rudenko 537c631ab8 Bump vulnerable deps
Drive-by: fixing the presubmit

Fixed: 343248814
Change-Id: I3ec86edbe2ce3d6e7b6a310827b5b5fb0b09c626
Reviewed-on: https://chromium-review.googlesource.com/c/devtools/devtools-frontend/+/5720898
Commit-Queue: Alex Rudenko <alexrudenko@chromium.org>
Reviewed-by: Simon Zünd <szuend@chromium.org>
2024-07-19 07:12:02 +00:00

56 lines
1.7 KiB
JavaScript

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);
}
}
};