arangoq 0.3.4

An AQL query builder layer and ArangoDb client 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
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124
125
126
127
128
129
130
131
132
133
134
135
136
137
138
139

#[cfg(feature = "actors")]
use actix::{Actor, System};
#[cfg(feature = "actors")]
use actix_rt::spawn;
use arangoq::*;
#[cfg(feature = "actors")]
use futures::future::FutureExt;
#[cfg(feature = "actors")]
use mockito;
#[cfg(feature = "actors")]
use mockito::mock;
use serde::{Deserialize, Serialize};

#[cfg(feature = "actors")]
#[test]
fn test_async_tooling() {
    std::env::set_var("RUST_LOG", "debug,hyper=info");
    let _res = env_logger::try_init();
    std::env::set_var("ARANGO_USER_NAME", "evt_write");
    std::env::set_var("ARANGO_PASSWORD", "notarealpw");

    let mock_resp = r#"{"result":[{"_key":"537130","id":8,"name":"NU","parent_id":"organizers/4242"}],"hasMore":false,"cached":false,"extra":{"stats":{"writesExecuted":0,"writesIgnored":0,"scannedFull":1,"scannedIndex":0,"filtered":0,"httpRequests":0,"executionTime":0.0012001991271972656,"peakMemoryUsage":8007},"warnings":[]},"error":false,"code":201}"#;
    let _m = mock("POST", "/_db/evt_test/_api/cursor")
        .with_status(200)
        .with_header("content-type", "application/json")
        .with_body(mock_resp)
        .expect(1)
        .create();

    // start system, it is a required step
    let _res = System::run(|| {
        let db_name = "evt_test".to_owned();
        // create new connection
        let connection =
            ArangoConnection::new(mockito::server_url(), db_name, reqwest::Client::new());
        // start new actor
        let addr = ArangoActorAsync { connection }.start();

        // create query
        let query = TestUser::query_builder("TestUsers").read().build();
        let dbq = DbQuery(query, std::marker::PhantomData::<TestUser>);

        // send message and get future for result
        let res = addr.send(dbq);

        // handle() returns tokio handle
        spawn(res.map(|res| {
            println!("RESULT: {:#?}", res);
            assert_eq!("NU", res.unwrap().unwrap().result.first().unwrap().name);
            // stop system and exit
            System::current().stop();
        }));
    });
}

#[cfg(feature = "actors")]
#[test]
fn test_json_async_tooling() {
    std::env::set_var("RUST_LOG", "debug,hyper=info");
    let _res = env_logger::try_init();
    std::env::set_var("ARANGO_USER_NAME", "evt_write");
    std::env::set_var("ARANGO_PASSWORD", "notarealpw");

    let mock_resp = r#"{"result":[{"_key":"537130","id":8,"name":"NU","parent_id":"organizers/4242"}],"hasMore":false,"cached":false,"extra":{"stats":{"writesExecuted":0,"writesIgnored":0,"scannedFull":1,"scannedIndex":0,"filtered":0,"httpRequests":0,"executionTime":0.0012001991271972656,"peakMemoryUsage":8007},"warnings":[]},"error":false,"code":201}"#;
    let _m = mock("POST", "/_db/evt_test/_api/cursor")
        .with_status(200)
        .with_header("content-type", "application/json")
        .with_body(mock_resp)
        .expect(1)
        .create();

    // start system, it is a required step
    let _res = System::run(|| {
        let db_name = "evt_test".to_owned();
        // create new connection
        let connection =
            ArangoConnection::new(mockito::server_url(), db_name, reqwest::Client::new());
        // start new actor
        let addr = ArangoActorAsync { connection }.start();

        // create query
        let query = TestUser::query_builder("TestUsers").read().build();

        // send message and get future for result
        let res = addr.send(query);

        // handle() returns tokio handle
        spawn(res.map(|res| {
            println!("RESULT: {:#?}", res);
            assert_eq!("NU", res.unwrap().unwrap().result.first().unwrap()["name"]);
            // stop system and exit
            System::current().stop();
        }));
    });
}

#[derive(Serialize, Deserialize, ArangoBuilder, Debug)]
pub struct TestUser {
    name: String,
}

#[cfg(feature = "actixclient")]
#[ignore]
#[test]
fn test_arango_connection_actix() {
    // use actix::prelude::*;
    use actix_web::client::Client;
    use actix_web::test;

    std::env::set_var("RUST_BACKTRACE", "1");
    let aconn = ArangoConnection::new("http://127.0.0.1:8529".to_owned(), Client::default());
    let collection_name = "Users";
    let query = TestUser::query_builder(collection_name).read().build();
    // let sys = System::new("db_example");
    // let res = Arbiter::spawn(
    //     futures::future::ok(query.exec(&aconn)).block_on()
    // );
    let res: Result<ArangoResponse<TestUser>, actix_web::Error> =
        test::block_on(query.exec(&aconn));
    debug!("{:#?}", res);
    // sys.run();
}

#[cfg(feature = "actixclient")]
#[ignore]
#[test]
fn test_db_get_from_collection() {
    use actix_web::client::Client;
    use actix_web::test;
    let coll = "test_coll";
    let res = test::block_fn(move || {
        _get_from_collection(&coll, &Client::default(), "http://localhost:8529")
    });
    let resp = test::block_on(res).unwrap();
    // let resp_json: serde_json::Value = test::block_on(resp.json()).unwrap();

    assert!(resp["result"][1]["globallyUniqueId"].eq("_statistics"));
    let _coll_resp: ArangoResponse<serde_json::Value> = serde_json::from_value(resp).unwrap();
}