diff options
| author | Gustav Sörnäs <gustav@sornas.net> | 2020-12-01 07:46:29 +0100 |
|---|---|---|
| committer | Gustav Sörnäs <gustav@sornas.net> | 2020-12-01 07:46:29 +0100 |
| commit | 8b8c829793c026eee5fac474399a9a7179a10c80 (patch) | |
| tree | 133d1102e7da0a1c89f0bf8b027e9461e4aaef59 /src/main.rs | |
| parent | c1b9d90f2f81f7acb0f4a88acf7056874e9cbe2f (diff) | |
| parent | 31f5366ef857bc3e50f7a4485250cbe50d903e0b (diff) | |
| download | kodapa-8b8c829793c026eee5fac474399a9a7179a10c80.tar.gz | |
Merge branch 'reminders' into main
Diffstat (limited to 'src/main.rs')
| -rw-r--r-- | src/main.rs | 13 |
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), ); } |
