Recipe: wallet watch

curl -s "https://farbeamlabs.com/api/v1/wallets/0x28C6c06298d514Db089934071355E5743bf21d60/activity?chain=ethereum" \
  | jq '.data | {blocks_scanned, from_block, to_block, items: (.items | length)}'

// watch.mjs: run with node watch.mjs
const ADDRESS = "0x28C6c06298d514Db089934071355E5743bf21d60";
const CHAIN = "ethereum";
const headers = process.env.FARBEAM_KEY ? { Authorization: `Bearer ${process.env.FARBEAM_KEY}` } : {};
const seen = new Set();
let first = true;

async function tick() {
  const res = await fetch(`https://farbeamlabs.com/api/v1/wallets/${ADDRESS}/activity?chain=${CHAIN}`, { headers });
  const { data, error } = await res.json();
  if (error) {
    console.error(error.code, error.message);
    return;
  }
  for (const item of data.items.slice().reverse()) {
    const id = `${item.tx}:${item.token_address}:${item.from}:${item.to}:${item.amount}`;
    if (seen.has(id)) continue;
    seen.add(id);
    if (!first) console.log(item.direction, item.amount, item.token, item.from_label ?? item.from, "->", item.to_label ?? item.to, item.tx);
  }
  first = false;
  console.log(`checked blocks ${data.from_block} to ${data.to_block}, ${data.blocks_scanned} blocks`);
}

await tick();
setInterval(() => tick().catch((err) => console.error(err.message)), 60000);

# watch.py: run with python3 watch.py
import os, time
import requests

ADDRESS = "0x28C6c06298d514Db089934071355E5743bf21d60"
CHAIN = "ethereum"
key = os.environ.get("FARBEAM_KEY")
headers = {"Authorization": f"Bearer {key}"} if key else {}
seen, first = set(), True

while True:
    try:
        body = requests.get(
            f"https://farbeamlabs.com/api/v1/wallets/{ADDRESS}/activity",
            params={"chain": CHAIN},
            headers=headers,
            timeout=30,
        ).json()
        if "error" in body:
            print(body["error"]["code"], body["error"]["message"])
        else:
            data = body["data"]
            for item in reversed(data["items"]):
                marker = (item["tx"], item["token_address"], item["from"], item["to"], item["amount"])
                if marker in seen:
                    continue
                seen.add(marker)
                if not first:
                    print(item["direction"], item["amount"], item["token"], item["tx"])
            first = False
            print("checked", data["from_block"], data["to_block"], data["blocks_scanned"])
    except requests.RequestException as err:
        print("error", err)
    time.sleep(60)