Subversion-Projekte lars-tiefland.laravel_shop

<?php namespace Clockwork\DataSource;

use Clockwork\Helpers\Serializer;
use Clockwork\Helpers\StackTrace;
use Clockwork\Request\Request;

use Illuminate\Queue\Queue;

// Data source for Laravel queue component, provides dispatched queue jobs
class LaravelQueueDataSource extends DataSource
{
        // Queue instance
        protected $queue;

        // Dispatched queue jobs
        protected $jobs = [];

        // Clockwork ID of the current request
        protected $currentRequestId;

        // Create a new data source instance, takes a queue as an argument
        public function __construct(Queue $queue)
        {
                $this->queue = $queue;
        }

        // Adds dispatched queue jobs to the request
        public function resolve(Request $request)
        {
                $request->queueJobs = array_merge($request->queueJobs, $this->getJobs());

                return $request;
        }

        // Reset the data source to an empty state, clearing any collected data
        public function reset()
        {
                $this->jobs = [];
        }

        // Listen to the queue events
        public function listenToEvents()
        {
                $this->queue->createPayloadUsing(function ($connection, $queue, $payload) {
                        $this->registerJob([
                                'id'         => $id = (new Request)->id,
                                'connection' => $connection,
                                'queue'      => $queue,
                                'name'       => $payload['displayName'],
                                'data'       => isset($payload['data']['command']) ? $payload['data']['command'] : null,
                                'maxTries'   => $payload['maxTries'],
                                'timeout'    => $payload['timeout'],
                                'time'       => microtime(true)
                        ]);

                        return [ 'clockwork_id' => $id, 'clockwork_parent_id' => $this->currentRequestId ];
                });
        }

        // Set Clockwork ID of the current request
        public function setCurrentRequestId($requestId)
        {
                $this->currentRequestId = $requestId;
                return $this;
        }

        // Collect a dispatched queue job
        protected function registerJob(array $job)
        {
                $trace = StackTrace::get()->resolveViewName();

                $job = array_merge($job, [
                        'trace' => (new Serializer)->trace($trace)
                ]);

                if ($this->passesFilters([ $job ])) {
                        $this->jobs[] = $job;
                }
        }

        // Get an array of dispatched queue jobs commands
        protected function getJobs()
        {
                return array_map(function ($query) {
                        return array_merge($query, [
                                'data' => isset($query['data']) ? (new Serializer)->normalize($query['data']) : null
                        ]);
                }, $this->jobs);
        }
}