rayforce 1.0.1

Convenient, high-performance Rust bindings for RayforceDB v2
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

//! End-to-end check of the `rayforce-q` Q IPC client against a *real* `q`
//! server (not the mock in `q.rs`). Gated on `RAYFORCE_Q_ADDR=host:port`
//! so it's a no-op when no Q endpoint is available (CI, no `q` binary).
//!
//! Start a server first, e.g.:
//!   QHOME=~/lynx/q/m64 ~/lynx/q/m64/m64/q fixsrv.q -q
//! then:
//!   RAYFORCE_Q_ADDR=127.0.0.1:5010 cargo test -p rayforce --test q_real -- --nocapture

use rayforce::{q::QConnection, Runtime, Table};

fn addr() -> Option<(String, u16)> {
    let a = std::env::var("RAYFORCE_Q_ADDR").ok()?;
    let (h, p) = a.rsplit_once(':')?;
    Some((h.to_string(), p.parse().ok()?))
}

#[test]
fn real_q_roundtrips_atoms_vectors_and_tables() {
    let Some((host, port)) = addr() else {
        eprintln!("RAYFORCE_Q_ADDR unset — skipping real-q e2e");
        return;
    };
    let _rt = Runtime::new().unwrap();
    let conn = QConnection::connect(&host, port).unwrap();

    // scalar
    let v = conn.execute("ping 41").unwrap();
    assert_eq!(v.format(), "42");

    // vector
    let v = conn.execute("exec seq from fixmsgs").unwrap();
    assert_eq!(v.as_slice::<i64>().unwrap(), &[1, 2, 3, 4, 5]);

    // full table
    let t = Table::from_value(conn.execute("select from fixmsgs").unwrap()).unwrap();
    assert_eq!(t.shape(), (5, 4));
    assert_eq!(
        t.column("seq").unwrap().as_slice::<i64>().unwrap(),
        &[1, 2, 3, 4, 5]
    );
    let sym = t.column("sym").unwrap();
    assert_eq!(sym.get(0).unwrap().as_sym().unwrap(), "AAPL");
    assert_eq!(sym.get(4).unwrap().as_sym().unwrap(), "TSLA");

    // RevoLT-style pull-by-sequence: only rows past a cursor
    let t = Table::from_value(conn.execute("select from fixmsgs where seq > 3").unwrap()).unwrap();
    assert_eq!(t.shape(), (2, 4));
    assert_eq!(t.column("seq").unwrap().as_slice::<i64>().unwrap(), &[4, 5]);

    // server-side error surfaces as Err
    assert!(conn.execute("1+`a").is_err());
}