Parameters

This method does not accept any parameters

Returns

stream

stream<StreamBlocksResponse>

An open-ended stream that emits one indexed response message for each new matching record.

height

string

The height of the returned Injective block.

proposer

string

The consensus address of the validator that proposed the block.

moniker

string

The human-readable name published by the validator.

block_hash

string

The cryptographic hash that identifies the Injective block.

parent_hash

string

The cryptographic hash of the preceding Injective block.

num_pre_commits

string

The number of validator pre-commit votes recorded for the block.

num_txs

string

The number of transactions included in the block.

txs

array

The indexed transactions included in the block.

id

string

The internal identifier assigned to the indexed transaction.

block_number

string

The height of the Injective block containing the record.

block_timestamp

string

The UTC timestamp of the block containing the record.

hash

string

The cryptographic hash that identifies the transaction.

codespace

string

The module namespace that produced the transaction result code.

messages

string

The serialized transaction messages returned by the indexer.

tx_number

string

The monotonically increasing transaction number assigned by the indexer.

error_log

string

The transaction error log when execution failed; otherwise empty.

code

integer

The numeric transaction result code; zero indicates successful execution.

claim_ids

array

The Peggy claim identifiers associated with deposit-claim messages in the transaction. Each value is returned as a decimal string.

timestamp

string

The UTC timestamp when the block was produced.

block_unix_timestamp

string

The block timestamp expressed in Unix milliseconds.

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