mongodb 2.8.2

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
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90

use std::time::Duration;

use crate::{
    bson::doc,
    client::options::ServerAddress,
    cmap::StreamDescription,
    operation::{test::handle_response_test, ListIndexes, Operation},
    options::{IndexOptions, IndexVersion, ListIndexesOptions, TextIndexVersion},
    IndexModel,
    Namespace,
};

#[test]
fn build() {
    let ns = Namespace {
        db: "test_db".to_string(),
        coll: "test_coll".to_string(),
    };

    let list_options = ListIndexesOptions::builder()
        .max_time(Some(Duration::from_millis(42)))
        .batch_size(Some(4))
        .build();
    let mut list_indexes = ListIndexes::new(ns, Some(list_options));

    let cmd = list_indexes
        .build(&StreamDescription::new_testing())
        .expect("ListIndexes command failed to build when it should have succeeded.");

    assert_eq!(
        cmd.body,
        doc! {
            "listIndexes": "test_coll",
            "maxTimeMS": 42,
            "cursor": doc! {
                "batchSize": 4,
            },
        }
    );
}

#[test]
fn handle_success() {
    let op = ListIndexes::empty();

    let first_batch = vec![
        IndexModel::builder()
            .keys(doc! {"x": 1})
            .options(Some(
                IndexOptions::builder()
                    .version(Some(IndexVersion::V1))
                    .name(Some("foo".to_string()))
                    .sparse(Some(false))
                    .build(),
            ))
            .build(),
        IndexModel::builder()
            .keys(doc! {"y": 1, "z": -1})
            .options(Some(
                IndexOptions::builder()
                    .version(Some(IndexVersion::V1))
                    .name(Some("x_1_z_-1".to_string()))
                    .text_index_version(Some(TextIndexVersion::V3))
                    .default_language(Some("spanish".to_string()))
                    .build(),
            ))
            .build(),
    ];

    let response = doc! {
        "cursor": {
            "id": 123,
            "ns": "test_db.test_coll",
            "firstBatch": bson::to_bson(&first_batch).unwrap(),
        },
        "ok": 1,
    };

    let cursor_spec = handle_response_test(&op, response).unwrap();

    assert_eq!(cursor_spec.id(), 123);
    assert_eq!(cursor_spec.address(), &ServerAddress::default());
    assert_eq!(cursor_spec.batch_size(), None);
    assert_eq!(cursor_spec.max_time(), None);

    assert_eq!(
        bson::to_bson(&cursor_spec.initial_buffer).unwrap(),
        bson::to_bson(&first_batch).unwrap(),
    );
}