torc 0.22.1

Workflow management system
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

#[cfg(test)]
pub(super) fn decode_path_segment(segment: &str) -> Option<String> {
    percent_encoding::percent_decode_str(segment)
        .decode_utf8()
        .ok()
        .map(|value| value.into_owned())
}

#[cfg(test)]
pub(super) fn parse_group_member_path(path: &str) -> Option<(i64, String)> {
    let suffix = path.strip_prefix("/torc-service/v1/access_groups/")?;
    let (group_id, tail) = suffix.split_once("/members/")?;
    if tail.contains('/') {
        return None;
    }
    Some((group_id.parse::<i64>().ok()?, decode_path_segment(tail)?))
}

#[cfg(test)]
pub(super) fn parse_access_group_members_collection_path(path: &str) -> Option<i64> {
    let group_id = path.strip_prefix("/torc-service/v1/access_groups/")?;
    let group_id = group_id.strip_suffix("/members")?;
    if group_id.contains('/') {
        return None;
    }
    group_id.parse::<i64>().ok()
}

#[cfg(test)]
pub(super) fn parse_user_groups_path(path: &str) -> Option<String> {
    let user_name = path.strip_prefix("/torc-service/v1/users/")?;
    let user_name = user_name.strip_suffix("/groups")?;
    if user_name.contains('/') {
        return None;
    }
    decode_path_segment(user_name)
}

#[cfg(test)]
pub(super) fn parse_workflow_access_groups_collection_path(path: &str) -> Option<i64> {
    let workflow_id = path.strip_prefix("/torc-service/v1/workflows/")?;
    let workflow_id = workflow_id.strip_suffix("/access_groups")?;
    if workflow_id.contains('/') {
        return None;
    }
    workflow_id.parse::<i64>().ok()
}

#[cfg(test)]
pub(super) fn parse_workflow_access_group_item_path(path: &str) -> Option<(i64, i64)> {
    let suffix = path.strip_prefix("/torc-service/v1/workflows/")?;
    let (workflow_id, tail) = suffix.split_once("/access_groups/")?;
    if tail.contains('/') {
        return None;
    }
    Some((workflow_id.parse::<i64>().ok()?, tail.parse::<i64>().ok()?))
}

#[cfg(test)]
pub(super) fn parse_access_check_path(path: &str) -> Option<(i64, String)> {
    let suffix = path.strip_prefix("/torc-service/v1/access_check/")?;
    let (workflow_id, user_name) = suffix.split_once('/')?;
    if user_name.contains('/') {
        return None;
    }
    Some((
        workflow_id.parse::<i64>().ok()?,
        decode_path_segment(user_name)?,
    ))
}

#[cfg(test)]
pub(super) fn parse_workflow_failure_handlers_path(path: &str) -> Option<i64> {
    let workflow_id = path.strip_prefix("/torc-service/v1/workflows/")?;
    let workflow_id = workflow_id.strip_suffix("/failure_handlers")?;
    if workflow_id.contains('/') {
        return None;
    }
    workflow_id.parse::<i64>().ok()
}

#[cfg(test)]
pub(super) fn parse_workflow_suffix_path(path: &str, suffix: &str) -> Option<i64> {
    let workflow_id = path.strip_prefix("/torc-service/v1/workflows/")?;
    let workflow_id = workflow_id.strip_suffix(suffix)?;
    if workflow_id.contains('/') {
        return None;
    }
    workflow_id.parse::<i64>().ok()
}

#[cfg(test)]
pub(super) fn parse_workflow_events_stream_path(path: &str) -> Option<i64> {
    parse_workflow_suffix_path(path, "/events/stream")
}