Gmg/refactor gyser rpc

Cargo.toml

@@ -5,11 +5,12 @@ members = [
     "lite-rpc",
     "quic-forward-proxy",
     "quic-forward-proxy-integration-test",
+    "cluster-endpoints",
     "bench"
 ]
 
 [workspace.package]
-version = "0.2.2"
+version = "0.2.3"
 authors = ["gmgalactus <[email protected]>", "Aniket Prajapati <[email protected]>"]
 repository = "https://github.com/blockworks-foundation/lite-rpc"
 license = "AGPL"
@@ -51,6 +52,10 @@ dotenv = "0.15.0"
 async-channel = "1.8.0"
 quinn = "0.9.3"
 rustls = { version = "=0.20.8", default-features = false }
-solana-lite-rpc-services = {path = "services", version="0.2.2"}
-solana-lite-rpc-core = {path = "core", version="0.2.2"}
+solana-lite-rpc-services = {path = "services", version="0.2.3"}
+solana-lite-rpc-core = {path = "core", version="0.2.3"}
+solana-lite-rpc-cluster-endpoints = {path = "cluster-endpoints", version="0.2.3"}
+
 async-trait = "0.1.68"
+yellowstone-grpc-client = "1.9.0"
+yellowstone-grpc-proto = "1.9.0"

bench/Cargo.toml

@@ -1,6 +1,6 @@
 [package]
 name = "bench"
-version = "0.2.2"
+version = "0.2.3"
 edition = "2021"
 
 [dependencies]

cluster-endpoints/Cargo.toml

@@ -0,0 +1,40 @@
+[package]
+name = "solana-lite-rpc-cluster-endpoints"
+version = "0.2.3"
+edition = "2021"
+description = "Core classes and methods used by solana lite rpc"
+rust-version = "1.67.1"
+repository = "https://github.com/blockworks-foundation/lite-rpc"
+license = "AGPL"
+
+[dependencies]
+solana-sdk = { workspace = true }
+solana-rpc-client-api = { workspace = true }
+solana-transaction-status = { workspace = true }
+solana-version = { workspace = true }
+solana-client = { workspace = true }
+solana-net-utils = { workspace = true }
+solana-pubsub-client = { workspace = true }
+solana-streamer = { workspace = true }
+serde = { workspace = true }
+serde_json = { workspace = true }
+tokio = "1.*"
+bincode = { workspace = true }
+bs58 = { workspace = true }
+base64 = { workspace = true }
+thiserror = { workspace = true }
+futures = { workspace = true }
+bytes = { workspace = true }
+anyhow = { workspace = true }
+log = { workspace = true }
+dashmap = { workspace = true }
+quinn = { workspace = true }
+chrono = { workspace = true }
+rustls = { workspace = true }
+async-trait = { workspace = true }
+derive_more = "0.99.17"
+async-channel = { workspace = true }
+solana-lite-rpc-core = { workspace = true }
+yellowstone-grpc-client = { workspace = true }
+yellowstone-grpc-proto = { workspace = true }
+itertools = {workspace = true}

cluster-endpoints/src/endpoint_stremers.rs

@@ -0,0 +1,9 @@
+use solana_lite_rpc_core::streams::{
+    BlockStream, ClusterInfoStream, SlotStream, VoteAccountStream,
+};
+pub struct EndpointStreaming {
+    pub blocks_notifier: BlockStream,
+    pub slot_notifier: SlotStream,
+    pub vote_account_notifier: VoteAccountStream,
+    pub cluster_info_notifier: ClusterInfoStream,
+}