Cutlery/invoiceninja
1
0
Fork 0
mirror of https://github.com/invoiceninja/invoiceninja.git synced 2025-07-08 19:34:39 -04:00
Code Issues Packages Projects Releases Wiki Activity

Add database queue data to the health check

Browse Source
This commit is contained in:
Hillel Coren 2024-07-11 09:09:06 +03:00
parent 4e2016b210
commit c91be53b6d
1 changed files with 17 additions and 5 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

22
app/Utils/SystemHealth.php
View File

@ -78,9 +78,9 @@ class SystemHealth
'open_basedir' => (bool) self::checkOpenBaseDir(), 'open_basedir' => (bool) self::checkOpenBaseDir(),
'mail_mailer' => (string) self::checkMailMailer(), 'mail_mailer' => (string) self::checkMailMailer(),
'flutter_renderer' => (string) config('ninja.flutter_canvas_kit'), 'flutter_renderer' => (string) config('ninja.flutter_canvas_kit'),
'jobs_pending' => (int) self::checkQueueSize(),
'pdf_engine' => (string) self::getPdfEngine(), 'pdf_engine' => (string) self::getPdfEngine(),
'queue' => (string) config('queue.default'), 'queue' => (string) config('queue.default'),
'queue_data' => self::checkQueueData(),
'trailing_slash' => (bool) self::checkUrlState(), 'trailing_slash' => (bool) self::checkUrlState(),
'file_permissions' => (string) ($check_file_system ? self::checkFileSystem() : ''), 'file_permissions' => (string) ($check_file_system ? self::checkFileSystem() : ''),
'exchange_rate_api_not_configured' => (bool)self::checkCurrencySanity(), 'exchange_rate_api_not_configured' => (bool)self::checkCurrencySanity(),
@ -117,16 +117,28 @@ class SystemHealth
return false; return false;
} }
private static function checkQueueSize() private static function checkQueueData()
{ {
$count = 0; $pending = 0;
$failed = 0;
$last_error = '';
try { try {
$count = Queue::size(); $pending = DB::table('jobs')->count();
$failed = DB::table('failed_jobs')->count();
if ($failed > 0) {
$failed_job = DB::table('failed_jobs')->latest('failed_at')->first();
$last_error = $failed_job->exception;
}
} catch (\Exception $e) { } catch (\Exception $e) {
} }
return $count; return [
'failed' => $failed,
'pending' => $pending,
'last_error' => $last_error,
];
} }
public static function checkFileSystem() public static function checkFileSystem()