123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128
// deno-lint-ignore-file no-explicit-any no-emptyimport { asyncIterToStream } from 'https://ghuc.cc/qwtel/whatwg-stream-to-async-iter/index.ts'
type SeenWeakSet = WeakSet<any>;
type Primitive = undefined | boolean | number | string | bigint | symbol;
export type ToJSON = { toJSON: (key?: any) => string }
export const isIterable = <T>(x: unknown): x is Iterable<T> =>  x != null && typeof x === 'object' && Symbol.iterator in x
export const isAsyncIterable = <T>(x: unknown): x is AsyncIterable<T> =>  x != null && typeof x === 'object' && Symbol.asyncIterator in x
const isPromiseLike = <T>(x: unknown): x is PromiseLike<T> =>  x != null && typeof x === 'object' && 'then' in x && typeof (<any>x).then === 'function'
const isToJSON = <J extends ToJSON>(x: unknown): x is J =>  x != null && typeof x === 'object' && 'toJSON' in x;
const safeAdd = (seen: SeenWeakSet, value: any) => {  if (seen.has(value)) throw TypeError('Converting circular structure to JSON')  seen.add(value)}
const check = (v: any) => {  if (v === undefined) return false;  const type = typeof v;  return type !== 'function' && type !== 'symbol'}
// TODO: Add replacer// TODO: add formatting/spaces// TODO: concurrent objects/arrays/** * @deprecated Change name to something more descriptive!?  */export async function* jsonStringifyGenerator(  value: null | Primitive | ToJSON | any[] | Record<string, any> | PromiseLike<any> | AsyncIterable<any> | ReadableStream,  seen: SeenWeakSet = new WeakSet(),): AsyncIterableIterator<string> {  if (isAsyncIterable(value)) {    yield '['    safeAdd(seen, value)    let first = true;    for await (const v of value) {      if (!first) yield ','; else first = false;      yield* jsonStringifyGenerator(v, seen)    }    seen.delete(value)    yield ']'  }  else if (isPromiseLike(value)) {    const v = await value    if (check(v)) {      safeAdd(seen, value)      yield* jsonStringifyGenerator(v, seen)      seen.delete(value)    }  }  else if (isToJSON(value)) {    const v = JSON.stringify(value);    if (check(v)) yield v  }  else if (Array.isArray(value)) {    yield '['    safeAdd(seen, value)    let first = true;    for (const v of value) {      if (!first) yield ','; else first = false;      yield* jsonStringifyGenerator(v, seen);    }    seen.delete(value)    yield ']'  }  else if (value != null && typeof value === 'object') {    yield '{'    safeAdd(seen, value)    let first = true;    for (const [k, v] of Object.entries(value)) {      if (check(v)) {        const generator = jsonStringifyGenerator(v, seen)        const peek = await generator.next()        if (check(peek.value)) {          if (!first) yield ','; else first = false;          yield `${JSON.stringify(k)}:`          yield peek.value          yield* generator;        }      }    }    seen.delete(value)    yield '}'  }  else {    yield check(value) ? JSON.stringify(value) : 'null'  }}
/** * @deprecated Change name to something more descriptive!?  */export function jsonStringifyStream(  value: null | Primitive | ToJSON | any[] | Record<string, any> | PromiseLike<any> | AsyncIterable<any> | ReadableStream,): ReadableStream<string> {  return asyncIterToStream(jsonStringifyGenerator(value))}
export class JSONStringifyReadable extends ReadableStream<string> {  constructor(value: any) {    let iterator: AsyncIterator<string>;    super({      start() {        iterator = jsonStringifyGenerator(value)[Symbol.asyncIterator]()      },      async pull(controller) {        // console.log('stringify', controller.desiredSize)        const { value, done } = await iterator.next();        if (!done) controller.enqueue(value); else controller.close();      },      async cancel(reason) {        try { await iterator.throw?.(reason) } catch { }      },    })  }}