aboutsummaryrefslogtreecommitdiffstats
path: root/src/main.rs
diff options
context:
space:
mode:
authorGustav Sörnäs <gustav@sornas.net>2020-12-01 07:46:29 +0100
committerGustav Sörnäs <gustav@sornas.net>2020-12-01 07:46:29 +0100
commit8b8c829793c026eee5fac474399a9a7179a10c80 (patch)
tree133d1102e7da0a1c89f0bf8b027e9461e4aaef59 /src/main.rs
parentc1b9d90f2f81f7acb0f4a88acf7056874e9cbe2f (diff)
parent31f5366ef857bc3e50f7a4485250cbe50d903e0b (diff)
downloadkodapa-8b8c829793c026eee5fac474399a9a7179a10c80.tar.gz
Merge branch 'reminders' into main
Diffstat (limited to 'src/main.rs')
-rw-r--r--src/main.rs13
1 files changed, 8 insertions, 5 deletions
diff --git a/src/main.rs b/src/main.rs
index 47daed8..8980b31 100644
--- a/src/main.rs
+++ b/src/main.rs
@@ -1,20 +1,23 @@
mod agenda;
mod discord;
+mod reminder;
mod slack;
use crate::agenda::AgendaPoint;
+use crate::reminder::ReminderType;
use futures::join;
-use tokio::sync::mpsc;
+use tokio::sync::{mpsc, watch};
#[tokio::main]
async fn main() {
- println!("Hello, world!");
-
let (from_discord, to_slack) = mpsc::unbounded_channel::<AgendaPoint>();
let (from_slack, to_discord) = mpsc::unbounded_channel::<AgendaPoint>();
+ let (reminder_sender, reminder_receiver) = watch::channel(ReminderType::Void);
+
join!(
- discord::handle(from_discord, to_discord),
- slack::handle(from_slack, to_slack),
+ reminder::handle(reminder_sender),
+ discord::handle(from_discord, to_discord, reminder_receiver.clone()),
+ slack::handle(from_slack, to_slack, reminder_receiver),
);
}