Send Crypto

curl -X POST https://crypto-api.yativo.com/api/v1/transactions/get-gas-price \
  -H "Authorization: Bearer eyJhbGciOiJSUzI1NiJ9.eyJzdWIiOiJ1c3JfMDFIWVo..." \
  -H "Content-Type: application/json" \
  -d '{
    "chainType": "ethereum",
    "priority": "medium",
    "token_symbol": "USDC"
  }'

import { YativoCrypto } from "@yativo/crypto-sdk";

const client = new YativoCrypto({
  apiKey: process.env.YATIVO_API_KEY!,
  baseUrl: "https://crypto-api.yativo.com/api/v1/",
});

const gasEstimate = await client.transactions.getGasPrice({
  chain: "ethereum",
  asset: "USDC",
});

console.log(gasEstimate);
/*
{
  chain: "ethereum",
  slow:   { gasPrice: "18.2", estimatedFeeUsd: "0.82",  estimatedTimeSeconds: 120 },
  medium: { gasPrice: "22.5", estimatedFeeUsd: "1.02",  estimatedTimeSeconds: 30  },
  fast:   { gasPrice: "31.0", estimatedFeeUsd: "1.40",  estimatedTimeSeconds: 10  },
  nativeAsset: "ETH",
  updatedAt: "2026-03-26T11:00:00Z"
}
*/

from yativo_crypto import YativoCrypto

client = YativoCrypto(
    api_key=os.environ["YATIVO_API_KEY"],
    base_url="https://crypto-api.yativo.com/api/v1/",
)

gas_estimate = client.transactions.get_gas_price(
    chain="ethereum",
    asset="USDC",
)
print(gas_estimate.medium.estimated_fee_usd)  # "1.02"

curl -X POST https://crypto-api.yativo.com/api/v1/transactions/send-funds \
  -H "Authorization: Bearer eyJhbGciOiJSUzI1NiJ9.eyJzdWIiOiJ1c3JfMDFIWVo..." \
  -H "Content-Type: application/json" \
  -H "Idempotency-Key: payout_01J2KG9MNPQ3R4S5T6UPAY001" \
  -d '{
    "account": "64b1f9e2a3c4d5e6f7a8b9c0",
    "assets": "64b1f9e2a3c4d5e6f7a8b9d1",
    "receiving_address": "0xd8dA6BF26964aF9D7eEd9e03E53415D37aA96045",
    "amount": 100,
    "type": "USDC",
    "chain": "ethereum",
    "category": "payment",
    "priority": "medium",
    "description": "Payout for order #ORD-9821"
  }'

import { v4 as uuidv4 } from "uuid";

// Generate a stable idempotency key tied to your payout record
const idempotencyKey = `payout_${payoutRecord.id}`;

const transaction = await client.transactions.sendFunds(
  {
    account: "64b1f9e2a3c4d5e6f7a8b9c0",
    assets: "64b1f9e2a3c4d5e6f7a8b9d1",
    receiving_address: "0xd8dA6BF26964aF9D7eEd9e03E53415D37aA96045",
    amount: 100,
    type: "USDC",
    chain: "ethereum",
    category: "payment",
    priority: "medium",
    description: "Payout for order #ORD-9821",
  },
  { idempotencyKey }
);

console.log(transaction.data.transaction_id);  // txn_01HX9KZMB3F7VNQP8R2WDGT4E5
console.log(transaction.data.transaction_hash); // 0x9f3e2d...

transaction = client.transactions.send_funds(
    account="64b1f9e2a3c4d5e6f7a8b9c0",
    assets="64b1f9e2a3c4d5e6f7a8b9d1",
    receiving_address="0xd8dA6BF26964aF9D7eEd9e03E53415D37aA96045",
    amount=100,
    type="USDC",
    chain="ethereum",
    category="payment",
    priority="medium",
    description="Payout for order #ORD-9821",
    idempotency_key=f"payout_{payout_record.id}",
)

print(transaction.data.transaction_id)      # txn_01HX9KZMB3F7VNQP8R2WDGT4E5
print(transaction.data.transaction_hash)    # 0x9f3e2d...

curl -X POST https://crypto-api.yativo.com/api/v1/transactions/get-transactions \
  -H "Authorization: Bearer eyJhbGciOiJSUzI1NiJ9.eyJzdWIiOiJ1c3JfMDFIWVo..." \
  -H "Content-Type: application/json" \
  -d '{
    "search": "txn_01J2KH3MNPQ7R4S5T6U7VSND99"
  }'

// Poll with exponential backoff
async function waitForTransaction(transactionId: string): Promise<any> {
  const maxAttempts = 20;
  let delay = 2000; // start at 2 seconds

  for (let attempt = 0; attempt < maxAttempts; attempt++) {
    const result = await client.transactions.getTransactions({ search: transactionId });
    const txn = result.data?.[0];

    if (!txn) throw new Error('Transaction not found');
    if (txn.status === 'completed') return txn;
    if (txn.status === 'failed') throw new Error(`Transaction failed: ${txn.error_message}`);

    await new Promise((resolve) => setTimeout(resolve, delay));
    delay = Math.min(delay * 1.5, 30000); // cap at 30s
  }

  throw new Error('Transaction did not complete within timeout');
}

const completed = await waitForTransaction('txn_01J2KH3MNPQ7R4S5T6U7VSND99');
console.log(completed.transaction_hash); // 0x9f3e2d1c4b7a5e8f2c9b3d6a1e4c7f2b5d8e1c4a...

import time

def wait_for_transaction(transaction_id: str) -> dict:
    max_attempts = 20
    delay = 2.0

    for attempt in range(max_attempts):
        result = client.transactions.get_transactions(search=transaction_id)
        txn = result.data[0] if result.data else None

        if not txn:
            raise Exception('Transaction not found')
        if txn.status == 'completed':
            return txn
        if txn.status == 'failed':
            raise Exception(f'Transaction failed: {txn.error_message}')

        time.sleep(delay)
        delay = min(delay * 1.5, 30.0)

    raise TimeoutError('Transaction did not complete within timeout')

completed = wait_for_transaction('txn_01J2KH3MNPQ7R4S5T6U7VSND99')
print(completed.transaction_hash)