Stream shreds. Route the packets that land the block.

// install · npm i @ample/sdk
import { Ample } from "@ample/sdk";

const ample = new Ample({
  apiKey: process.env.AMPLE_KEY,
  region: "ams",
});

for await (const tx of ample.shreds.subscribe({
  programs: ["JUP6Lk...", "whirL..."],
})) {
  console.log(tx.signer, tx.slot, tx.accounts.length);
}

// cargo add ample-sdk
use ample_sdk::{Client, ShredFilter};

let ample = Client::new(env!("AMPLE_KEY"))
    .region("fra");

let mut stream = ample
    .shreds()
    .filter(ShredFilter::programs(&["JUP6Lk..."]))
    .subscribe().await?;

while let Some(tx) = stream.next().await {
    println!("{} {} {}", tx.signer, tx.slot, tx.accounts.len());
}

# pip install ample-sdk
from ample import Ample

ample = Ample(api_key=os.environ["AMPLE_KEY"], region="ams")

async for tx in ample.shreds.subscribe(programs=["JUP6Lk...", "whirL..."]):
    print(tx.signer, tx.slot, len(tx.accounts))

// go get github.com/ample/sdk-go
package main

import (
    "context"
    "os"
    "github.com/ample/sdk-go"
)

func main() {
    a := ample.New(os.Getenv("AMPLE_KEY"), ample.Region("ams"))
    s, _ := a.Shreds.Subscribe(ctx, ample.ShredFilter{
        Programs: []string{"JUP6Lk...", "whirL..."},
    })
    for tx := range s.C { fmt.Println(tx.Signer, tx.Slot, len(tx.Accounts)) }
}

# websocket · decoded shred stream
wscat -c "wss://ams.ample.sh/v1/shreds" \
  -H "authorization: Bearer $AMPLE_KEY" \
  -x '{ "programs": ["JUP6Lk...", "whirL..."] }'

# or http long-poll, if you must
curl -N https://ams.ample.sh/v1/shreds \
  -H "authorization: Bearer $AMPLE_KEY"