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

cleanups

This commit is contained in:
GroovieGermanikus 2024-06-13 10:14:04 +02:00
parent 4c2f41d441
commit c3e4370a7f
No known key found for this signature in database
GPG Key ID: 5B6EB831A5CD2015
3 changed files with 5 additions and 9 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

8
examples/stream_blocks_mainnet_task.rs
View File

@ -5,9 +5,7 @@ use std::env;
use base64::Engine;
use itertools::Itertools;
use solana_sdk::borsh0_10::try_from_slice_unchecked;
/// This file mocks the core model of the RPC server.
use solana_sdk::{borsh0_10, borsh0_9, compute_budget};
use solana_sdk::compute_budget::ComputeBudgetInstruction;
use solana_sdk::hash::Hash;
use solana_sdk::instruction::CompiledInstruction;
@ -118,7 +116,7 @@ pub async fn main() {
subscribe_timeout: Duration::from_secs(5),
receive_timeout: Duration::from_secs(5),
};
let (exit_send, exit_notify) = tokio::sync::broadcast::channel(1);
let (_exit_send, exit_notify) = tokio::sync::broadcast::channel(1);
let green_config =
GrpcSourceConfig::new(grpc_addr_green, grpc_x_token_green, None, timeouts.clone());
@ -271,7 +269,7 @@ pub fn map_produced_block(
.iter()
.find_map(|i| {
if i.program_id(message.static_account_keys())
.eq(&compute_budget::id())
.eq(&solana_sdk::compute_budget::id())
{
if let Ok(ComputeBudgetInstruction::SetComputeUnitLimit(limit)) =
solana_sdk::borsh1::try_from_slice_unchecked(i.data.as_slice())
@ -287,7 +285,7 @@ pub fn map_produced_block(
.iter()
.find_map(|i| {
if i.program_id(message.static_account_keys())
.eq(&compute_budget::id())
.eq(&solana_sdk::compute_budget::id())
{
if let Ok(ComputeBudgetInstruction::SetComputeUnitPrice(price)) =
solana_sdk::borsh1::try_from_slice_unchecked(i.data.as_slice())

2
examples/stream_blocks_single.rs
View File

@ -73,7 +73,7 @@ pub async fn main() {
tracing_subscriber::fmt::init();
// console_subscriber::init();
let COMMITMENT_LEVEL = CommitmentConfig::processed();
const COMMITMENT_LEVEL: CommitmentConfig = CommitmentConfig::processed();
let grpc_addr_green = env::var("GRPC_ADDR").expect("need grpc url for green");
let grpc_x_token_green = env::var("GRPC_X_TOKEN").ok();

4
src/yellowstone_grpc_util.rs
View File

@ -1,14 +1,12 @@
use std::time::Duration;
use tonic_health::pb::health_client::HealthClient;
use yellowstone_grpc_client::{GeyserGrpcBuilder, GeyserGrpcBuilderError, GeyserGrpcBuilderResult, GeyserGrpcClient, GeyserGrpcClientError, GeyserGrpcClientResult, InterceptorXToken};
use yellowstone_grpc_proto::geyser::geyser_client::GeyserClient;
use yellowstone_grpc_proto::geyser::SubscribeRequest;
use yellowstone_grpc_proto::prost::bytes::Bytes;
use tonic;
use tonic::metadata::errors::InvalidMetadataValue;
use tonic::metadata::AsciiMetadataValue;
use tonic::service::Interceptor;
use tonic::transport::{Channel, ClientTlsConfig, Endpoint};
use tonic::transport::ClientTlsConfig;
pub type GeyserGrpcWrappedResult<T> = Result<T, GrpcErrorWrapper>;