pmrs 0.0.2

Rust support to process mining functions. Includes a library and a small cli-interface.
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
43
44
45
46
47
48
49
50
51
52

#[allow(unused_imports)]
use crate::objects::ocel::{Ocel, OcelSerde, OcelEvent, OcelObject, OcelEventSerde, OcelObjectSerde};
use ahash::{AHashMap, AHashSet, RandomState};
use indexmap::IndexMap;
use std::{fs::OpenOptions, io::{BufWriter, Write}, error::Error};

pub(crate) fn export_json_ocel(log: &Ocel, file_path: &str) -> Result<bool, Box<dyn Error>> {
    let log_serde: OcelSerde = generate_ocel_serde(log);

    let serde_ocel = serde_json::to_string(&log_serde).unwrap();
    let output_file = OpenOptions::new().create(true).write(true).truncate(true).open(file_path).unwrap();
    
    let mut f = BufWriter::new(output_file);
    f.write_all(serde_ocel.as_bytes()).expect("Unable to write data");

    Ok(true)
}

pub(crate) fn export_json_ocel_pretty(log: &Ocel, file_path: &str) -> Result<bool, Box<dyn Error>> {
    let log_serde: OcelSerde = generate_ocel_serde(log);

    let serde_ocel = serde_json::to_string_pretty(&log_serde).unwrap();
    let output_file = OpenOptions::new().create(true).write(true).truncate(true).open(file_path).unwrap();
    
    let mut f = BufWriter::new(output_file);
    f.write_all(serde_ocel.as_bytes()).expect("Unable to write data");

    Ok(true)
}


pub(crate) fn generate_ocel_serde(log: &Ocel) -> OcelSerde {
    let hasher = RandomState::new();
    let mut log_serde: OcelSerde = OcelSerde { global_log: log.global_log.to_owned(), global_event: log.global_event.to_owned(), global_object: log.global_object.to_owned(), objects: AHashMap::new(), events: IndexMap::with_hasher(hasher) };

    for (oid, data) in &log.objects {
        log_serde.objects.insert(log.object_map.get_by_right(oid).expect("This can't fail").to_owned(), OcelObjectSerde { obj_type: data.obj_type.to_owned(), ovmap: data.ovmap.to_owned() });
    }


    for (eid, data) in &log.events {
        let mut serde_event = OcelEventSerde {activity: data.activity.to_owned(), timestamp: data.timestamp, vmap: data.vmap.to_owned(), omap: AHashSet::new()};

        for oid in data.omap.iter() {
            serde_event.omap.insert(log.object_map.get_by_right(oid).expect("This can't fail").to_owned());
        }
        log_serde.events.insert(log.event_map.get_by_right(eid).expect("This can't fail").to_owned(), serde_event);
    }
    
    log_serde

}