PhyrePanel-mirror/web/app/Livewire/JobQueueNotifications.php

<?php

namespace App\Livewire;

use Illuminate\Contracts\View\View;
use Illuminate\Support\Facades\DB;
use Livewire\Component;

class JobQueueNotifications extends Component
{

    public function render(): View
    {

        $jobs = [];
        $getJobs = DB::table('jobs')->orderBy('id', 'desc')->get();
        foreach ($getJobs as $job) {
            $job->payload = json_decode($job->payload);
            if (isset($job->payload->displayName)) {
                $jobClassInstance = new $job->payload->displayName;
                $displayName = 'Unknown Job';
                if (method_exists($jobClassInstance, 'getDisplayName')) {
                    $displayName = $jobClassInstance->getDisplayName();
                } else {
                    $explodeDisplayName = explode('\\', $job->payload->displayName);
                    $displayName = end($explodeDisplayName);
                }
                $jobs[] = [
                    'id' => $job->id,
                    'displayName' => $displayName,
                    'status' => $job->attempts == 0 ? 'Pending' : 'Processing',
                    'createdAt' => $job->created_at
                ];

            }
        }

        return view('filament.job-queue-notifications', [
            'jobs' => $jobs
        ]);
    }

}