refactor a bit

Cargo.toml

@@ -1,7 +1,3 @@
-[workspace]
-members = ["helix", "commands"]
-resolver = "2"
-
 [package]
 name = "botoh"
 version = "0.1.0"

commands/Cargo.toml

@@ -1,6 +0,0 @@
-[package]
-name = "commands"
-version = "0.1.0"
-edition = "2021"
-
-[dependencies]

commands/src/main.rs

@@ -1,3 +0,0 @@
-fn main() {
-    println!("Hello, world!");
-}

flake.nix

@@ -46,7 +46,7 @@
         hooks = {
           # rust
           rustfmt.enable = true;
-          clippy.enable = true;
+          clippy.enable = false;
           taplo.enable = true;
           # nix
           statix.enable = true;

helix/Cargo.toml

@@ -1,6 +0,0 @@
-[package]
-name = "helix"
-version = "0.1.0"
-edition = "2021"
-
-[dependencies]

helix/src/main.rs

@@ -1,3 +0,0 @@
-fn main() {
-    println!("Hello, world!");
-}

src/main.rs

@@ -1,6 +1,9 @@
 use dotenv::dotenv;
+use std::collections::HashMap;
 use std::env;
 use twitch_irc::login::StaticLoginCredentials;
+use twitch_irc::message::ReplyToMessage;
+use twitch_irc::message::ServerMessage;
 use twitch_irc::ClientConfig;
 use twitch_irc::SecureTCPTransport;
 use twitch_irc::TwitchIRCClient;
@@ -29,15 +32,51 @@ pub async fn main() {
     let (mut incoming_messages, client) =
         TwitchIRCClient::<SecureTCPTransport, StaticLoginCredentials>::new(config);
 
-    let join_handle =
+    let mut initial_channels = HashMap::new();
-        tokio::spawn(async move { while let Some(message) = incoming_messages.recv().await {} });
 
-    client.join("notnotoh".to_owned()).unwrap();
+    initial_channels.insert("notnotoh", ());
+    initial_channels.insert("notohh", ());
+    initial_channels.insert("daph", ());
+    initial_channels.insert("ryanpotat", ());
 
-    client
+    for (channels, _) in initial_channels.iter() {
-        .say("notnotoh".to_owned(), "test".to_owned())
+        match client.join(channels.to_owned().to_string()) {
-        .await
+            Ok(_) => println!("Joined channels {}", channels),
-        .unwrap();
+            Err(e) => eprintln!("Failed to join channels! {}", e),
+        }
+    }
+
+    let prefix = "?";
+
+    let join_handle = tokio::spawn(async move {
+        while let Some(message) = incoming_messages.recv().await {
+            match message {
+                ServerMessage::Privmsg(msg) => {
+                    println!(
+                        "(#{}) {}: {}",
+                        msg.channel_login, msg.sender.name, msg.message_text
+                    );
+                    if msg.sender.name == "notohh" {
+                        match msg.message_text.as_str() {
+                            "?ping" => client
+                                .say(msg.channel_login.to_owned(), "Pong!".to_owned())
+                                .await
+                                .unwrap(),
+                            "?test" => client
+                                .say(msg.channel_login.to_owned(), "test".to_owned())
+                                .await
+                                .unwrap(),
+                            _ => {}
+                        }
+                    }
+                }
+                ServerMessage::Whisper(msg) => {
+                    println!("(w) {}: {}", msg.sender.name, msg.message_text);
+                }
+                _ => {}
+            }
+        }
+    });
 
     join_handle.await.unwrap();
 }