dialoguedb / client-nodejs / 26549428352

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

import { getDialogue } from "../methods/getDialogue";

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 = Number(raw);

  if (!Number.isInteger(n)) {

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

  return n;

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

  if (process.stdin.isTTY) {

    throw new Error(

  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 loadDialogueOrExit(id: string, namespace?: string) {

  const d = await getDialogue({

    ...(namespace && { namespace }),

  if (!d) {

    process.stderr.write(`Dialogue ${id} not found\n`);

    process.exit(1);

  return d;

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);