Merge pull request #1 from ZyLacx/radko-rework

rework for anyhow

Cargo.lock

@@ -43,6 +43,12 @@ dependencies = [
  "libc",
 ]
 
+[[package]]
+name = "anyhow"
+version = "1.0.71"
+source = "registry+https://github.com/rust-lang/crates.io-index"
+checksum = "9c7d0618f0e0b7e8ff11427422b64564d5fb0be1940354bfe2e0529b18a9d9b8"
+
 [[package]]
 name = "async-trait"
 version = "0.1.70"
@@ -956,6 +962,7 @@ dependencies = [
 name = "moover_rust"
 version = "0.1.0"
 dependencies = [
+ "anyhow",
  "cron",
  "dotenv",
  "mongodb",

Cargo.toml

@@ -6,6 +6,7 @@ edition = "2021"
 # See more keys and their definitions at https://doc.rust-lang.org/cargo/reference/manifest.html
 
 [dependencies]
+anyhow = "1.0.71"
 cron = "0.12.0"
 dotenv = "0.15.0"
 mongodb = "2.6.0"

src/main.rs

@@ -2,12 +2,12 @@ use std::sync::Arc;
 
 use poise::serenity_prelude::GuildChannel;
 use serenity::async_trait;
+use serenity::http::{self, Http};
 use serenity::model::channel::Message;
 use serenity::model::gateway::Ready;
 use serenity::model::id::ChannelId;
 use serenity::prelude::*;
 use util::security::dotenv_var;
-use serenity::http::{self, Http};
 
 mod util;
 
@@ -26,48 +26,37 @@ impl EventHandler for Handler {
     async fn ready(&self, ctx: Context, ready: Ready) {
         println!("{} is connected!", ready.user.name);
         // if (ready.user.name != "MOOver Debug") {
-        let messages = ["AAAAAAAAAAAAAAAAAAAA", "Henlooo", "Good day y'all!",
+        let messages = [
-                        "May have crashed...", "MOOOooo", "Heyyyyy!", "I'm baaaaack!",
+            "AAAAAAAAAAAAAAAAAAAA",
-                        "Whom'st have summoned the ancient one?"];
+            "Henlooo",
+            "Good day y'all!",
+            "May have crashed...",
+            "MOOOooo",
+            "Heyyyyy!",
+            "I'm baaaaack!",
+            "Whom'st have summoned the ancient one?",
+        ];
 
         // }
-        let opt_token = dotenv_var("TOKEN");
-        if opt_token.is_none() {
-            return;
-        }
 
-        let token = opt_token.unwrap();
+        let channel = ctx.http.get_channel(780439236867653635).await.unwrap();
-        let channel_result = ctx.http.get_channel(780439236867653635).await;
-        let channel = channel_result.unwrap();
-        // let channel = await http.get_channel(780439236867653635);
-        // GuildChannel::say(&self, http, content)
-        // self.message(ctx, new_message)
-        // C = ;
 
-        // const debug_channel = 
     }
 }
 
-
-
 #[tokio::main]
-async fn main() {
+async fn main() -> anyhow::Result<()> {
-    let opt_token = dotenv_var("TOKEN");
+    use anyhow::Context;
-    if opt_token.is_none() {
+    let token = dotenv_var("TOKEN").context("No TOKEN in env")?;
-        return;
-    }
-
-    let token = opt_token.unwrap();
-
     let intents = GatewayIntents::GUILD_MESSAGES
         | GatewayIntents::DIRECT_MESSAGES
         | GatewayIntents::MESSAGE_CONTENT;
     
     let mut client = Client::builder(&token, intents)
         .event_handler(Handler)
-                                .await.expect("Error creating client");
+        .await
+        .context("Failed to build client")?;
     
-    if let Err(why) = client.start().await {
+    client.start().await?;
-        println!("Client error: {:?}", why);
+    Ok(())
-    }
 }

src/sample.rs

@@ -0,0 +1,19 @@
+struct MyStruct {
+    niečo: String,
+}
+impl MyStruct {
+    fn add(&mut self) {
+        self.niečo.push(char::from_digit(2, 2).unwrap());
+    }
+}
+trait Countable {
+    fn count(&self) -> usize;
+}
+impl Countable for MyStruct {
+    fn count(&self) -> usize {
+        self.niečo.len()
+    }
+}
+fn smt(var: Box<dyn Countable>) {
+    var.count();
+}