From c01c8716de4a91e4c60f61cf0bb6eaeca5cbf619 Mon Sep 17 00:00:00 2001
From: =?UTF-8?q?Gustav=20S=C3=B6rn=C3=A4s?= <gustav@sornas.net>
Date: Wed, 11 Nov 2020 13:12:32 +0100
Subject: refactor to new files

---
 src/slack.rs | 39 +++++++++++++++++++++++++++++++++++++++
 1 file changed, 39 insertions(+)
 create mode 100644 src/slack.rs

(limited to 'src/slack.rs')

diff --git a/src/slack.rs b/src/slack.rs
new file mode 100644
index 0000000..40e465c
--- /dev/null
+++ b/src/slack.rs
@@ -0,0 +1,39 @@
+use slack_api as slack;
+use tokio::sync::mpsc;
+
+pub async fn handle(
+    token: Option<String>,
+    sender: mpsc::UnboundedSender<String>,
+    _receiver: mpsc::UnboundedReceiver<String>,
+) {
+    println!("Setting up Slack");
+
+    let token = std::env::var("SLACK_API_TOKEN")
+        .unwrap_or(token.unwrap());
+    let client = slack::default_client().unwrap();
+
+    let request = slack::rtm::StartRequest::default();
+    let response = slack::rtm::start(&client,
+                                     &token,
+                                     &request).await;
+
+    if let Ok(response) = response {
+        if let Some(channels) = response.channels {
+            let channel_names = channels
+                .iter()
+                .filter_map(|c| c.name.as_ref())
+                .collect::<Vec<_>>();
+            sender.send(format!("Got channels {:?}", channel_names).to_string()).unwrap();
+        }
+
+        if let Some(users) = response.users {
+            let user_names = users
+                .iter()
+                .filter_map(|u| u.name.as_ref())
+                .collect::<Vec<_>>();
+            sender.send(format!("Got users {:?}", user_names).to_string()).unwrap();
+        }
+    } else { //TODO NotAuth etc
+        println!("{:?}", response)
+    }
+}
-- 
cgit v1.2.1