mongodb 3.9.1

The official MongoDB driver for Rust
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

use std::time::Duration;

use crate::{
    bson::{doc, oid::ObjectId, RawDocumentBuf},
    bson_compat::RawError,
    event::command::{CommandEvent, CommandFailedEvent, CommandSucceededEvent},
};

pub use crate::cmap::ConnectionInfo;

use super::CommandStartedEvent;

#[derive(Debug, Clone)]
pub(crate) enum RawCommandEvent {
    Started(RawCommandStartedEvent),
    Succeeded(RawCommandSucceededEvent),
    Failed(CommandFailedEvent),
}

#[derive(Debug, Clone)]
pub(crate) struct RawCommandStartedEvent {
    pub(crate) command: RawDocumentBuf,
    pub(crate) db: String,
    pub(crate) command_name: String,
    pub(crate) request_id: i32,
    pub(crate) connection: ConnectionInfo,
    pub(crate) service_id: Option<ObjectId>,
}

#[derive(Clone, Debug)]
pub(crate) struct RawCommandSucceededEvent {
    pub(crate) duration: Duration,
    pub(crate) reply: RawDocumentBuf,
    pub(crate) command_name: String,
    pub(crate) request_id: i32,
    pub(crate) connection: ConnectionInfo,
    pub(crate) service_id: Option<ObjectId>,
}

impl Into<CommandEvent> for RawCommandEvent {
    fn into(self) -> CommandEvent {
        match self {
            RawCommandEvent::Started(ev) => CommandEvent::Started(CommandStartedEvent {
                command: ev.command.try_into().unwrap_or_else(
                    |e: RawError| doc! { "invalid command document": e.to_string() },
                ),
                db: ev.db,
                command_name: ev.command_name,
                request_id: ev.request_id,
                connection: ev.connection,
                service_id: ev.service_id,
            }),
            RawCommandEvent::Succeeded(ev) => CommandEvent::Succeeded(CommandSucceededEvent {
                duration: ev.duration,
                reply: ev
                    .reply
                    .try_into()
                    .unwrap_or_else(|e: RawError| doc! { "invalid reply document": e.to_string() }),
                command_name: ev.command_name,
                request_id: ev.request_id,
                connection: ev.connection,
                service_id: ev.service_id,
            }),
            RawCommandEvent::Failed(ev) => CommandEvent::Failed(ev),
        }
    }
}