Datastream

export OPENINFRA_API_KEY=sk_live_xxxxxxxxxxxx

curl -fsS https://openinfra.sh/protos/stream_service.proto -o stream_service.proto grpcurl \  -proto stream_service.proto \  -H "x-api-key: $OPENINFRA_API_KEY" \  -d '{"topic":"prod.rpc.solana.system.blocks-confirmed","format":"JSON"}' \  stream.sol.openinfra.sh:443 nln.stream.v1.StreamService/Subscribe

npm install @grpc/grpc-js @grpc/proto-loader

import grpc from "@grpc/grpc-js";import protoLoader from "@grpc/proto-loader"; const definition = protoLoader.loadSync("stream_service.proto", {  longs: String,  enums: String,  defaults: true,  oneofs: true,});const service = grpc.loadPackageDefinition(definition).nln.stream.v1;const client = new service.StreamService(  "stream.sol.openinfra.sh:443",  grpc.credentials.createSsl(),); const metadata = new grpc.Metadata();metadata.set("x-api-key", process.env.OPENINFRA_API_KEY!); const stream = client.Subscribe({  topic: "prod.rpc.solana.system.blocks-confirmed",  format: "JSON",}, metadata); stream.on("data", (message) => {  const payload = Buffer.isBuffer(message.payload)    ? message.payload    : Buffer.from(message.payload, "base64");  console.log({    topic: message.topic,    offset: message.offset,    data: JSON.parse(payload.toString("utf8")),  });});stream.on("error", console.error);