RMusicBot/src/main.rs

152 lines
4.2 KiB
Rust
Raw Normal View History

2018-08-14 16:42:53 +00:00
extern crate serenity;
2018-08-13 16:45:49 +00:00
2018-08-14 16:42:53 +00:00
extern crate parking_lot;
extern crate serde_json;
2018-08-13 16:45:49 +00:00
extern crate typemap;
2018-08-14 17:08:13 +00:00
mod confighandler;
mod macros;
2018-08-13 16:45:49 +00:00
// Import the client's bridge to the voice manager. Since voice is a standalone
// feature, it's not as ergonomic to work with as it could be. The client
// provides a clean bridged integration with voice.
use serenity::client::bridge::voice::ClientVoiceManager;
2018-08-15 17:32:44 +00:00
use serenity::client::{Client, Context, EventHandler};
2018-08-13 16:45:49 +00:00
use serenity::framework::StandardFramework;
use serenity::model::channel::Message;
use serenity::model::gateway::Ready;
// Import the `Context` from the client and `parking_lot`'s `Mutex`.
//
// `parking_lot` offers much more efficient implementations of `std::sync`'s
// types. You can read more about it here:
//
// <https://github.com/Amanieu/parking_lot#features>
use serenity::prelude::Mutex;
use serenity::Result as SerenityResult;
use std::sync::Arc;
use typemap::Key;
2018-08-14 17:08:13 +00:00
use confighandler::*;
2018-08-13 16:45:49 +00:00
2018-08-14 16:42:53 +00:00
mod player;
mod youtube;
use player::*;
/*
const fn empty_vec<T>() -> Vec<T> {
Vec::new()
}
*/
pub struct VoiceManager;
2018-08-13 16:45:49 +00:00
impl Key for VoiceManager {
type Value = Arc<Mutex<ClientVoiceManager>>;
}
struct Handler;
impl EventHandler for Handler {
fn ready(&self, _: Context, ready: Ready) {
println!("{} is connected!", ready.user.name);
}
}
2018-08-15 17:32:44 +00:00
struct Config {
token: String,
prefix: String,
}
impl Default for Config {
fn default() -> Self {
Self {
token: String::new(),
prefix: String::new(),
}
}
}
2018-08-13 16:45:49 +00:00
fn main() {
// read config file
2018-08-15 17:32:44 +00:00
let config_file = check_result_return!(read_config("bot.conf"));
let mut config = Config::default();
match config_file.get("Meta") {
Some(info) => {
match info.get("token") {
Some(token_pair) => {
display_error!(token_pair.set_value(&mut config.token));
}
None => {
println!("couldn't find token inside meta section");
return;
}
2018-08-13 16:45:49 +00:00
}
2018-08-15 17:32:44 +00:00
match info.get("prefix") {
Some(prefix_pair) => {
display_error!(prefix_pair.set_value(&mut config.prefix));
}
None => {
println!("couldn't find prefix inside meta section");
return;
}
2018-08-13 16:45:49 +00:00
}
2018-08-15 17:32:44 +00:00
}
2018-08-13 16:45:49 +00:00
None => {
println!("couldn't find Meta section in config file");
return;
}
};
2018-08-14 16:42:53 +00:00
2018-08-15 17:32:44 +00:00
let mut client = Client::new(&config.token, Handler).expect("Err creating client");
2018-08-13 16:45:49 +00:00
// Obtain a lock to the data owned by the client, and insert the client's
// voice manager into it. This allows the voice manager to be accessible by
// event handlers and framework commands.
{
let mut data = client.data.lock();
data.insert::<VoiceManager>(Arc::clone(&client.voice_manager));
}
2018-08-14 16:42:53 +00:00
let media_data = Arc::new(MediaData::default());
client.with_framework(
StandardFramework::new()
2018-08-15 17:32:44 +00:00
.configure(|c| c.prefix(&config.prefix).on_mention(true))
2018-08-14 16:42:53 +00:00
.cmd("play", Play::new(media_data.clone()))
.cmd("pause", Pause::new(media_data.clone()))
2018-08-15 17:32:44 +00:00
.cmd(
"help",
Help::new(
&config.prefix,
vec![
"play".to_string(),
"pause".to_string(),
"stop".to_string(),
"help".to_string(),
"list".to_string(),
2018-09-16 08:35:23 +00:00
"help".to_string(),
"skip".to_string(),
"ip".to_string(),
2018-08-15 17:32:44 +00:00
],
),
).cmd("stop", Stop::new(media_data.clone()))
2018-09-16 08:25:57 +00:00
.cmd("list", List::new(media_data.clone()))
.cmd("skip", Skip::new(media_data.clone()))
.cmd("ip", IP::new()),
2018-08-14 16:42:53 +00:00
);
let _ = client
.start()
.map_err(|why| println!("Client ended: {:?}", why));
2018-08-13 16:45:49 +00:00
}
/// Checks that a message successfully sent; if not, then logs why to stdout.
fn check_msg(result: SerenityResult<Message>) {
if let Err(why) = result {
println!("Error sending message: {:?}", why);
}
}