LaserStream Historical Replay: Backfill Missing Data

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

const subscriptionRequest: SubscribeRequest = {
  transactions: {
    client: {
      accountInclude: ['TokenkegQfeZyiNwAJbNbGKPFXCWuBvf9Ss623VQ5DA'],
      vote: false,
      failed: false
    }
  },
  commitment: CommitmentLevel.CONFIRMED,
  accounts: {},
  slots: {},
  blocks: {},
  blocksMeta: {},
  entry: {},
  accountsDataSlice: [],
  fromSlot: '224339000' // Start replay from this slot (must be within last 3000 slots)
};

const config: LaserstreamConfig = {
  apiKey: 'YOUR_API_KEY',
  endpoint: 'https://laserstream-mainnet-ewr.helius-rpc.com', // Choose your closest region
};

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

const ws = new WebSocket('wss://laserstream-mainnet-ewr.helius-rpc.com/ws');

const subscribeMessage = {
  jsonrpc: '2.0',
  id: 1,
  method: 'transactionSubscribe',
  params: {
    transactions: {
      client: {
        accountInclude: ['6EF8rrecthR5Dkzon8Nwu78hRvfCKubJ14M5uBEwF6P'],
        vote: false,
        failed: false
      }
    },
    commitment: 'confirmed',
    fromSlot: '224339000' // Start replay from this slot (must be within last 3000 slots)
  }
};

ws.onopen = () => {
  ws.send(JSON.stringify(subscribeMessage));
};

ws.onmessage = (event) => {
  const data = JSON.parse(event.data);
  console.log('Received data:', data);
};