Solana gRPC: Yellowstone Geyser stream.

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26

// npm i @triton-one/yellowstone-grpc@9 · ESM ("type": "module") · run: npx tsx subscribe.ts
import Client, { CommitmentLevel, type SubscribeUpdate } from '@triton-one/yellowstone-grpc';

// http:// endpoint. Vortex authorises your registered source IP: no x-token.
const client = new Client('http://fra.vortex.raiden.wtf:10001', undefined, undefined);
await client.connect(); // required since v5.0.1

const stream = await client.subscribe();
stream.on('data', (update: SubscribeUpdate) => {
  if (update.transaction) console.log(`slot ${update.transaction.slot}`);
});
stream.on('error', (err) => console.error(err));

stream.write({
  transactions: {
    pumpfun: {
      vote: false,
      failed: false,
      accountInclude: ['6EF8rrecthR5Dkzon8Nwu78hRvfCKubJ14M5uBEwF6P'],
      accountExclude: [],
      accountRequired: [],
    },
  },
  // blocks, blocksMeta and entry omitted: not served by Vortex
  commitment: CommitmentLevel.PROCESSED,
});

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27

# pip install grpcio grpcio-tools; copy proto/*.proto from github.com/rpcpool/yellowstone-grpc (yellowstone-grpc-proto/proto), then:
# python -m grpc_tools.protoc -I proto --python_out=. --grpc_python_out=. proto/geyser.proto proto/solana-storage.proto
import threading
import grpc
import geyser_pb2
import geyser_pb2_grpc

# Plain gRPC channel. Vortex authorises your registered source IP: no token.
channel = grpc.insecure_channel("fra.vortex.raiden.wtf:10001")
stub = geyser_pb2_grpc.GeyserStub(channel)

def requests():
    yield geyser_pb2.SubscribeRequest(
        transactions={
            "pumpfun": geyser_pb2.SubscribeRequestFilterTransactions(
                vote=False,
                failed=False,
                account_include=["6EF8rrecthR5Dkzon8Nwu78hRvfCKubJ14M5uBEwF6P"],
            ),
        },
        commitment=geyser_pb2.CommitmentLevel.PROCESSED,
    )  # blocks, blocks_meta and entry omitted: not served by Vortex
    threading.Event().wait()  # keep the request stream open

for update in stub.Subscribe(requests()):
    if update.HasField("transaction"):
        print(f"slot {update.transaction.slot}")