enhanced-notifications-example.ts

import {
  address,
  createDefaultRpcSubscriptionsTransport,
  createSubscriptionRpc,
} from '@solana/web3.js';
import { DEFAULT_RPC_CONFIG } from '@solana/rpc';

import { createSolanaRpcEnhancedSubscriptionsApi } from './enhanced-notifications';

// -----------------------------------------------------------------------------

(async (rpcSubscriptionsUrl: string) => {
  const api = createSolanaRpcEnhancedSubscriptionsApi(
    DEFAULT_RPC_CONFIG,
  );
  const transport = createDefaultRpcSubscriptionsTransport({ url: rpcSubscriptionsUrl });
  const rpcSubscriptions = createSubscriptionRpc({ api, transport });

  const abortController = new AbortController();

  const transactionNotifications = await rpcSubscriptions
    .transactionNotifications({
      accountInclude: [address('5Q544fKrFoe6tsEbD7S8EmxGTJYAKtTVhAW5Q5pge4j1')],
    }, {
      commitment: 'processed',
      showRewards: false,
      encoding: 'jsonParsed',
      transactionDetails: 'full',
      maxSupportedTransactionVersion: 0,
    })
    .subscribe({ abortSignal: abortController.signal });

  for await (const notification of transactionNotifications) {
    console.log(notification);
  }
})(process.env.SOL_ATLAS_WS_URL || 'wss://atlas-mainnet.helius-rpc.com/?api-key=00000000-0000-0000-0000-000000000000');