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.
npx claudepluginhub avecloud/ave-cloud-skill --plugin ave-cloud-skillThis skill uses the workspace's default tool permissions.
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).
Manages WebSocket sessions for real-time DEX on-chain data using onchainos CLI (start/poll/stop/list/channels/channel-info) or custom Python/Node/Rust scripts. Covers 9 channels: price, candles, trades, price-info, signals, tracker, meme scanning.
Handles on-chain DEX token swaps, wallet portfolio/balance queries, gas estimation, transaction broadcasting, and token info on EVM/Solana chains using OKX Web3 DEX API node scripts.
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.
Share bugs, ideas, or general feedback.
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.