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
#[derive(Debug, thiserror::Error)]
pub enum GlimeshError {
#[error("Graphql error(s): {0:?}")]
GraphqlErrors(Vec<graphql_client::Error>),
#[error("Missing response data")]
NoData,
}
#[derive(Debug, thiserror::Error)]
pub enum AuthError {
#[error("{0} response from api")]
BadStatus(u16),
#[error("Missing redirect uri in client config")]
MissingRedirect,
#[error("Missing refresh token")]
MissingRefreshToken,
#[error(transparent)]
Unknown(#[from] anyhow::Error),
}
#[cfg(feature = "http")]
#[derive(Debug, thiserror::Error)]
pub enum HttpConnectionError {
#[error(transparent)]
Glimesh(#[from] GlimeshError),
#[error(transparent)]
Auth(#[from] AuthError),
#[error("{0} response from api")]
BadStatus(u16),
#[error(transparent)]
Unknown(#[from] anyhow::Error),
}
#[cfg(feature = "websocket")]
#[derive(Debug, thiserror::Error)]
pub enum WebsocketConnectionError {
#[error(transparent)]
Glimesh(#[from] GlimeshError),
#[error(transparent)]
Auth(#[from] AuthError),
#[error(transparent)]
QueryParamSerialization(#[from] serde_urlencoded::ser::Error),
#[error(transparent)]
SerdeJson(#[from] serde_json::Error),
#[error(transparent)]
Tungstenite(#[from] async_tungstenite::tungstenite::Error),
#[error("failed to send socket message over channel, {0}")]
SendError(#[from] tokio::sync::mpsc::error::SendError<async_tungstenite::tungstenite::Message>),
#[error("request timed out")]
Timeout(#[from] tokio::time::error::Elapsed),
#[error("attempt to connect a socket that is already holding on to a connection")]
AlreadyConnected,
#[error("attmpted to send or receive on a closed socket")]
SocketClosed,
#[error(transparent)]
Unknown(#[from] anyhow::Error),
}