subscribe gRPC Method - Solana gRPC

Solana gRPC est inclus dans les plans Scale et Business. Pour les plans Build et Accelerate, il reste disponible via l'extension Solana gRPC.

Paramètres

Cette méthode n'accepte aucun paramètre

Renvoie

résultat

objet

Chargement...

Requête

1
package main
2

3
import (
4
	"context"
5
	"crypto/tls"
6
	"fmt"
7
	"log"
8
	"time"
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
	endpoint = "YOUR_QN_ENDPOINT:10000"
27
	token    = "YOUR_TOKEN_NUMBER"
28
)
29

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

38
	conn, err := grpc.NewClient(endpoint, opts...)
39
	if err != nil {
40
		log.Fatalf("Échec de la connexion : %v", err)
41
	}
42
	defer conn.Close()
43

44
	client := 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
        return
64
    }
65

66
    if err = stream.Send(subReq); err != nil {
67
        fmt.Printf("Failed to send subscription request: %v\n", err)
68
        return
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
            return
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
package main
2

3
import (
4
	"context"
5
	"crypto/tls"
6
	"fmt"
7
	"log"
8
	"time"
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
	endpoint = "YOUR_QN_ENDPOINT:10000"
27
	token    = "YOUR_TOKEN_NUMBER"
28
)
29

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

38
	conn, err := grpc.NewClient(endpoint, opts...)
39
	if err != nil {
40
		log.Fatalf("Échec de la connexion : %v", err)
41
	}
42
	defer conn.Close()
43

44
	client := 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
        return
64
    }
65

66
    if err = stream.Send(subReq); err != nil {
67
        fmt.Printf("Failed to send subscription request: %v\n", err)
68
        return
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
            return
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 POINT D'EXTRÉMITÉ = "VOTRE_POINT_D'ACCÈS_QN:10000";
9
const TOKEN = "VOTRE_NUMÉRO_DE_TOKEN";
10

11
async function main() {
12
    const client = new Client(ENDPOINT, TOKEN, {});
13

14
    const engagement = Niveau d'engagement.CONFIRMÉ;
15

16
    essayer {
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
main()
95
    .catch((err) => {
96
        console.error("Erreur non gérée :", err);
97
        process.exit(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 POINT D'EXTRÉMITÉ = "VOTRE_POINT_D'ACCÈS_QN:10000";
9
const TOKEN = "VOTRE_NUMÉRO_DE_TOKEN";
10

11
async function main() {
12
    const client = new Client(ENDPOINT, TOKEN, {});
13

14
    const engagement = Niveau d'engagement.CONFIRMÉ;
15

16
    essayer {
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
main()
95
    .catch((err) => {
96
        console.error("Erreur non gérée :", err);
97
        process.exit(1);
98
    });

Vous n'avez pas encore de compte ?

Créez votre endpoint Quicknode en quelques secondes et commencez à développer

Commencez gratuitement