Solana Data Streaming Quickstart

Get your first real-time Solana data stream running in under 5 minutes. LaserStream gRPC, LaserStream WebSocket, and Webhooks setup guide.

Quick Setup

Get streaming Solana data in minutes with working code examples. Choose your approach based on your needs (ordered fastest to slowest):

Method	Best For	Plan Required
[Preconfirmations]	propAMMs, snipers, copy traders, liquidation bots — earliest transaction signal	Professional+
Shred Delivery	propAMMs, snipers, copy traders, liquidation bots, arbitrage — pre-execution data	All plans (paid add-on)
LaserStream gRPC	Mission-critical, backend services	All plans (Devnet), Business+ (Mainnet)
LaserStream WSS	Most apps, real-time UIs, broad compatibility	Free+ (Helius extensions: Developer+)
Webhooks	Server notifications, event-driven apps	Free+

Need raw shreds? Subscribe from the Shreds tab in your Helius Dashboard. See How to Subscribe to Raw Shreds for setup steps.

Option 1: LaserStream gRPC

Most reliable option with 24-hour historical replay and multi-node failover. Best for mission-critical backends and indexers.

npm install helius-laserstream

import {
  subscribe,
  CommitmentLevel,
  LaserstreamConfig,
  SubscribeRequest,
} from "helius-laserstream";

async function main() {
  const subscriptionRequest: SubscribeRequest = {
    transactions: {
      "token-filter": {
        // user-defined label for this filter
        accountInclude: ["TokenkegQfeZyiNwAJbNbGKPFXCWuBvf9Ss623VQ5DA"],
        accountExclude: [],
        accountRequired: [],
        vote: false,
        failed: false,
      },
    },
    commitment: CommitmentLevel.CONFIRMED,
    accounts: {},
    slots: {},
    transactionsStatus: {},
    blocks: {},
    blocksMeta: {},
    entry: {},
    accountsDataSlice: [],
  };

  const config: LaserstreamConfig = {
    apiKey: "YOUR_API_KEY",
    endpoint: "https://laserstream-mainnet-ewr.helius-rpc.com",
  };

  await subscribe(
    config,
    subscriptionRequest,
    async (data) => {
      console.log(data);
    },
    async (error) => {
      console.error(error);
    },
  );
}

main().catch(console.error);

LaserStream Guide

Complete LaserStream documentation with historical replay

Get started

Get your LaserStream gRPC token and endpoint in your Helius dashboard

Option 2: LaserStream WebSocket

LaserStream WebSocket serves the standard Solana subscription methods and Helius extensions like transactionSubscribe on a single unified endpoint. Perfect for browser/UI clients and broad ecosystem compatibility.

const WebSocket = require("ws");

const ws = new WebSocket("wss://mainnet.helius-rpc.com/?api-key=YOUR_API_KEY");

ws.on("open", () => {
  console.log("WebSocket connected");

  // Helius extension: transactionSubscribe with rich filtering
  ws.send(
    JSON.stringify({
      jsonrpc: "2.0",
      id: 1,
      method: "transactionSubscribe",
      params: [
        {
          accountInclude: ["TokenkegQfeZyiNwAJbNbGKPFXCWuBvf9Ss623VQ5DA"],
          vote: false,
          failed: false,
        },
        {
          commitment: "confirmed",
          encoding: "jsonParsed",
          transactionDetails: "full",
        },
      ],
    }),
  );

  // Keep connection alive
  setInterval(() => ws.ping(), 30000);
});

ws.on("message", (data) => {
  const message = JSON.parse(data);
  console.log("Transaction:", message);
});

Replace YOUR_API_KEY with your key from dashboard.helius.dev.

LaserStream WebSocket Overview

All subscription methods (standard Solana + Helius extensions) with parameter reference and examples

Option 3: Webhooks

For server-side applications that need event notifications without holding a persistent connection.

# Create a webhook
curl -X POST "https://mainnet.helius-rpc.com/v0/webhooks" \
  -H "Authorization: Bearer YOUR_API_KEY" \
  -H "Content-Type: application/json" \
  -d '{
    "webhookURL": "https://your-server.com/webhook",
    "transactionTypes": ["Any"],
    "accountAddresses": ["YOUR_ACCOUNT_ADDRESS"],
    "webhookType": "enhanced"
  }'

// Handle webhook events (Express.js example)
app.post("/webhook", (req, res) => {
  req.body.forEach((event) => {
    console.log("Blockchain event:", event);
  });
  res.status(200).send("OK");
});

Webhooks Guide

Complete webhook setup and event handling

Common Use Cases

Monitor Token Transfers

// Subscribe to Token Program activity
method: "programSubscribe",
params: ["TokenkegQfeZyiNwAJbNbGKPFXCWuBvf9Ss623VQ5DA", {...}]

Track Pump.fun trades

// Subscribe to Pump.fun program transactions
method: "transactionSubscribe",
params: [
  {
    accountInclude: ["6EF8rrecthR5Dkzon8Nwu78hRvfCKubJ14M5uBEwF6P"],
    vote: false,
    failed: false
  },
  { commitment: "confirmed" }
]

Watch Wallet Activity

// Monitor specific wallet
method: "accountSubscribe",
params: ["WALLET_ADDRESS", {...}]

Next Steps

Streaming Overview

Learn about all streaming options and when to use each

API Reference

Complete method documentation and parameters

Need help? Join our Discord or check support docs.