Transmitir slots y bloques Solana con gRPC

import { subscribe } from "./stream.mts";

for await (const update of subscribe({
  slots: { slots: { filterByCommitment: true } },
  blocksMeta: { blocks: {} },
})) {
  if (update.slot) {
    console.log("slot", update.slot.slot, update.slot.parent, update.slot.status);
  }
  if (update.blockMeta) {
    console.log("block", update.blockMeta.slot, update.blockMeta.blockhash,
      update.blockMeta.executedTransactionCount);
  }
}

import { subscribe } from "./stream.mts";

const address = process.env.WATCH_ADDRESS;
if (!address) throw new Error("Set WATCH_ADDRESS");

for await (const update of subscribe({
  blocks: {
    selected: {
      accountInclude: [address],
      includeTransactions: true,
      includeAccounts: false,
      includeEntries: false,
    },
  },
})) {
  if (!update.block) continue;
  console.log(update.block.slot, update.block.transactions.length);
}