bve 0.0.1

Remaking OpenBVE using a modern architecture, using Unity and Rust.
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

use crate::log::common::*;
use crate::log::{Message, SerializationMethod};
use crossbeam::Receiver;
use num_traits::FromPrimitive;
use std::io::{BufWriter, Write};
use tracing::Id;

pub(super) fn run_writer(receiver: &Receiver<Command>, dest: impl Write + Send, method: &SerializationMethod) {
    let mut buffered = BufWriter::new(dest);

    while let Ok(message) = receiver.recv() {
        let to_serialize = match message.data {
            CommandData::CreateSpan { id, metadata, data } => Message::CreateSpan {
                id: id.into_u64(),
                name: metadata.name().to_string(),
                module: metadata.module_path().map_or_else(String::new, str::to_string),
                file: metadata.file().map_or_else(String::new, str::to_string),
                line: metadata.line().and_then(u16::from_u32).unwrap_or_else(u16::max_value),
                severity: metadata.level().into(),
                values: data,
            },
            CommandData::RecordRelationship { parent, child } => Message::SpanParent {
                parent: parent.into_u64(),
                child: child.into_u64(),
            },
            CommandData::RecordSpanData { id, data } => Message::SpanData {
                id: id.into_u64(),
                values: data,
            },
            CommandData::Event {
                span_id,
                metadata,
                mut data,
            } => {
                // Remove the message from the data map
                let message = data.remove("message").map(|v| format!("{}", v));
                Message::Event {
                    span_id: span_id.as_ref().map(Id::into_u64),
                    file: metadata.file().map_or_else(String::new, str::to_string),
                    line: metadata.line().and_then(u16::from_u32).unwrap_or_else(u16::max_value),
                    severity: metadata.level().into(),
                    message,
                    values: data,
                }
            }
        };

        method.serialize(&mut buffered, &to_serialize);

        buffered.flush().expect("Flushing to log destination failed");
    }
}