From 99fe076b5af379f6d5ceed37ec288536fbe16bb7 Mon Sep 17 00:00:00 2001
From: Andras Bacsai <andras.bacsai@gmail.com>
Date: Mon, 4 Mar 2024 12:17:33 +0100
Subject: [PATCH] Add scheduled task for database cleanup if not in cloud
 environment

---
 app/Console/Kernel.php | 54 +++++++++++++++++++++++-------------------
 1 file changed, 29 insertions(+), 25 deletions(-)

diff --git a/app/Console/Kernel.php b/app/Console/Kernel.php
index e92c602cf..4ff1d8020 100644
--- a/app/Console/Kernel.php
+++ b/app/Console/Kernel.php
@@ -47,6 +47,10 @@ protected function schedule(Schedule $schedule): void
             $this->check_resources($schedule);
             $this->pull_helper_image($schedule);
             $this->check_scheduled_tasks($schedule);
+
+            if (!isCloud()) {
+                $schedule->command('cleanup:database --yes')->daily();
+            }
         }
     }
     private function pull_helper_image($schedule)
@@ -68,35 +72,35 @@ private function check_resources($schedule)
             $containerServers = $servers->where('settings.is_swarm_worker', false)->where('settings.is_build_server', false);
         }
         foreach ($containerServers as $server) {
-            $schedule->job(new ContainerStatusJob($server))->everyMinute()->onOneServer();
-            // $schedule
-            //     ->call(function () use ($server) {
-            //         $randomSeconds = rand(1, 40);
-            //         $job = new ContainerStatusJob($server);
-            //         $job->delay($randomSeconds);
-            //         ray('dispatching container status job in ' . $randomSeconds . ' seconds');
-            //         dispatch($job);
-            //     })->name('container-status-' . $server->id)->everyMinute()->onOneServer();
+            // $schedule->job(new ContainerStatusJob($server))->everyMinute()->onOneServer();
+            $schedule
+                ->call(function () use ($server) {
+                    $randomSeconds = rand(1, 40);
+                    $job = new ContainerStatusJob($server);
+                    $job->delay($randomSeconds);
+                    ray('dispatching container status job in ' . $randomSeconds . ' seconds');
+                    dispatch($job);
+                })->name('container-status-' . $server->id)->everyMinute()->onOneServer();
             if ($server->isLogDrainEnabled()) {
-                $schedule->job(new CheckLogDrainContainerJob($server))->everyMinute()->onOneServer();
-                // $schedule
-                //     ->call(function () use ($server) {
-                //         $randomSeconds = rand(1, 40);
-                //         $job = new CheckLogDrainContainerJob($server);
-                //         $job->delay($randomSeconds);
-                //         dispatch($job);
-                //     })->name('log-drain-container-check-' . $server->id)->everyMinute()->onOneServer();
+                // $schedule->job(new CheckLogDrainContainerJob($server))->everyMinute()->onOneServer();
+                $schedule
+                    ->call(function () use ($server) {
+                        $randomSeconds = rand(1, 40);
+                        $job = new CheckLogDrainContainerJob($server);
+                        $job->delay($randomSeconds);
+                        dispatch($job);
+                    })->name('log-drain-container-check-' . $server->id)->everyMinute()->onOneServer();
             }
         }
         foreach ($servers as $server) {
-            $schedule->job(new ServerStatusJob($server))->everyMinute()->onOneServer();
-            // $schedule
-            //     ->call(function () use ($server) {
-            //         $randomSeconds = rand(1, 40);
-            //         $job = new ServerStatusJob($server);
-            //         $job->delay($randomSeconds);
-            //         dispatch($job);
-            //     })->name('server-status-job-' . $server->id)->everyMinute()->onOneServer();
+            // $schedule->job(new ServerStatusJob($server))->everyMinute()->onOneServer();
+            $schedule
+                ->call(function () use ($server) {
+                    $randomSeconds = rand(1, 40);
+                    $job = new ServerStatusJob($server);
+                    $job->delay($randomSeconds);
+                    dispatch($job);
+                })->name('server-status-job-' . $server->id)->everyMinute()->onOneServer();
         }
     }
     private function instance_auto_update($schedule)