NewBlocks
最後更新於
這有幫助嗎？
這有幫助嗎？
package main
import (
"context"
"fmt"
// directory of the generated code using the provided relay.proto file
pb "github.com/BlockRazorinc/eth_relay_example/protobuf"
"google.golang.org/grpc"
"google.golang.org/grpc/credentials/insecure"
)
// auth will be used to verify the credential
type Authentication struct {
apiKey string
}
func (a *Authentication) GetRequestMetadata(context.Context, ...string) (map[string]string, error) {
return map[string]string{"apikey": a.apiKey}, nil
}
func (a *Authentication) RequireTransportSecurity() bool {
return false
}
func main() {
// BlockRazor relay endpoint address
blzrelayEndPoint := "ip:port"
// auth will be used to verify the credential
auth := Authentication{
"your auth token",
}
// open gRPC connection to BlockRazor relay
var err error
conn, err := grpc.NewClient(blzrelayEndPoint, grpc.WithTransportCredentials(insecure.NewCredentials()), grpc.WithPerRPCCredentials(&auth), grpc.WithWriteBufferSize(0), grpc.WithInitialConnWindowSize(128*1024))
if err != nil {
fmt.Println("error: ", err)
return
}
defer conn.Close()
// use the Relay client connection interface
client := pb.NewRelayClient(conn)
// create context and defer cancel of context
ctx, cancel := context.WithCancel(context.Background())
defer cancel()
// create a subscription using the stream-specific method and request
stream, err := client.NewBlocks(ctx, &pb.NewBlocksRequest{ParsedTxs: true})
if err != nil {
fmt.Println("failed to subscribe new block: ", err)
return
}
for {
reply, err := stream.Recv()
if err != nil {
fmt.Println("stream receive error: ", err)
return
}
header := reply.GetHeader()
fmt.Println("receive new block, block hash is ", reply.Hash, " number is ", header.GetNumber(), " txs are ", len(reply.Transactions))
}
}
syntax = "proto3";
package relay.v1;
option go_package = "github.com/BlockRazorinc/eth_relay_example/protobuf";
service Relay {
rpc SendTx(SendTxRequest) returns (SendTxReply);
rpc NewTxs(NewTxsRequest) returns (stream NewTx);
rpc NewBlocks(NewBlocksRequest) returns (stream NewBlock);
}
message SendTxRequest {
bytes raw_tx = 1;
}
message SendTxReply {
string tx_hash = 1;
}
message NewTxsRequest {
bool include_raw_tx = 1;
}
message NewTx {
string tx_hash = 1;
bytes raw_tx = 2;
int64 first_seen_unix_ns = 3;
string source = 4;
}
message NewBlocksRequest {
bool parsed_txs = 1;
}
message NewBlock {
string hash = 1;
BlockHeader header = 2;
repeated BlockTransaction transactions = 3;
repeated Withdrawal withdrawals = 4;
}
message BlockHeader {
string parent_hash = 1;
string sha3_uncles = 2;
string miner = 3;
string state_root = 4;
string transactions_root = 5;
string receipts_root = 6;
string logs_bloom = 7;
string difficulty = 8;
string number = 9;
string gas_limit = 10;
string gas_used = 11;
string timestamp = 12;
string extra_data = 13;
string mix_hash = 14;
string nonce = 15;
string base_fee_per_gas = 16;
string withdrawals_root = 17;
string blob_gas_used = 18;
string excess_blob_gas = 19;
string parent_beacon_block_root = 20;
}
message BlockTransaction {
bytes raw_tx = 1;
bytes from = 2;
}
message Withdrawal {
string address = 1;
string amount = 2;
string index = 3;
string validator_index = 4;
}
{
"hash": "0xaf1f...4116",
"header": {
"parentHash": "0x4603...cfee",
"sha3Uncles": "0x1dcc...9347",
"miner": "0x0e33b1c214463062753ad849a28e54667e0c87c2",
"stateRoot": "0x4c26...1c96",
"transactionsRoot": "0xb6b8...731e",
"receiptsRoot": "0xd9ae...75ea",
"logsBloom": "0x263c...59fdb",
"difficulty": "0x0",
"number": "0x1845661",
"gasLimit": "0x3938700",
"gasUsed": "0x14c4d26",
"timestamp": "0x6a475117",
"extraData": "0x",
"mixHash": "0xb048...3154",
"nonce": "0x0000000000000000",
"baseFeePerGas": "71769385",
"withdrawalsRoot": "0xe5de...f2f2",
"blobGasUsed": "0x20000",
"excessBlobGas": "0xa8d8c53",
"parentBeaconBlockRoot": "0x0319...7a00"
},
"transactions": [
{
"rawTx": "<base64 encoded raw transaction>",
"from": "<base64 encoded sender>"
}
],
"withdrawals": [
{
"address": "0x1135fa96848f34bff9d003f4c1699ae97418de29",
"amount": "0xda361b",
"index": "0x80678fb",
"validatorIndex": "0x1b1fc1"
}
]
}rpc error: code = Unknown desc = data streams have exceeded its max limit [5]