mob_push 0.2.1

notify pusher using Mob Push
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

use std::fmt::{Debug, Display};

use crate::{http_client::PushClient, UserSubscribeManage};

/// mob push 推送期间的异常
pub enum MobPushError<M, C>
where
    M: UserSubscribeManage,
    C: PushClient,
{
    /// 用户订阅持久化管理出现的异常
    Manage(M::Err),
    /// 发起请求时异常
    Request(C::Error),
    /// json 序列化、反序列化异常
    Json(serde_json::Error),
    /// mob 推送响应异常
    Mob { state: u16, msg: String },
}

impl<M, C> std::fmt::Debug for MobPushError<M, C>
where
    M: UserSubscribeManage,
    C: PushClient,
    C::Error: Debug,
{
    fn fmt(&self, f: &mut std::fmt::Formatter<'_>) -> std::fmt::Result {
        match self {
            Self::Manage(err) => f.debug_tuple("Manage").field(err).finish(),
            Self::Request(err) => f.debug_tuple("Request").field(err).finish(),
            MobPushError::Mob { state, msg } => f
                .debug_struct("Mob")
                .field("state", state)
                .field("msg", msg)
                .finish(),
            MobPushError::Json(err) => f.debug_tuple("Json").field(err).finish(),
        }
    }
}

impl<M, C> std::fmt::Display for MobPushError<M, C>
where
    M: UserSubscribeManage,
    C: PushClient,
    C::Error: Display,
{
    fn fmt(&self, f: &mut std::fmt::Formatter<'_>) -> std::fmt::Result {
        match self {
            MobPushError::Manage(err) => write!(f, "Subscribe Manage Error : {err}"),
            MobPushError::Request(err) => write!(f, "Request Error : {err}"),
            MobPushError::Mob { state, msg } => write!(f, "Mob Pusher Error : [{}] {}", state, msg),
            MobPushError::Json(err) => write!(f, "Json Error : {err}"),
        }
    }
}

impl<M, C> std::error::Error for MobPushError<M, C>
where
    M: UserSubscribeManage,
    C: PushClient,
    C::Error: std::error::Error,
{
}

impl<M: UserSubscribeManage, C: PushClient> From<(u16, String)> for MobPushError<M, C> {
    fn from((state, msg): (u16, String)) -> Self {
        Self::Mob { state, msg }
    }
}

impl<M: UserSubscribeManage, C: PushClient> From<serde_json::Error> for MobPushError<M, C> {
    fn from(err: serde_json::Error) -> Self {
        Self::Json(err)
    }
}