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
|
use serenity::{
client::Context,
model::{
id::{
ChannelId,
MessageId,
},
permissions::Permissions,
},
};
use lazy_static::lazy_static;
use log::debug;
use serenity::{
all::CreateMessage,
futures::{
AsyncReadExt,
StreamExt,
},
};
use url::Url;
use crate::{
audio::PlayQueue,
Result,
CONFIG,
};
pub async fn currently_playing(ctx: &Context) -> bool {
let queue_lock = {
let data = ctx.data.read().await;
data.get::<PlayQueue>().cloned().unwrap()
};
let play_queue = queue_lock.read().unwrap();
play_queue.playing.is_some()
}
pub async fn users_listening(ctx: &Context) -> Result<bool> {
let channel = CONFIG.discord.voice_channel().to_channel(&ctx).await?;
let res = channel
.guild()
.and_then(|ch| ch.guild(&ctx))
.map(|g| {
(&g.voice_states)
.into_iter()
.any(|(_, state)| state.channel_id == Some(CONFIG.discord.voice_channel()))
})
.unwrap_or(false);
Ok(res)
}
#[inline]
pub async fn send(
ctx: &Context,
channel: ChannelId,
text: impl AsRef<str>,
tts: bool,
) -> Result<()> {
send_result(ctx, channel, text, tts).await.map(|_| ())
}
pub async fn send_result(
ctx: &Context,
channel: ChannelId,
text: impl AsRef<str>,
tts: bool,
) -> Result<MessageId> {
let text = text.as_ref();
debug!("sending message {:?} to channel {:?} (tts: {})", text, channel, tts);
let result = channel.send_message(ctx, CreateMessage::default().content(text).tts(tts)).await?;
Ok(result.id)
}
lazy_static! {
static ref REQUIRED_PERMS: Permissions = Permissions::EMBED_LINKS
| Permissions::READ_MESSAGES
| Permissions::ADD_REACTIONS
| Permissions::SEND_MESSAGES
| Permissions::SEND_TTS_MESSAGES
| Permissions::MENTION_EVERYONE
| Permissions::USE_EXTERNAL_EMOJIS
| Permissions::CONNECT
| Permissions::SPEAK
| Permissions::CHANGE_NICKNAME
| Permissions::USE_VAD
| Permissions::ATTACH_FILES;
}
lazy_static! {
pub static ref OAUTH_URL: Url = Url::parse(&format!(
"https://discordapp.com/api/oauth2/authorize?scope=bot&permissions={}&client_id={}",
REQUIRED_PERMS.bits(),
CONFIG.discord.auth.client_id,
))
.unwrap();
}
|
