Function graph_path_and_subgraph

nodedb/tests/executor_tests/test_graph.rs:90–141

()

#[test]
fn graph_path_and_subgraph() {
    let (mut core, mut tx, mut rx, _dir) = make_core();

    for (s, d) in &[("a", "b"), ("b", "c")] {
        send_ok(
            &mut core,
            &mut tx,
            &mut rx,
            PhysicalPlan::Graph(GraphOp::EdgePut {
                collection: "col".into(),
                src_id: s.to_string(),
                label: "L".into(),
                dst_id: d.to_string(),
                properties: vec![],
                src_surrogate: nodedb_types::Surrogate::ZERO,
                dst_surrogate: nodedb_types::Surrogate::ZERO,
            }),
        );
    }

    let payload = send_ok(
        &mut core,
        &mut tx,
        &mut rx,
        PhysicalPlan::Graph(GraphOp::Path {
            src: "a".into(),
            dst: "c".into(),
            edge_label: Some("L".into()),
            max_depth: 5,
            options: Default::default(),
            rls_filters: Vec::new(),
            frontier_bitmap: None,
        }),
    );
    let path: Vec<String> = serde_json::from_value(payload_value(&payload)).unwrap();
    assert_eq!(path, vec!["a", "b", "c"]);

    let payload = send_ok(
        &mut core,
        &mut tx,
        &mut rx,
        PhysicalPlan::Graph(GraphOp::Subgraph {
            start_nodes: vec!["a".into()],
            edge_label: None,
            depth: 2,
            options: Default::default(),
            rls_filters: Vec::new(),
        }),
    );
    let edges: Vec<serde_json::Value> = serde_json::from_value(payload_value(&payload)).unwrap();
    assert_eq!(edges.len(), 2);
}

#[test]
fn edge_delete_updates_csr() {