richat

Next iteration of Yellowstone Dragon's Mouth / Geyser gRPC that was originally developed and currently maintained by Triton One. Richat includes code derived from Dragon's Mouth (copyright Triton One Limited) with significant architecture changes.

In addition to Yellowstone Drangon's Mouth / Geyser gRPC richat includes Solana PubSub implementation.

Please use issues only for reporting bugs or discussing feature-related topics. If you're having trouble loading a plugin or need guidance on how to use crates, please post your question in the Telegram group: https://t.me/lamportsdev

Sponsored by

Blueprint

flowchart LR
    P[plugin] -->|full stream| R1(richat)
    R1 -->|full stream| R2(richat)
    R2 -->|filtered stream| C1(client)
    R1 -->|filtered stream| C2(client)
    R1 -->|filtered stream| C3(client)
    R2 -->|filtered stream| C4(client)

flowchart LR
    subgraph agave1 [**agave**]
        subgraph geyser1 [richat-plugin-agave]
        end
    end

    subgraph agave2 [**agave**]
        subgraph geyser2 [richat-plugin-agave]
        end
    end

    subgraph richat0 [**richat**]
        subgraph richat0_server [richat-server]
        end
    end

    subgraph richat1 [**richat**]
        subgraph tokio1 [Tokio Runtime]
            richat1_tokio1_receiver(receiver)
            richat1_channel[(messages<br/>storage)]
        end

        subgraph tokio2 [Tokio Runtime]
            subgraph grpc1 [gRPC]
                richat1_grpc1_streaming1(streaming)
                richat1_grpc1_unary(unary)

                richat1_grpc1_blockmeta[(block meta<br/>storage)]
                richat1_grpc1_subscriptions[(clients<br/>subscriptions)]
            end

            subgraph pubsub1 [Solana PubSub]
                richat1_pubsub1_server(server)
            end

            subgraph richat_server1 [Richat]
                richat_server1_sender(server)
            end
        end

        subgraph pubsub1_pool [Filters Thread Pool]
            richat1_pubsub1_pool_worker1(worker 1)
            richat1_pubsub1_pool_worker2(worker N)
        end

        subgraph pubsub1_main [Subscriptions Thread]
            richat1_pubsub1_subscriptions[(clients<br/>subscriptions)]
        end

        subgraph blockmeta_recv [BlockMeta Thread]
            richat1_blockmeta_recv_thread(blockmeta receiver)
        end

        subgraph grpc_workers [gRPC Filters Thread Pool]
            richat1_grpc_worker1(worker 1)
            richat1_grpc_worker2(worker N)
        end
    end

    client1(client)
    client2(client)
    client3(client)

    geyser1 -->|Tcp / gRPC / Quic<br/>full stream| richat1_tokio1_receiver
    geyser2 -->|Tcp / gRPC / Quic<br/>full stream| richat1_tokio1_receiver
    richat0_server -->|Tcp / gRPC / Quic<br/>full stream| richat1_tokio1_receiver
    richat1_tokio1_receiver --> richat1_channel
    richat1_channel --> richat1_blockmeta_recv_thread
    richat1_channel --> richat1_grpc_worker1
    richat1_channel --> richat1_grpc_worker2
    richat1_blockmeta_recv_thread --> richat1_grpc1_blockmeta
    richat1_grpc1_blockmeta <--> richat1_grpc1_unary
    richat1_grpc_worker1 <--> richat1_grpc1_subscriptions
    richat1_grpc_worker2 <--> richat1_grpc1_subscriptions
    richat1_grpc1_subscriptions <--> richat1_grpc1_streaming1
    client1 <--> |gRPC<br/>filtered stream| richat1_grpc1_streaming1
    client1 --> richat1_grpc1_unary
    richat1_channel --> richat_server1_sender
    richat_server1_sender -->|Tcp / gRPC / Quic<br/>full stream| client2
    richat1_channel --> richat1_pubsub1_subscriptions
    richat1_pubsub1_subscriptions <--> richat1_pubsub1_pool_worker1
    richat1_pubsub1_subscriptions <--> richat1_pubsub1_pool_worker2
    richat1_pubsub1_subscriptions <--> richat1_pubsub1_server
    richat1_pubsub1_server <-->|WebSocket| client3

Components

• cli — CLI client for full stream, gRPC stream with filters, simple Solana PubSub
• client — library for building consumers
• filter — library for filtering geyser messages
• plugin-agave — Agave validator geyser plugin https://docs.anza.xyz/validator/geyser
• proto — library with proto files, re-imports structs from crate yellowstone-grpc-proto
• richat — app with full stream consumer and producers: gRPC (Dragon's Mouth), Solana PubSub
• shared — shared code between components (except client)

Releases

Branches

• master — development branch
• agave-v2.0 — development branch for agave v2.0
• agave-v2.1 — development branch for agave v2.1
• agave-v2.2 — development branch for agave v2.2

Tags

• cli-v0.0.0
• client-v0.0.0
• filter-v0.0.0
• plugin-agave-v0.0.0
• plugin-agave-v0.0.0+solana.2.1.5
• proto-v0.0.0
• richat-v0.0.0
• shared-v0.0.0

At one moment of time we can support more than one agave version (like v2.0 and v2.1), as result we can have two different major supported versions of every component, for example: cli-v1.y.z for agave-v2.0 and cli-v2.y.z for agave-v2.1. In addition to standard version, plugin-agave can have one or more tags with pinned solana version.

List of RPC providers with Dragon's Mouth support

• ERPC — https://erpc.global/en/
• Gadfly Node — https://gadflynode.com/
• Geeks Labs — https://discord.gg/geekslabs
• GetBlock — https://getblock.io/
• Helius — https://www.helius.dev/
• InstantNodes — https://instantnodes.io/
• OrbitFlare — https://orbitflare.com/
• PublicNode — https://solana-rpc.publicnode.com/
• QuickNode — https://www.quicknode.com/
• Shyft — https://shyft.to/
• Solana Tracker — https://www.solanatracker.io/solana-rpc
• SolSqueezer — https://solsqueezer.io/
• Triton One — https://triton.one/
• Urban Node — https://urbannode.io/

If your RPC provider not in the list, please open Issue / PR!