Messages
{
"type": "join",
"room": "liquidity:pool:9d9mb8kooFfaD3SctgZtkxQypkshx6ezhbKio89ixyy2"
}{
"type": "leave",
"room": "liquidity:pool:9d9mb8kooFfaD3SctgZtkxQypkshx6ezhbKio89ixyy2"
}{
"type": "message",
"room": "liquidity:pool:9d9mb8kooFfaD3SctgZtkxQypkshx6ezhbKio89ixyy2",
"data": [
{
"tx": "5V4apVkgHf49J5acYPiuh5rB89EGsF8ocSysgnD9vFfZsTtDamhN3MFDKJSq7Dn7Z6Y5XhjghuVYuvvYWnSFpnvW",
"type": "add_liquidity",
"program": "pumpfun-amm",
"programId": "pAMMBay6oceH9fJKBRHGP5D4bD4sWpmSwMn52FMfXEA",
"instruction": "deposit",
"pool": "9d9mb8kooFfaD3SctgZtkxQypkshx6ezhbKio89ixyy2",
"wallet": "F7R61te4Ac8xZ4pfkJUdF6iaaHy9tnM8nVRUPv8H8EMi",
"time": 1789722000000,
"slot": 370000000,
"amountBasis": "transfer",
"tokens": [
{
"address": "6p6xgHyF7AeE6TZkSmFsko444wqoP15icUSqi2jfGiPN",
"amount": "123.000001",
"amountRaw": "123000001",
"decimals": 6
},
{
"address": "So11111111111111111111111111111111111111112",
"amount": "9.000000001",
"amountRaw": "9000000001",
"decimals": 9
}
]
}
]
}Liquidity
Solana 交易池流动性变化 WebSocket 流
通过 Datastream WebSocket 接收单个 Solana 交易池内所有代币的流动性增减。房间：liquidity:pool:。
WSS
/
指定池中涉及各代币的流动性操作。 房间：
liquidity:pool:{pool}。添加 :enriched 获取当前钱包身份。事件处于 processed 状态，尚未确认；重叠房间可能重复发送同一操作。
SDK Example
import { Datastream } from '@solana-tracker/data-api';
const dataStream = new Datastream({
wsUrl: 'wss://datastream.solanatracker.io/YOUR_API_KEY',
});
dataStream.on('error', console.error);
await dataStream.connect();
const sub = dataStream.subscribe.liquidity.pool('9d9mb8kooFfaD3SctgZtkxQypkshx6ezhbKio89ixyy2', { enriched: true }).on((data) => {
console.log(data);
});
// sub.unsubscribe();
Messages
{
"type": "join",
"room": "liquidity:pool:9d9mb8kooFfaD3SctgZtkxQypkshx6ezhbKio89ixyy2"
}{
"type": "leave",
"room": "liquidity:pool:9d9mb8kooFfaD3SctgZtkxQypkshx6ezhbKio89ixyy2"
}{
"type": "message",
"room": "liquidity:pool:9d9mb8kooFfaD3SctgZtkxQypkshx6ezhbKio89ixyy2",
"data": [
{
"tx": "5V4apVkgHf49J5acYPiuh5rB89EGsF8ocSysgnD9vFfZsTtDamhN3MFDKJSq7Dn7Z6Y5XhjghuVYuvvYWnSFpnvW",
"type": "add_liquidity",
"program": "pumpfun-amm",
"programId": "pAMMBay6oceH9fJKBRHGP5D4bD4sWpmSwMn52FMfXEA",
"instruction": "deposit",
"pool": "9d9mb8kooFfaD3SctgZtkxQypkshx6ezhbKio89ixyy2",
"wallet": "F7R61te4Ac8xZ4pfkJUdF6iaaHy9tnM8nVRUPv8H8EMi",
"time": 1789722000000,
"slot": 370000000,
"amountBasis": "transfer",
"tokens": [
{
"address": "6p6xgHyF7AeE6TZkSmFsko444wqoP15icUSqi2jfGiPN",
"amount": "123.000001",
"amountRaw": "123000001",
"decimals": 6
},
{
"address": "So11111111111111111111111111111111111111112",
"amount": "9.000000001",
"amountRaw": "9000000001",
"decimals": 9
}
]
}
]
}apiKey
type:httpApiKey
API key for authentication. Include your Datastream key in the connection URL: wss://datastream.solanatracker.io/{DATASTREAM_KEY}
Subscribe to pool liquidity
type:object
Unsubscribe from pool liquidity
type:object
Pool liquidity notification
type:object
此页面对您有帮助吗？