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
use serde::{Serialize, de::DeserializeOwned};
#[allow(unused)]
use serde_json::Value;
use connection::Manager as ConnectionManager;
use models::{
OpCode,
Command,
Event,
payload::Payload,
message::Message,
commands::{SubscriptionArgs, Subscription},
};
#[cfg(feature = "rich_presence")]
use models::rich_presence::{
SetActivityArgs,
Activity,
SendActivityJoinInviteArgs,
CloseActivityRequestArgs,
};
use error::{Result, Error};
#[derive(Clone)]
pub struct Client {
connection_manager: ConnectionManager,
}
impl Client {
pub fn new(client_id: u64) -> Self {
let connection_manager = ConnectionManager::new(client_id);
Self { connection_manager }
}
pub fn start(&mut self) {
self.connection_manager.start();
}
fn execute<A, E>(&mut self, cmd: Command, args: A, evt: Option<Event>) -> Result<Payload<E>>
where A: Serialize + Send + Sync,
E: Serialize + DeserializeOwned + Send + Sync
{
let message = Message::new(OpCode::Frame, Payload::with_nonce(cmd, Some(args), None, evt));
self.connection_manager.send(message)?;
let Message { payload, .. } = self.connection_manager.recv()?;
let response: Payload<E> = serde_json::from_str(&payload)?;
match response.evt {
Some(Event::Error) => Err(Error::SubscriptionFailed),
_ => Ok(response)
}
}
#[cfg(feature = "rich_presence")]
pub fn set_activity<F>(&mut self, f: F) -> Result<Payload<Activity>>
where F: FnOnce(Activity) -> Activity
{
self.execute(Command::SetActivity, SetActivityArgs::new(f), None)
}
#[cfg(feature = "rich_presence")]
pub fn clear_activity(&mut self) -> Result<Payload<Activity>> {
self.execute(Command::SetActivity, SetActivityArgs::default(), None)
}
#[cfg(feature = "rich_presence")]
pub fn send_activity_join_invite(&mut self, user_id: u64) -> Result<Payload<Value>> {
self.execute(Command::SendActivityJoinInvite, SendActivityJoinInviteArgs::new(user_id), None)
}
#[cfg(feature = "rich_presence")]
pub fn close_activity_request(&mut self, user_id: u64) -> Result<Payload<Value>> {
self.execute(Command::CloseActivityRequest, CloseActivityRequestArgs::new(user_id), None)
}
pub fn subscribe<F>(&mut self, evt: Event, f: F) -> Result<Payload<Subscription>>
where F: FnOnce(SubscriptionArgs) -> SubscriptionArgs
{
self.execute(Command::Subscribe, f(SubscriptionArgs::new()), Some(evt))
}
pub fn unsubscribe<F>(&mut self, evt: Event, f: F) -> Result<Payload<Subscription>>
where F: FnOnce(SubscriptionArgs) -> SubscriptionArgs
{
self.execute(Command::Unsubscribe, f(SubscriptionArgs::new()), Some(evt))
}
}