2.0.16

Cargo.toml

@@ -1,6 +1,6 @@
 [package]
 name = "geyser-grpc-connector"
-version = "0.10.1+yellowstone.1.12"
+version = "0.11.0+yellowstone.2.0.0"
 edition = "2021"
 
 description = "Multiplexing and Reconnection on Yellowstone gRPC Geyser client streaming"
@@ -9,16 +9,16 @@ authors = ["GroovieGermanikus <[email protected]>"]
 repository = "https://github.com/blockworks-foundation/geyser-grpc-connector"
 
 [dependencies]
-yellowstone-grpc-client = { version = "1.13.0+solana.1.17.15", git = "https://github.com/rpcpool/yellowstone-grpc.git", tag = "v1.12.0+solana.1.17.15" }
-yellowstone-grpc-proto = { version = "1.12.0+solana.1.17.15", git = "https://github.com/rpcpool/yellowstone-grpc.git", tag = "v1.12.0+solana.1.17.15" }
-
+# note: as timewriting there are versions 3.0.0 and 4.0.0; we will come back to that later
+yellowstone-grpc-client = { version = "2.0.0", git = "https://github.com/rpcpool/yellowstone-grpc.git", tag = "v2.0.0+solana.2.0.16" }
+yellowstone-grpc-proto = { version = "2.0.0", git = "https://github.com/rpcpool/yellowstone-grpc.git", tag = "v2.0.0+solana.2.0.16" }
 
 # required for CommitmentConfig
-solana-sdk = "~1.17.15"
+solana-sdk = "~2.0.16"
 
 url = "2.5.0"
 async-stream = "0.3.5"
-tokio = { version = "1.28" , features = ["rt"] }
+tokio = { version = "1.28" , features = ["rt", "rt-multi-thread"] }
 futures = "0.3.28"
 merge-streams = "0.1.2"
 anyhow = "1.0.70"
@@ -31,7 +31,19 @@ base64 = "0.21.5"
 bincode = "1.3.3"
 
 csv = "1.3.0"
+dashmap = "6.1.0"
+tonic = { version= "0.12.3", features=["gzip"] }
+tonic-health = "0.12.3"
+regex = "1.10.4"
+clap = { version = "4.2", features = ["derive"] }
+
+lz4_flex = "0.11.3"
 
 [dev-dependencies]
 tracing-subscriber = "0.3.16"
-solana-logger = "1"
+solana-logger = "2"
+solana-account-decoder = "~2.0.16"
+
+[patch.crates-io.curve25519-dalek]
+git = "https://github.com/anza-xyz/curve25519-dalek.git"
+rev = "b500cdc2a920cd5bff9e2dd974d7b97349d61464"

README.md

@@ -23,7 +23,7 @@ These are the currently maintained versions of the library: [see Wiki](https://g
 ```cargo add geyser-grpc-connector ```
 
 
-An example how to use the library is provided in `stream_blocks_mainnet.rs`.
+An example how to use the library is provided in `stream_blocks_mainnet_stream.rs`.
 
 ## Known issues
 * Library does not support other data than Blocks/Slots very well.

ci/rust-version.sh

@@ -23,7 +23,7 @@
 if [[ -n $RUST_STABLE_VERSION ]]; then
   stable_version="$RUST_STABLE_VERSION"
 else
-  stable_version=1.70.0
+  stable_version=1.78.0
 fi
 
 if [[ -n $RUST_NIGHTLY_VERSION ]]; then
@@ -91,7 +91,7 @@ export rust_nightly_docker_image=solanalabs/rust-nightly:"$nightly_version"
 if [[ -n $RUST_STABLE_VERSION ]]; then
   stable_version="$RUST_STABLE_VERSION"
 else
-  stable_version=1.70.0
+  stable_version=1.78.0
 fi
 
 if [[ -n $RUST_NIGHTLY_VERSION ]]; then

examples/accounts_meta_to_csv.rs

@@ -0,0 +1,40 @@
+use itertools::Itertools;
+use std::fs::File;
+use std::io;
+use std::io::BufRead;
+use std::path::PathBuf;
+
+pub fn main() {
+    let accounts_meta_file =
+        PathBuf::from("/Users/stefan/mango/projects/geyser-misc/ledger-debug-accounts.txt");
+
+    let file = File::open(accounts_meta_file).expect("file must exist");
+    let reader = io::BufReader::new(file);
+    for blocks in &reader.lines().chunks(9) {
+        let blocks = blocks.collect_vec();
+        let account_pk = blocks[0].as_ref().unwrap().replace(':', "");
+        if account_pk.is_empty() {
+            break;
+        }
+        let owner_pk = blocks[2].as_ref().unwrap();
+        let ltick = owner_pk.find('\'');
+        let rtick = owner_pk.rfind('\'');
+        let owner_pk = &owner_pk[ltick.unwrap() + 1..rtick.unwrap()];
+
+        let data_len = blocks[6].as_ref().unwrap().replace("  data_len: ", "");
+
+        println!("{};{};{}", account_pk, owner_pk, data_len);
+    }
+}
+
+/*
+16FMCmgLzCNNz6eTwGanbyN2ZxvTBSLuQ6DZhgeMshg:
+  balance: 0.00095352 SOL
+  owner: 'Feature111111111111111111111111111111111111'
+  executable: false
+  slot: 0
+  rent_epoch: 0
+  data_len: 9
+  data: 'AQAAAAAAAAAA'
+  encoding: "base64"
+*/