spell 0.1.6

Spell is a Streaming Parser for Event Logs using an LCS (Longest Common Subsequence)
Documentation 
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42

use std::error::Error;
use std::fs::File;
use std::io::{BufRead, BufReader};

type Result<T> = std::result::Result<T, Box<Error>>;

use spell::map::LcsMap;

fn main() -> Result<()> {
    let path: String = std::env::args().nth(1).unwrap();

    let max_lines: usize = std::env::args()
        .nth(2)
        .map(|i| i.parse().unwrap())
        .unwrap_or_else(|| usize::max_value());

    let input = File::open(path)?;
    let buffered = BufReader::new(input);

    let mut map = LcsMap::new();

    buffered
        .lines()
        .filter_map(|line| match line {
            Ok(line) => {
                map.insert(&line);
                Some(())
            }
            Err(err) => {
                eprintln!("Error processing line: {:?}", err);
                None
            }
        })
        .enumerate()
        .take_while(|(i, _line)| *i + 1 < max_lines)
        .for_each(|(_i, _line)| {});

    println!("----------------------------");
    println!("{}", map.to_string());

    Ok(())
}