Stats
Actions
Tags
From ave-cloud-skill
Streams real-time on-chain data including swaps, liquidity events, klines, and prices via AVE WebSocket API. Provides Python REPL, CLI watchers, and Docker daemon for chains like ETH, BSC, Solana. Requires pro plan.
How this skill is triggered — by the user, by Claude, or both
Slash command
/ave-cloud-skill:data-wssThe summary Claude sees in its skill listing — used to decide when to auto-load this skill
Live on-chain data streams via the AVE Cloud WebSocket API. For shared connection discipline and response rules, see [operator-playbook.md](../../references/operator-playbook.md).
Live on-chain data streams via the AVE Cloud WebSocket API. For shared connection discipline and response rules, see operator-playbook.md.
export AVE_API_KEY="your_api_key_here"
export API_PLAN="pro"
pip install -r scripts/requirements.txt
All WebSocket streams require API_PLAN=pro (20 TPS). Connection discipline matters more than TPS: keep one REPL or server connection open, switch topics with subscribe / unsubscribe, and avoid stacking parallel sockets unless there is a hard need.
All Data REST chains are supported for streaming, including bsc, eth, base, solana, tron, polygon, arbitrum.
Use one interactive connection for multi-topic monitoring.
python scripts/ave_data_wss.py wss-repl
| Command | Description |
|---|---|
subscribe price <addr-chain> [...] | Stream live price changes for one or more tokens |
| `subscribe tx [tx | multi_tx |
subscribe kline <pair> <chain> [interval] | Stream live candle updates for a pair |
unsubscribe | Cancel the current subscription |
quit | Close the connection and exit |
Stream live swap or liquidity events for a pair.
python scripts/ave_data_wss.py watch-tx --address <pair_address> --chain <chain> [--topic tx]
Stream live kline updates for a pair.
python scripts/ave_data_wss.py watch-kline --address <pair_address> --chain <chain> [--interval k60] [--format raw|markdown]
Stream live price changes for one or more tokens.
python scripts/ave_data_wss.py watch-price --tokens <addr1>-<chain1> [<addr2>-<chain2> ...]
Start or stop the reusable Docker-backed connection.
python scripts/ave_data_wss.py start-server
python scripts/ave_data_wss.py stop-server
python scripts/ave_data_wss.py serve
Open one connection, watch swaps, then switch to price without opening a second socket.
python scripts/ave_data_wss.py wss-repl
# at the prompt:
subscribe tx <pair_address> bsc
unsubscribe
subscribe price <token_address>-bsc
quit
Use shared references for operator rules, recovery patterns, response style, and the full streaming API surface.
npx claudepluginhub avecloud/ave-cloud-skill --plugin ave-cloud-skillManages real-time DEX WebSocket sessions via onchainos ws CLI and custom scripts. Covers 9 channels for price, candles, trades, signals, tracker, and meme scanning.
Executes on-chain DEX swaps, wallet portfolio queries, gas estimation, and transaction broadcasting on EVM/Solana chains via OKX Web3 API. Use for token swaps, balance checks, or tx broadcast on Ethereum, Solana, Base, BSC, Arbitrum, Polygon, etc.
Streams real-time Kraken spot/futures data via WebSocket: tickers, trades, order books, OHLC, balances, executions. Handles authenticated feeds and low-latency order mutations via CLI.