Method drainBuffer

npm_modules/cli/src/utils/daemonClient.ts:147–182

()

  }
}

// ─── Packet encoding ─────────────────────────────────────────────────────────

const MAGIC = Buffer.from([0x33, 0xc6, 0x00, 0x01]);
const HEADER_SIZE = 8; // 4 magic + 4 uint32LE length
// Heap dumps and element snapshots legitimately exceed trace-sized payloads. Keep generic
// framing bounded while applying the tighter trace limit once the inner request is identified.
export const MAX_DAEMON_INNER_PAYLOAD_BYTES = 64 * 1024 * 1024;
export const MAX_DAEMON_PACKET_PAYLOAD_BYTES = 128 * 1024 * 1024;
export const MAX_DAEMON_TRACE_PAYLOAD_BYTES = 4 * 1024 * 1024;
const MAX_DAEMON_BUFFERED_BYTES = HEADER_SIZE + MAX_DAEMON_PACKET_PAYLOAD_BYTES;

function encodePacket(json: object): Buffer {
  const serialized = JSON.stringify(json);
  const payloadLength = Buffer.byteLength(serialized, 'utf8');
  if (payloadLength > MAX_DAEMON_PACKET_PAYLOAD_BYTES) {
    throw new Error(`ValdiPacket payload exceeds the ${MAX_DAEMON_PACKET_PAYLOAD_BYTES}-byte limit.`);
  }
  const payload = Buffer.from(serialized, 'utf8');
  const header = Buffer.alloc(8);
  MAGIC.copy(header, 0);
  header.writeUInt32LE(payload.length, 4);
  return Buffer.concat([header, payload]);
}

// ─── DaemonConnection ────────────────────────────────────────────────────────

// In the direct-to-device protocol we are "client 1" (non-zero required by device JS check).
const DIRECT_CLIENT_ID = 1;
const ADB_FORWARD_REFRESH_INTERVAL_MS = 5000;
const adbForwardedAtByEndpoint = new Map<string, number>();
const adbForwardRefreshByEndpoint = new Map<string, Promise<void>>();

interface PendingRequest {
  resolve: (value: Record<string, unknown>) => void;
  reject: (err: Error) => void;
}

interface PendingPayloadRequest extends PendingRequest {