Avoid panicking and reconnect

blockworks-foundation · Jan 17, 2024 · a3e8e89 · a3e8e89
1 parent 4b78113
commit a3e8e89
Showing 1 changed file with 4 additions and 2 deletions.
diff --git a/src/grpc_subscription_autoreconnect.rs b/src/grpc_subscription_autoreconnect.rs
@@ -214,7 +214,8 @@ pub fn create_geyser_reconnecting_stream(
                             (ConnectionState::WaitReconnect(attempt), Message::Connecting(attempt))
                         },
                         Err(geyser_grpc_task_error) => {
-                            panic!("! task aborted - should not happen :{geyser_grpc_task_error}");
+                            log::error!("! task aborted - should not happen :{geyser_grpc_task_error}");
+                            (ConnectionState::WaitReconnect(attempt), Message::Connecting(attempt))
                         }
                     }
 
@@ -234,7 +235,8 @@ pub fn create_geyser_reconnecting_stream(
                         }
                         None =>  {
                             // should not arrive here, Mean the stream close.
-                            panic!("geyser stream closed on {} - retrying", grpc_source);
+                            log::error!("! ready stream closed");
+                            (ConnectionState::WaitReconnect(attempt), Message::Connecting(attempt))
                         }
                     }