123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778
// Copyright 2018-2024 the Deno authors. All rights reserved. MIT license.
import { assertEquals, assertRejects } from "../assert/mod.ts";import {  JsonStringifyStream,  type StringifyStreamOptions,} from "./json_stringify_stream.ts";
async function assertValidStringify(  transformer: typeof JsonStringifyStream,  chunks: unknown[],  expect: string[],  options?: StringifyStreamOptions,) {  const r = ReadableStream.from(chunks)    .pipeThrough(new transformer(options));  const res = await Array.fromAsync(r);  assertEquals(res, expect);}
async function assertInvalidStringify(  transformer: typeof JsonStringifyStream,  chunks: unknown[],  options: StringifyStreamOptions,  // deno-lint-ignore no-explicit-any  ErrorClass: new (...args: any[]) => Error,  msgIncludes: string | undefined,) {  const r = ReadableStream.from(chunks)    .pipeThrough(new transformer(options));  await assertRejects(    async () => await Array.fromAsync(r),    ErrorClass,    msgIncludes,  );}
Deno.test({  name: "JsonStringifyStream",  async fn() {    await assertValidStringify(      JsonStringifyStream,      [{ foo: "bar" }, { foo: "bar" }],      ['{"foo":"bar"}\n', '{"foo":"bar"}\n'],    );  },});
Deno.test({  name: "JsonStringifyStream throws on error",  async fn() {    const cyclic: Record<string, unknown> = {};    cyclic.cyclic = cyclic;    await assertInvalidStringify(      JsonStringifyStream,      [cyclic],      {},      TypeError,      "Converting circular structure to JSON",    );  },});
Deno.test({  name: "JsonStringifyStream handles prefix and suffix",  async fn() {    await assertValidStringify(      JsonStringifyStream,      [{ foo: "bar" }, { foo: "bar" }],      [        '[[prefix]]{"foo":"bar"}[[suffix]]',        '[[prefix]]{"foo":"bar"}[[suffix]]',      ],      { prefix: "[[prefix]]", suffix: "[[suffix]]" },    );  },});