dialoguedb / client-nodejs / 26546440990

import { DialogueDBError } from "../errors";

export function parseJSON(label: string, raw: string): unknown {

  try {

    return JSON.parse(raw);

    const message = e instanceof Error ? e.message : String(e);

    throw new Error(`--${label} is not valid JSON: ${message}`);

export function parseCSV(raw: string): string[] {

  return raw

    .map((s) => s.trim())

    .filter((s) => s.length > 0);

export function parseIntStrict(label: string, raw: string): number {

  const n = parseInt(raw, 10);

  if (Number.isNaN(n)) {

    throw new Error(`--${label} must be an integer, got "${raw}"`);

  return n;

export async function readStdin(): Promise<string> {

  const chunks: Buffer[] = [];

  for await (const chunk of process.stdin) {

    chunks.push(typeof chunk === "string" ? Buffer.from(chunk) : chunk);

  return Buffer.concat(chunks).toString("utf8");

export async function resolveContent(opts: {

  if (opts.stdin) return (await readStdin()).trimEnd();

  if (opts.content !== undefined) return opts.content;

  throw new Error("Provide --content <text> or --stdin");

export function output(value: unknown): void {

  process.stdout.write(JSON.stringify(value, null, 2) + "\n");

export function withErrorHandler<A extends unknown[]>(

  return async (...args: A): Promise<void> => {

    try {

      await fn(...args);

      if (e instanceof DialogueDBError) {

        process.stderr.write(

        process.stderr.write(`${e instanceof Error ? e.message : String(e)}\n`);

      process.exit(1);