Messages
{
"type": "join",
"room": "liquidity:6p6xgHyF7AeE6TZkSmFsko444wqoP15icUSqi2jfGiPN"
}{
"type": "leave",
"room": "liquidity:6p6xgHyF7AeE6TZkSmFsko444wqoP15icUSqi2jfGiPN"
}{
"type": "message",
"room": "liquidity:6p6xgHyF7AeE6TZkSmFsko444wqoP15icUSqi2jfGiPN",
"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:。
WSS
/
涉及此代币的所有流动性操作。 房间：
liquidity:{mint}。添加 :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.token('6p6xgHyF7AeE6TZkSmFsko444wqoP15icUSqi2jfGiPN', { enriched: true }).on((data) => {
console.log(data);
});
// sub.unsubscribe();
Messages
{
"type": "join",
"room": "liquidity:6p6xgHyF7AeE6TZkSmFsko444wqoP15icUSqi2jfGiPN"
}{
"type": "leave",
"room": "liquidity:6p6xgHyF7AeE6TZkSmFsko444wqoP15icUSqi2jfGiPN"
}{
"type": "message",
"room": "liquidity:6p6xgHyF7AeE6TZkSmFsko444wqoP15icUSqi2jfGiPN",
"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 token liquidity
type:object
Unsubscribe from token liquidity
type:object
Token liquidity notification
type:object
此页面对您有帮助吗？