Method handle_next_action

components/scheduler/src/guild_handler.rs:179–211

(&mut self, action: NextGuildAction)

    #[instrument(skip(self), fields(guild_id = self.guild_id.get(), action = action.span_info()))]
    pub(crate) async fn handle_next_action(&mut self, action: NextGuildAction) -> bool {
        match action {
            NextGuildAction::GuildCommand(GuildCommand::Shutdown) => {
                info!("got shutdown signal");
                return false;
            }
            NextGuildAction::GuildCommand(cmd) => {
                self.handle_guild_command(cmd).await;
            }
            NextGuildAction::WorkerMessage(msg) => {
                let Some(session) = &mut self.session else {
                    return true;
                };

                let events = session.handle_worker_msg(msg);
                return self.handle_session_events(events).await;
            }
            NextGuildAction::CheckScheduledTasks => {
                let tasks = self.scheduled_tasks_man.start_triggered_tasks().await;
                for task in tasks {
                    self.dispatch_scheduled_task(task).await;
                }
            }
            NextGuildAction::CheckIntervalTimers => {
                let timers = self.interval_timers_man.trigger_timers().await;
                for timer in timers {
                    self.dispatch_interval_timer(timer).await;
                }
            }
        }

        true
    }

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