esrc 0.1.0

Primitives for implementing event sourcing and CQRS systems
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

use async_nats::jetstream::consumer::pull::{MessagesError, OrderedError};
use async_nats::jetstream::consumer::StreamError;
use async_nats::jetstream::context::{
    CreateStreamError,
    GetStreamError,
    PublishError,
    PublishErrorKind,
};
use async_nats::jetstream::stream::{ConsumerError, PurgeError};

use crate::error::Error;

impl From<PublishError> for Error {
    fn from(value: PublishError) -> Self {
        match value.kind() {
            PublishErrorKind::WrongLastSequence => Self::Conflict,
            _ => Self::Internal(value.into()),
        }
    }
}

macro_rules! impl_from {
    ($error:ty, $variant:ident) => {
        impl From<$error> for crate::error::Error {
            fn from(value: $error) -> Self {
                Self::$variant(value.into())
            }
        }
    };
}

impl_from!(CreateStreamError, Internal);
impl_from!(ConsumerError, Internal);
impl_from!(GetStreamError, Internal);
impl_from!(MessagesError, Internal);
impl_from!(OrderedError, Internal);
impl_from!(PurgeError, Internal);
impl_from!(StreamError, Internal);