Wallet activity — address activity stream

curl -X POST "https://triport.io/v1/wallet/watch/$SUB_ID/watchlist" \
  -H "Authorization: Bearer $TRIPORT_API_KEY" \
  -H "Content-Type: application/json" \
  -d '{"add": ["0x023ab8e20a4682d315daef4c91db96bd77934d66"], "remove": ["0x133243d447026345c2b368d7ffe435dbe3c566eb"]}'
# {"added":1,"removed":1,"total":2}

cursor=""
while :; do
  page=$(curl -s "https://triport.io/v1/wallet/watch/$SUB_ID/watchlist?limit=5000&cursor=$cursor" \
    -H "Authorization: Bearer $TRIPORT_API_KEY")
  echo "$page" | jq -r '.watchlist[]'
  [ "$(echo "$page" | jq -r .has_more)" = "true" ] || break
  cursor=$(echo "$page" | jq -r .next_cursor)
done

import WebSocket from "ws";


let cursor = loadCursor();          // your persisted last cursor, or ""
const seen = new Set();             // event_ids seen in the last ≥ 5 minutes


function connect() {
  const q = new URLSearchParams({ id: process.env.SUB_ID });
  if (cursor) q.set("cursor", cursor);
  const ws = new WebSocket(`wss://triport.io/ws/wallet-watch?${q}`, {
    headers: { Authorization: `Bearer ${process.env.TRIPORT_API_KEY}` },
  });
  ws.on("message", (raw) => {
    const m = JSON.parse(raw);
    if (m.type === "resume") return;                 // m.mode: none | seq | blocks
    if (m.type === "cursor_expired") {               // followed by close 4410
      console.warn("events lost before", m.oldest_cursor);
      cursor = m.oldest_cursor;
      return;
    }
    if (!seen.has(m.event_id)) {
      seen.add(m.event_id);
      if (m.type === "reorg_revert") m.removed_event_ids.forEach(dropEvent);
      else if (m.type === "gap") markUnverified(m.chain, m.from_block, m.to_block, m.reason);
      else handleActivity(m);                        // wallet_activity
    }
    cursor = m.cursor;
    saveCursor(cursor);
  });
  ws.on("close", () => setTimeout(connect, 1000));
}
connect();

import { createHmac, timingSafeEqual } from "node:crypto";


export function onWebhook(rawBody, headers, secret, store) {
  const expected = "sha256=" + createHmac("sha256", secret).update(rawBody).digest("hex");
  const got = headers["x-triport-signature"] ?? "";
  if (got.length !== expected.length || !timingSafeEqual(Buffer.from(got), Buffer.from(expected))) return 401;
  const id = headers["x-triport-event-id"];
  if (store.has(id)) return 200;                     // at-least-once: already processed
  store.add(id, JSON.parse(rawBody));
  store.saveCursor(headers["x-triport-cursor"]);
  return 200;
}

import os, requests


API = f"https://triport.io/v1/wallet/watch/{os.environ['SUB_ID']}/events"
H = {"Authorization": f"Bearer {os.environ['TRIPORT_API_KEY']}"}
cursor, seen = load_cursor(), set()
while True:
    r = requests.get(API, params={"cursor": cursor, "limit": 1000}, headers=H, timeout=30)
    if r.status_code == 410:                 # cursor_expired: the gap cannot be recovered
        cursor = r.json()["oldest_cursor"]
        continue
    page = r.json()
    for ev in page["events"]:
        if ev["event_id"] not in seen:
            seen.add(ev["event_id"])
            handle(ev)
    cursor = page["next_cursor"]
    if not page["has_more"]:
        break
save_cursor(cursor)

curl -s "https://triport.io/v1/wallet/watch/coverage" -H "Authorization: Bearer $TRIPORT_API_KEY" \
  | jq '.chains[] | {chain, internal_native: .levels.internal_native, lag: .scanner.lag}'