@motosan-whale/solana-ws

Layer 1: WebSocket streaming for Solana whale tracking.

Part of the motosan-whale SDK — agent-first whale tracking tools.

Implements the StreamingSource interface from @motosan-whale/core.

Install

pnpm add @motosan-whale/solana-ws

Usage

import { SolanaWsClient } from '@motosan-whale/solana-ws'

const ws = new SolanaWsClient({
  wsUrl: 'wss://api.mainnet-beta.solana.com',
  commitment: 'confirmed',
})

// Watch a specific address
const { data: unsub } = await ws.watchAddress(
  'So11...1111',
  'solana',
  (tx) => console.log('address tx', tx),
)

// Watch large transactions across the network
const { data: unsubLarge } = await ws.watchLargeTxs(
  { minAmountUsd: 100_000 },
  (tx) => console.log('whale tx', tx),
)

// Clean up
unsub()
unsubLarge()
ws.dispose()

Config

SolanaWsConfig options:

| Option | Type | Required | Description | |--------|------|----------|-------------| | wsUrl | string | Yes | WebSocket endpoint URL (e.g. wss://api.mainnet-beta.solana.com) | | rpcUrl | string | No | JSON-RPC endpoint URL; used to derive wsUrl if not provided | | commitment | "processed" \| "confirmed" \| "finalized" | No | Default commitment level for subscriptions. Defaults to "confirmed" |

API

| Method | Description | |--------|-------------| | watchAddress(address, chain, callback) | Subscribe to new transactions for a specific address | | watchLargeTxs(opts, callback) | Subscribe to large transactions across the network | | dispose() | Tear down all subscriptions and release resources |

License

MIT