Jupiter-Swaps mit Parsed Streams verfolgen

In diesem Leitfaden erstellst du Schritt für Schritt einen echten Filter: Beobachte die Jupiter-Swaps einer Wallet. Nutze dazu die Programmerkennung, damit der Filter korrekt ist, bevor du überhaupt eine Subscription öffnest.

Look Up the Program

Erratene Anweisungsnamen sind der häufigste Grund dafür, dass ein Filter unbemerkt keine Treffer liefert. Rufe zuerst describeProgram auf, um die exakten Namen abzurufen, mit denen der Matcher vergleicht. Dies ist derzeit nur auf wss://fs-beta.helius-rpc.com/?api-key=<API_KEY> verfügbar. Sende den request daher dorthin und nicht über deine Subscription-Verbindung.

Request

{ "jsonrpc": "2.0", "id": 1, "method": "describeProgram", "params": [{ "program": "JUP6LkbZbjS1jKKwapdHNy74zcZ3tLUZoi5QNyVTaV4" }] }

Response

{
  "jsonrpc": "2.0", "id": 1,
  "result": {
    "id": "JUP6LkbZbjS1jKKwapdHNy74zcZ3tLUZoi5QNyVTaV4",
    "name": "jupiter",
    "instructions": ["route", "shared_accounts_route", "exact_out_route"],
    "events": ["SwapEvent"],
    "roles": ["user_transfer_authority", "destination_token_account"]
  }
}

Verwende vorzugsweise die Adresse des Programms statt eines Katalognamens. Mehrere Katalogeinträge können denselben Namen haben, und eine Namenssuche kann eine ältere Version des Programms zurückgeben. route und shared_accounts_route sind die beiden Anweisungen, die die meisten Jupiter-v6-Swaps abdecken. Deshalb filterst du nach ihnen.

Build the Filter

Kombiniere die Programm-ID, die Namen der Anweisungen aus dem vorherigen Schritt und die Wallet, die du beobachtest. Die Felder werden mit AND verknüpft. So findest du Route-Anweisungen, die das SOL-Konto der Wallet verwenden:

{
  "programs": ["JUP6LkbZbjS1jKKwapdHNy74zcZ3tLUZoi5QNyVTaV4"],
  "instructionNames": ["route", "shared_accounts_route"],
  "accounts": {
    "include": ["So11111111111111111111111111111111111111112"],
    "roles": { "user_transfer_authority": "9xQeWvG816bUx9EPjHmaT23yvVM2ZWbrrpZb9PusVFin" }
  },
  "includeFailed": false,
  "includeCpi": true
}

accounts.roles bindet user_transfer_authority an die exakte Position der Wallet in der Anweisung. Das ist strenger als accounts.include allein: Eine einfache Übereinstimmung mit der Adresse würde auch Treffer liefern, wenn die Wallet an anderer Stelle in der Anweisung als nicht zugehöriges Konto vorkommt. Rollennamen müssen exakt übereinstimmen. Kopiere sie deshalb aus der Liste roles von describeProgram, statt sie zu erraten. Belasse includeCpi: true auf dem Standardwert. Die token eines Swaps werden tatsächlich in inneren Anweisungen übertragen.

Subscribe and Handle Notifications

Öffne die Subscription mit dem Filter. Lies dann die decodierten Argumente jeder gefundenen Anweisung:

import WebSocket from "ws";

const ws = new WebSocket("wss://beta.helius-rpc.com/?api-key=<API_KEY>");

const filter = {
  programs: ["JUP6LkbZbjS1jKKwapdHNy74zcZ3tLUZoi5QNyVTaV4"],
  instructionNames: ["route", "shared_accounts_route"],
  accounts: {
    include: ["So11111111111111111111111111111111111111112"],
    roles: { user_transfer_authority: "9xQeWvG816bUx9EPjHmaT23yvVM2ZWbrrpZb9PusVFin" },
  },
  includeFailed: false,
  includeCpi: true,
};

ws.on("open", () => {
  ws.send(JSON.stringify({
    jsonrpc: "2.0",
    id: 1,
    method: "parsedTransactionSubscribe",
    params: [filter, { commitment: "confirmed", details: "full" }],
  }));
});

ws.on("message", (data) => {
  const msg = JSON.parse(data.toString());
  if (msg.method === "parsedTransactionNotification") {
    const { transaction, instructions, matchedIndexes } = msg.params.result.value;
    for (const i of matchedIndexes) {
      const ix = instructions[i];
      if (!ix.decoded) continue;
      console.log(transaction.signature, ix.decoded.args.in_amount, ix.decoded.args.slippage_bps);
    }
  }
});

matchedIndexes verweist nur auf die Anweisungen, die dein Filter gefunden hat. Überspringe alle anderen Anweisungen in der Transaktion. Prüfe vor dem Lesen, ob decoded vorhanden ist: Eine Route-Anweisung aus einer nicht indexierten Programmversion kommt stattdessen mit decoded: null und Rohfeldern an.

Hier starten

Echtzeitdaten

Trading mit niedriger Latenz

Historische Daten und Wallet-Daten

Anleitungen zu RPC-Methoden

Produktionsreife

Orb verwenden

Weitere Anleitungen

Jupiter-Swaps mit Parsed Streams verfolgen

Nächste Schritte

Filter Fields Reference

Handling Reconnects

​Nächste Schritte

Filter Fields Reference

Handling Reconnects

Nächste Schritte