rs-bag 0.1.0

Read, write and modify ROS 2 rosbag2 sqlite3 (.db3) storage files
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 turso::Row;

use crate::Error;
use crate::error::Result;

#[derive(Debug, serde::Serialize, serde::Deserialize)]
pub struct Topic {
    pub id: i64,
    pub name: String,
    #[serde(rename = "type")]
    pub r#type: String,
    pub serialization_format: String,
    pub offered_qos_profiles: String,
}

impl PartialEq for Topic {
    fn eq(&self, other: &Topic) -> bool {
        self.id == other.id
    }
}

impl Eq for Topic {}

impl std::hash::Hash for Topic {
    fn hash<H: std::hash::Hasher>(&self, state: &mut H) {
        self.id.hash(state);
    }
}

impl TryFrom<Row> for Topic {
    type Error = Error;

    fn try_from(value: Row) -> Result<Self> {
        let id = value
            .get_value(0)?
            .as_integer()
            .copied()
            .ok_or(Error::row_conversion("id", "an integer"))?;

        let name = value
            .get_value(1)?
            .as_text()
            .cloned()
            .ok_or(Error::row_conversion("name", "text"))?;

        let r#type = value
            .get_value(2)?
            .as_text()
            .cloned()
            .ok_or(Error::row_conversion("type", "text"))?;

        let serialization_format = value
            .get_value(3)?
            .as_text()
            .cloned()
            .ok_or(Error::row_conversion("serialization_format", "text"))?;

        let offered_qos_profiles = value
            .get_value(4)?
            .as_text()
            .cloned()
            .ok_or(Error::row_conversion("offered_qos_profiles", "text"))?;

        Ok(Self {
            id,
            name,
            r#type,
            serialization_format,
            offered_qos_profiles,
        })
    }
}