mvp Message::ConfigFile processing

components/bldr/src/config_file.rs

@@ -55,8 +55,8 @@ impl fmt::Display for ServiceGroup {
 /// The config file struct.
 #[derive(Clone, Debug, Eq, RustcDecodable, RustcEncodable)]
 pub struct ConfigFile {
-    service_group: ServiceGroup,
-    file_name: String,
+    pub service_group: ServiceGroup,
+    pub file_name: String,
     body: Vec<u8>,
     checksum: String,
     version_number: u64,
@@ -164,7 +164,7 @@ impl ConfigFileList {
         }
     }
 
-    pub fn process(&mut self, mut remote_cf: ConfigFile) -> bool {
+    pub fn process(&mut self, remote_cf: ConfigFile) -> bool {
         if let Some(mut current_cf) = self.get_mut(&remote_cf.service_group, &remote_cf.file_name) {
             return current_cf.update_via(remote_cf);
         }

components/bldr/src/gossip/rumor.rs

@@ -265,6 +265,22 @@ impl RumorList {
         }
     }
 
+    pub fn prune_config_files_for(&mut self, config_file: &ConfigFile) {
+        let mut prune_list: Vec<RumorId> = Vec::new();
+        for (rid, rumor) in self.rumors.iter() {
+            if let Message::ConfigFile(ref cf) = rumor.payload {
+                if config_file.service_group == cf.service_group &&
+                   config_file.file_name == cf.file_name {
+                    prune_list.push(rid.clone());
+                }
+            }
+        }
+        for rid in prune_list.iter() {
+            self.rumors.remove(&rid);
+        }
+    }
+
+
     pub fn remove_rumor(&mut self, rumor_id: &RumorId) {
         self.rumors.remove(rumor_id);
         for (_member, mut rumor_map) in self.heat.iter_mut() {

components/bldr/src/gossip/server.rs

@@ -505,7 +505,8 @@ pub fn process_rumors(remote_rumors: RumorList,
                 };
                 if processed {
                     let mut rl = rumor_list.write().unwrap();
-                    // TODO: something magical and amazing happens here
+                    rl.prune_config_files_for(&config_file);
+                    rl.add_rumor(Rumor::config_file(config_file));
                 }
             }
             Message::Blank => {}