On-Chain Whale Alerts

export interface OnChainWhaleAlerts {
    asset:  Asset;
    amount: number;
    usd:    number;
    from:   From;
    to:     To;
    ts:     number;
}

export enum Asset {
    Btc = "BTC",
    Eth = "ETH",
    Sol = "SOL",
    Usdt = "USDT",
}

export enum From {
    Binance = "binance",
    Coinbase = "coinbase",
    Kraken = "kraken",
    Unknown = "unknown",
}

export enum To {
    Bybit = "bybit",
    ColdWallet = "cold-wallet",
    Okx = "okx",
    Unknown = "unknown",
}


import { OmniClient } from "omnistream-sdk";

const client = new OmniClient({ token: process.env.OMNI_ACCESS_TOKEN! });

// Fully typed: `data` is inferred as OnChainWhaleAlerts.
const stream = await client.subscribe<OnChainWhaleAlerts>("whale-alerts");
stream.on("data", (data) => {
  console.log(data);
});