large refactor: reorganize code

This commit is contained in:
2024-10-11 20:33:12 -04:00
parent ecbf4cad06
commit 4e08e25575
10 changed files with 240 additions and 183 deletions

73
src/commands/dox.rs Normal file
View File

@@ -0,0 +1,73 @@
use crate::common::{Context, Error};
use poise::serenity_prelude as serenity;
use serenity::Colour;
fn get_dox_output(ctx: &mut Context<'_>,
user: &serenity::User,
member: Option<&serenity::Member>,
show_permissions: bool) -> String {
let mut output = String::new();
if user.bot {
output.push_str("This user is a bot.\n");
}
output.push_str(&format!("**User ID**: {}\n", user.id));
if let Some(locale) = &user.locale {
output.push_str(&format!("**Locale**: {locale}\n"));
}
if let Some(verified) = &user.verified {
output.push_str(&format!("**Verified**: {verified}\n"));
}
output.push_str(&format!("**Account Created**: {}\n", user.created_at()));
if let Some(Some(join_date)) = member.as_ref().map(|m| m.joined_at) {
output.push_str(&format!("**Joined this Server at**: {join_date}\n"));
}
if let Some(Some(premium_since)) = member.as_ref().map(|m| m.premium_since) {
output.push_str(
&format!("**Boosting this Server**: Yes\n**Boosting since**: {premium_since}\n"));
}
if let Some(Ok(permissions)) = member.map(|m| m.permissions(ctx)).filter(|_| show_permissions) {
output.push_str(&format!("**Permissions**: {}\n",
permissions.get_permission_names().join(", ")))
}
output
}
/// Display information about a given user
#[poise::command(slash_command, prefix_command)]
pub async fn dox(mut ctx: Context<'_>,
#[description = "The user to display information of"]
user: serenity::User,
#[rename = "permissions"]
#[description = "Rather or not to show the user's permissions"]
show_permissions: Option<bool>) -> Result<(), Error>
{
let user = ctx.http().get_user(user.id).await?;
let member = if let Some(guild) = ctx.guild_id() {
guild.member(ctx.http(), user.id).await.ok()
} else {
None
};
let embed = serenity::CreateEmbed::default()
.title(format!("Information about {}", user.name))
.description(get_dox_output(
&mut ctx, &user, member.as_ref(), show_permissions.unwrap_or(false)))
.colour(member.map(|m| m.colour(ctx.cache()))
.unwrap_or(None)
.unwrap_or(user.accent_colour.unwrap_or(Colour::from_rgb(255, 255, 255))))
.image(user.face());
ctx.send(poise::CreateReply::default().embed(embed)).await?;
Ok(())
}

View File

@@ -0,0 +1,20 @@
use super::get_user_wealth_mut;
use crate::common::{Context, Error};
use poise::serenity_prelude as serenity;
#[poise::command(slash_command, prefix_command)]
pub async fn balance(ctx: Context<'_>, user: Option<serenity::User>) -> Result<(), Error> {
let user = user.as_ref().unwrap_or(ctx.author());
let mut users = ctx.data().users.lock().await;
let wealth = get_user_wealth_mut(&mut users, user.id);
ctx.reply(format!("{} **{}** token(s).",
if user.id == ctx.author().id {
"You have".to_string()
} else {
format!("{} has", user.name)
}, *wealth)).await?;
Ok(())
}

View File

@@ -0,0 +1,29 @@
use crate::{Context, Error};
use super::get_user_wealth_mut;
use poise::serenity_prelude as serenity;
#[poise::command(slash_command, prefix_command)]
pub async fn give(ctx: Context<'_>, user: serenity::User, amount: usize) -> Result<(), Error> {
if user.bot {
ctx.reply("Don't waste your token(s) by giving them to a bot!").await?;
return Ok(());
}
let mut users = ctx.data().users.lock().await;
let author_wealth = get_user_wealth_mut(&mut users, ctx.author().id);
if *author_wealth < amount {
ctx.reply(format!("You only have **{}** token(s) and cannot give away **{}**.",
*author_wealth, amount)).await?;
return Ok(());
}
*author_wealth -= amount;
let receiver_wealth = get_user_wealth_mut(&mut users, user.id);
*receiver_wealth += amount;
ctx.reply(format!("You've given **{}** **{}** token(s).", user.name, amount)).await?;
Ok(())
}

View File

@@ -0,0 +1,14 @@
use std::collections::HashMap;
use poise::serenity_prelude::UserId;
pub mod balance;
pub mod give;
pub mod wager;
pub(self) fn get_user_wealth_mut(users: &mut HashMap<UserId, usize>, id: UserId) -> &mut usize {
if users.get(&id).is_none() {
users.insert(id, 100);
}
users.get_mut(&id).unwrap()
}

View File

@@ -0,0 +1,26 @@
use crate::common::{Context, Error};
use super::get_user_wealth_mut;
#[poise::command(slash_command, prefix_command)]
pub async fn wager(ctx: Context<'_>, amount: usize) -> Result<(), Error> {
let mut users = ctx.data().users.lock().await;
let wealth = get_user_wealth_mut(&mut users, ctx.author().id);
if *wealth < amount {
ctx.reply("You do not have enough tokens to wager this amount.").await?;
return Ok(());
}
if rand::random() {
*wealth += amount;
ctx.reply(format!("You just gained {} token(s)! You now have **{}**.",
amount, *wealth)).await?;
} else {
*wealth -= amount;
ctx.reply(format!("You've lost **{}** token(s), you now have **{}**.",
amount, *wealth)).await?;
}
Ok(())
}

19
src/commands/mod.rs Normal file
View File

@@ -0,0 +1,19 @@
use crate::{Data, Error};
use poise::Command;
mod ping;
mod dox;
mod yeehaw;
mod gambling;
pub fn commands() -> Vec<Command<Data, Error>> {
vec![
ping::ping(),
dox::dox(),
yeehaw::yeehaw(),
gambling::balance::balance(),
gambling::give::give(),
gambling::wager::wager(),
]
}

17
src/commands/ping.rs Normal file
View File

@@ -0,0 +1,17 @@
use crate::common::{Context, Error};
/// Display the bot's latency to Discord's REST and Gateway APIs
#[poise::command(slash_command, prefix_command)]
pub async fn ping(ctx: Context<'_>) -> Result<(), Error> {
use std::time::Instant;
let start = Instant::now();
let msg = ctx.say("Pong! \u{1F3D3}").await?;
let time = start.elapsed();
msg.edit(ctx, poise::reply::CreateReply::default()
.content(format!("Pong! \u{1F3D3}\nREST: {:.2?}\nGateway: {:.2?}",
time, ctx.ping().await))).await?;
Ok(())
}

18
src/commands/yeehaw.rs Normal file
View File

@@ -0,0 +1,18 @@
use crate::common::{Context, Error};
use std::iter;
/// Pardner
#[poise::command(slash_command, prefix_command)]
pub async fn yeehaw(ctx: Context<'_>,
#[min = 1]
width: Option<usize>,
#[min = 1]
height: Option<usize>) -> Result<(), Error>
{
ctx.reply(iter::repeat("\u{1F920}".to_string().repeat(width.unwrap_or(1)))
.take(height.unwrap_or(1))
.collect::<Vec<_>>()
.join("\n")).await?;
Ok(())
}

11
src/common.rs Normal file
View File

@@ -0,0 +1,11 @@
use std::sync::Arc;
use tokio::sync::Mutex;
use std::collections::HashMap;
use poise::serenity_prelude::UserId;
pub struct Data {
pub users: Arc<Mutex<HashMap<UserId, usize>>>
}
pub type Error = Box<dyn std::error::Error + Send + Sync>;
pub type Context<'a> = poise::Context<'a, Data, Error>;

View File

@@ -1,187 +1,15 @@
mod commands;
pub mod common;
use crate::common::{Context, Error, Data};
use std::collections::HashMap; use std::collections::HashMap;
use std::env; use std::env;
use std::iter;
use std::sync::Arc; use std::sync::Arc;
use poise::serenity_prelude as serenity;
use tokio::sync::Mutex; use tokio::sync::Mutex;
use poise::{serenity_prelude::{self as serenity, Colour, UserId}, CreateReply};
struct Data {
users: Arc<Mutex<HashMap<UserId, usize>>>
}
type Error = Box<dyn std::error::Error + Send + Sync>;
type Context<'a> = poise::Context<'a, Data, Error>;
/// Display the bot's latency to Discord's REST and Gateway APIs
#[poise::command(slash_command, prefix_command)]
async fn ping(ctx: Context<'_>) -> Result<(), Error> {
use std::time::Instant;
let start = Instant::now();
let msg = ctx.say("Pong! \u{1F3D3}").await?;
let time = start.elapsed();
msg.edit(ctx, poise::reply::CreateReply::default()
.content(format!("Pong! \u{1F3D3}\nREST: {:.2?}\nGateway: {:.2?}",
time, ctx.ping().await))).await?;
Ok(())
}
fn get_dox_output(ctx: &mut Context<'_>,
user: &serenity::User,
member: Option<&serenity::Member>,
show_permissions: bool) -> String {
let mut output = String::new();
if user.bot {
output.push_str("This user is a bot.\n");
}
output.push_str(&format!("**User ID**: {}\n", user.id));
if let Some(locale) = &user.locale {
output.push_str(&format!("**Locale**: {locale}\n"));
}
if let Some(verified) = &user.verified {
output.push_str(&format!("**Verified**: {verified}\n"));
}
output.push_str(&format!("**Account Created**: {}\n", user.created_at()));
if let Some(Some(join_date)) = member.as_ref().map(|m| m.joined_at) {
output.push_str(&format!("**Joined this Server at**: {join_date}\n"));
}
if let Some(Some(premium_since)) = member.as_ref().map(|m| m.premium_since) {
output.push_str(
&format!("**Boosting this Server**: Yes\n**Boosting since**: {premium_since}\n"));
}
if let Some(Ok(permissions)) = member.map(|m| m.permissions(ctx)).filter(|_| show_permissions) {
output.push_str(&format!("**Permissions**: {}\n", permissions.get_permission_names().join(", ")))
}
output
}
/// Display information about a given user
#[poise::command(slash_command, prefix_command)]
async fn dox(
mut ctx: Context<'_>,
#[description = "The user to display information of"]
user: serenity::User,
#[rename = "permissions"]
#[description = "Rather or not to show the user's permissions"]
show_permissions: Option<bool>) -> Result<(), Error> {
let user = ctx.http().get_user(user.id).await?;
let member = if let Some(guild) = ctx.guild_id() {
guild.member(ctx.http(), user.id).await.ok()
} else {
None
};
let embed = serenity::CreateEmbed::default()
.title(format!("Information about {}", user.name))
.description(get_dox_output(&mut ctx, &user, member.as_ref(), show_permissions.unwrap_or(false)))
.colour(member.map(|m| m.colour(ctx.cache()))
.unwrap_or(None)
.unwrap_or(user.accent_colour.unwrap_or(Colour::from_rgb(255, 255, 255))))
.image(user.face());
ctx.send(CreateReply::default().embed(embed)).await?;
Ok(())
}
/// Pardner
#[poise::command(slash_command, prefix_command)]
async fn yeehaw(ctx: Context<'_>,
#[min = 1]
width: Option<usize>,
#[min = 1]
height: Option<usize>) -> Result<(), Error> {
ctx.reply(iter::repeat("\u{1F920}".to_string().repeat(width.unwrap_or(1)))
.take(height.unwrap_or(1))
.collect::<Vec<_>>()
.join("\n")).await?;
Ok(())
}
fn get_user_wealth_mut(users: &mut HashMap<UserId, usize>, id: UserId) -> &mut usize {
if users.get(&id).is_none() {
users.insert(id, 100);
}
users.get_mut(&id).unwrap()
}
#[poise::command(slash_command, prefix_command)]
async fn wager(ctx: Context<'_>, amount: usize) -> Result<(), Error> {
let mut users = ctx.data().users.lock().await;
let wealth = get_user_wealth_mut(&mut users, ctx.author().id);
if *wealth < amount {
ctx.reply("You do not have enough tokens to wager this amount.").await?;
return Ok(());
}
if rand::random() {
*wealth += amount;
ctx.reply(format!("You just gained {} token(s)! You now have **{}**.", amount, *wealth)).await?;
} else {
*wealth -= amount;
ctx.reply(format!("You've lost **{}** token(s), you now have **{}**.", amount, *wealth)).await?;
}
Ok(())
}
#[poise::command(slash_command, prefix_command)]
async fn give(ctx: Context<'_>, user: serenity::User, amount: usize) -> Result<(), Error> {
if user.bot {
ctx.reply("Don't waste your token(s) by giving them to a bot!").await?;
return Ok(());
}
let mut users = ctx.data().users.lock().await;
let author_wealth = get_user_wealth_mut(&mut users, ctx.author().id);
if *author_wealth < amount {
ctx.reply(format!("You only have **{}** token(s) and cannot give away **{}**.", *author_wealth, amount)).await?;
return Ok(());
}
*author_wealth -= amount;
let reciever_wealth = get_user_wealth_mut(&mut users, user.id);
*reciever_wealth += amount;
ctx.reply(format!("You've given **{}** **{}** token(s).", user.name, amount)).await?;
Ok(())
}
#[poise::command(slash_command, prefix_command)]
async fn balance(ctx: Context<'_>, user: Option<serenity::User>) -> Result<(), Error> {
let user = user.as_ref().unwrap_or(ctx.author());
let mut users = ctx.data().users.lock().await;
let wealth = get_user_wealth_mut(&mut users, user.id);
ctx.reply(format!("{} **{}** token(s).",
if user.id == ctx.author().id {
"You have".to_string()
} else {
format!("{} has", user.name)
}, *wealth)).await?;
Ok(())
}
#[tokio::main] #[tokio::main]
async fn main() -> Result<(), Error> { async fn main() -> Result<(), Error> {
@@ -192,10 +20,11 @@ async fn main() -> Result<(), Error> {
let framework = poise::Framework::builder() let framework = poise::Framework::builder()
.options(poise::FrameworkOptions { .options(poise::FrameworkOptions {
commands: vec![ping(), dox(), yeehaw(), wager(), balance(), give()], commands: commands::commands(),
prefix_options: poise::PrefixFrameworkOptions { prefix_options: poise::PrefixFrameworkOptions {
prefix: Some("%".into()), prefix: Some("%".into()),
edit_tracker: Some(Arc::new(poise::EditTracker::for_timespan(std::time::Duration::from_secs(3600)))), edit_tracker: Some(Arc::new(
poise::EditTracker::for_timespan(std::time::Duration::from_secs(3600)))),
case_insensitive_commands: true, case_insensitive_commands: true,
..Default::default() ..Default::default()
}, },
@@ -209,7 +38,8 @@ async fn main() -> Result<(), Error> {
}) })
.build(); .build();
let client = serenity::ClientBuilder::new(token, intents).framework(framework).await; let client = serenity::ClientBuilder::new(token, intents)
.framework(framework).await;
client.unwrap().start().await?; client.unwrap().start().await?;