impl ward condition for max view ward (#106)

* impl ward condition for max view ward

simulations/src/warding/ttf.rs

@@ -6,13 +6,18 @@ use serde::Deserialize;
 /// the set threshold.
 #[derive(Debug, Deserialize, Copy, Clone)]
 pub struct MaxViewWard {
-    _max_view: usize,
+    max_view: usize,
 }
 
 impl<N: Node> SimulationWard<N> for MaxViewWard {
     type SimulationState = SimulationState<N>;
-    fn analyze(&mut self, _state: &Self::SimulationState) -> bool {
+    fn analyze(&mut self, state: &Self::SimulationState) -> bool {
-        true // TODO: implement using simulation state
+        !state
+            .nodes
+            .read()
+            .expect("simulations: MaxViewWard panic when requiring a read lock")
+            .iter()
+            .any(|n| n.current_view() >= self.max_view)
     }
 }
 
@@ -31,7 +36,7 @@ mod test {
             type Settings = ();
             type State = Self;
 
-            fn new<R: Rng>(rng: &mut R, id: NodeId, settings: Self::Settings) -> Self {
+            fn new<R: Rng>(_rng: &mut R, id: NodeId, _settings: Self::Settings) -> Self {
                 id.inner()
             }
 
@@ -51,13 +56,15 @@ mod test {
                 self.add_assign(1);
             }
         }
-        let mut ttf = MaxViewWard { _max_view: 10 };
+        let mut ttf = MaxViewWard { max_view: 10 };
-        let mut cond = false;
 
-        let node = 11;
+        let node = 9;
-        let mut state = SimulationState {
+        let state = SimulationState {
             nodes: Arc::new(RwLock::new(vec![node])),
         };
         assert!(ttf.analyze(&state));
+
+        state.nodes.write().unwrap().push(11);
+        assert!(!ttf.analyze(&state));
     }
 }