Commerce sur les transactions prétraitées

preprocessedSubscribe diffuse les transactions signées avant qu’elles n’atteignent le niveau d’engagement processed, décodées à partir des fragments à leur arrivée au validateur, sans infrastructure de défragmentation requise de votre côté. Ce guide construit un moniteur qui surveille un programme de trading avant exécution, déduplique le flux, reste sous la limite de contre-pression du serveur et rapproche les données traitées avant d’agir.

Transactions prétraitées sont disponibles sur tous les plans payants et coûtent 0.1 crédits par message, avec jusqu’à 10 connexions simultanées par clé API.

Ciblez l’abonnement sur votre objectif

Il n’y a pas de flux non filtré : accountInclude et accountRequired doivent nommer au moins un compte entre eux. Pour un moniteur de trading, incluez le programme contre lequel vous tradez et excluez le bruit que vous paieriez autrement :

{
  "jsonrpc": "2.0",
  "id": 1,
  "method": "preprocessedSubscribe",
  "params": {
    "accountInclude": ["JUP6LkbZbjS1jKKwapdHNy74zcZ3tLUZoi5QNyVTaV4"],
    "accountExclude": ["Vote111111111111111111111111111111111111111"],
    "accountRequired": []
  }
}

Les filtres se combinent avec AND, chaque liste accepte jusqu’à 5 000 adresses, et Helius résout les tables de recherche d’adresses côté serveur, de sorte qu’un compte chargé via un ALT correspond toujours. Pour surveiller les interactions d’un portefeuille spécifique avec le programme, placez les deux dans le champ accountRequired à la place.

Décoder les trames et dédupliquer par signature

Les notifications arrivent sous forme de trames binaires : un préfixe de 73 octets, puis la transaction sérialisée en bincode. La signature est dans le préfixe, vous pouvez donc dédupliquer sans décoder le corps. Le flux agrège plusieurs sources avant exécution, et la même transaction peut arriver plus d’une fois :

monitor.js

const WebSocket = require('ws');
const bs58module = require('bs58');
const bs58 = bs58module.default ?? bs58module;

const ws = new WebSocket('wss://beta.helius-rpc.com/?api-key=YOUR_API_KEY');
const seen = new Set(); // rotate or expire entries in production
const queue = [];       // decode off the receive path; see next step

ws.on('open', () => {
  ws.send(JSON.stringify({
    jsonrpc: '2.0',
    id: 1,
    method: 'preprocessedSubscribe',
    params: {
      accountInclude: ['JUP6LkbZbjS1jKKwapdHNy74zcZ3tLUZoi5QNyVTaV4'],
      accountExclude: ['Vote111111111111111111111111111111111111111'],
      accountRequired: []
    }
  }));
  setInterval(() => ws.ping(), 30_000);
});

ws.on('message', (data, isBinary) => {
  if (!isBinary) {
    const msg = JSON.parse(data.toString());
    if (msg.id === 1) console.log('Subscribed, ID:', msg.result);
    return;
  }

  // version (u8) | slot (u64 LE) | signature ([u8; 64]) | bincode(VersionedTransaction)
  const buf = Buffer.from(data);
  if (buf.readUInt8(0) !== 1) return; // unknown schema version; update your decoder
  const signature = bs58.encode(buf.subarray(9, 73));
  if (seen.has(signature)) return;
  seen.add(signature);

  queue.push({
    slot: buf.readBigUInt64LE(1),
    signature,
    txBytes: buf.subarray(73)
  });
});

ws.on('error', console.error);
ws.on('close', () => process.exit(1)); // supervisor restarts and resubscribes

Gardez la boucle de réception plus rapide que le flux

Helius ne tamponne pas indéfiniment pour les consommateurs lents : si plus de 4 000 messages s’accumulent côté serveur, la connexion est fermée. C’est pourquoi le gestionnaire ci-dessus ne lit que le préfixe de 73 octets et met en file d’attente. La désérialisation et la logique de stratégie s’exécutent dans une boucle séparée :

setImmediate(async function drain() {
  const { VersionedTransaction } = require('@solana/web3.js');
  while (true) {
    const item = queue.shift();
    if (!item) { await new Promise(r => setTimeout(r, 1)); continue; }
    const tx = VersionedTransaction.deserialize(item.txBytes);
    strategy.onPreExecution(item.slot, item.signature, tx);
  }
});

Si la file d’attente croît sans limite, resserrez les filtres. Les transactions que vous écartez côté client coûtent toujours 0.1 crédits chacune et comptent toujours dans la limite de contre-pression.

Reconcile against processed data

Une transaction prétraitée montre ce que l’expéditeur a essayé de faire, pas ce qui s’est passé. Elle ne comporte pas de statut d’exécution, de changements de solde ou de journaux, et elle peut échouer, être abandonnée ou atterrir sur une autre branche. La livraison est au mieux sans relecture historique, donc :

Rapprochez-vous de transactionSubscribe à processed ou confirmed avant que votre stratégie ne réserve quoi que ce soit comme un fait.
En cas de déconnexion, réabonnez-vous immédiatement et acceptez l’écart, car il n’y a pas de relecture pour le combler.
Si vous avez besoin de l’état du compte en temps réel plutôt que des intentions de transaction, cela n’existe qu’après exécution : utilisez LaserStream gRPC à processed.

Guides connexes

Référence de preprocessedSubscribe

Disposition complète de la charge utile, règles de filtrage, contre-pression, et tarification

Commerce sur les pré-confirmations

Le signal de transaction le plus précoce offert par Helius, directement du planificateur

Commencez ici

Données en temps réel

Trading à faible latence

Données historiques et de portefeuille

Guides des méthodes RPC

Préparation à la production

Utilisation d'Orb

Autres modes d'emploi

Commerce sur les transactions prétraitées

Ciblez l’abonnement sur votre objectif

Décoder les trames et dédupliquer par signature

Gardez la boucle de réception plus rapide que le flux

Reconcile against processed data

Guides connexes

Référence de preprocessedSubscribe

Commerce sur les pré-confirmations

​Ciblez l’abonnement sur votre objectif

​Décoder les trames et dédupliquer par signature

​Gardez la boucle de réception plus rapide que le flux

​Reconcile against processed data

​Guides connexes

Référence de preprocessedSubscribe

Commerce sur les pré-confirmations

Ciblez l’abonnement sur votre objectif

Décoder les trames et dédupliquer par signature

Gardez la boucle de réception plus rapide que le flux

Reconcile against processed data

Guides connexes