From 4a6b39d054717de52925bee4cb9df2287c54ba9e Mon Sep 17 00:00:00 2001 From: GroovieGermanikus Date: Fri, 7 Jun 2024 09:45:55 +0200 Subject: [PATCH] prefix rpc tests --- README.md | 2 +- src/rpcnode_check_alive.rs | 8 ++++---- src/rpcnode_define_checks.rs | 16 ++++++++-------- 3 files changed, 13 insertions(+), 13 deletions(-) diff --git a/README.md b/README.md index 04bad10..e04619b 100644 --- a/README.md +++ b/README.md @@ -7,7 +7,7 @@ RUST_LOG=info,rpc_node_check_alive=debug RPCNODE_LABEL=nodename -CHECKS_ENABLED=Gpa,TokenAccouns,Gsfa,GetAccountInfo,GeyserAllAccounts,GeyserTokenAccount,WebsocketAccount +CHECKS_ENABLED=RpcGpa,RpcTokenAccouns,RpcGsfa,RpcGetAccountInfo,GeyserAllAccounts,GeyserTokenAccount,WebsocketAccount RPC_HTTP_ADDR=https://... RPC_WS_ADDR=wss://... GRPC_ADDR=http://....:10000/ diff --git a/src/rpcnode_check_alive.rs b/src/rpcnode_check_alive.rs index 2f5d99f..7f85020 100644 --- a/src/rpcnode_check_alive.rs +++ b/src/rpcnode_check_alive.rs @@ -19,10 +19,10 @@ enum CheckResult { #[derive(Clone, Debug, PartialEq, Sequence)] enum Check { - Gpa, - TokenAccouns, - Gsfa, - GetAccountInfo, + RpcGpa, + RpcTokenAccouns, + RpcGsfa, + RpcGetAccountInfo, GeyserAllAccounts, GeyserTokenAccount, WebsocketAccount, diff --git a/src/rpcnode_define_checks.rs b/src/rpcnode_define_checks.rs index 5852d1e..0d0fb3e 100644 --- a/src/rpcnode_define_checks.rs +++ b/src/rpcnode_define_checks.rs @@ -27,30 +27,30 @@ use yellowstone_grpc_proto::geyser::subscribe_update::UpdateOneof; use yellowstone_grpc_proto::geyser::{SubscribeRequest, SubscribeRequestFilterAccounts}; pub fn define_checks(checks_enabled: &[Check], all_check_tasks: &mut JoinSet) { - if checks_enabled.contains(&Check::Gpa) { + if checks_enabled.contains(&Check::RpcGpa) { let rpc_client = read_rpc_config(); - add_task(Check::Gpa, rpc_gpa(rpc_client.clone()), all_check_tasks); + add_task(Check::RpcGpa, rpc_gpa(rpc_client.clone()), all_check_tasks); } - if checks_enabled.contains(&Check::TokenAccouns) { + if checks_enabled.contains(&Check::RpcTokenAccouns) { let rpc_client = read_rpc_config(); add_task( - Check::TokenAccouns, + Check::RpcTokenAccouns, rpc_get_token_accounts_by_owner(rpc_client.clone()), all_check_tasks, ); } - if checks_enabled.contains(&Check::Gsfa) { + if checks_enabled.contains(&Check::RpcGsfa) { let rpc_client = read_rpc_config(); add_task( - Check::Gsfa, + Check::RpcGsfa, rpc_get_signatures_for_address(rpc_client.clone()), all_check_tasks, ); } - if checks_enabled.contains(&Check::GetAccountInfo) { + if checks_enabled.contains(&Check::RpcGetAccountInfo) { let rpc_client = read_rpc_config(); add_task( - Check::GetAccountInfo, + Check::RpcGetAccountInfo, rpc_get_account_info(rpc_client.clone()), all_check_tasks, );