Pagination

import { Bloklake } from "@bloklake/client";

const bl = new Bloklake({ chain: "eth" });
const TRANSFER = "0xddf252ad1be2c89b69c2b068fc378daa952ba7f163c4a11628f55a4df523b3ef";

let total = 0;
for await (const page of bl.paginate({
  fromBlock: 19426000,
  toBlock: 19427499,
  logs: [{ address: ["0xa0b86991c6218b36c1d19d4a2e9eb0ce3606eb48"], topic0: [TRANSFER] }],
  fields: { log: ["blockNumber", "logIndex", "topic1", "topic2", "data"] },
})) {
  total += page.logs.length; // store(page.logs)
  console.log(`blocks ${page.meta.fromBlock}..${page.meta.toBlock}: ${page.logs.length} logs`);
}
console.log(total, "transfers");

from bloklake import Bloklake

bl = Bloklake(chain="eth")
TRANSFER = "0xddf252ad1be2c89b69c2b068fc378daa952ba7f163c4a11628f55a4df523b3ef"

total = 0
for page in bl.paginate({
    "from_block": 19426000,
    "to_block": 19427499,
    "logs": [{"address": ["0xa0b86991c6218b36c1d19d4a2e9eb0ce3606eb48"], "topic0": [TRANSFER]}],
    "fields": {"log": ["block_number", "log_index", "topic1", "topic2", "data"]},
}):
    total += len(page.logs)  # store(page.logs)
    print(f"blocks {page.meta.from_block}..{page.meta.to_block}: {len(page.logs)} logs")
print(total, "transfers")

use bloklake::{Client, LogField, LogFilter, Query};

const TRANSFER: &str = "0xddf252ad1be2c89b69c2b068fc378daa952ba7f163c4a11628f55a4df523b3ef";

#[tokio::main]
async fn main() -> bloklake::Result<()> {
    let client = Client::builder().chain("eth").build()?;
    let query = Query::new()
        .from_block(19426000)
        .to_block(19427499)
        .log(LogFilter::new().address(["0xa0b86991c6218b36c1d19d4a2e9eb0ce3606eb48"]).topic0([TRANSFER]))
        .log_fields([LogField::BlockNumber, LogField::LogIndex, LogField::Topic1, LogField::Topic2, LogField::Data]);

    let mut total = 0;
    let mut pages = client.paginate(&query);
    while let Some(page) = pages.next().await? {
        total += page.logs.len(); // store(&page.logs)
        let m = page.meta.unwrap();
        println!("blocks {}..{}: {} logs", m.from_block, m.to_block, page.logs.len());
    }
    println!("{total} transfers");
    Ok(())
}

def read_range(body: dict, start: int, end: int):
    frm = start
    while frm <= end:
        tables, meta = query({**body, "fromBlock": frm, "toBlock": end})
        yield tables
        frm = int(meta["bl.next_block"])

async function* readRange(body: object, start: number, end: number) {
  let from = start;
  while (from <= end) {
    const { tables, meta } = await query({ ...body, fromBlock: from, toBlock: end });
    yield tables;
    from = Number(meta.get("bl.next_block"));
  }
}

from=19426000; end=19427499
while [ "$from" -le "$end" ]; do
  page=$(curl -s https://api.bloklake.com/v1/chains/eth/query/json \
    -H "Authorization: Bearer $BLOKLAKE_API_KEY" -H 'content-type: application/json' \
    -d "{\"fromBlock\": $from, \"toBlock\": $end, \"logs\": [{\"address\": [\"0xa0b86991c6218b36c1d19d4a2e9eb0ce3606eb48\"]}], \"fields\": {\"log\": {\"blockNumber\": true}}}")
  echo "$page" | jq -c '.logs[]'
  from=$(echo "$page" | jq .next_block)
done