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

more cases on connect

This commit is contained in:
GroovieGermanikus 2024-01-18 13:30:49 +01:00
parent e093a589a2
commit def0853c0f
No known key found for this signature in database
GPG Key ID: 5B6EB831A5CD2015
1 changed files with 20 additions and 7 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

27
src/grpc_subscription_autoreconnect.rs
View File

@ -310,8 +310,6 @@ pub fn create_geyser_reconnecting_task(
let config = grpc_source.tls_config.clone();
let connect_timeout = grpc_source.timeouts.as_ref().map(|t| t.connect_timeout);
let request_timeout = grpc_source.timeouts.as_ref().map(|t| t.request_timeout);
let subscribe_timeout = grpc_source.timeouts.as_ref().map(|t| t.subscribe_timeout);
let subscribe_filter = subscribe_filter.clone();
log!(if attempt > 1 { Level::Warn } else { Level::Debug }, "Connecting attempt #{} to {}", attempt, addr);
let connect_result = GeyserGrpcClient::connect_with_timeout(
addr, token, config,
@ -320,17 +318,32 @@ pub fn create_geyser_reconnecting_task(
false)
.await;
match connect_result {
Ok(client) => {
Connected(attempt, client)
}
Err(_) => {
todo!()
Err(GeyserGrpcClientError::InvalidUri(_)) => {
FatalError(attempt)
}
Err(GeyserGrpcClientError::MetadataValueError(_)) => {
FatalError(attempt)
}
Err(GeyserGrpcClientError::InvalidXTokenLength(_)) => {
FatalError(attempt)
}
Err(GeyserGrpcClientError::TonicError(tonic_error)) => {
warn!("! connect failed on {} - aborting: {:?}", grpc_source, tonic_error);
FatalError(attempt)
}
Err(GeyserGrpcClientError::TonicStatus(tonic_status)) => {
warn!("! connect failed on {} - retrying: {:?}", grpc_source, tonic_status);
RecoverableConnectionError(attempt)
}
Err(GeyserGrpcClientError::SubscribeSendError(send_error)) => {
warn!("! connect failed with send error on {} - retrying: {:?}", grpc_source, send_error);
RecoverableConnectionError(attempt)
}
}
}
Connected(attempt, mut client) => {
let subscribe_timeout = grpc_source.timeouts.as_ref().map(|t| t.subscribe_timeout);