Method next_event

components/scheduler/src/guild_handler.rs:213–273

(&mut self)

    }

    pub(crate) async fn next_event(&mut self) -> Option<NextGuildAction> {
        self.scheduled_tasks_man.init_next_task_time().await;

        let scheduled_task_sleep_check = match self.scheduled_tasks_man.next_action() {
            scheduled_task_manager::NextAction::None => tokio::time::sleep(Duration::MAX),
            scheduled_task_manager::NextAction::Wait(until) => {
                let sleep_dur = (until - chrono::Utc::now())
                    .to_std()
                    .unwrap_or_else(|_| Duration::from_millis(1));
                tokio::time::sleep(sleep_dur)
            }
            scheduled_task_manager::NextAction::Run => {
                return Some(NextGuildAction::CheckScheduledTasks);
            }
        };

        let interval_timers_sleep_check = match self.interval_timers_man.next_action() {
            interval_timer_manager::NextAction::None => tokio::time::sleep(Duration::MAX),
            interval_timer_manager::NextAction::Wait(until) => {
                let sleep_dur = (until - chrono::Utc::now())
                    .to_std()
                    .unwrap_or_else(|_| Duration::from_millis(1));
                tokio::time::sleep(sleep_dur)
            }
            interval_timer_manager::NextAction::Run => {
                return Some(NextGuildAction::CheckIntervalTimers);
            }
        };

        tokio::pin!(scheduled_task_sleep_check);
        tokio::pin!(interval_timers_sleep_check);

        if let Some(session) = &mut self.session {
            tokio::select! {
                msg = session.recv() => {
                    Some(NextGuildAction::WorkerMessage(msg))
                },
                next_guild_evt = self.guild_rx.recv() => {
                    next_guild_evt.map(NextGuildAction::GuildCommand)
                },
                _ = scheduled_task_sleep_check => {
                    Some(NextGuildAction::CheckScheduledTasks)
                },
                _ = interval_timers_sleep_check => {
                    Some(NextGuildAction::CheckIntervalTimers)
                }
            }
        } else {
            tokio::select! {
                next_guild_evt = self.guild_rx.recv() => {
                    next_guild_evt.map(NextGuildAction::GuildCommand)
                },
                _ = scheduled_task_sleep_check => {
                    Some(NextGuildAction::CheckScheduledTasks)
                },
                _ = interval_timers_sleep_check => {
                    Some(NextGuildAction::CheckIntervalTimers)
                }