idontwant duplicate config

cli.hpp

@@ -701,6 +701,8 @@ struct SimulationConfig {
     yaml.at({"gossip", "mesh_n"}).get(gossip_config.mesh_n);
     yaml.at({"gossip", "non_mesh_n"}).get(gossip_config.non_mesh_n);
     yaml.at({"gossip", "idontwant"}).get(gossip_config.idontwant);
+    yaml.at({"gossip", "idontwant_duplicate"})
+        .get(gossip_config.idontwant_duplicate);
 
     auto &consts = beamsim::consts();
     yaml.at({"consts", "signature_time"}).get(consts.signature_time);

src/beamsim/gossip/config.hpp

@@ -7,5 +7,6 @@ namespace beamsim::gossip {
     PeerIndex mesh_n = 4;
     PeerIndex non_mesh_n = 4;
     bool idontwant = true;
+    bool idontwant_duplicate = true;
   };
 }  // namespace beamsim::gossip

src/beamsim/gossip/peer.hpp

@@ -70,7 +70,9 @@ namespace beamsim::gossip {
           continue;
         }
         auto message_hash = publish.message->hash();
-        if (config_.idontwant) {
+        if (config_.idontwant
+            and (config_.idontwant_duplicate
+                 or not duplicate_cache_.contains(message_hash))) {
           for (auto &to_peer : views_.at(publish.topic_index).publishTo()) {
             if (to_peer == from_peer) {
               continue;