routers_codec 0.1.3

Encoding and Decoding Primitives for Routers
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

use crate::osm::element::{TagString, Tags};
use crate::osm::speed_limit::limit::{SpeedLimitEntry, SpeedLimitVariant};
use crate::osm::speed_limit::subtypes::SpeedLimitConditions;
use crate::osm::speed_limit::{PossiblyConditionalSpeedLimit, SpeedLimitExt};
use crate::osm::{OsmTripConfiguration, Parser};
use core::fmt::Debug;
use core::ops::Deref;
use itertools::Itertools;
use serde::Serialize;

#[derive(Debug, Clone, Serialize)]
pub struct SpeedLimitCollection(pub(crate) Vec<SpeedLimitEntry>);

impl Deref for SpeedLimitCollection {
    type Target = Vec<SpeedLimitEntry>;

    fn deref(&self) -> &Self::Target {
        &self.0
    }
}

impl SpeedLimitExt for SpeedLimitCollection {
    fn relevant_limits(
        &self,
        runtime: &OsmTripConfiguration,
        conditions: SpeedLimitConditions,
    ) -> Vec<PossiblyConditionalSpeedLimit> {
        // Must match the conditions if they exist, otherwise blanketed.
        self.0
            .clone()
            .into_iter()
            .filter(|limit| {
                limit
                    .restriction
                    .transport_mode
                    .is_none_or(|mode| mode == runtime.transport_mode)
            })
            .filter(|limit| {
                limit
                    .restriction
                    .directionality
                    .is_none_or(|dir| dir == conditions.directionality)
            })
            .filter_map(|SpeedLimitEntry { limit, .. }| match limit {
                SpeedLimitVariant::Blanket(blanket) => Some(blanket),
                SpeedLimitVariant::PerLane(per_lane) => per_lane
                    .0
                    .get(conditions.lane?.get() as usize)
                    .cloned()
                    .and_then(|x| x),
            })
            .collect::<Vec<_>>()
    }
}

impl Parser for SpeedLimitCollection {
    fn parse(tags: &Tags) -> Option<Self> {
        // Standard structure follows:
        let known_limits = tags
            .iter()
            .filter(|(key, _)| key.starts_with(TagString::MAX_SPEED))
            .filter_map(|(l, v)| SpeedLimitEntry::parse_tag(l, v))
            .sorted_by_key(|item| format!("{:?}", item))
            .collect::<Vec<_>>();

        if known_limits.is_empty() {
            return None;
        }

        Some(Self(known_limits))
    }
}