ebi_bpmn 0.0.29

A BPMN parser, writer and executor
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

use crate::{
    BusinessProcessModelAndNotation,
    importer::parse_attribute,
    parser::{tag_definitions::DraftDefinitions, tags::OpenedTag},
};
use anyhow::{Context, Result, anyhow};
use ebi_activity_key::ActivityKey;
use quick_xml::events::BytesStart;
use std::collections::{HashMap, hash_map::Entry};

pub(crate) struct ParserState {
    pub(crate) activity_key: ActivityKey,
    pub(crate) open_tag_names: Vec<Vec<u8>>,
    pub(crate) open_tags: Vec<OpenedTag>,
    pub(crate) ids: HashMap<String, usize>,

    pub(crate) draft_definitionss: Vec<DraftDefinitions>,

    pub(crate) not_recognised_id_2_tag: HashMap<String, String>,
}

pub type GlobalIndex = (usize, ());

impl ParserState {
    pub(crate) fn new() -> Self {
        Self {
            activity_key: ActivityKey::new(),
            open_tag_names: vec![],
            ids: HashMap::new(),
            open_tags: vec![],
            draft_definitionss: vec![],
            not_recognised_id_2_tag: HashMap::new(),
        }
    }

    pub(crate) fn to_model(
        self,
        disallow_sequence_flow_weights: bool,
    ) -> Result<BusinessProcessModelAndNotation> {
        let ParserState {
            activity_key,
            mut draft_definitionss,
            ..
        } = self;
        if draft_definitionss.len() == 1 {
            let draft_definition = draft_definitionss.remove(0);
            let DraftDefinitions {
                global_index: definitions_index,
                id: definitions_id,
                collaboration_index,
                collaboration_id,
                stochastic_namespace,
                elements,
                message_flows,
            } = draft_definition;
            //construct result
            let result = BusinessProcessModelAndNotation {
                stochastic_namespace,
                activity_key,
                collaboration_index,
                collaboration_id,
                definitions_index,
                definitions_id,
                elements,
                message_flows,
            };

            if disallow_sequence_flow_weights {
                //verify that the model has no sequence flows with weights
                for sequence_flow in result.sequence_flows() {
                    if sequence_flow.weight.is_some() {
                        return Err(anyhow!(
                            "Sequence flow `{}` has a weight, which is not allowed in this import mode.",
                            sequence_flow.id
                        ));
                    }
                }
            }

            //check structural correctness
            result
                .is_structurally_correct()
                .with_context(|| "The model is not structurally correct.")?;
            Ok(result)
        } else {
            if draft_definitionss.len() == 0 {
                Err(anyhow!("no process found"))
            } else {
                Err(anyhow!("multiple processes found"))
            }
        }
    }

    pub(crate) fn read_and_add_id(&mut self, e: &BytesStart) -> Result<(GlobalIndex, String)> {
        let new_index = self.ids.len();
        if let Some(id) = parse_attribute(e, "id") {
            match self.ids.entry(id.clone()) {
                Entry::Occupied(_) => Err(anyhow!("two elements have the id `{}`", id)),
                Entry::Vacant(vacant_entry) => {
                    vacant_entry.insert(new_index);
                    Ok(((new_index, ()), id))
                }
            }
        } else {
            Err(anyhow!("element must have an id"))
        }
    }
}