Use Cadenced ECUs, only show unused stuff for now, warn for unsupported packets

1 files changed, 12 insertions, 3 deletions

diff --git a/src/main.rs b/src/main.rs
index e4f2e7e..1866813 100644
--- a/src/main.rs
+++ b/src/main.rs
@@ -30,6 +30,7 @@ use std::collections::hash_map::Entry;
 use std::vec::Vec;
 
 use types::Value;
+use definitions::CadencedECUs;
 
 fn packet_print(id: u16, bytes: &[u8]) -> String {
     let mut ret: String = String::new();
@@ -79,7 +80,7 @@ fn main() {
         );
 
         trace!("Preparing an Interval to run the requests");
-        let always_defs = futures::stream::iter_ok(raw_defs.iter().cycle());
+        let always_defs = futures::stream::iter_ok(CadencedECUs::new());
         let every_100ms = Interval::new(Instant::now(), Duration::from_millis(100));
         let zipped = every_100ms.zip(always_defs);
 
@@ -110,18 +111,26 @@ fn main() {
                             let curmap = current.get_mut().unwrap();
                             for entry in decoded {
                                 let name = entry.get_name().to_owned();
+                                if !name.contains(".unused_") {
+                                    continue;
+                                }
                                 let value = entry.get_value().unwrap();
                                 match curmap.entry(name.clone()) {
                                     Entry::Occupied(o) => if value != *o.get() {
-                                        info!("{} changed {:?} -> {:?}", name, o.get(), value);
+                                        info!("{} changed {} -> {}", name, o.get(), value);
                                     },
                                     Entry::Vacant(_) => {
-                                        info!("{} changed None -> {:?}", name, value);
+                                        info!("{} changed None -> {}", name, value);
                                     }
                                 };
                                 curmap.insert(name, value);
                             }
                         }
+                    } else {
+                        warn!(
+                            "Cannot locate Raw RCU Entry for {}",
+                            packet_print(frame.0, &frame.1)
+                        );
                     }
 
                     Ok(())