rosbag 0.6.3

Utilities for reading ROS bag 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

use super::{Error, Result};

use crate::cursor::Cursor;

use crate::field_iter::FieldIterator;
use crate::record_types::{Chunk, ChunkInfo, Connection, IndexData, MessageData, RecordGen};

/// Enum with all possible record variants
#[derive(Debug, Clone)]
pub(crate) enum Record<'a> {
    Chunk(Chunk<'a>),
    Connection(Connection<'a>),
    MessageData(MessageData<'a>),
    IndexData(IndexData<'a>),
    ChunkInfo(ChunkInfo<'a>),
}

impl<'a> Record<'a> {
    pub(crate) fn next_record(c: &mut Cursor<'a>) -> Result<Self> {
        let header = c.next_chunk()?;

        let mut op = None;
        for item in FieldIterator::new(header) {
            let (name, val) = item?;
            if name == "op" {
                if val.len() == 1 {
                    op = Some(val[0]);
                    break;
                } else {
                    return Err(Error::InvalidRecord);
                }
            }
        }

        Ok(match op {
            Some(IndexData::OP) => Record::IndexData(IndexData::read(header, c)?),
            Some(Chunk::OP) => Record::Chunk(Chunk::read(header, c)?),
            Some(ChunkInfo::OP) => Record::ChunkInfo(ChunkInfo::read(header, c)?),
            Some(Connection::OP) => Record::Connection(Connection::read(header, c)?),
            Some(MessageData::OP) => Record::MessageData(MessageData::read(header, c)?),
            _ => return Err(Error::InvalidRecord),
        })
    }

    /// Get string name of the stored recrod type.
    pub fn get_type(&self) -> &'static str {
        match self {
            Record::Chunk(_) => "Chunk",
            Record::Connection(_) => "Connection",
            Record::MessageData(_) => "MessageData",
            Record::IndexData(_) => "IndexData",
            Record::ChunkInfo(_) => "ChunkInfo",
        }
    }
}