Real-Time Solana Token Tracking with WebSocket and Next.js

import { Connection, PublicKey } from "@solana/web3.js";
 
const connection = new Connection("wss://api.devnet.solana.com", "confirmed");
 
const tokenAccount = new PublicKey("TOKEN_ACCOUNT_ADDRESS");
 
const subId = connection.onAccountChange(tokenAccount, (accountInfo) => {
  console.log("Account updated:", {
    lamports: accountInfo.lamports,
    dataLength: accountInfo.data.length,
    owner: accountInfo.

const programId = new PublicKey("PROGRAM_ID");
 
connection.onLogs(programId, (logs) => {
  console.log("Transaction:", logs.signature);
  console.log("Logs:", logs.logs);
 
  if (logs.logs.some(log => log.includes("Transfer"))) {
    console.log("Token transfer detected!");
  }
});

npm install @nestjs/websockets @nestjs/platform-socket.io socket.io

// src/gateway/token.gateway.ts
import {
  WebSocketGateway,
  WebSocketServer,
  SubscribeMessage,
  MessageBody,
  ConnectedSocket,
} from "@nestjs/websockets";
import { Server, Socket } from "socket.io";
import { Logger } from "@nestjs/common";
import { Connection, PublicKey } from "@solana/web3.js";
 
@WebSocketGateway({
  cors: { origin: "*" },
  namespace: "/tokens",
})
export class TokenGateway

// src/services/price.service.ts
import { Injectable, Logger } from "@nestjs/common";
import { Connection, PublicKey } from "@solana/web3.js";
import { AccountLayout } from "@solana/spl-token";
 
@Injectable()
export class PriceService {
  private readonly logger = new Logger(PriceService.name);
 
  constructor(private readonly connection: Connection) {}
 
  async getPoolReserves(poolAddress: string) {
    const accountInfo

npm install socket.io-client

// hooks/useSolanaSocket.ts
"use client";
import { useEffect, useState, useCallback, useRef } from "react";
import { io, Socket } from "socket.io-client";
 
interface AccountUpdate {
  address: string;
  lamports: number;
  data: string;
  timestamp: number;
}
 
export function useSolanaSocket(address: string | null) {
  const [data, setData] = useState

"use client";
import { useSolanaSocket } from "@/hooks/useSolanaSocket";
import { LAMPORTS_PER_SOL } from "@solana/web3.js";
 
export function LiveBalance({ address }: { address: string }) {
  const { data, connected } = useSolanaSocket(address);
 
  const balance = data ? data.lamports / LAMPORTS_PER_SOL : null;
 
  return (
    <div className="flex items-center gap-2">
      <span className=

// Reconnection with exponential backoff
socket.on("disconnect", (reason) => {
  if (reason === "io server disconnect") {
    socket.connect(); // Reconnect immediately
  }
  // Otherwise, socket.io auto-reconnects with backoff
});
 
// Re-subscribe after reconnection
socket.on("connect", () => {
  for (const address of watchedAddresses) {
    socket.emit("subscribe:account", { address });
  }
});

import { throttle } from "lodash";
 
const emitThrottled = throttle((address: string, data: any) => {
  this.server.to(address).emit("account:update", data);
}, 500); // Max 2 updates per second per account