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

update yellowstone to v1.15.0+solana.1.17

This commit is contained in:
GroovieGermanikus 2024-07-31 21:38:45 +02:00
parent 14c815f416
commit d0a6dff5a3
No known key found for this signature in database
GPG Key ID: 5B6EB831A5CD2015
3 changed files with 34 additions and 1533 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

1530
Cargo.lock generated
View File

File diff suppressed because it is too large Load Diff

4
Cargo.toml
View File

@ -15,8 +15,8 @@ solana-account-decoder = "1.17"
solana-sdk = "1.17"
solana-logger = "1.17"
yellowstone-grpc-client = "1.13.0"
yellowstone-grpc-proto = "1.13.0"
yellowstone-grpc-client = { version = "1.15.0", git = "https://github.com/blockworks-foundation/yellowstone-grpc.git", tag = "v1.15.0+solana.1.17" }
yellowstone-grpc-proto = { version = "1.14.0", git = "https://github.com/blockworks-foundation/yellowstone-grpc.git", tag = "v1.15.0+solana.1.17" }
jsonrpc-core = "18.0.0"
jsonrpc-core-client = { version = "18.0.0", features = ["ws", "http"] }

33
connector/src/grpc_plugin_source.rs
View File

@ -93,9 +93,6 @@ async fn feed_data_geyser(
let mut accounts = HashMap::new();
let mut slots = HashMap::new();
let blocks = HashMap::new();
let transactions = HashMap::new();
let blocks_meta = HashMap::new();
match &filter_config.entity_filter {
EntityFilter::FilterByProgramId(program_id) => {
@ -133,15 +130,10 @@ async fn feed_data_geyser(
{
let request = SubscribeRequest {
accounts: Default::default(),
blocks,
blocks_meta,
entry: Default::default(),
commitment: None,
slots,
transactions,
accounts_data_slice: vec![],
ping: None,
..Default::default()
};
let response = client.subscribe(once(async move { request })).await?;
subscriptions.insert(usize::MAX, response.into_inner());
@ -157,14 +149,9 @@ async fn feed_data_geyser(
for (i, accounts) in account_chunks.into_iter().enumerate() {
let request = SubscribeRequest {
accounts,
blocks: Default::default(),
blocks_meta: Default::default(),
entry: Default::default(),
commitment: None,
slots: Default::default(),
transactions: Default::default(),
accounts_data_slice: vec![],
ping: None,
..Default::default()
};
let response = client.subscribe(once(async move { request })).await?;
subscriptions.insert(i, response.into_inner());
@ -313,13 +300,8 @@ async fn feed_data_geyser(
// Rewrite the update to use the local write version and bump it
write.write_version = write_version_mapping.slot as u64;
write_version_mapping.slot += 1;
},
UpdateOneof::Block(_) => {},
UpdateOneof::Transaction(_) => {},
UpdateOneof::BlockMeta(_) => {},
UpdateOneof::Entry(_) => {},
UpdateOneof::Ping(_) => {},
UpdateOneof::Pong(_) => {},
}
_ => {}
}
sender.send(Message::GrpcUpdate(update)).await.expect("send success");
},
@ -592,12 +574,7 @@ pub async fn process_events(
.await
.expect("send success");
}
UpdateOneof::Block(_) => {}
UpdateOneof::Transaction(_) => {}
UpdateOneof::BlockMeta(_) => {}
UpdateOneof::Entry(_) => {}
UpdateOneof::Ping(_) => {}
UpdateOneof::Pong(_) => {}
_ => {}
}
}
Message::Snapshot(update) => {