preview-glide-rust 0.2.0

Valkey GLIDE — native Rust client for Valkey and Redis OSS, built on glide-core.
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

// Copyright Valkey GLIDE Project Contributors - SPDX Identifier: Apache-2.0
//! Per-command geospatial integration tests (RESP2 + RESP3).

mod common;

use glide::commands::geo::{GeoUnit, GeospatialData};
use glide::{AsyncCommands, GeoCommands};

fn palermo() -> GeospatialData {
    GeospatialData {
        longitude: 13.361389,
        latitude: 38.115556,
    }
}
fn catania() -> GeospatialData {
    GeospatialData {
        longitude: 15.087269,
        latitude: 37.502669,
    }
}

matrix_test!(geoadd, c, {
    let k = common::key("geo");
    let added = c
        .geoadd(&k, &[("Palermo", palermo()), ("Catania", catania())])
        .await
        .unwrap();
    assert_eq!(added, 2);
    // Re-adding the same members returns 0 new.
    assert_eq!(c.geoadd(&k, &[("Palermo", palermo())]).await.unwrap(), 0);
});

matrix_test!(geodist_km, c, {
    let k = common::key("geo");
    c.geoadd(&k, &[("Palermo", palermo()), ("Catania", catania())])
        .await
        .unwrap();
    let dist = c
        .geodist(&k, "Palermo", "Catania", Some(GeoUnit::Kilometers))
        .await
        .unwrap();
    let d = dist.unwrap();
    // Known distance ~166 km.
    assert!(d > 160.0 && d < 170.0);
});

matrix_test!(geodist_missing_member_none, c, {
    let k = common::key("geo");
    c.geoadd(&k, &[("Palermo", palermo())]).await.unwrap();
    assert_eq!(
        c.geodist(&k, "Palermo", "Nowhere", None).await.unwrap(),
        None
    );
});

matrix_test!(geohash, c, {
    let k = common::key("geo");
    c.geoadd(&k, &[("Palermo", palermo())]).await.unwrap();
    let hashes = c.geohash(&k, &["Palermo", "Missing"]).await.unwrap();
    assert!(hashes[0].is_some());
    assert!(hashes[1].is_none());
});

matrix_test!(geopos, c, {
    let k = common::key("geo");
    c.geoadd(&k, &[("Palermo", palermo())]).await.unwrap();
    let positions = c.geopos(&k, &["Palermo", "Missing"]).await.unwrap();
    let (lon, lat) = positions[0].unwrap();
    assert!((lon - 13.361389).abs() < 0.001);
    assert!((lat - 38.115556).abs() < 0.001);
    assert!(positions[1].is_none());
});

matrix_test!(geosearch_by_radius, c, {
    let k = common::key("geo");
    c.geoadd(&k, &[("Palermo", palermo()), ("Catania", catania())])
        .await
        .unwrap();
    let found = c
        .geosearch_by_radius_from_member(&k, "Palermo", 200.0, GeoUnit::Kilometers)
        .await
        .unwrap();
    assert_eq!(found.len(), 2);
    let narrow = c
        .geosearch_by_radius_from_member(&k, "Palermo", 1.0, GeoUnit::Kilometers)
        .await
        .unwrap();
    assert_eq!(narrow.len(), 1);
});

matrix_test!(geo_wrong_type_errors, c, {
    let k = common::key("wt");
    c.set::<_, _, ()>(&k, "notgeo").await.unwrap();
    assert_request_error!(c.geoadd(&k, &[("X", palermo())]).await);
});