astroport-circular-buffer 0.2.0

Circular buffer to store time series data in CosmWasm contracts
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

use cosmwasm_std::StdError;
use thiserror::Error;

pub type BufferResult<R> = Result<R, BufferError>;

/// This enum describes pair contract errors
#[derive(Error, Debug, PartialEq)]
pub enum BufferError {
    #[error("{0}")]
    Std(#[from] StdError),

    #[error("Can't reduce capacity because buffer contains key(s) greater than new head")]
    ReduceCapacityError {},

    #[error("Can't save value at index {0} which greater than capacity")]
    SaveValueError(u32),

    #[error("Can't read value at index {0} which greater than capacity")]
    ReadAheadError(u32),

    #[error("Index {0} not found")]
    IndexNotFound(u32),

    #[error("Buffer not initialized")]
    BufferNotInitialized {},

    #[error("Buffer already initialized")]
    BufferAlreadyInitialized {},
}

impl From<BufferError> for StdError {
    fn from(value: BufferError) -> Self {
        match value {
            BufferError::Std(err) => err,
            _ => StdError::generic_err(value.to_string()),
        }
    }
}

#[cfg(test)]
mod testing {
    use super::*;

    #[test]
    fn test_buffer_error() {
        let err = BufferError::Std(StdError::generic_err("test"));
        let std_err: StdError = err.into();
        assert_eq!(std_err, StdError::generic_err("test"));

        let custom_err = BufferError::ReduceCapacityError {};
        let std_err: StdError = custom_err.into();
        assert_eq!(
            std_err,
            StdError::generic_err(
                "Can't reduce capacity because buffer contains key(s) greater than new head"
            )
        );
    }
}