subscribe gRPC Method - Solana gRPC

Solana gRPC está incluido en los planes Scale y Business. En los planes Build y Accelerate, sigue estando disponible a través del complemento Solana gRPC.

Parámetros

Este método no admite ningún parámetro

Devoluciones

resultado

objeto

Cargando...

Solicitud

1
paquete principal
2

3
import (
4
	«contexto»
5
	«crypto/tls»
6
	«fmt»
7
	«registro»
8
	«tiempo»
9
	"github.com/mr-tron/base58"
10
	«encoding/json»
11

12
	pb «yellowstone/proto»
13

14
	"google.golang.org/grpc"
15
	"google.golang.org/grpc/credentials"
16
	"google.golang.org/grpc/encoding/gzip"
17
	"google.golang.org/grpc/keepalive"
18
)
19

20
// Quicknode endpoints consist of two crucial components: the endpoint name and the corresponding token
21
// For eg: QN Endpoint: https://docs-demo.solana-mainnet.quiknode.pro/abcde123456789
22
// endpoint will be: docs-demo.solana-mainnet.quiknode.pro:10000  {10000 is the port number for gRPC}
23
// token will be : abcde123456789
24

25
var (
26
	punto final = "TU_QN_ENDPOINT:10000"
27
	token    = "TU_NÚMERO_DE_TOKEN"
28
)
29

30
func main() {
31
	opts := []grpc.DialOption{
32
		grpc.WithTransportCredentials(credenciales.NewTLS(&tls.Config{})),
33
		grpc.WithKeepaliveParams(kacp),
34
		grpc.WithDefaultCallOptions(grpc.MaxCallRecvMsgSize(1024*1024*1024), grpc.UseCompressor(gzip.Nombre)),
35
		grpc.WithPerRPCCredentials(tokenAuth{token: token}),
36
	}
37

38
	conn, err := grpc.NewClient(punto de conexión, opts...)
39
	si err != nil {
40
		registro.Fatalf(«Error al conectarse: %v», err)
41
	}
42
	aplazar conn.Cerrar()
43

44
	cliente := pb.NewGeyserClient(conn)
45

46
    commitment := pb.CommitmentLevel_FINALIZED
47
    subReq := &pb.SubscribeRequest{
48
        Commitment: &commitment,
49
        BlocksMeta: map[string]*pb.SubscribeRequestFilterBlocksMeta{
50
            "blocks": {},
51
        },
52
        Slots: map[string]*pb.SubscribeRequestFilterSlots{
53
            "slots": {},
54
        },
55
    }
56

57
    d, _ := json.Marshal(subReq)
58
    fmt.Printf("Subscription request: %s\n", string(d))
59

60
    stream, err := client.Subscribe(context.Background())
61
    if err != nil {
62
        fmt.Printf("Failed to subscribe to yellowstone: %v\n", err)
63
        volver
64
    }
65

66
    if err = stream.Send(subReq); err != nil {
67
        fmt.Printf("Failed to send subscription request: %v\n", err)
68
        volver
69
    }
70

71
    for {
72
        m, err := stream.Recv()
73
        if err != nil {
74
            fmt.Printf("Failed to receive yellowstone message: %v\n", err)
75
            volver
76
        }
77

78
        switch {
79
        case m.GetBlock() != nil:
80
            fmt.Printf("Block: %d\n", m.GetBlock().GetBlockHeight())
81
        case m.GetBlockMeta() != nil:
82
            fmt.Printf("BlockMeta: %d\n", m.GetBlockMeta().GetBlockHeight())
83
        case m.GetTransaction() != nil:
84
            fmt.Printf("Transaction: %s\n", base58.Encode(m.GetTransaction().GetTransaction().GetSignature()))
85
        case m.GetSlot() != nil:
86
            fmt.Printf("Slot: %d\n", m.GetSlot().GetSlot())
87
        }
88
    }
89
}

1
paquete principal
2

3
import (
4
	«contexto»
5
	«crypto/tls»
6
	«fmt»
7
	«registro»
8
	«tiempo»
9
	"github.com/mr-tron/base58"
10
	«encoding/json»
11

12
	pb «yellowstone/proto»
13

14
	"google.golang.org/grpc"
15
	"google.golang.org/grpc/credentials"
16
	"google.golang.org/grpc/encoding/gzip"
17
	"google.golang.org/grpc/keepalive"
18
)
19

20
// Quicknode endpoints consist of two crucial components: the endpoint name and the corresponding token
21
// For eg: QN Endpoint: https://docs-demo.solana-mainnet.quiknode.pro/abcde123456789
22
// endpoint will be: docs-demo.solana-mainnet.quiknode.pro:10000  {10000 is the port number for gRPC}
23
// token will be : abcde123456789
24

25
var (
26
	punto final = "TU_QN_ENDPOINT:10000"
27
	token    = "TU_NÚMERO_DE_TOKEN"
28
)
29

30
func main() {
31
	opts := []grpc.DialOption{
32
		grpc.WithTransportCredentials(credenciales.NewTLS(&tls.Config{})),
33
		grpc.WithKeepaliveParams(kacp),
34
		grpc.WithDefaultCallOptions(grpc.MaxCallRecvMsgSize(1024*1024*1024), grpc.UseCompressor(gzip.Nombre)),
35
		grpc.WithPerRPCCredentials(tokenAuth{token: token}),
36
	}
37

38
	conn, err := grpc.NewClient(punto de conexión, opts...)
39
	si err != nil {
40
		registro.Fatalf(«Error al conectarse: %v», err)
41
	}
42
	aplazar conn.Cerrar()
43

44
	cliente := pb.NewGeyserClient(conn)
45

46
    commitment := pb.CommitmentLevel_FINALIZED
47
    subReq := &pb.SubscribeRequest{
48
        Commitment: &commitment,
49
        BlocksMeta: map[string]*pb.SubscribeRequestFilterBlocksMeta{
50
            "blocks": {},
51
        },
52
        Slots: map[string]*pb.SubscribeRequestFilterSlots{
53
            "slots": {},
54
        },
55
    }
56

57
    d, _ := json.Marshal(subReq)
58
    fmt.Printf("Subscription request: %s\n", string(d))
59

60
    stream, err := client.Subscribe(context.Background())
61
    if err != nil {
62
        fmt.Printf("Failed to subscribe to yellowstone: %v\n", err)
63
        volver
64
    }
65

66
    if err = stream.Send(subReq); err != nil {
67
        fmt.Printf("Failed to send subscription request: %v\n", err)
68
        volver
69
    }
70

71
    for {
72
        m, err := stream.Recv()
73
        if err != nil {
74
            fmt.Printf("Failed to receive yellowstone message: %v\n", err)
75
            volver
76
        }
77

78
        switch {
79
        case m.GetBlock() != nil:
80
            fmt.Printf("Block: %d\n", m.GetBlock().GetBlockHeight())
81
        case m.GetBlockMeta() != nil:
82
            fmt.Printf("BlockMeta: %d\n", m.GetBlockMeta().GetBlockHeight())
83
        case m.GetTransaction() != nil:
84
            fmt.Printf("Transaction: %s\n", base58.Encode(m.GetTransaction().GetTransaction().GetSignature()))
85
        case m.GetSlot() != nil:
86
            fmt.Printf("Slot: %d\n", m.GetSlot().GetSlot())
87
        }
88
    }
89
}

1
import Client, { CommitmentLevel, SubscribeRequest, SubscribeUpdate, SubscribeUpdateTransaction } from "@triton-one/yellowstone-grpc";
2

3
// Quicknode endpoints consist of two crucial components: the endpoint name and the corresponding token
4
// For eg: QN Endpoint: https://docs-demo.solana-mainnet.quiknode.pro/abcde123456789
5
// endpoint will be: docs-demo.solana-mainnet.quiknode.pro:10000  {10000 is the port number for gRPC}
6
// token will be : abcde123456789
7

8
const PUNTO FINAL = "TU_QN_ENDPOINT:10000";
9
const TOKEN = "TU_NÚMERO_DE_TOKEN";
10

11
asíncrono función main() {
12
    const client = new Client(ENDPOINT, TOKEN, {});
13

14
    const compromiso = NivelDeCompromiso.CONFIRMADO;
15

16
    prueba {
17
        const stream = await client.subscribe();
18

19
        // Set up error and end handlers
20
        stream.on("error", (error) => {
21
            console.error("Stream error:", error);
22
            stream.end();
23
        });
24

25
        stream.on("end", () => {
26
            console.log("Stream ended");
27
        });
28

29
        // Handle incoming data
30
        stream.on("data", (data: SubscribeUpdate) => {
31
            handleSubscribeUpdate(data);
32
        });
33

34
        // Create subscription request
35
        const request: SubscribeRequest = {
36
            slots: { client: { filterByCommitment: true } },
37
            transactions: {
38
                client: {
39
                    vote: false,
40
                    failed: false,
41
                    signature: undefined,
42
                    accountInclude: [],
43
                    accountExclude: [],
44
                    accountRequired: [],
45
                },
46
            },
47
            commitment: commitment,
48
            accounts: {},
49
            transactionsStatus: {},
50
            entry: {},
51
            blocks: {},
52
            blocksMeta: {},
53
            accountsDataSlice: [],
54
            ping: undefined,
55
        };
56

57
        // Send subscription request
58
        await new Promise<void>((resolve, reject) => {
59
            stream.write(request, (err: Error | null | undefined) => {
60
                if (err) {
61
                    reject(err);
62
                } else {
63
                    resolve();
64
                }
65
            });
66
        });
67

68
        console.log("Subscription started. Waiting for events...");
69

70
        // Keep the script running
71
        await new Promise(() => {});
72

73
    } catch (error) {
74
        console.error("Error in subscription process:", error);
75
    }
76
}
77

78
function handleSubscribeUpdate(data: SubscribeUpdate) {
79
    if ("slot" in data) {
80
        console.log("Slot update:", data.slot);
81
    } else if ("transaction" in data) {
82
        const transaction = data.transaction as SubscribeUpdateTransaction;
83
        if (transaction && transaction.transaction) {
84
            console.log("Transaction update:", {
85
                signature: Buffer.from(transaction.transaction.signature).toString('base64'),
86
                slot: transaction.slot,
87
            });
88
        }
89
    } else {
90
        console.log("Other update:", data);
91
    }
92
}
93

94
principal()
95
    .captura((err) => {
96
        consola.error(«Error no gestionado:», err);
97
        proceso.salir(1);
98
    });

1
import Client, { CommitmentLevel, SubscribeRequest, SubscribeUpdate, SubscribeUpdateTransaction } from "@triton-one/yellowstone-grpc";
2

3
// Quicknode endpoints consist of two crucial components: the endpoint name and the corresponding token
4
// For eg: QN Endpoint: https://docs-demo.solana-mainnet.quiknode.pro/abcde123456789
5
// endpoint will be: docs-demo.solana-mainnet.quiknode.pro:10000  {10000 is the port number for gRPC}
6
// token will be : abcde123456789
7

8
const PUNTO FINAL = "TU_QN_ENDPOINT:10000";
9
const TOKEN = "TU_NÚMERO_DE_TOKEN";
10

11
asíncrono función main() {
12
    const client = new Client(ENDPOINT, TOKEN, {});
13

14
    const compromiso = NivelDeCompromiso.CONFIRMADO;
15

16
    prueba {
17
        const stream = await client.subscribe();
18

19
        // Set up error and end handlers
20
        stream.on("error", (error) => {
21
            console.error("Stream error:", error);
22
            stream.end();
23
        });
24

25
        stream.on("end", () => {
26
            console.log("Stream ended");
27
        });
28

29
        // Handle incoming data
30
        stream.on("data", (data: SubscribeUpdate) => {
31
            handleSubscribeUpdate(data);
32
        });
33

34
        // Create subscription request
35
        const request: SubscribeRequest = {
36
            slots: { client: { filterByCommitment: true } },
37
            transactions: {
38
                client: {
39
                    vote: false,
40
                    failed: false,
41
                    signature: undefined,
42
                    accountInclude: [],
43
                    accountExclude: [],
44
                    accountRequired: [],
45
                },
46
            },
47
            commitment: commitment,
48
            accounts: {},
49
            transactionsStatus: {},
50
            entry: {},
51
            blocks: {},
52
            blocksMeta: {},
53
            accountsDataSlice: [],
54
            ping: undefined,
55
        };
56

57
        // Send subscription request
58
        await new Promise<void>((resolve, reject) => {
59
            stream.write(request, (err: Error | null | undefined) => {
60
                if (err) {
61
                    reject(err);
62
                } else {
63
                    resolve();
64
                }
65
            });
66
        });
67

68
        console.log("Subscription started. Waiting for events...");
69

70
        // Keep the script running
71
        await new Promise(() => {});
72

73
    } catch (error) {
74
        console.error("Error in subscription process:", error);
75
    }
76
}
77

78
function handleSubscribeUpdate(data: SubscribeUpdate) {
79
    if ("slot" in data) {
80
        console.log("Slot update:", data.slot);
81
    } else if ("transaction" in data) {
82
        const transaction = data.transaction as SubscribeUpdateTransaction;
83
        if (transaction && transaction.transaction) {
84
            console.log("Transaction update:", {
85
                signature: Buffer.from(transaction.transaction.signature).toString('base64'),
86
                slot: transaction.slot,
87
            });
88
        }
89
    } else {
90
        console.log("Other update:", data);
91
    }
92
}
93

94
principal()
95
    .captura((err) => {
96
        consola.error(«Error no gestionado:», err);
97
        proceso.salir(1);
98
    });

¿Aún no tienes una cuenta?

Crea tu punto de conexión de Quicknode en cuestión de segundos y empieza a desarrollar

Empieza gratis