fix: deno stderr, examples and tests

examples/json/.npmrc

@@ -1 +1,2 @@
+package-lock=false
 @jsr:registry=https://npm.jsr.io

examples/json/deno.json

@@ -0,0 +1,7 @@
+{
+  "lock": false,
+  "imports": {
+    "@denosaurs/log": "jsr:@denosaurs/log",
+    "@std/json": "jsr:@std/json"
+  }
+}

examples/json/test.ts

@@ -0,0 +1,42 @@
+import { assert } from "jsr:@std/assert";
+import { assertIsLog, createJSONLineStream } from "../../utils/test.ts";
+
+assert(
+  (await new Deno.Command("npm", {
+    args: ["install"],
+    cwd: import.meta.dirname,
+  }).spawn().status).success,
+);
+
+Deno.test("deno", async () => {
+  const { success, stdout } = await new Deno.Command("deno", {
+    args: ["run", "--quiet", "--no-npm", "main.js"],
+    cwd: import.meta.dirname,
+  }).output();
+  assert(success);
+  for await (const line of createJSONLineStream(stdout)) {
+    assertIsLog(line);
+  }
+});
+
+Deno.test("bun", async () => {
+  const { success, stdout } = await new Deno.Command("bun", {
+    args: ["main.js"],
+    cwd: import.meta.dirname,
+  }).output();
+  assert(success);
+  for await (const line of createJSONLineStream(stdout)) {
+    assertIsLog(line);
+  }
+});
+
+Deno.test("node", async () => {
+  const { success, stdout } = await new Deno.Command("node", {
+    args: ["main.js"],
+    cwd: import.meta.dirname,
+  }).output();
+  assert(success);
+  for await (const line of createJSONLineStream(stdout)) {
+    assertIsLog(line);
+  }
+});

examples/tee/.npmrc

@@ -0,0 +1,2 @@
+package-lock=false
+@jsr:registry=https://npm.jsr.io

examples/tee/deno.json

@@ -0,0 +1,7 @@
+{
+  "lock": false,
+  "imports": {
+    "@denosaurs/log": "jsr:@denosaurs/log",
+    "@std/json": "jsr:@std/json"
+  }
+}

examples/tee/main.js

@@ -0,0 +1,23 @@
+// Ensure Bun compatibility
+import "@denosaurs/log/transforms/text_encoder_stream";
+
+import { ConsoleReadableStream } from "@denosaurs/log";
+import { stderr } from "@denosaurs/log/writables/stderr";
+import { stdout } from "@denosaurs/log/writables/stdout";
+
+import { JsonStringifyStream } from "@std/json";
+
+const stream = new ConsoleReadableStream();
+const [a, b] = stream
+  .pipeThrough(new JsonStringifyStream())
+  .pipeThrough(new TextEncoderStream())
+  .tee();
+
+a.pipeTo(stderr);
+b.pipeTo(stdout);
+
+console.log("Hello, world!");
+console.group("Group 1");
+console.debug("Debug message");
+console.groupEnd();
+console.info("Info message");

examples/tee/package.json

@@ -0,0 +1,7 @@
+{
+  "type": "module",
+  "dependencies": {
+    "@std/json": "npm:@jsr/std__json",
+    "@denosaurs/log": "npm:@jsr/denosaurs__log"
+  }
+}

examples/tee/test.ts

@@ -0,0 +1,54 @@
+import { assert } from "jsr:@std/assert";
+import { assertIsLog, createJSONLineStream } from "../../utils/test.ts";
+
+assert(
+  (await new Deno.Command("npm", {
+    args: ["install"],
+    cwd: import.meta.dirname,
+  }).spawn().status).success,
+);
+
+Deno.test("deno", async () => {
+  const { success, stdout, stderr } = await new Deno.Command("deno", {
+    args: ["run", "--quiet", "--no-npm", "main.js"],
+    cwd: import.meta.dirname,
+  }).output();
+  assert(success);
+  for await (const line of createJSONLineStream(stdout)) {
+    assertIsLog(line);
+  }
+
+  for await (const line of createJSONLineStream(stderr)) {
+    assertIsLog(line);
+  }
+});
+
+Deno.test("bun", async () => {
+  const { success, stdout, stderr } = await new Deno.Command("bun", {
+    args: ["main.js"],
+    cwd: import.meta.dirname,
+  }).output();
+  assert(success);
+  for await (const line of createJSONLineStream(stdout)) {
+    assertIsLog(line);
+  }
+
+  for await (const line of createJSONLineStream(stderr)) {
+    assertIsLog(line);
+  }
+});
+
+Deno.test("node", async () => {
+  const { success, stdout, stderr } = await new Deno.Command("node", {
+    args: ["main.js"],
+    cwd: import.meta.dirname,
+  }).output();
+  assert(success);
+  for await (const line of createJSONLineStream(stdout)) {
+    assertIsLog(line);
+  }
+
+  for await (const line of createJSONLineStream(stderr)) {
+    assertIsLog(line);
+  }
+});

utils/runtime.ts

@@ -1,19 +1,19 @@
+// deno-fmt-ignore-file
+
 export const isDeno = typeof Deno !== "undefined";
+
 // @ts-expect-error: The type checking environment is deno, the bun types are not available
-export const isBun = typeof process?.versions?.bun !== "undefined" &&
-  "isBun" in process && process?.isBun;
+export const isBun = typeof process?.versions?.bun !== "undefined" && "isBun" in process && process?.isBun;
+
 // @ts-expect-error: The type checking environment is deno, the node types are not available
 export const isNode = typeof process !== "undefined" && !isDeno && !isBun;
+
 // @ts-expect-error: The type checking environment is deno, the browser types are not available
-export const isBrowser = typeof globalThis !== "undefined" &&
-  typeof globalThis.document?.createElement !== "undefined";
+export const isBrowser = typeof globalThis !== "undefined" && typeof globalThis.document?.createElement !== "undefined";
 
-export const environment = isDeno
-  ? "deno"
-  : isBun
-  ? "bun"
-  : isNode
-  ? "node"
-  : isBrowser
-  ? "browser"
-  : "unknown";
+export const environment =
+    isDeno    ? "deno"
+  : isBun     ? "bun"
+  : isNode    ? "node"
+  : isBrowser ? "browser"
+              : "unknown";

utils/test.ts

@@ -0,0 +1,21 @@
+import { assert, assertStrictEquals } from "jsr:@std/assert";
+import { TextLineStream } from "jsr:@std/streams";
+import { JsonParseStream } from "jsr:@std/json";
+import { Log, LOG_LEVELS } from "../mod.ts";
+
+// deno-lint-ignore no-explicit-any
+export function assertIsLog(log: any): asserts log is Log {
+  assertStrictEquals(typeof log, "object");
+  assertStrictEquals(typeof log.timestamp, "number");
+  assertStrictEquals(typeof log.level, "string");
+  assert(Object.keys(LOG_LEVELS).includes(log.level));
+  assert(Array.isArray(log.groups));
+  assert(Array.isArray(log.data));
+}
+
+export function createJSONLineStream(...buffers: Uint8Array[]) {
+  return ReadableStream.from(buffers)
+    .pipeThrough(new TextDecoderStream())
+    .pipeThrough(new TextLineStream())
+    .pipeThrough(new JsonParseStream());
+}

writables/stderr.ts

@@ -4,7 +4,7 @@ let writable: WritableStream<Uint8Array>;
 
 switch (environment) {
   case "deno":
-    writable = globalThis.Deno.stdout.writable;
+    writable = globalThis.Deno.stderr.writable;
     break;
   case "bun": {
     // Once https://github.com/oven-sh/bun/issues/3927 is completed we can use the node code for bun.