feat(cbor/unstable): Introduce @std/cbor

_tools/check_circular_package_dependencies.ts

@@ -40,6 +40,7 @@ type Mod =
   | "async"
   | "bytes"
   | "cache"
+  | "cbor"
   | "cli"
   | "collections"
   | "crypto"
@@ -83,6 +84,7 @@ const ENTRYPOINTS: Record<Mod, string[]> = {
   async: ["mod.ts"],
   bytes: ["mod.ts"],
   cache: ["mod.ts"],
+  cbor: ["mod.ts"],
   cli: ["mod.ts"],
   collections: ["mod.ts"],
   crypto: ["mod.ts"],

_tools/check_docs.ts

@@ -35,6 +35,7 @@ const ENTRY_POINTS = [
   "../async/mod.ts",
   "../bytes/mod.ts",
   "../cache/mod.ts",
+  "../cbor/mod.ts",
   "../cli/mod.ts",
   "../cli/unstable_spinner.ts",
   "../crypto/mod.ts",

browser-compat.tsconfig.json

@@ -12,6 +12,7 @@
     "./assert",
     "./async",
     "./bytes",
+    "./cbor",
     "./cli",
     "./collections",
     "./crypto",

cbor/_common.ts

@@ -0,0 +1,80 @@
+// Copyright 2018-2024 the Deno authors. All rights reserved. MIT license.
+
+export type ReleaseLock = (value?: unknown) => void;
+
+export function numberToArray(bytes: number, x: number | bigint): Uint8Array {
+  const view = new DataView(new ArrayBuffer(8));
+  if (typeof x === "bigint" || x % 1 === 0) view.setBigUint64(0, BigInt(x));
+  else view.setFloat64(0, x);
+  return new Uint8Array(view.buffer.slice(-bytes));
+}
+
+export function arrayToNumber(
+  buffer: ArrayBufferLike & { BYTES_PER_ELEMENT?: never },
+  isInteger: true,
+): number | bigint;
+export function arrayToNumber(
+  buffer: ArrayBufferLike & { BYTES_PER_ELEMENT?: never },
+  isInteger: false,
+): number;
+export function arrayToNumber(
+  buffer: ArrayBufferLike & { BYTES_PER_ELEMENT?: never },
+  isInteger: boolean,
+): number | bigint {
+  const view = new DataView(buffer);
+  if (isInteger) {
+    switch (buffer.byteLength) {
+      case 1:
+        return view.getUint8(0);
+      case 2:
+        return view.getUint16(0);
+      case 4:
+        return view.getUint32(0);
+      default:
+        return view.getBigUint64(0);
+    }
+  }
+  switch (buffer.byteLength) {
+    case 2:
+      return view.getFloat16(0);
+    case 4:
+      return view.getFloat32(0);
+    default:
+      return view.getFloat64(0);
+  }
+}
+
+export function upgradeStreamFromGen(
+  gen: AsyncGenerator<Uint8Array>,
+): ReadableStream<Uint8Array> {
+  return new ReadableStream({
+    type: "bytes",
+    async pull(controller) {
+      const value = await async function () {
+        while (true) {
+          const { done, value } = await gen.next();
+          if (done) return undefined;
+          if (value.length) return value;
+        }
+      }();
+
+      if (value == undefined) {
+        controller.close();
+        return controller.byobRequest?.respond(0);
+      }
+
+      if (controller.byobRequest?.view) {
+        const buffer = new Uint8Array(controller.byobRequest.view.buffer);
+        const size = buffer.length;
+        if (value.length > size) {
+          buffer.set(value.slice(0, size));
+          controller.byobRequest.respond(size);
+          controller.enqueue(value.slice(size));
+        } else {
+          buffer.set(value);
+          controller.byobRequest.respond(value.length);
+        }
+      } else controller.enqueue(value);
+    },
+  });
+}