Parameters

sender

string

The Ethereum sender address used to filter Peggy deposits.

receiver

string

The Injective destination address used to filter Peggy deposits.

limit

integer

The maximum number of records to return.

skip

integer

The number of matching records to skip before returning results.

Returns

field

array

The Peggy bridge deposits that match the request.

sender

string

The Ethereum address that initiated the bridged deposit.

receiver

string

The Injective address receiving the bridged deposit.

event_nonce

string

The nonce of the corresponding Peggy claim event emitted on Ethereum.

event_height

string

The Ethereum block height where the corresponding Peggy claim event was emitted.

amount

string

The coin amount represented as a decimal string in base denomination units.

denom

string

The denomination that identifies the transferred or fee coin.

orchestrator_address

string

The Peggy orchestrator address associated with the bridge record.

state

string

The current lifecycle state of the indexed bridge or IBC transfer.

claim_type

integer

The numeric Peggy claim type identifying a deposit claim.

tx_hashes

array

The Injective transaction hashes associated with the bridge record.

created_at

string

The UTC timestamp when the bridge or transfer record was created.

updated_at

string

The UTC timestamp when the indexed bridge or transfer record was last updated.

Request

1
package main
2

3
import (
4
	"context"
5
	"crypto/tls"
6
	"fmt"
7
	"log"
8
	"time"
9

10
	"google.golang.org/grpc"
11
	"google.golang.org/grpc/credentials"
12
	"google.golang.org/grpc/metadata"
13
	"google.golang.org/protobuf/encoding/protojson"
14

15
	pb "injective-indexer-grpc/pb/explorer"
16
)
17

18
// Example Quicknode endpoint: https://example-endpoint.injective-testnet.quiknode.pro/YOUR_TOKEN/
19
const grpcEndpoint = "example-endpoint.injective-testnet.quiknode.pro:443"
20
const authToken = "YOUR_TOKEN"
21

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

30
	ctx, cancel := context.WithTimeout(context.Background(), 20*time.Second)
31
	defer cancel()
32
	ctx = metadata.AppendToOutgoingContext(ctx, "x-token", authToken)
33

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

41
	response, err := client.GetPeggyDepositTxs(ctx, request)
42
	if err != nil {
43
		log.Fatal(err)
44
	}
45

46
	data, err := protojson.MarshalOptions{UseProtoNames: true, Indent: "  "}.Marshal(response)
47
	if err != nil {
48
		log.Fatal(err)
49
	}
50
	data = append(data, '\n')
51
	fmt.Print(string(data))
52
}
53

1
package main
2

3
import (
4
	"context"
5
	"crypto/tls"
6
	"fmt"
7
	"log"
8
	"time"
9

10
	"google.golang.org/grpc"
11
	"google.golang.org/grpc/credentials"
12
	"google.golang.org/grpc/metadata"
13
	"google.golang.org/protobuf/encoding/protojson"
14

15
	pb "injective-indexer-grpc/pb/explorer"
16
)
17

18
// Example Quicknode endpoint: https://example-endpoint.injective-testnet.quiknode.pro/YOUR_TOKEN/
19
const grpcEndpoint = "example-endpoint.injective-testnet.quiknode.pro:443"
20
const authToken = "YOUR_TOKEN"
21

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

30
	ctx, cancel := context.WithTimeout(context.Background(), 20*time.Second)
31
	defer cancel()
32
	ctx = metadata.AppendToOutgoingContext(ctx, "x-token", authToken)
33

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

41
	response, err := client.GetPeggyDepositTxs(ctx, request)
42
	if err != nil {
43
		log.Fatal(err)
44
	}
45

46
	data, err := protojson.MarshalOptions{UseProtoNames: true, Indent: "  "}.Marshal(response)
47
	if err != nil {
48
		log.Fatal(err)
49
	}
50
	data = append(data, '\n')
51
	fmt.Print(string(data))
52
}
53

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

5
// Example Quicknode endpoint: https://example-endpoint.injective-testnet.quiknode.pro/YOUR_TOKEN/
6
const GRPC_ENDPOINT = 'example-endpoint.injective-testnet.quiknode.pro:443'
7
const AUTH_TOKEN = 'YOUR_TOKEN'
8

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

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

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

30
const request = {
31
	limit: 1,
32
}
33

34
client.GetPeggyDepositTxs(
35
	request,
36
	metadata,
37
	{ deadline: Date.now() + 20000 },
38
	(error, response) => {
39
		if (error) {
40
			console.error(error)
41
			process.exitCode = 1
42
			return
43
		}
44

45
		console.log(JSON.stringify(response, null, 2))
46
		client.close()
47
	}
48
)
49

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

5
// Example Quicknode endpoint: https://example-endpoint.injective-testnet.quiknode.pro/YOUR_TOKEN/
6
const GRPC_ENDPOINT = 'example-endpoint.injective-testnet.quiknode.pro:443'
7
const AUTH_TOKEN = 'YOUR_TOKEN'
8

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

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

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

30
const request = {
31
	limit: 1,
32
}
33

34
client.GetPeggyDepositTxs(
35
	request,
36
	metadata,
37
	{ deadline: Date.now() + 20000 },
38
	(error, response) => {
39
		if (error) {
40
			console.error(error)
41
			process.exitCode = 1
42
			return
43
		}
44

45
		console.log(JSON.stringify(response, null, 2))
46
		client.close()
47
	}
48
)
49

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
# Example Quicknode endpoint: https://example-endpoint.injective-testnet.quiknode.pro/YOUR_TOKEN/
8
GRPC_ENDPOINT = "example-endpoint.injective-testnet.quiknode.pro:443"
9
AUTH_TOKEN = "YOUR_TOKEN"
10

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

15
request_data = {
16
  "limit": 1
17
}
18
request = ParseDict(request_data, injective_explorer_rpc_pb2.GetPeggyDepositTxsRequest())
19

20
try:
21
    response = client.GetPeggyDepositTxs(request, metadata=metadata, timeout=20)
22
    print(MessageToJson(response, preserving_proto_field_name=True, indent=2))
23
except grpc.RpcError as error:
24
    print(f"gRPC error {error.code().name}: {error.details()}")
25
    raise
26
finally:
27
    channel.close()
28

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
# Example Quicknode endpoint: https://example-endpoint.injective-testnet.quiknode.pro/YOUR_TOKEN/
8
GRPC_ENDPOINT = "example-endpoint.injective-testnet.quiknode.pro:443"
9
AUTH_TOKEN = "YOUR_TOKEN"
10

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

15
request_data = {
16
  "limit": 1
17
}
18
request = ParseDict(request_data, injective_explorer_rpc_pb2.GetPeggyDepositTxsRequest())
19

20
try:
21
    response = client.GetPeggyDepositTxs(request, metadata=metadata, timeout=20)
22
    print(MessageToJson(response, preserving_proto_field_name=True, indent=2))
23
except grpc.RpcError as error:
24
    print(f"gRPC error {error.code().name}: {error.details()}")
25
    raise
26
finally:
27
    channel.close()
28

Don't have an account yet?

Create your Quicknode endpoint in seconds and start building

Get started for free