Function addUtxo

packages/cashscript/test/test-util.ts:58–81

(
  provider: NetworkProvider,
  address: string,
  utxo: Utxo,
)

//   transaction.
// Token UTXOs are only supported on MockNetworkProvider.
export async function addUtxo(
  provider: NetworkProvider,
  address: string,
  utxo: Utxo,
): Promise<Utxo> {
  if (provider instanceof MockNetworkProvider) {
    return provider.addUtxo(address, utxo);
  }

  if (utxo.token) {
    throw new Error('addUtxo: creating token UTXOs on a live network is not supported');
  }

  // Serialize all live addUtxo calls through a single-slot queue. Parallel calls would
  // otherwise race to fetch and spend the same funder UTXO, causing txn-mempool-conflict.
  // As a fallback, p-retry retries up to 10 times on mempool conflicts if one still slips
  // through (e.g. the electrum server hadn't yet indexed the previous change UTXO).
  const result = await liveAddUtxoQueue.add(() => pRetry(
    () => sendLiveAddUtxo(provider, address, utxo),
    { shouldRetry: ({ error }) => isMempoolConflictError(error) },
  ));
  if (!result) throw new Error('addUtxo: live queue returned no result');
  return result;
}

function isMempoolConflictError(error: unknown): boolean {
  const message = error instanceof Error ? error.message : String(error);