X-Git-Url: http://git.scottworley.com/tablify/blobdiff_plain/8110b492cfa41fd99bfb639d7491b4e075fa9385..58b5f36de045c760efa51b21a6d841f5b62558db:/src/lib.rs?ds=inline diff --git a/src/lib.rs b/src/lib.rs index 56a2b6d..fcf5dc8 100644 --- a/src/lib.rs +++ b/src/lib.rs @@ -1,4 +1,6 @@ #[cfg(test)] +use std::collections::{HashMap, HashSet}; +#[cfg(test)] use std::io::BufRead; #[cfg(test)] use std::iter::Iterator; @@ -66,6 +68,24 @@ fn read_rows(input: impl std::io::Read) -> impl Iterator Vec<(usize, String)> { + let mut counts: Vec<_> = rows + .iter() + .flat_map(|r| r.entries.iter().collect::>().into_iter()) + .fold(HashMap::new(), |mut cs, e| { + cs.entry(String::from(e)) + .and_modify(|n| *n += 1) + .or_insert(1); + cs + }) + .into_iter() + .map(|(col, n)| (n, col)) + .collect(); + counts.sort(); + counts +} + pub fn tablify(_input: &impl std::io::Read) -> String { String::from("Hello, world!") } @@ -167,4 +187,32 @@ mod tests { assert!(bad2.is_err()); assert!(format!("{bad2:?}").contains("3: Entry with no header")); } + + #[test] + fn test_column_counts() { + assert_eq!( + column_counts( + &read_rows(&b"foo\n bar\n baz\n"[..]) + .collect::, _>>() + .unwrap() + ), + vec![(1, String::from("bar")), (1, String::from("baz"))] + ); + assert_eq!( + column_counts( + &read_rows(&b"foo\n bar\n baz\nquux\n baz"[..]) + .collect::, _>>() + .unwrap() + ), + vec![(1, String::from("bar")), (2, String::from("baz"))] + ); + assert_eq!( + column_counts( + &read_rows(&b"foo\n bar\n bar\n baz\n bar\nquux\n baz"[..]) + .collect::, _>>() + .unwrap() + ), + vec![(1, String::from("bar")), (2, String::from("baz"))] + ); + } }