fix: remove incorrect limit (#1036)

Fixes a bug where the call to get_committee would only return one validator instead of all of them
tari-project · May 20, 2024 · cbcd92f · cbcd92f
1 parent 9ef62bb
commit cbcd92f
Show file tree

Hide file tree

Showing 2 changed files with 7 additions and 1 deletion.
diff --git a/applications/tari_indexer/src/event_manager.rs b/applications/tari_indexer/src/event_manager.rs
@@ -293,6 +293,13 @@ impl EventManager {
         );
 
         for (member, _) in &committee.members {
+            debug!(
+                target: LOG_TARGET,
+                "Trying to get blocks from VN {} (epoch={}, shard={})",
+                member,
+                epoch,
+                shard
+            );
             let resp = self.get_blocks_from_vn(member, start_block_id).await;
 
             match resp {

diff --git a/dan_layer/storage_sqlite/src/global/backend_adapter.rs b/dan_layer/storage_sqlite/src/global/backend_adapter.rs
@@ -531,7 +531,6 @@ impl<TAddr: NodeAddressable> GlobalDbAdapter for SqliteGlobalDbAdapter<TAddr> {
             ))
             .filter(committees::epoch.eq(epoch.as_u64() as i64))
             .filter(validator_nodes::sidechain_id.eq(db_sidechain_id))
-            .limit(1)
             .load::<(i64, String, Vec<u8>)>(tx.connection())
             .map_err(|source| SqliteStorageError::DieselError {
                 source,