falkordb 0.1.7

A FalkorDB Rust client
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
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
96
97
98
99
100
101
102
103
104
105
106
107

/*
 * Copyright FalkorDB Ltd. 2023 - present
 * Licensed under the MIT License.
 */

use crate::{
    parser::{redis_value_as_float, redis_value_as_vec},
    FalkorDBError::ParsingVec32,
    FalkorResult,
};

#[derive(Clone, Debug, Default, PartialEq)]
pub struct Vec32 {
    /// The values of the vector
    pub values: Vec<f32>,
}

impl Vec32 {
    /// Parses a Vec32 from a redis::Value::Array,
    /// # Arguments
    /// * `value`: The value to parse
    ///
    /// # Returns
    /// Self, if successful
    #[cfg_attr(
        feature = "tracing",
        tracing::instrument(name = "Parse Vec32", skip_all, level = "trace")
    )]
    pub fn parse(value: redis::Value) -> FalkorResult<Vec32> {
        let values: Vec<redis::Value> =
            redis_value_as_vec(value).map_err(|e| ParsingVec32(e.to_string()))?;

        let parsed_values: Vec<f32> = values
            .into_iter()
            .map(redis_value_as_float)
            .collect::<Result<_, _>>()?;
        let vec32 = Vec32 {
            values: parsed_values,
        };

        Ok(vec32)
    }
}
#[cfg(test)]
mod tests {
    use super::*;
    use crate::FalkorDBError;

    #[test]
    fn test_parse_valid_vec32() {
        let value = redis::Value::Array(vec![
            redis::Value::SimpleString("45.0".to_string()),
            redis::Value::SimpleString("90.0".to_string()),
        ]);
        let result = Vec32::parse(value);
        assert!(result.is_ok());
        let vec = result.unwrap().values;
        assert_eq!(vec.len(), 2);
        assert_eq!(vec[0], 45.0);
        assert_eq!(vec[1], 90.0);
    }

    #[test]
    fn test_parse_invalid_vec32_not_an_array() {
        let value = redis::Value::SimpleString("not an array".to_string());
        let result = Vec32::parse(value);
        assert!(result.is_err());
        assert_eq!(
            result.unwrap_err(),
            FalkorDBError::ParsingVec32("Element was not of type Array".to_string())
        );
    }

    #[test]
    fn test_parse_invalid_vec32_invalid_elements() {
        let value = redis::Value::Array(vec![
            redis::Value::SimpleString("45.0".to_string()),
            redis::Value::SimpleString("not a number".to_string()),
        ]);
        let result = Vec32::parse(value);
        assert!(result.is_err());
        assert_eq!(result.unwrap_err(), FalkorDBError::ParsingF32);
    }

    #[test]
    fn test_parse_empty_vec32() {
        let value = redis::Value::Array(vec![]);
        let result = Vec32::parse(value);
        assert!(result.is_ok());
        assert!(result.unwrap().values.is_empty());
    }
}

#[test]
fn test_parse_special_float_values() {
    let value = redis::Value::Array(vec![
        redis::Value::SimpleString("NaN".to_string()),
        redis::Value::SimpleString("Infinity".to_string()),
        redis::Value::SimpleString("-Infinity".to_string()),
    ]);
    let result = Vec32::parse(value);
    assert!(result.is_ok());
    let vec = result.unwrap().values;
    assert!(vec[0].is_nan());
    assert!(vec[1].is_infinite());
    assert!(vec[2].is_infinite());
}