Parameters

This method does not accept any parameters

Returns

stream

stream<StreamBlocksResponse>

Loading...

height

string

Loading...

proposer

string

Loading...

moniker

string

Loading...

block_hash

string

Loading...

parent_hash

string

Loading...

num_pre_commits

string

Loading...

num_txs

string

Loading...

txs

array

Loading...

id

string

Loading...

block_number

string

Loading...

block_timestamp

string

Loading...

hash

string

Loading...

codespace

string

Loading...

messages

string

Loading...

tx_number

string

Loading...

error_log

string

Loading...

code

integer

Loading...

claim_ids

array

Loading...

timestamp

string

Loading...

block_unix_timestamp

string

Loading...

Request

1
package main
2

3
import (
4
	"context"
5
	"crypto/tls"
6
	"fmt"
7
	"io"
8
	"log"
9
	"os"
10
	"os/signal"
11

12
	"google.golang.org/grpc"
13
	"google.golang.org/grpc/credentials"
14
	"google.golang.org/grpc/metadata"
15
	"google.golang.org/protobuf/encoding/protojson"
16

17
	pb "injective-indexer-grpc/pb/explorer"
18
)
19

20
const grpcEndpoint = "YOUR_ENDPOINT_NAME.injective-mainnet.quiknode.pro:443"
21
const authToken = "YOUR_TOKEN"
22

23
func main() {
24
	creds := credentials.NewTLS(&tls.Config{MinVersion: tls.VersionTLS12})
25
	conn, err := grpc.Dial(grpcEndpoint, grpc.WithTransportCredentials(creds))
26
	if err != nil {
27
		log.Fatal(err)
28
	}
29
	defer conn.Close()
30

31
	ctx, stop := signal.NotifyContext(context.Background(), os.Interrupt)
32
	defer stop()
33
	ctx = metadata.AppendToOutgoingContext(ctx, "x-token", authToken)
34

35
	client := pb.NewInjectiveExplorerRPCClient(conn)
36
	request := &pb.StreamBlocksRequest{}
37
	requestJSON := `{}`
38
	if err := protojson.Unmarshal([]byte(requestJSON), request); err != nil {
39
		log.Fatal(err)
40
	}
41

42
	stream, err := client.StreamBlocks(ctx, request)
43
	if err != nil {
44
		log.Fatal(err)
45
	}
46

47
	for {
48
		response, err := stream.Recv()
49
		if err == io.EOF {
50
			return
51
		}
52
		if err != nil {
53
			if ctx.Err() != nil {
54
				return
55
			}
56
			log.Fatal(err)
57
		}
58

59
		data, err := protojson.MarshalOptions{UseProtoNames: true, Indent: "  "}.Marshal(response)
60
		if err != nil {
61
			log.Fatal(err)
62
		}
63
		fmt.Println(string(data))
64
	}
65
}
66

1
package main
2

3
import (
4
	"context"
5
	"crypto/tls"
6
	"fmt"
7
	"io"
8
	"log"
9
	"os"
10
	"os/signal"
11

12
	"google.golang.org/grpc"
13
	"google.golang.org/grpc/credentials"
14
	"google.golang.org/grpc/metadata"
15
	"google.golang.org/protobuf/encoding/protojson"
16

17
	pb "injective-indexer-grpc/pb/explorer"
18
)
19

20
const grpcEndpoint = "YOUR_ENDPOINT_NAME.injective-mainnet.quiknode.pro:443"
21
const authToken = "YOUR_TOKEN"
22

23
func main() {
24
	creds := credentials.NewTLS(&tls.Config{MinVersion: tls.VersionTLS12})
25
	conn, err := grpc.Dial(grpcEndpoint, grpc.WithTransportCredentials(creds))
26
	if err != nil {
27
		log.Fatal(err)
28
	}
29
	defer conn.Close()
30

31
	ctx, stop := signal.NotifyContext(context.Background(), os.Interrupt)
32
	defer stop()
33
	ctx = metadata.AppendToOutgoingContext(ctx, "x-token", authToken)
34

35
	client := pb.NewInjectiveExplorerRPCClient(conn)
36
	request := &pb.StreamBlocksRequest{}
37
	requestJSON := `{}`
38
	if err := protojson.Unmarshal([]byte(requestJSON), request); err != nil {
39
		log.Fatal(err)
40
	}
41

42
	stream, err := client.StreamBlocks(ctx, request)
43
	if err != nil {
44
		log.Fatal(err)
45
	}
46

47
	for {
48
		response, err := stream.Recv()
49
		if err == io.EOF {
50
			return
51
		}
52
		if err != nil {
53
			if ctx.Err() != nil {
54
				return
55
			}
56
			log.Fatal(err)
57
		}
58

59
		data, err := protojson.MarshalOptions{UseProtoNames: true, Indent: "  "}.Marshal(response)
60
		if err != nil {
61
			log.Fatal(err)
62
		}
63
		fmt.Println(string(data))
64
	}
65
}
66

1
const grpc = require('@grpc/grpc-js')
2
const protoLoader = require('@grpc/proto-loader')
3
const path = require('path')
4

5
const GRPC_ENDPOINT = 'YOUR_ENDPOINT_NAME.injective-mainnet.quiknode.pro:443'
6
const AUTH_TOKEN = 'YOUR_TOKEN'
7

8
const definition = protoLoader.loadSync(
9
	path.join(__dirname, 'proto/explorer/injective_explorer_rpc.proto'),
10
	{
11
		keepCase: true,
12
		longs: String,
13
		enums: String,
14
		bytes: String,
15
		defaults: true,
16
		oneofs: true,
17
	}
18
)
19

20
const proto = grpc.loadPackageDefinition(definition).injective_explorer_rpc
21
const client = new proto.InjectiveExplorerRPC(
22
	GRPC_ENDPOINT,
23
	grpc.credentials.createSsl()
24
)
25

26
const metadata = new grpc.Metadata()
27
metadata.add('x-token', AUTH_TOKEN)
28

29
const request = {}
30

31
const stream = client.StreamBlocks(request, metadata)
32

33
stream.on('data', response => {
34
	console.log(JSON.stringify(response, null, 2))
35
})
36

37
stream.on('error', error => {
38
	if (error.code !== grpc.status.CANCELLED) {
39
		console.error(error)
40
		process.exitCode = 1
41
	}
42
})
43

44
stream.on('end', () => client.close())
45

46
process.on('SIGINT', () => {
47
	stream.cancel()
48
	client.close()
49
})
50

1
const grpc = require('@grpc/grpc-js')
2
const protoLoader = require('@grpc/proto-loader')
3
const path = require('path')
4

5
const GRPC_ENDPOINT = 'YOUR_ENDPOINT_NAME.injective-mainnet.quiknode.pro:443'
6
const AUTH_TOKEN = 'YOUR_TOKEN'
7

8
const definition = protoLoader.loadSync(
9
	path.join(__dirname, 'proto/explorer/injective_explorer_rpc.proto'),
10
	{
11
		keepCase: true,
12
		longs: String,
13
		enums: String,
14
		bytes: String,
15
		defaults: true,
16
		oneofs: true,
17
	}
18
)
19

20
const proto = grpc.loadPackageDefinition(definition).injective_explorer_rpc
21
const client = new proto.InjectiveExplorerRPC(
22
	GRPC_ENDPOINT,
23
	grpc.credentials.createSsl()
24
)
25

26
const metadata = new grpc.Metadata()
27
metadata.add('x-token', AUTH_TOKEN)
28

29
const request = {}
30

31
const stream = client.StreamBlocks(request, metadata)
32

33
stream.on('data', response => {
34
	console.log(JSON.stringify(response, null, 2))
35
})
36

37
stream.on('error', error => {
38
	if (error.code !== grpc.status.CANCELLED) {
39
		console.error(error)
40
		process.exitCode = 1
41
	}
42
})
43

44
stream.on('end', () => client.close())
45

46
process.on('SIGINT', () => {
47
	stream.cancel()
48
	client.close()
49
})
50

1
import json
2
import grpc
3
from google.protobuf.json_format import MessageToJson, ParseDict
4
from explorer import injective_explorer_rpc_pb2
5
from explorer import injective_explorer_rpc_pb2_grpc
6

7
GRPC_ENDPOINT = "YOUR_ENDPOINT_NAME.injective-mainnet.quiknode.pro:443"
8
AUTH_TOKEN = "YOUR_TOKEN"
9

10
channel = grpc.secure_channel(GRPC_ENDPOINT, grpc.ssl_channel_credentials())
11
client = injective_explorer_rpc_pb2_grpc.InjectiveExplorerRPCStub(channel)
12
metadata = (("x-token", AUTH_TOKEN),)
13

14
request_data = {}
15
request = ParseDict(request_data, injective_explorer_rpc_pb2.StreamBlocksRequest())
16

17
stream = client.StreamBlocks(request, metadata=metadata)
18

19
try:
20
    for response in stream:
21
        print(MessageToJson(response, preserving_proto_field_name=True, indent=2))
22
except KeyboardInterrupt:
23
    stream.cancel()
24
finally:
25
    channel.close()
26

1
import json
2
import grpc
3
from google.protobuf.json_format import MessageToJson, ParseDict
4
from explorer import injective_explorer_rpc_pb2
5
from explorer import injective_explorer_rpc_pb2_grpc
6

7
GRPC_ENDPOINT = "YOUR_ENDPOINT_NAME.injective-mainnet.quiknode.pro:443"
8
AUTH_TOKEN = "YOUR_TOKEN"
9

10
channel = grpc.secure_channel(GRPC_ENDPOINT, grpc.ssl_channel_credentials())
11
client = injective_explorer_rpc_pb2_grpc.InjectiveExplorerRPCStub(channel)
12
metadata = (("x-token", AUTH_TOKEN),)
13

14
request_data = {}
15
request = ParseDict(request_data, injective_explorer_rpc_pb2.StreamBlocksRequest())
16

17
stream = client.StreamBlocks(request, metadata=metadata)
18

19
try:
20
    for response in stream:
21
        print(MessageToJson(response, preserving_proto_field_name=True, indent=2))
22
except KeyboardInterrupt:
23
    stream.cancel()
24
finally:
25
    channel.close()
26

Don't have an account yet?

Create your Quicknode endpoint in seconds and start building

Get started for free