Compare commits
No commits in common. "48b50f783d0847732cd62565a7471b11a76b85a7" and "bec92177cb611c37fc8da9a2a8747b0978467244" have entirely different histories.
48b50f783d
...
bec92177cb
2
Cargo.lock
generated
2
Cargo.lock
generated
@ -2215,7 +2215,7 @@ dependencies = [
|
|||||||
|
|
||||||
[[package]]
|
[[package]]
|
||||||
name = "soundfx-rs"
|
name = "soundfx-rs"
|
||||||
version = "1.5.12"
|
version = "1.5.11"
|
||||||
dependencies = [
|
dependencies = [
|
||||||
"axum",
|
"axum",
|
||||||
"dashmap",
|
"dashmap",
|
||||||
|
@ -2,7 +2,7 @@
|
|||||||
name = "soundfx-rs"
|
name = "soundfx-rs"
|
||||||
description = "Discord bot for custom sound effects and soundboards"
|
description = "Discord bot for custom sound effects and soundboards"
|
||||||
license = "AGPL-3.0-only"
|
license = "AGPL-3.0-only"
|
||||||
version = "1.5.12"
|
version = "1.5.11"
|
||||||
authors = ["jellywx <judesouthworth@pm.me>"]
|
authors = ["jellywx <judesouthworth@pm.me>"]
|
||||||
edition = "2018"
|
edition = "2018"
|
||||||
|
|
||||||
|
@ -1,8 +1,6 @@
|
|||||||
use poise::serenity_prelude::{Attachment, GuildId, RoleId};
|
use poise::serenity_prelude::{Attachment, GuildId, RoleId};
|
||||||
use tokio::fs::File;
|
use tokio::fs::File;
|
||||||
|
|
||||||
#[cfg(feature = "metrics")]
|
|
||||||
use crate::metrics::{DELETE_COUNTER, UPLOAD_COUNTER};
|
|
||||||
use crate::{
|
use crate::{
|
||||||
cmds::autocomplete_sound,
|
cmds::autocomplete_sound,
|
||||||
consts::{MAX_SOUNDS, PATREON_GUILD, PATREON_ROLE},
|
consts::{MAX_SOUNDS, PATREON_GUILD, PATREON_ROLE},
|
||||||
@ -23,9 +21,6 @@ pub async fn upload_new_sound(
|
|||||||
#[description = "Name to upload sound to"] name: String,
|
#[description = "Name to upload sound to"] name: String,
|
||||||
#[description = "Sound file (max. 2MB)"] file: Attachment,
|
#[description = "Sound file (max. 2MB)"] file: Attachment,
|
||||||
) -> Result<(), Error> {
|
) -> Result<(), Error> {
|
||||||
#[cfg(feature = "metrics")]
|
|
||||||
UPLOAD_COUNTER.inc();
|
|
||||||
|
|
||||||
ctx.defer().await?;
|
ctx.defer().await?;
|
||||||
|
|
||||||
fn is_numeric(s: &String) -> bool {
|
fn is_numeric(s: &String) -> bool {
|
||||||
@ -115,9 +110,6 @@ pub async fn delete_sound(
|
|||||||
#[autocomplete = "autocomplete_sound"]
|
#[autocomplete = "autocomplete_sound"]
|
||||||
name: String,
|
name: String,
|
||||||
) -> Result<(), Error> {
|
) -> Result<(), Error> {
|
||||||
#[cfg(feature = "metrics")]
|
|
||||||
DELETE_COUNTER.inc();
|
|
||||||
|
|
||||||
let pool = ctx.data().database.clone();
|
let pool = ctx.data().database.clone();
|
||||||
|
|
||||||
let uid = ctx.author().id.0;
|
let uid = ctx.author().id.0;
|
||||||
|
@ -25,13 +25,13 @@ pub async fn play(
|
|||||||
#[channel_types("Voice")]
|
#[channel_types("Voice")]
|
||||||
channel: Option<GuildChannel>,
|
channel: Option<GuildChannel>,
|
||||||
) -> Result<(), Error> {
|
) -> Result<(), Error> {
|
||||||
#[cfg(feature = "metrics")]
|
|
||||||
PLAY_COUNTER.inc();
|
|
||||||
|
|
||||||
ctx.defer().await?;
|
ctx.defer().await?;
|
||||||
|
|
||||||
let guild = ctx.guild().unwrap();
|
let guild = ctx.guild().unwrap();
|
||||||
|
|
||||||
|
#[cfg(feature = "metrics")]
|
||||||
|
PLAY_COUNTER.inc();
|
||||||
|
|
||||||
ctx.say(
|
ctx.say(
|
||||||
play_from_query(
|
play_from_query(
|
||||||
&ctx.serenity_context(),
|
&ctx.serenity_context(),
|
||||||
@ -78,15 +78,9 @@ pub async fn play_random(
|
|||||||
join_channel(ctx.serenity_context(), guild.clone(), channel).await;
|
join_channel(ctx.serenity_context(), guild.clone(), channel).await;
|
||||||
|
|
||||||
let sounds = ctx.data().guild_sounds(guild.id, None).await?;
|
let sounds = ctx.data().guild_sounds(guild.id, None).await?;
|
||||||
if sounds.len() == 0 {
|
|
||||||
ctx.say("No sounds in this server!").await?;
|
|
||||||
return Ok(());
|
|
||||||
}
|
|
||||||
|
|
||||||
let ts = SystemTime::now().duration_since(UNIX_EPOCH).unwrap();
|
let ts = SystemTime::now().duration_since(UNIX_EPOCH).unwrap();
|
||||||
|
|
||||||
println!("{}", ts.subsec_micros());
|
|
||||||
|
|
||||||
// This is far cheaper and easier than using an RNG. No reason to use a full RNG here
|
// This is far cheaper and easier than using an RNG. No reason to use a full RNG here
|
||||||
// anyway.
|
// anyway.
|
||||||
match sounds.get(ts.subsec_micros() as usize % sounds.len()) {
|
match sounds.get(ts.subsec_micros() as usize % sounds.len()) {
|
||||||
@ -103,9 +97,6 @@ pub async fn play_random(
|
|||||||
)
|
)
|
||||||
.await
|
.await
|
||||||
.unwrap();
|
.unwrap();
|
||||||
|
|
||||||
ctx.say(format!("Playing {} (ID {})", sound.name, sound.id))
|
|
||||||
.await?;
|
|
||||||
}
|
}
|
||||||
|
|
||||||
None => {
|
None => {
|
||||||
|
@ -30,6 +30,7 @@ type Database = MySql;
|
|||||||
|
|
||||||
pub struct Data {
|
pub struct Data {
|
||||||
database: Pool<Database>,
|
database: Pool<Database>,
|
||||||
|
http: reqwest::Client,
|
||||||
guild_data_cache: DashMap<GuildId, Arc<RwLock<GuildData>>>,
|
guild_data_cache: DashMap<GuildId, Arc<RwLock<GuildData>>>,
|
||||||
join_sound_cache: DashMap<UserId, DashMap<Option<GuildId>, Option<u32>>>,
|
join_sound_cache: DashMap<UserId, DashMap<Option<GuildId>, Option<u32>>>,
|
||||||
}
|
}
|
||||||
@ -158,6 +159,7 @@ async fn main() -> Result<(), Box<dyn std::error::Error + Send + Sync>> {
|
|||||||
.unwrap();
|
.unwrap();
|
||||||
|
|
||||||
Ok(Data {
|
Ok(Data {
|
||||||
|
http: reqwest::Client::new(),
|
||||||
database,
|
database,
|
||||||
guild_data_cache: Default::default(),
|
guild_data_cache: Default::default(),
|
||||||
join_sound_cache: Default::default(),
|
join_sound_cache: Default::default(),
|
||||||
|
@ -8,11 +8,7 @@ use prometheus::{register_int_counter, IntCounter, Registry};
|
|||||||
lazy_static! {
|
lazy_static! {
|
||||||
static ref REGISTRY: Registry = Registry::new();
|
static ref REGISTRY: Registry = Registry::new();
|
||||||
pub static ref PLAY_COUNTER: IntCounter =
|
pub static ref PLAY_COUNTER: IntCounter =
|
||||||
register_int_counter!("play_cmd", "Number of calls to /play").unwrap();
|
register_int_counter!("play", "Number of calls to /play").unwrap();
|
||||||
pub static ref UPLOAD_COUNTER: IntCounter =
|
|
||||||
register_int_counter!("upload_cmd", "Number of calls to /upload").unwrap();
|
|
||||||
pub static ref DELETE_COUNTER: IntCounter =
|
|
||||||
register_int_counter!("delete_cmd", "Number of calls to /delete").unwrap();
|
|
||||||
}
|
}
|
||||||
|
|
||||||
pub fn init_metrics() {
|
pub fn init_metrics() {
|
||||||
|
Loading…
Reference in New Issue
Block a user