v3

packages/shared/package.json

@@ -9,9 +9,11 @@
   "dependencies": {
     "@msgpack/msgpack": "^3.1.3",
     "@noble/ciphers": "^2.2.0",
-    "@noble/hashes": "^2.2.0"
+    "@noble/hashes": "^2.2.0",
+    "lz4js": "^0.2.0"
   },
   "devDependencies": {
+    "@types/lz4js": "^0.2.2",
     "typescript": "^5.9.3",
     "vitest": "^4.1.7"
   },

packages/shared/src/compression.test.ts

@@ -0,0 +1,26 @@
+import { describe, expect, it } from "vitest";
+import { compress, decompress, utf8ToBytes } from "./index";
+
+describe("compression", () => {
+  it("round-trips small text", () => {
+    const data = utf8ToBytes("hello world");
+    const compressed = compress(data);
+    const decompressed = decompress(compressed);
+    expect(decompressed).toEqual(data);
+  });
+
+  it("round-trips highly compressible data", () => {
+    const data = utf8ToBytes("a".repeat(10_000));
+    const compressed = compress(data);
+    expect(compressed.length).toBeLessThan(data.length);
+    const decompressed = decompress(compressed);
+    expect(decompressed).toEqual(data);
+  });
+
+  it("round-trips arbitrary bytes", () => {
+    const data = new Uint8Array([0, 128, 255, 1, 2, 3, 200, 100]);
+    const compressed = compress(data);
+    const decompressed = decompress(compressed);
+    expect(decompressed).toEqual(data);
+  });
+});

packages/shared/src/compression.ts

@@ -0,0 +1,9 @@
+import LZ4 from "lz4js";
+
+export function compress(data: Uint8Array): Uint8Array {
+  return LZ4.compress(data);
+}
+
+export function decompress(data: Uint8Array): Uint8Array {
+  return LZ4.decompress(data);
+}

packages/shared/src/crypto.ts

@@ -1,9 +1,14 @@
 import { xchacha20poly1305 } from "@noble/ciphers/chacha.js";
-import { managedNonce, randomBytes, utf8ToBytes } from "@noble/ciphers/utils.js";
+import { managedNonce, randomBytes } from "@noble/ciphers/utils.js";
 import { scrypt } from "@noble/hashes/scrypt.js";
 
-export { bytesToUtf8, utf8ToBytes } from "@noble/ciphers/utils.js";
-export { randomBytes } from "@noble/ciphers/utils.js";
+export {
+  bytesToUtf8,
+  utf8ToBytes,
+  hexToBytes,
+  bytesToHex,
+  randomBytes,
+} from "@noble/ciphers/utils.js";
 
 const N = 2 ** 15;
 const KEY_SIZE = 32;
@@ -25,17 +30,3 @@ export function decrypt(data: Uint8Array, key: Uint8Array): Uint8Array {
   const chacha = managedNonce(xchacha20poly1305)(key);
   return chacha.decrypt(data);
 }
-
-export function bytesToHex(bytes: Uint8Array): string {
-  return Array.from(bytes)
-    .map((b) => b.toString(16).padStart(2, "0"))
-    .join("");
-}
-
-export function hexToBytes(hex: string): Uint8Array {
-  const bytes = new Uint8Array(hex.length / 2);
-  for (let i = 0; i < bytes.length; i++) {
-    bytes[i] = Number.parseInt(hex.slice(i * 2, i * 2 + 2), 16);
-  }
-  return bytes;
-}

packages/shared/src/index.ts

@@ -1,4 +1,5 @@
 export * from "./crypto.js";
 export * from "./types.js";
 export * from "./api.js";
-export { encode, decode } from "@msgpack/msgpack";
+export * from "./compression.js";
+export { encode, decode } from "@msgpack/msgpack";