gRPC İstemcisi (Yellowstone)

Kurulum

npm install @orbitflare/sdk @grpc/grpc-js yaml

@grpc/grpc-js ve yaml isteğe bağlı peer bağımlılıklardır. Yalnızca gRPC istemcisini (veya YAML yapılandırmasını) kullanıyorsanız kurun.

İstemciyi oluşturma

Tüm seçeneklerin ayarlı olduğu bir istemci:

import { GeyserClientBuilder } from '@orbitflare/sdk/grpc';
import type { RetryPolicy } from '@orbitflare/sdk';

const client = new GeyserClientBuilder()
  .url('http://ny.rpc.orbitflare.com:10000')
  .fallbackUrl('http://fra.rpc.orbitflare.com:10000')
  .retry({
    initialDelayMs: 100,
    maxDelayMs: 30_000,
    multiplier: 2.0,
    maxAttempts: 0,
  })
  .timeoutSecs(30)
  .keepaliveSecs(60)
  .pingIntervalSecs(10)
  .maxMissedPongs(3)
  .channelCapacity(4096)
  .build();

Minimal kurulum:

const client = new GeyserClientBuilder()
  .url('http://ny.rpc.orbitflare.com:10000')
  .build();

Builder yöntemleri

.url(url) - Birincil gRPC uç noktası. ORBITFLARE_GRPC_URL ortam değişkenine düşer.

.url('http://ny.rpc.orbitflare.com:10000')

.urls([...]) - Tek çağrıda birincil + yedekler. İlk eleman birincildir.

.urls(['http://ny.rpc.orbitflare.com:10000', 'http://fra.rpc.orbitflare.com:10000'])

.fallbackUrl(url) / .fallbackUrls([...]) - Yedek uç noktalar ekler. Bağlantı hatasında SDK aralarında döner.

.fallbackUrl('http://fra.rpc.orbitflare.com:10000')

.retry(policy) - Yeniden bağlanma geri çekilmesini denetler. Bağlantı koptuğunda SDK önce initialDelayMs bekler, sonra her denemede gecikmeyi iki katına çıkarır (maxDelayMs ile sınırlı). maxAttempts değerini 0 yaparak sonsuz yeniden deneme ayarlayın. Varsayılan: 100 ms başlangıç, 30 sn üst sınır, 2x çarpan, sonsuz.

.retry({
  initialDelayMs: 200,
  maxDelayMs: 15_000,
  multiplier: 2.0,
  maxAttempts: 0,
})

.timeoutSecs(n) - İstek başına gRPC zaman aşımı. Varsayılan: 30.

.timeoutSecs(15)

.keepaliveSecs(n) - TCP keepalive aralığı. İşletim sistemi bu aralıkta ölü bağlantıları TCP düzeyinde tespit etmek için probe gönderir. Varsayılan: 60.

.keepaliveSecs(30)

.pingIntervalSecs(n) - SDK’nın sunucuya proto düzeyinde Ping gönderme sıklığı. Sunucunun Pong ile yanıt vermesi beklenir. Varsayılan: 10.

.pingIntervalSecs(15)

.maxMissedPongs(n) - SDK’nın bağlantıyı ölü sayıp yeniden bağlanmadan önce ardışık kaç ping’in yanıtsız kalabileceği. Varsayılan: 3. Varsayılanlarla ölü bağlantı yaklaşık 30 saniye içinde tespit edilir.

.maxMissedPongs(5)

.channelCapacity(n) - Arka plan görevi ile kodunuz arasındaki sınırlı tampon. Olayları tüketmek yavaşsa ve bu dolarsa arka plan görevi sınırsız bellek yemek yerine duraklar. Varsayılan: 4096.

.channelCapacity(8192)

YAML yapılandırması yazma

İstediğiniz filtrelerle bir YAML dosyası oluşturun:

# grpc.yml
transactions:
  pumpfun:
    vote: false
    failed: false
    account_include:
      - "6EF8rrecthR5Dkzon8Nwu78hRvfCKubJ14M5uBEwF6P"
  jupiter:
    vote: false
    failed: false
    account_include:
      - "JUP6LkbZbjS1jKKwapdHNy74zcZ3tLUZoi5QNyVTaV4"

accounts:
  usdc_mint:
    account:
      - "EPjFWdd5AufqSSqeM2qN1xzybapC8G4wEGGkZwyTDt1v"
  token_program:
    owner:
      - "TokenkegQfeZyiNwAJbNbGKPFXCWuBvf9Ss623VQ5DA"

slots:
  all:
    filter_by_commitment: true

commitment: confirmed

YAML filtre referansı

transactions - her giriş adlı bir filtredir. Bir işlem account_include adreslerinden herhangi birini içeriyorsa eşleşir. account_exclude eşleşmeleri çıkarır. account_required listelenen tüm adreslerin bulunmasını gerektirir. vote ve failed işlem tipine göre filtreler. accounts - adresle belirli hesapları izleyin veya owner ile bir programa ait tüm hesapları izleyin. slots - slot güncellemelerine abone olun. filter_by_commitment yalnızca taahhüt düzeyinizdeki güncellemeleri gönderir. commitment - 'processed', 'confirmed' veya 'finalized'. Varsayılan: 'confirmed'. YAML ${ENV_VAR} genişletmesini destekler:

transactions:
  target:
    account_include:
      - "${TARGET_PROGRAM}"

Olaylara abone olma ve okuma

YAML’dan

const stream = client.subscribeYaml('grpc.yml');

Programatik olarak

Çalışma zamanında oluşturulan dinamik filtreler için:

import { proto } from '@orbitflare/sdk/proto';

const request: proto.geyser.SubscribeRequest = {
  transactions: {
    target: {
      vote: false,
      failed: false,
      signature: undefined,
      accountInclude: [someAddress],
      accountExclude: [],
      accountRequired: [],
    },
  },
  accounts: {},
  slots: {},
  transactionsStatus: {},
  blocks: {},
  blocksMeta: {},
  entry: {},
  accountsDataSlice: [],
  commitment: 1,
  ping: { id: 1 },
};

const stream = client.subscribe(request);

Akışı okuma

Hem subscribeYaml hem subscribe bir GeyserStream döndürür. Bu bir async iterable’dır - for await kullanın:

for await (const update of stream) {
  if (update.transaction) {
    // update.transaction.slot - the slot this transaction was in
    // update.transaction.transaction - the transaction info (signature, accounts, instructions, meta)
  } else if (update.account) {
    // update.account.slot - the slot
    // update.account.account - account info (pubkey, lamports, owner, data)
    // update.account.isStartup - true during initial account snapshot
  } else if (update.slot) {
    // update.slot.slot - the slot number
    // update.slot.status - processed, confirmed, finalized, etc.
  } else if (update.blockMeta) {
    // update.blockMeta.slot, update.blockMeta.blockhash, update.blockMeta.parentSlot
    // update.blockMeta.executedTransactionCount
  }
}

Veya tek seferde bir olay çekmek için doğrudan await stream.next() çağırın. Akış kapalıysa undefined döner. Yeniden denemeler tükendiyse bir sonraki iterasyon hata fırlatır. Pong iletileri dahili tüketilir ve akışınızda asla görünmez.

Kapatma

stream.close();

Arka plan görevini anında durdurur.

Birden çok akış

Tek istemci aynı anda birçok akış çalıştırabilir. Her biri kendi arka plan bağlantısını alır:

const pumpfun = client.subscribeYaml('config/pumpfun.yml');
const raydium = client.subscribeYaml('config/raydium.yml');
const slots = client.subscribeYaml('config/slots.yml');

Uç nokta sağlık durumunu paylaşırlar - bir akış başarısız bir uç noktayı karantinaya alırsa diğerleri bir sonraki yeniden bağlanmada onu atlar. Ancak bağlantıları ve yaşam döngüleri tamamen bağımsızdır. Mevcut bir akıştan gelen veriye dayalı olarak da dahil olmak üzere istediğiniz zaman yeni akışlar başlatabilirsiniz.

Tam örnek

pump.fun işlemlerini izleyen, imzayı çözen ve her biri için bir özet yazdıran bir akış.

import bs58 from 'bs58';
import { GeyserClientBuilder } from '@orbitflare/sdk/grpc';

async function main() {
  const client = new GeyserClientBuilder()
    .url('http://ny.rpc.orbitflare.com:10000')
    .fallbackUrl('http://fra.rpc.orbitflare.com:10000')
    .build();

  const stream = client.subscribeYaml('grpc.yml');
  let txCount = 0;

  console.log('streaming...');

  for await (const update of stream) {
    if (update.transaction) {
      txCount += 1;
      const info = update.transaction.transaction;
      if (info?.signature) {
        const sig = bs58.encode(info.signature);
        const fee = info.meta?.fee ?? 0n;
        const ixCount = info.transaction?.message?.instructions.length ?? 0;
        console.log(
          `#${txCount} slot=${update.transaction.slot} sig=${sig.slice(0, 16)}... fee=${fee} instructions=${ixCount}`,
        );
      }
    } else if (update.slot) {
      console.log(`slot ${update.slot.slot} (${update.slot.status})`);
    }
  }
}

void main();

Bu grpc.yml ile:

transactions:
  pumpfun:
    vote: false
    failed: false
    account_include:
      - "6EF8rrecthR5Dkzon8Nwu78hRvfCKubJ14M5uBEwF6P"

slots:
  all:
    filter_by_commitment: true

commitment: confirmed

​Kurulum

​İstemciyi oluşturma

​Builder yöntemleri

​YAML yapılandırması yazma

​YAML filtre referansı

​Olaylara abone olma ve okuma

​YAML’dan

​Programatik olarak

​Akışı okuma

​Kapatma

​Birden çok akış

​Tam örnek