Skip to content

Commit

Permalink
update mev-protos to the latest version (#4)
Browse files Browse the repository at this point in the history
  • Loading branch information
segfaultdoc authored Dec 17, 2023
1 parent 16ac3ad commit 06c46d4
Show file tree
Hide file tree
Showing 4 changed files with 10 additions and 2 deletions.
2 changes: 1 addition & 1 deletion examples/backrun/src/main.rs
Original file line number Diff line number Diff line change
Expand Up @@ -250,7 +250,7 @@ async fn backrun_loop(
{
Ok((mut searcher_client, cluster_data)) => {
let mempool_receiver = searcher_client
.subscribe_mempool_accounts(&accounts_to_backrun[..], 1_000)
.subscribe_mempool_accounts(&accounts_to_backrun[..], vec![], 1_000)
.await;
if let Err(e) = mempool_receiver {
mempool_subscription_conns_errs += 1;
Expand Down
2 changes: 1 addition & 1 deletion protos/mev-protos
Submodule mev-protos updated 1 files
+37 −4 searcher.proto
5 changes: 5 additions & 0 deletions rust-toolchain.toml
Original file line number Diff line number Diff line change
@@ -0,0 +1,5 @@
[toolchain]
# Needs to be compiled with the same rust version that the RPC loading this plugin was compiled with.
# https://github.com/solana-labs/solana/blob/v1.16.14/rust-toolchain.toml
channel = "1.73.0"
components = [ "rustfmt", "rustc-dev", "clippy", "cargo" ]
3 changes: 3 additions & 0 deletions searcher_client/src/lib.rs
Original file line number Diff line number Diff line change
Expand Up @@ -161,6 +161,8 @@ where
pub async fn subscribe_mempool_accounts(
&self,
accounts: &[Pubkey],
// Regions to subscribe to
regions: Vec<String>,
buffer_size: usize,
) -> SearcherClientResult<Receiver<Vec<VersionedTransaction>>> {
let (sender, receiver) = channel(buffer_size);
Expand All @@ -175,6 +177,7 @@ where
accounts: accounts.iter().map(|account| account.to_string()).collect(),
},
)),
regions,
})
.await?
.into_inner();
Expand Down

0 comments on commit 06c46d4

Please sign in to comment.