fix: realtime indexer condition

blockscout · Jan 9, 2024 · b74b9f6 · b74b9f6
1 parent e3adf9d
commit b74b9f6
Show file tree

Hide file tree

Showing 2 changed files with 2 additions and 2 deletions.
diff --git a/user-ops-indexer/user-ops-indexer-logic/src/indexer/v06/indexer.rs b/user-ops-indexer/user-ops-indexer-logic/src/indexer/v06/indexer.rs
@@ -60,7 +60,7 @@ impl<'a, C: PubsubClient> IndexerV06<'a, C> {
                     .subscribe_logs(&filter)
                     .await?
                     .filter_map(|log| {
-                        future::ready(if log.removed == Some(true) {
+                        future::ready(if log.removed != Some(true) {
                             log.transaction_hash
                         } else {
                             None

diff --git a/user-ops-indexer/user-ops-indexer-server/src/indexer.rs b/user-ops-indexer/user-ops-indexer-server/src/indexer.rs
@@ -8,7 +8,7 @@ pub async fn run(
 ) -> Result<(), anyhow::Error> {
     tracing::info!("connecting to rpc");
 
-    let ws_client = Ws::connect_with_reconnects(settings.indexer.rpc_url, 3).await?;
+    let ws_client = Ws::connect_with_reconnects(settings.indexer.rpc_url, 20).await?;
     let client = Provider::new(ws_client);
 
     if settings.indexer.entrypoints.v06 {