mongodb 0.2.8

A native MongoDB driver developed under MongoDB labs.
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
91
92
93
94
95
96
97
98

use json::FromValueResult;

use mongodb::common::ReadPreference;
use mongodb::topology::TopologyType;

use serde_json::{self, Value};

use std::fs::File;
use std::str::FromStr;

use super::server::Server;
use super::topology_description::TopologyDescription;

pub struct Suite {
    pub in_latency_window: Vec<Server>,
    pub write: bool,
    pub read_preference: ReadPreference,
    pub suitable_servers: Vec<Server>,
    pub topology_description: TopologyDescription,
}

fn get_server_array(vals: &[Value]) -> Result<Vec<Server>, String> {
    let mut servers = Vec::new();

    for json in vals.iter() {
        match *json {
            Value::Object(ref obj) => {
                match Server::from_json(obj) {
                    Ok(server) => servers.push(server),
                    Err(err) => return Err(err),
                }
            }
            _ => return Err(String::from("Some servers could not be parsed for topology")),
        }
    }

    Ok(servers)
}

pub trait SuiteContainer: Sized {
    fn from_file(path: &str) -> Result<Self, String>;
    fn get_suite(&self) -> Result<Suite, String>;
}

impl SuiteContainer for Value {
    fn from_file(path: &str) -> Result<Value, String> {
        let mut file = File::open(path).expect(&format!("Unable to open file: {}", path));
        Ok(serde_json::from_reader(&mut file).expect(&format!("Invalid JSON file: {}", path)))
    }

    fn get_suite(&self) -> Result<Suite, String> {
        let object = val_or_err!(*self,
                                 Value::Object(ref object) => object.clone(),
                                 "`get_suite` requires a JSON object");

        let operation = val_or_err!(object.get("operation"),
                                    Some(&Value::String(ref s)) => s.to_owned(),
                                    "suite requires an operation string.");

        let write = operation == "write";

        let read_preference = val_or_err!(object.get("read_preference"),
                                          Some(&Value::Object(ref object)) =>
                                          try!(ReadPreference::from_json(object)),
                                          "suite requires a read_preference object.");

        let in_latency_window = val_or_err!(object.get("in_latency_window"),
                                           Some(&Value::Array(ref array)) =>
                                           try!(get_server_array(array)),
                                           "suite requires an in_latency_window array.");

        let suitable_servers = val_or_err!(object.get("suitable_servers"),
                                           Some(&Value::Array(ref array)) =>
                                           try!(get_server_array(array)),
                                           "suite requires a suitable_servers array.");

        let topology_obj = val_or_err!(object.get("topology_description"),
                                       Some(&Value::Object(ref obj)) => obj,
                                       "suite requires a topology_description object.");

        let top_servers = val_or_err!(topology_obj.get("servers"),
                                      Some(&Value::Array(ref array)) =>
                                      try!(get_server_array(array)),
                                      "topology requires an array of servers.");

        let ttype = val_or_err!(topology_obj.get("type"),
                                Some(&Value::String(ref s)) => TopologyType::from_str(s).unwrap(),
                                "topology requires a type");

        Ok(Suite {
            in_latency_window: in_latency_window,
            write: write,
            read_preference: read_preference,
            suitable_servers: suitable_servers,
            topology_description: TopologyDescription::new(top_servers, ttype),
        })
    }
}