bgpkit-commons 0.10.3

A library for common BGP-related data and functions.
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

use crate::Result;
use crate::mrt_collectors::{MrtCollector, MrtCollectorProject, ToMrtCollector};
use chrono::DateTime;
use serde::Deserialize;

#[derive(Deserialize, Debug, Clone)]
#[allow(dead_code)]
struct RisCollector {
    pub id: i64,
    pub name: String,
    pub geographical_location: String,
    pub topological_location: String,
    pub activated_on: String,
    pub deactivated_on: String,
}

#[derive(Deserialize, Debug, Clone)]
#[allow(dead_code)]
struct Data {
    pub rrcs: Vec<RisCollector>,
}

#[derive(Deserialize, Debug, Clone)]
#[allow(dead_code)]
struct RisData {
    pub data: Data,
    pub status: String,
    pub status_code: i64,
}

impl ToMrtCollector for RisCollector {
    fn to_mrt_collector(&self) -> Option<MrtCollector> {
        let activated_on = match DateTime::parse_from_rfc3339(
            format!("{}-01T00:00:00Z", self.activated_on.as_str()).as_str(),
        ) {
            Ok(t) => t.naive_utc(),
            Err(_) => return None,
        };

        let deactivated_on = match self.deactivated_on.is_empty() {
            true => None,
            false => match DateTime::parse_from_rfc3339(
                format!("{}-01T00:00:00Z", self.deactivated_on.as_str()).as_str(),
            ) {
                Ok(t) => Some(t.naive_utc()),
                Err(_) => return None,
            },
        };

        let name = self.name.to_lowercase();

        let data_url = format!("https://data.ris.ripe.net/{}", name.as_str());

        let country = self
            .geographical_location
            .split(',')
            .map(|c| c.trim())
            .collect::<Vec<&str>>()[1]
            .to_string();

        Some(MrtCollector {
            data_url,
            name,
            project: MrtCollectorProject::RipeRis,
            activated_on,
            deactivated_on,
            country,
        })
    }
}

/// Get RIPE RIS mrt_collectors meta information
pub fn get_riperis_collectors() -> Result<Vec<MrtCollector>> {
    let data = oneio::read_json_struct::<RisData>("https://stat.ripe.net/data/rrc-info/data.json")?;
    Ok(data
        .data
        .rrcs
        .into_iter()
        .map(|c| c.to_mrt_collector().unwrap())
        .collect())
}