Function withMachineJsonConsole

src/gep/cliContracts.js:830–878

(enabled, deps, fn)

}

async function withMachineJsonConsole(enabled, deps, fn) {
  if (!enabled) return fn();
  const original = {
    log: console.log,
    info: console.info,
    warn: console.warn,
    error: console.error,
    debug: console.debug,
    stdoutWrite: process.stdout.write,
    stderrWrite: process.stderr.write,
  };
  const hadOriginalStdoutWrite = Object.prototype.hasOwnProperty.call(deps, MACHINE_JSON_STDOUT_WRITE);
  const previousOriginalStdoutWrite = deps[MACHINE_JSON_STDOUT_WRITE];
  const write = (...args) => {
    try { process.stderr.write(sanitizeText(util.format(...args), deps) + '\n'); } catch (_) {}
  };
  deps[MACHINE_JSON_STDOUT_WRITE] = original.stdoutWrite;
  process.stdout.write = function (chunk, encoding, callback) {
    const clean = sanitizeStderrChunk(chunk, encoding, deps);
    if (typeof encoding === 'function') return original.stderrWrite.call(process.stderr, clean, encoding);
    return original.stderrWrite.call(process.stderr, clean, encoding, callback);
  };
  process.stderr.write = function (chunk, encoding, callback) {
    const clean = sanitizeStderrChunk(chunk, encoding, deps);
    if (typeof encoding === 'function') return original.stderrWrite.call(process.stderr, clean, encoding);
    return original.stderrWrite.call(process.stderr, clean, encoding, callback);
  };
  console.log = write;
  console.info = write;
  console.warn = write;
  console.error = write;
  console.debug = write;
  try {
    return await fn();
  } finally {
    console.log = original.log;
    console.info = original.info;
    console.warn = original.warn;
    console.error = original.error;
    console.debug = original.debug;
    process.stdout.write = original.stdoutWrite;
    process.stderr.write = original.stderrWrite;
    if (hadOriginalStdoutWrite) {
      deps[MACHINE_JSON_STDOUT_WRITE] = previousOriginalStdoutWrite;
    } else {
      delete deps[MACHINE_JSON_STDOUT_WRITE];
    }
  }
}

function classifyError(e, command) {
  if (e instanceof ContractError) return { reason: e.reason, message: e.safeMessage, retryable: e.reason === 'network_error' };