honeybadger-io/honeybadger-laravel

<?php

namespace Honeybadger\HoneybadgerLaravel\Events;

use Illuminate\Events\Dispatcher;
use Illuminate\Queue\Events\JobProcessed as LaravelJobProcessed;
use Illuminate\Queue\Events\JobProcessing;

class JobProcessed extends ApplicationEvent
{
    public string $handles = LaravelJobProcessed::class;

    private float $startTime;

    /**
     * @param LaravelJobProcessed $event
     * @return EventPayload
     */
    public function getEventPayload($event): EventPayload
    {
        $job = $event->job;
        $metadata = [
            'connectionName' => $event->connectionName,

            // we have to call 'resolveName' because sometimes the actual job is wrapped (i.e. DatabaseJob -> Job)
            'job' => $job->resolveName(),

            'id' => $job->getJobId(),

            // number of attempts made to process the job
            'attempts' => $job->attempts(),

            // if the job has been marked as failed
            'hasFailed' => $job->hasFailed(),

            // if the job has been released back into the queue
            'isReleased' => $job->isReleased(),

            // if the job has been deleted (i.e. it's not in the queue anymore)
            'isDeleted' => $job->isDeleted(),

            // number of times the job can be retried
            'maxTries' => $job->maxTries(),

            // number of exceptions that can be thrown before the job is considered failed (regardless of the number of attempts)
            'maxExceptions' => $job->maxExceptions(),

            // number of seconds the job can run before it's considered timed out
            'timeout' => $job->timeout(),

            // timestamp indicating when the job should timeout
            'retryUntil' => $job->retryUntil(),

            // duration in milliseconds of the job processing
            // calculated by measuring the time difference since the JobProcessing event was raised
            'duration' => $this->getDurationInMs($this->startTime),
        ];

        return new EventPayload(
            'job',
            'job.processed',
            'Job processed',
            $metadata,
        );
    }

    /**
     * Register the listeners for the subscriber.
     * We are overriding the register() method from the parent class,
     * so we can listen to the JobProcessing event as well.
     */
    public function register(): void
    {
        /** @var Dispatcher $dispatcher */
        $dispatcher = app('events');

        $dispatcher->listen(JobProcessing::class, function ($event) {
            $this->startTime = microtime(true);
        });

        $dispatcher->listen($this->handles, [$this, 'handle']);

    }
}