Take subscriptions into account in all_messages_to_tracked_chains_del…

…ivered_up_to.
afck · Nov 4, 2024 · 6bef71d · 6bef71d
1 parent e3db8d0
commit 6bef71d
Showing 1 changed file with 13 additions and 1 deletion.
diff --git a/linera-core/src/chain_worker/state/mod.rs b/linera-core/src/chain_worker/state/mod.rs
@@ -518,8 +518,20 @@ where
         };
         let mut targets = self.chain.outboxes.indices().await?;
         {
+            let publishers = self
+                .chain
+                .execution_state
+                .system
+                .subscriptions
+                .indices()
+                .await?
+                .iter()
+                .map(|subscription| subscription.chain_id)
+                .collect::<HashSet<_>>();
             let tracked_chains = tracked_chains.read().unwrap();
-            targets.retain(|target| tracked_chains.contains(&target.recipient));
+            targets.retain(|target| {
+                tracked_chains.contains(&target.recipient) || publishers.contains(&target.recipient)
+            });
         }
         let outboxes = self.chain.outboxes.try_load_entries(&targets).await?;
         for outbox in outboxes {