Messages
{
"type": "join",
"room": "liquidity:6p6xgHyF7AeE6TZkSmFsko444wqoP15icUSqi2jfGiPN:9d9mb8kooFfaD3SctgZtkxQypkshx6ezhbKio89ixyy2:F7R61te4Ac8xZ4pfkJUdF6iaaHy9tnM8nVRUPv8H8EMi"
}{
"type": "leave",
"room": "liquidity:6p6xgHyF7AeE6TZkSmFsko444wqoP15icUSqi2jfGiPN:9d9mb8kooFfaD3SctgZtkxQypkshx6ezhbKio89ixyy2:F7R61te4Ac8xZ4pfkJUdF6iaaHy9tnM8nVRUPv8H8EMi"
}{
"type": "message",
"room": "liquidity:6p6xgHyF7AeE6TZkSmFsko444wqoP15icUSqi2jfGiPN:9d9mb8kooFfaD3SctgZtkxQypkshx6ezhbKio89ixyy2:F7R61te4Ac8xZ4pfkJUdF6iaaHy9tnM8nVRUPv8H8EMi",
"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
Stream a wallet's liquidity in one pool
Stream one wallet’s liquidity adds and removes for a Solana token in one pool over Datastream WebSocket. Room: liquidity:::.
WSS
/
Liquidity actions by one wallet for a token in one pool. Room:
liquidity:{mint}:{pool}:{wallet}. Append :enriched for current wallet identity. Events are provisional at processed commitment; overlapping rooms can deliver the same action more than once.
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.tokenPoolWallet('6p6xgHyF7AeE6TZkSmFsko444wqoP15icUSqi2jfGiPN', '9d9mb8kooFfaD3SctgZtkxQypkshx6ezhbKio89ixyy2', 'FbMxP3GVq8TQ36nbYgx4NP9iygMpwAwFWJwW81ioCiSF', { enriched: true }).on((data) => {
console.log(data);
});
// sub.unsubscribe();
Messages
{
"type": "join",
"room": "liquidity:6p6xgHyF7AeE6TZkSmFsko444wqoP15icUSqi2jfGiPN:9d9mb8kooFfaD3SctgZtkxQypkshx6ezhbKio89ixyy2:F7R61te4Ac8xZ4pfkJUdF6iaaHy9tnM8nVRUPv8H8EMi"
}{
"type": "leave",
"room": "liquidity:6p6xgHyF7AeE6TZkSmFsko444wqoP15icUSqi2jfGiPN:9d9mb8kooFfaD3SctgZtkxQypkshx6ezhbKio89ixyy2:F7R61te4Ac8xZ4pfkJUdF6iaaHy9tnM8nVRUPv8H8EMi"
}{
"type": "message",
"room": "liquidity:6p6xgHyF7AeE6TZkSmFsko444wqoP15icUSqi2jfGiPN:9d9mb8kooFfaD3SctgZtkxQypkshx6ezhbKio89ixyy2:F7R61te4Ac8xZ4pfkJUdF6iaaHy9tnM8nVRUPv8H8EMi",
"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, pool and wallet liquidity
type:object
Unsubscribe from token, pool and wallet liquidity
type:object
Token, pool and wallet liquidity notification
type:object
Was this page helpful?