blockworks-foundation
/
mango-feeds
mirror of https://github.com/blockworks-foundation/mango-feeds.git
1
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

grpc1.11.2+solana_1.17.12

This commit is contained in:
godmodegalactus 2023-12-26 12:25:43 +01:00
parent 7c844614b9
commit 2bb31a4b25
No known key found for this signature in database
GPG Key ID: 22DA4A30887FDA3C
3 changed files with 1441 additions and 1016 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

2433
Cargo.lock generated
View File

File diff suppressed because it is too large Load Diff

17
Cargo.toml
View File

@ -8,14 +8,14 @@ members = [
jsonrpc-core-client = { git = "https://github.com/ckamm/jsonrpc.git", branch = "ckamm/http-with-gzip-default-v18.0.0" }
[workspace.dependencies]
solana-rpc = "~1.16.7"
solana-client = "~1.16.7"
solana-account-decoder = "~1.16.7"
solana-sdk = "~1.16.7"
solana-logger = "~1.16.7"
solana-rpc = "~1.17.12"
solana-client = "~1.17.12"
solana-account-decoder = "~1.17.12"
solana-sdk = "~1.17.12"
solana-logger = "~1.17.12"
yellowstone-grpc-client = "1.9.0"
yellowstone-grpc-proto = "1.9.0"
yellowstone-grpc-client = {git = "https://github.com/rpcpool/yellowstone-grpc.git", tag = "v1.11.2+solana.1.17.12"}
yellowstone-grpc-proto = {git = "https://github.com/rpcpool/yellowstone-grpc.git", tag = "v1.11.2+solana.1.17.12"}
jsonrpc-core = "18.0.0"
jsonrpc-core-client = { version = "18.0.0", features = ["ws", "http"] }
@ -44,7 +44,8 @@ jemallocator = "0.3.2"
chrono = "0.4.23"
clap = { version = "3.1.8", features = ["derive", "env"] }
tokio = { version = "1", features = ["full"] }
tokio = { version = "1.28.1", features = ["full"] }
tokio-util = "0.7.10"
tokio-tungstenite = "0.17"
rustls = "0.20.8"

7
connector/src/grpc_plugin_source.rs
View File

@ -115,7 +115,9 @@ async fn feed_data_geyser(
}
}
slots.insert("client".to_owned(), SubscribeRequestFilterSlots {});
slots.insert("client".to_owned(), SubscribeRequestFilterSlots {
filter_by_commitment: None,
});
let request = SubscribeRequest {
accounts,
@ -126,6 +128,7 @@ async fn feed_data_geyser(
slots,
transactions,
accounts_data_slice: vec![],
ping: None,
};
info!("Going to send request: {:?}", request);
@ -267,6 +270,7 @@ async fn feed_data_geyser(
UpdateOneof::BlockMeta(_) => {},
UpdateOneof::Entry(_) => {},
UpdateOneof::Ping(_) => {},
UpdateOneof::Pong(_) => {},
}
sender.send(Message::GrpcUpdate(update)).await.expect("send success");
},
@ -531,6 +535,7 @@ pub async fn process_events(
UpdateOneof::BlockMeta(_) => {}
UpdateOneof::Entry(_) => {}
UpdateOneof::Ping(_) => {}
UpdateOneof::Pong(_) => {}
}
}
Message::Snapshot(update) => {