indradb 0.19.0

A graph database server
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

use client_datastore::ClientDatastore;
use indradb::util::generate_temporary_path;
use indradb::{Datastore, Transaction};
use server;
use std::panic::catch_unwind;
use std::sync::atomic::AtomicUsize;
use std::sync::atomic::Ordering;
use std::thread::spawn;

const START_PORT: u16 = 27616;

lazy_static! {
    static ref CURRENT_PORT: AtomicUsize = AtomicUsize::new(START_PORT as usize);
}

full_test_impl!({
    let port = (*CURRENT_PORT).fetch_add(1, Ordering::SeqCst);
    spawn(move || server::start(&format!("127.0.0.1:{}", port), "memory://", 1));
    ClientDatastore::new(port as u16)
});

#[test]
fn should_create_rocksdb_datastore() {
    let port = (*CURRENT_PORT).fetch_add(1, Ordering::SeqCst);

    spawn(move || {
        let connection_string = format!("rocksdb://{}", generate_temporary_path());
        server::start(&format!("127.0.0.1:{}", port), &connection_string, 1)
    });

    // Just make sure we can run a command
    let datastore = ClientDatastore::new(port as u16);
    let trans = datastore.transaction().unwrap();
    let count = trans.get_vertex_count().unwrap();

    assert_eq!(count, 0);
}

#[test]
fn should_panic_on_bad_connection_string() {
    let result = catch_unwind(|| server::start("127.0.0.1:9999", "foo://", 1));
    assert!(result.is_err());
}