Method dispatchMessage

npm_modules/cli/src/utils/daemonClient.ts:184–233

(msg: Record<string, unknown>)

  reject: (err: Error) => void;
}

interface PendingPayloadRequest extends PendingRequest {
  maxPayloadBytes: number;
}

const MAX_DAEMON_TRACE_EVENT_COUNT = 10_000;
const MAX_DAEMON_TRACE_NAME_BYTES = 2048;
const MAX_DAEMON_TRACE_CONTEXT_ID_BYTES = 4096;
const MAX_DAEMON_TRACE_ERROR_BYTES = 64 * 1024;

function isRecord(value: unknown): value is Record<string, unknown> {
  return value !== null && typeof value === 'object' && !Array.isArray(value);
}

function isPerformanceTraceMessageType(value: unknown): boolean {
  return (
    value === DaemonMsgType.PERFORMANCE_TRACE_STATUS_REQUEST ||
    value === DaemonMsgType.PERFORMANCE_TRACE_STATUS_RESPONSE ||
    value === DaemonMsgType.PERFORMANCE_TRACE_START_REQUEST ||
    value === DaemonMsgType.PERFORMANCE_TRACE_START_RESPONSE ||
    value === DaemonMsgType.PERFORMANCE_TRACE_STOP_REQUEST ||
    value === DaemonMsgType.PERFORMANCE_TRACE_STOP_RESPONSE
  );
}

function isPerformanceTraceRequestType(value: DaemonMsgType): boolean {
  return (
    value === DaemonMsgType.PERFORMANCE_TRACE_STATUS_REQUEST ||
    value === DaemonMsgType.PERFORMANCE_TRACE_START_REQUEST ||
    value === DaemonMsgType.PERFORMANCE_TRACE_STOP_REQUEST
  );
}

function assertOptionalFiniteNumber(body: Record<string, unknown>, key: string): void {
  const value = body[key];
  if (value !== undefined && (typeof value !== 'number' || !Number.isFinite(value))) {
    throw new TypeError(`Valdi runtime trace response has an invalid ${key}.`);
  }
}

function assertOptionalBoundedString(
  body: Record<string, unknown>,
  key: string,
  maximumBytes: number,
  allowEmpty: boolean,
): void {
  const value = body[key];
  if (
    value !== undefined &&
    (typeof value !== 'string' ||
      (!allowEmpty && value.length === 0) ||
      Buffer.byteLength(value, 'utf8') > maximumBytes)
  ) {