Parameters

sender

string

The Injective sender address used to filter Peggy withdrawals.

receiver

string

The Ethereum destination address used to filter Peggy withdrawals.

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 withdrawals that match the request.

sender

string

The Injective address that initiated the bridged withdrawal.

receiver

string

The Ethereum address receiving the bridged withdrawal.

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.

bridge_fee

string

The amount paid to bridge the withdrawal to Ethereum.

outgoing_tx_id

string

The unique, incrementing identifier assigned to the Peggy withdrawal request.

batch_timeout

string

The Unix timestamp after which the Peggy withdrawal batch expires.

batch_nonce

string

The unique, incrementing nonce assigned to the Peggy withdrawal batch.

orchestrator_address

string

The Peggy orchestrator address associated with the bridge record.

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.

state

string

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

claim_type

integer

The numeric Peggy claim type identifying a batch-withdrawal 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.GetPeggyWithdrawalTxsRequest{}
36
	requestJSON := `{"limit":1}`
37
	if err := protojson.Unmarshal([]byte(requestJSON), request); err != nil {
38
		log.Fatal(err)
39
	}
40

41
	response, err := client.GetPeggyWithdrawalTxs(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.GetPeggyWithdrawalTxsRequest{}
36
	requestJSON := `{"limit":1}`
37
	if err := protojson.Unmarshal([]byte(requestJSON), request); err != nil {
38
		log.Fatal(err)
39
	}
40

41
	response, err := client.GetPeggyWithdrawalTxs(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.GetPeggyWithdrawalTxs(
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.GetPeggyWithdrawalTxs(
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.GetPeggyWithdrawalTxsRequest())
19

20
try:
21
    response = client.GetPeggyWithdrawalTxs(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.GetPeggyWithdrawalTxsRequest())
19

20
try:
21
    response = client.GetPeggyWithdrawalTxs(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