ebi 0.3.12

A stochastic process mining utility and library
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
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124

use crate::{
    ebi_framework::{
        ebi_command::{EBI_COMMANDS, EbiCommand, search_command_in_source_files},
        ebi_output::EbiOutput,
    },
    python::python::pm4py_function_name,
};
use ebi_objects::anyhow::Result;

pub fn generate_pm4py_module() -> Result<EbiOutput> {
    let imports = format!(
        "#![allow(unsafe_op_in_unsafe_fn)]
#![allow(unused_variables)]

// This file has been automatically generated. Manual changes will be overridden.

use pyo3::prelude::*;
use pyo3::types::PyAny;
use super::{{python_link::import_or_load, python_export::ExportableToPM4Py}};
use crate::ebi_framework::ebi_command::EbiCommand;"
    );
    let mut functions = String::new();
    let mut module = format!(
        "#[pymodule]\npub fn ebi(_py: Python<'_>, m: &Bound<'_, PyModule>) -> PyResult<()> {{"
    );

    for path in EBI_COMMANDS.get_command_paths() {
        if path.last().unwrap().is_in_python() {
            let (fn_name, body) = ebi_command_to_pm4py_function(&path)?;
            functions.push_str(&body);
            module.push_str(&format!(
                "    m.add_function(wrap_pyfunction!({}, m)?)?;\n",
                fn_name
            ));
        }
    }

    module.push_str(
        "    Ok(())
}
",
    );

    let result = format!("{}\n\n{}\n\n{}", imports, functions, module);
    Ok(EbiOutput::String(result))
}

/// return the tupe (string1, string2) where
/// string1 - function name
/// string2 - function body
fn ebi_command_to_pm4py_function(path: &Vec<&EbiCommand>) -> Result<(String, String)> {
    // Derive raw name and fn name
    let fn_name = pm4py_function_name(path);

    let library_name = search_command_in_source_files(path)?;

    // Extract input_types
    let (input_types, exact_arithmetic) = if let EbiCommand::Command {
        input_types,
        exact_arithmetic,
        ..
    } = path[path.len() - 1]
    {
        (input_types, *exact_arithmetic)
    } else {
        return Ok((String::new(), String::new()));
    };

    // Start building function
    let mut body = format!(
        r###"#[pyfunction]
fn {fname}(py: Python<'_>, {args}) -> PyResult<Py<PyAny>> {{
    {exact}
    let command: &&EbiCommand = &&{library_name};
    let input_types = match **command {{
        EbiCommand::Command {{ input_types, .. }} => input_types,
        _ => return Err(pyo3::exceptions::PyValueError::new_err("Expected a command.")),
    }};
"###,
        fname = fn_name,
        args = (0..input_types.len())
            .map(|i| format!("arg{}: &Bound<'_, PyAny>", i))
            .collect::<Vec<_>>()
            .join(", "),
        exact = if exact_arithmetic {
            "ebi_objects::ebi_arithmetic::exact::set_exact_globally(true);"
        } else {
            "ebi_objects::ebi_arithmetic::exact::set_exact_globally(false);"
        },
        library_name = library_name
    );

    // Import each argument
    for idx in 0..input_types.len() {
        body.push_str(&format!(r###"    let input{idx} = import_or_load(arg{idx}, input_types[{idx}], {idx})
            .map_err(|e| pyo3::exceptions::PyValueError::new_err(format!("Could not import argument {idx}: {{}}", e)))?;
    "###,
            idx = idx
        ));
    }

    // Collect inputs
    let inputs = (0..input_types.len())
        .map(|i| format!("input{}", i))
        .collect::<Vec<_>>()
        .join(", ");
    body.push_str(&format!(
        r###"    let inputs = vec![{}];

    // Execute the command.
    let result = command.execute_with_inputs(inputs)
        .map_err(|e| pyo3::exceptions::PyException::new_err(format!("Command error: {{}}", e)))?
        .export_to_pm4py(py)
        .map_err(|e| pyo3::exceptions::PyException::new_err(format!("Export error: {{}}", e)))?;

    Ok(result)
}}

"###,
        inputs
    ));

    Ok((fn_name, body))
}