Send initial events first followed by other early events

gnosisguild · Sep 13, 2024 · 13fc7aa · 13fc7aa
1 parent bd48529
commit 13fc7aa
Showing 1 changed file with 3 additions and 3 deletions.
diff --git a/packages/ciphernode/core/src/registry.rs b/packages/ciphernode/core/src/registry.rs
@@ -208,32 +208,32 @@ impl Registry {
         if let Some(act) = self.public_keys.get(e3_id) {
             let msgs = self.get_msgs(e3_id.clone(), "public_keys");
             let recipient = act.clone().recipient();
+            recipient.do_send(msg.clone());
             for m in msgs {
                 recipient.do_send(m);
             }
-            recipient.do_send(msg.clone());
         } else {
             self.store_msg(e3_id.clone(), msg.clone(), "public_keys");
         }
 
         if let Some(act) = self.plaintexts.get(e3_id) {
             let msgs = self.get_msgs(e3_id.clone(), "plaintexts");
             let recipient = act.clone().recipient();
+            recipient.do_send(msg.clone());
             for m in msgs {
                 recipient.do_send(m);
             }
-            recipient.do_send(msg.clone());
         } else {
             self.store_msg(e3_id.clone(), msg.clone(), "plaintexts");
         }
 
         if let Some(act) = self.ciphernodes.get(e3_id) {
             let msgs = self.get_msgs(e3_id.clone(), "ciphernodes");
             let recipient = act.clone().recipient();
+            recipient.do_send(msg.clone());
             for m in msgs {
                 recipient.do_send(m);
             }
-            recipient.do_send(msg.clone());
         } else {
             self.store_msg(e3_id.clone(), msg.clone(), "ciphernodes");
         }