Build a wallet PnL tracker

const API_KEY = process.env.ZERION_API_KEY;
const BASE_URL = "https://api.zerion.io/v1";
const headers = {
  accept: "application/json",
  authorization: `Basic ${btoa(API_KEY + ":")}`,
};

async function getPortfolioPnL(address, currency = "usd") {
  const response = await fetch(
    `${BASE_URL}/wallets/${address}/pnl?currency=${currency}`,
    { headers }
  );
  const { data } = await response.json();
  return data.attributes;
}

const pnl = await getPortfolioPnL("0x42b9df65b219b3dd36ff330a4dd8f327a6ada990");
console.log(`Realized Gain:     $${pnl.realized_gain.toFixed(2)}`);
console.log(`Unrealized Gain:   $${pnl.unrealized_gain.toFixed(2)}`);
console.log(`Net Invested:      $${pnl.net_invested.toFixed(2)}`);
console.log(`Total Fees:        $${pnl.total_fee.toFixed(2)}`);
console.log(`Received External: $${pnl.received_external.toFixed(2)}`);
console.log(`Sent External:     $${pnl.sent_external.toFixed(2)}`);

const params = new URLSearchParams({
  currency: "usd",
  "filter[fungible_ids]": "eth,uni,wbtc",
});

const response = await fetch(
  `${BASE_URL}/wallets/${address}/pnl?${params}`,
  { headers }
);
const { data } = await response.json();
const breakdown = data.attributes.breakdown?.by_id;

for (const [tokenId, stats] of Object.entries(breakdown)) {
  console.log(`${tokenId}: $${stats.total_gain?.toFixed(2)} gain (${stats.relative_total_gain_percentage?.toFixed(1)}%)`);
}

{
  "breakdown": {
    "by_id": {
      "eth": {
        "average_buy_price": 3450.85,
        "average_sell_price": 3527.83,
        "realized_gain": -5.48,
        "unrealized_gain": -1.97,
        "total_fee": 1.88,
        "net_invested": 38.24,
        "received_external": 52.18,
        "sent_external": 0.13,
        "sent_for_nfts": 5.00,
        "received_for_nfts": 0
      }
    }
  }
}

const params = new URLSearchParams({
  currency: "usd",
  "filter[fungible_implementations]": [
    "ethereum:",                                             // ETH on Ethereum (native asset)
    "base:",                                                 // ETH on Base (native asset)
    "ethereum:0xa0b86991c6218b36c1d19d4a2e9eb0ce3606eb48",  // USDC on Ethereum
    "base:0x833589fcd6edb6e08f4c7c32d4f71b54bda02913",      // USDC on Base
  ].join(","),
});

const response = await fetch(
  `${BASE_URL}/wallets/${address}/pnl?${params}`,
  { headers }
);
const { data } = await response.json();
const breakdown = data.attributes.breakdown?.by_implementation;

for (const [impl, stats] of Object.entries(breakdown)) {
  const [chain, addr] = impl.split(":");
  const label = addr ? `${chain}:${addr.slice(0, 10)}…` : `${chain} (native)`;
  console.log(`${label}: gain $${stats.realized_gain?.toFixed(2)}, unrealized $${stats.unrealized_gain?.toFixed(2)}`);
}

// PnL for calendar year 2025
const since = new Date("2025-01-01T00:00:00Z").getTime(); // 1735689600000
const till = new Date("2026-01-01T00:00:00Z").getTime();  // 1767225600000

const params = new URLSearchParams({
  currency: "usd",
  since: since.toString(),
  till: till.toString(),
});

const response = await fetch(
  `${BASE_URL}/wallets/${address}/pnl?${params}`,
  { headers }
);

# PnL for calendar year 2025 (annual recap)
curl -u YOUR_API_KEY: \
  -H "accept: application/json" \
  "https://api.zerion.io/v1/wallets/{address}/pnl?currency=usd&since=1735689600000&till=1767225600000"

curl -g -u "YOUR_API_KEY:" \
  "https://api.zerion.io/v1/wallets/0x42b9df65b219b3dd36ff330a4dd8f327a6ada990/pnl?currency=usd&filter[chain_ids]=ethereum,base"

const API_KEY = process.env.ZERION_API_KEY;
const BASE_URL = "https://api.zerion.io/v1";
const headers = {
  accept: "application/json",
  authorization: `Basic ${btoa(API_KEY + ":")}`,
};

async function fetchPnL(address, params = {}, retries = 3) {
  const query = new URLSearchParams({ currency: "usd", ...params });
  const res = await fetch(`${BASE_URL}/wallets/${address}/pnl?${query}`, { headers });

  // Handle bootstrap: new/cold wallets may return 503 with Retry-After
  if (res.status === 503) {
    if (retries <= 0) throw new Error("Wallet PnL bootstrap timed out after retries");
    const retryAfter = res.headers.get("Retry-After") || "5";
    console.log(`Wallet bootstrapping... retrying in ${retryAfter}s (${retries} retries left)`);
    await new Promise((r) => setTimeout(r, parseInt(retryAfter) * 1000));
    return fetchPnL(address, params, retries - 1);
  }

  if (!res.ok) throw new Error(`API error: ${res.status}`);
  return res.json();
}

async function buildDashboard(address, tokenIds) {
  // 1. Portfolio-level PnL
  const overall = await fetchPnL(address);
  const pnl = overall.data.attributes;

  console.log("=== PORTFOLIO SUMMARY ===");
  console.log(`Realized Gain:     $${pnl.realized_gain.toFixed(2)}`);
  console.log(`Unrealized Gain:   $${pnl.unrealized_gain.toFixed(2)}`);
  console.log(`Net Invested:      $${pnl.net_invested.toFixed(2)}`);
  console.log(`Fees:              $${pnl.total_fee.toFixed(2)}`);
  console.log(`Received External: $${pnl.received_external.toFixed(2)}`);
  console.log(`Sent External:     $${pnl.sent_external.toFixed(2)}`);

  // 2. Per-token breakdown
  if (tokenIds?.length) {
    const batch = await fetchPnL(address, {
      "filter[fungible_ids]": tokenIds.join(","),
    });
    const breakdown = batch.data.attributes.breakdown?.by_id || {};

    console.log("\n=== TOKEN BREAKDOWN ===");
    for (const [id, s] of Object.entries(breakdown)) {
      console.log(`${id.toUpperCase()}`);
      console.log(`  Buy avg: $${s.average_buy_price?.toFixed(2)}  ->  Sell avg: $${s.average_sell_price?.toFixed(2)}`);
      console.log(`  Realized: $${s.realized_gain?.toFixed(2)} (${s.relative_realized_gain_percentage?.toFixed(1)}%)`);
      console.log(`  Unrealized: $${s.unrealized_gain?.toFixed(2)}`);
      console.log(`  Invested: $${s.total_invested?.toFixed(2)}  |  Fees: $${s.total_fee?.toFixed(2)}`);
    }
  }
}

buildDashboard("0x42b9df65b219b3dd36ff330a4dd8f327a6ada990", [
  "eth", "uni", "wbtc",
]);