infinite-db 0.4.0

A spatial-graph database using n-dimensional curves and hyperedges for engineering logic.
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

//! Minimal TCP client for manual server smoke tests.
//!
//! ```text
//! cargo run --bin infinite-db-test --features sync -- <host:port> ping
//! cargo run --bin infinite-db-test --features sync -- 127.0.0.1:9000 query
//! ```

use std::env;

use infinite_db::infinitedb_core::address::{DimensionVector, SpaceId};
use infinite_db::infinitedb_core::snapshot::SnapshotId;
use infinite_db::{client_roundtrip, Request};
use tokio::runtime::Runtime;

fn main() {
    let mut args = env::args().skip(1);
    let addr: std::net::SocketAddr = args
        .next()
        .expect("usage: infinite-db-test <host:port> <ping|query>")
        .parse()
        .expect("invalid address");
    let cmd = args.next().unwrap_or_else(|| "ping".to_string());

    let request = match cmd.as_str() {
        "ping" => Request::Ping,
        "query" => Request::Query {
            space: SpaceId(1),
            snapshot: SnapshotId(0),
            key_range: None,
            as_of: None,
            include_tombstones: false,
        },
        "write" => Request::Write {
            address: infinite_db::infinitedb_core::address::Address::new(
                SpaceId(1),
                DimensionVector::new(vec![0, 0]),
            ),
            revision: infinite_db::infinitedb_core::address::RevisionId(1),
            data: vec![1, 2, 3],
        },
        other => panic!("unknown command {other}"),
    };

    let runtime = Runtime::new().expect("tokio runtime");
    let response = runtime
        .block_on(client_roundtrip(addr, request))
        .expect("request failed");
    println!("{response:?}");
}