From b74b9f6f3d1ed10155e29fd8321317e65bc351a1 Mon Sep 17 00:00:00 2001
From: Kirill Fedoseev <kirill@blockscout.com>
Date: Tue, 9 Jan 2024 14:50:21 +0200
Subject: [PATCH] fix: realtime indexer condition

---
 .../user-ops-indexer-logic/src/indexer/v06/indexer.rs           | 2 +-
 user-ops-indexer/user-ops-indexer-server/src/indexer.rs         | 2 +-
 2 files changed, 2 insertions(+), 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
index f19f4c4ec..98733109b 100644
--- 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
index ef6afc67e..aa77a44d4 100644
--- 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 {