Added utilities for websockets

Author: Guthib-of-Dan

README.md

@@ -7,3 +7,5 @@ This package lets you parse payload coming from http requests ( + multipart). Fu
 ## parseSimpleBody and parseFormDataBody
 
 (sorry, docs are now incomplete. Look into <a href="./index.d.ts">TS declaration file</a> for more)
+
+(and also importing "@ublitzjs/payload/ws" gives you 2 special high-performant cross-platform functions for easier handling of websocket messages)

index.cjs cjs/index.cjsindex.cjs renamed to cjs/index.cjs

@@ -3,7 +3,7 @@ var { EventEmitter } = require("tseep");
 var { tooLargeBody } = require("@ublitzjs/core");
 var busboy = require("busboy");
 var { nanoid } = require("nanoid");
-var { createWriteStream, WriteStream } = require("node:fs");
+var { createWriteStream} = require("node:fs");
 var { Buffer } = require("node:buffer");
 var { promises: fs } = require("node:fs");
 var wroteToDiskFileEvent = Symbol(),

cjs/ws.cjs

@@ -0,0 +1,25 @@
+var encoder = new TextEncoder(), decoder = new TextDecoder();
+function preParseWSMessage(rawMessage){ 
+    var view = new Uint8Array(rawMessage);
+    var eventLength = view[0]
+    if (eventLength>100) throw new Error("event size > 100 bytes")
+    if (eventLength + 2 > rawMessage.byteLength) throw new Error("Malformed payload")
+    return {
+      event: decoder.decode(view.subarray(1, 1 + eventLength)),
+      message: view.subarray(1 + eventLength)
+    }
+}
+function encodeWSMessage(event, payload){
+  var encodedEvent = encoder.encode(event)
+  if(encodedEvent.length > 100) throw new Error("event size > 100 bytes")
+  var totalLength = 1 + encodedEvent.length + payload.byteLength
+  var message = new Uint8Array(totalLength);
+  message[0] = encodedEvent.length;
+  message.set(encodedEvent, 1);
+  message.set(payload instanceof Uint8Array 
+    ? payload : new Uint8Array(payload),
+    1 + encodedEvent.length
+  );
+  return message;
+}
+module.exports = {preParseWSMessage, encodeWSMessage}

index.mjs mjs/index.mjsindex.mjs renamed to mjs/index.mjs

@@ -3,7 +3,7 @@ import { EventEmitter } from "tseep";
 import { tooLargeBody } from "@ublitzjs/core";
 import busboy from "busboy";
 import { nanoid } from "nanoid";
-import { createWriteStream, WriteStream } from "node:fs";
+import { createWriteStream } from "node:fs";
 import { Buffer } from "node:buffer";
 import { promises as fs } from "node:fs";
 var wroteToDiskFileEvent = Symbol(),

mjs/ws.mjs

@@ -0,0 +1,26 @@
+var encoder = new TextEncoder(), decoder = new TextDecoder();
+function preParseWSMessage(rawMessage){ 
+    var view = new Uint8Array(rawMessage);
+    var eventLength = view[0]
+    if (eventLength>100) throw new Error("event size > 100 bytes")
+    if (eventLength + 2 > rawMessage.byteLength) throw new Error("Malformed payload")
+    return {
+      event: decoder.decode(view.subarray(1, 1 + eventLength)),
+      message: view.subarray(1 + eventLength)
+    }
+}
+function encodeWSMessage(event, payload){
+  var encodedEvent = encoder.encode(event)
+  if(encodedEvent.length > 100) throw new Error("event size > 100 bytes")
+  var totalLength = 1 + encodedEvent.length + payload.byteLength
+  var message = new Uint8Array(totalLength);
+  message[0] = encodedEvent.length;
+  message.set(encodedEvent, 1);
+  message.set(payload instanceof Uint8Array 
+    ? payload : new Uint8Array(payload),
+    1 + encodedEvent.length
+  );
+  return message;
+}
+export {preParseWSMessage, encodeWSMessage}
+

package.json

@@ -1,20 +1,29 @@
 {
   "name": "@ublitzjs/payload",
-  "version": "0.0.1",
+  "version": "0.1.0",
   "exports": {
-    "types": "./index.d.ts",
-    "import": "./index.mjs",
-    "require": "./index.cjs"
+    ".": {
+      "types": "./types/index.d.ts",
+      "import": "./mjs/index.mjs",
+      "require": "./cjs/index.cjs"
+    },
+    "./ws": {
+      "types": "./types/ws.d.ts",
+      "import": "./mjs/ws.mjs",
+      "require": "./cjs/ws.cjs"
+    }
   },
   "dependencies": {
     "nanoid": "^5.1.5",
     "tseep": "^1.3.1",
-    "@ublitzjs/core": "^0.0.1",
+    "@ublitzjs/core": "^0.1.0",
     "busboy": "^1.6.0"
   },
   "devDependencies": {
-    "vitest": "^3.1.4",
-    "undici": "^7.10.0"
+    "@types/busboy": "^1.5.4",
+    "@types/node": "^24.3.1",
+    "undici": "^7.10.0",
+    "vitest": "^3.1.4"
   },
   "publishConfig": {
     "access": "public"

index.d.ts types/index.d.tsindex.d.ts renamed to types/index.d.ts

@@ -0,0 +1,5 @@
+export function preParseWSMessage(rawMessage: ArrayBuffer): {
+    event: string;
+    message: Uint8Array<ArrayBuffer>;
+}
+export function encodeWSMessage(event: string, payload: Uint8Array | ArrayBufferLike): Uint8Array