> ## Documentation Index
> Fetch the complete documentation index at: https://www.helius.dev/docs/llms.txt
> Use this file to discover all available pages before exploring further.
# Cara Mengalirkan Data Pump AMM Solana
> Pelajari cara mengalirkan data langsung Pump AMM Solana menggunakan LaserStream WebSocket. Pemantauan berbasis log tersedia di semua paket dengan penyambungan ulang otomatis.
## Menggunakan LaserStream WebSocket
[LaserStream WebSocket](/docs/id/rpc/websocket) menyediakan integrasi WebSocket yang sederhana dan tersedia di semua paket Helius, sehingga menjadi pilihan praktis bagi pengembang. Contoh ini menggunakan metode `logsSubscribe` Solana, sehingga Anda hanya menerima pesan log.
LaserStream WebSocket hingga 200 ms lebih cepat daripada implementasi WebSocket standar berbasis Agave RPC.
### Cara kerjanya
Hubungkan ke [titik akhir LaserStream WebSocket](https://www.helius.dev/docs/api-reference/endpoints), berlangganan log yang menyebut [program Pump AMM](https://orbmarkets.io/address/pAMMBay6oceH9fJKBRHGP5D4bD4sWpmSwMn52FMfXEA/history), lalu proses data log yang masuk.
Contoh berikut menyertakan logika penyambungan ulang otomatis dengan jeda eksponensial.
## Persyaratan
- Node.js ≥ 18 (diuji dengan v20)
- TypeScript ≥ 5 jika Anda berencana menjalankan sampel
.ts dengan ts‑node
- Paket Helius apa pun – berfungsi di semua tingkatan paket
- Variabel lingkungan bernama
HELIUS\_API\_KEY yang menyimpan kunci API Anda
Instal dependensi secara global: npm i -g typescript ts‑node
## Implementasi
```bash theme={"system"}
npm install ws
```
Buat file bernama `standard-ws-pump.ts` dengan kode berikut:
```ts theme={"system"}
// standard-ws-pump.ts
import WebSocket from 'ws';
// Configuration
const MAX_RETRIES = 5;
const INITIAL_RETRY_DELAY = 1000; // 1 second
let retryCount = 0;
let retryTimeout: NodeJS.Timeout | null = null;
let subscriptionId: number | null = null;
// Create a WebSocket connection
let ws: WebSocket;
function connect() {
ws = new WebSocket(`wss://mainnet.helius-rpc.com/?api-key=${process.env.HELIUS_API_KEY}`);
// Function to send a request to the WebSocket server
function sendRequest(ws: WebSocket): void {
const request = {
"jsonrpc": "2.0",
"id": 1,
"method": "logsSubscribe",
"params": [
{
"mentions": ["pAMMBay6oceH9fJKBRHGP5D4bD4sWpmSwMn52FMfXEA"]
}
]
};
console.log('Sending subscription request:', JSON.stringify(request, null, 2));
ws.send(JSON.stringify(request));
}
// Function to send a ping to the WebSocket server
function startPing(ws: WebSocket): void {
setInterval(() => {
if (ws.readyState === WebSocket.OPEN) {
ws.ping();
console.log('Ping sent');
}
}, 30000); // Ping every 30 seconds
}
// Define WebSocket event handlers
ws.on('open', function open() {
console.log('WebSocket is open');
retryCount = 0; // Reset retry count on successful connection
sendRequest(ws); // Send a request once the WebSocket is open
startPing(ws); // Start sending pings
});
ws.on('message', function incoming(data: WebSocket.Data) {
const messageStr = data.toString('utf8');
try {
const messageObj = JSON.parse(messageStr);
// Handle subscription confirmation
if (messageObj.result && typeof messageObj.result === 'number') {
subscriptionId = messageObj.result;
console.log('Successfully subscribed with ID:', subscriptionId);
return;
}
// Handle actual log data
if (messageObj.params && messageObj.params.result) {
const logData = messageObj.params.result;
console.log('Received log data:', JSON.stringify(logData, null, 2));
// Extract the transaction signature if available
if (logData.signature) {
console.log('Transaction signature:', logData.signature);
// You can call getTransaction with this signature to get the full transaction details
}
} else {
console.log('Received message:', JSON.stringify(messageObj, null, 2));
}
} catch (e) {
console.error('Failed to parse JSON:', e);
}
});
ws.on('error', function error(err: Error) {
console.error('WebSocket error:', err);
});
ws.on('close', function close() {
console.log('WebSocket is closed');
if (subscriptionId) {
console.log('Last subscription ID was:', subscriptionId);
}
reconnect();
});
}
function reconnect() {
if (retryCount >= MAX_RETRIES) {
console.error('Max retry attempts reached. Please check your connection and try again.');
return;
}
const delay = INITIAL_RETRY_DELAY * Math.pow(2, retryCount);
console.log(`Attempting to reconnect in ${delay/1000} seconds... (Attempt ${retryCount + 1}/${MAX_RETRIES})`);
retryTimeout = setTimeout(() => {
retryCount++;
connect();
}, delay);
}
// Start the initial connection
connect();
// Cleanup function
process.on('SIGINT', () => {
if (retryTimeout) {
clearTimeout(retryTimeout);
}
if (ws) {
ws.close();
}
process.exit();
});
```
Tambahkan kunci API Helius Anda sebagai variabel lingkungan:
```bash theme={"system"}
export HELIUS_API_KEY=your-helius-api-key
```
Ganti `your-helius-api-key` dengan kunci API Helius Anda yang sebenarnya dari dasbor.
Jika Anda belum memiliki kunci API, [daftar](https://dashboard.helius.dev/signup) atau minta agen Anda membuatnya secara terprogram dengan [Helius CLI](/docs/id/agents/cli).
Jalankan skrip untuk mulai mengalirkan data Pump AMM:
```bash theme={"system"}
npx ts-node standard-ws-pump.ts
```
Anda akan menerima pesan log yang menyebut program Pump AMM. Untuk mengambil transaksi lengkap, panggil [`getTransaction`](/docs/id/api-reference/rpc/http/gettransaction) dengan tanda tangan dari entri log.
## Manfaat utama
* **Akses universal** - Tersedia di semua paket Helius, termasuk tingkat gratis
* **Ringan** - Transfer data minimal karena hanya log yang dialirkan, bukan transaksi lengkap
* **Mudah diterapkan** - Menggunakan protokol WebSocket RPC Solana standar
* **Hambatan masuk rendah** - Ideal untuk pembuatan prototipe dan pemantauan awal
## Mendapatkan detail transaksi lengkap
Karena WebSocket Standar hanya menyediakan pesan log, Anda memerlukan langkah tambahan untuk mendapatkan data transaksi lengkap:
```ts theme={"system"}
// Example of how to fetch a full transaction from a log entry
async function fetchFullTransaction(signature: string) {
const response = await fetch(`https://mainnet.helius-rpc.com/?api-key=${process.env.HELIUS_API_KEY}`, {
method: 'POST',
headers: {
'Content-Type': 'application/json',
},
body: JSON.stringify({
jsonrpc: '2.0',
id: 'my-id',
method: 'getTransaction',
params: [
signature,
{
encoding: 'jsonParsed',
maxSupportedTransactionVersion: 1
}
]
})
});
const data = await response.json();
return data.result;
}
```
## Masalah umum dan solusinya
Pastikan HELIUS\_API\_KEY Anda sudah benar.
Pastikan alamat program Pump AMM sudah benar dan terdapat aktivitas pada program tersebut.
Terapkan logika penyambungan ulang yang lebih andal atau periksa stabilitas jaringan.