6e9da035-ea78-453b-a56d-5a8c77f86def

Build # 6e9da035-ea78-453b-a56d-5a8c77f86def

Build Type

push

circleci

Committed by squigg

Commit Message

Improve test config

Run Details

51 of 51 relevant lines covered (100.0%)

10.94 hits per line

Source File
Press 'n' to go to next uncovered line, 'b' for previous

100.0

/src/AzureJob.php

<?php

namespace Squigg\AzureQueueLaravel;

use Illuminate\Container\Container;
use Illuminate\Contracts\Queue\Job as JobContract;
use Illuminate\Queue\Jobs\Job;
use MicrosoftAzure\Storage\Queue\Internal\IQueue;
use MicrosoftAzure\Storage\Queue\Models\QueueMessage;

class AzureJob extends Job implements JobContract
{

    /**
     * The Azure QueueRestProxy instance.
     */
    protected IQueue $azure;

    /**
     * The Azure QueueMessage instance.
     */
    protected QueueMessage $job;

    /**
     * The queue that the job belongs to.
     */
    protected $queue;

    /**
     * Create a new job instance.
     *
     * @param Container $container
     * @param IQueue $azure
     * @param QueueMessage $job
     * @param string $connectionName
     * @param string $queue
     *
     */
    public function __construct(Container    $container,
                                IQueue       $azure,
                                QueueMessage $job,
                                string       $connectionName,
                                string       $queue)
    {
        $this->azure = $azure;
        $this->job = $job;
        $this->queue = $queue;
        $this->container = $container;
        $this->connectionName = $connectionName;
    }

    /**
     * Delete the job from the queue.
     */
    public function delete(): void
    {
        parent::delete();
        $this->azure->deleteMessage($this->queue, $this->job->getMessageId(), $this->job->getPopReceipt());
    }

    /**
     * Release the job back into the queue.
     *
     * @param int $delay
     */
    public function release($delay = 0): void
    {
        parent::release($delay);
        $this->azure->updateMessage($this->queue, $this->job->getMessageId(), $this->job->getPopReceipt(), null,
            $delay);
    }

    /**
     * Get the number of times the job has been attempted.
     */
    public function attempts(): int
    {
        return $this->job->getDequeueCount();
    }

    /**
     * Get the IoC container instance.
     */
    public function getContainer(): Container
    {
        return $this->container;
    }

    /**
     * Get the underlying Azure client instance.
     */
    public function getAzure(): IQueue
    {
        return $this->azure;
    }

    /**
     * Get the underlying raw Azure job.
     */
    public function getAzureJob(): QueueMessage
    {
        return $this->job;
    }

    /**
     * Get the job ID
     */
    public function getJobId(): int
    {
        return $this->job->getMessageId();
    }

    /**
     * Get the raw body string for the job.
     */
    public function getRawBody(): string
    {
        return $this->job->getMessageText();
    }
}

1	<?php
2
3	namespace Squigg\AzureQueueLaravel;
4
5	use Illuminate\Container\Container;
6	use Illuminate\Contracts\Queue\Job as JobContract;
7	use Illuminate\Queue\Jobs\Job;
8	use MicrosoftAzure\Storage\Queue\Internal\IQueue;
9	use MicrosoftAzure\Storage\Queue\Models\QueueMessage;
10
11	class AzureJob extends Job implements JobContract
12	{
13
14	/**
15	* The Azure QueueRestProxy instance.
16	*/
17	protected IQueue $azure;
18
19	/**
20	* The Azure QueueMessage instance.
21	*/
22	protected QueueMessage $job;
23
24	/**
25	* The queue that the job belongs to.
26	*/
27	protected $queue;
28
29	/**
30	* Create a new job instance.
31	*
32	* @param Container $container
33	* @param IQueue $azure
34	* @param QueueMessage $job
35	* @param string $connectionName
36	* @param string $queue
37	*
38	*/
39	public function __construct(Container $container,
40	IQueue $azure,
41	QueueMessage $job,
42	string $connectionName,
43	string $queue)
44	{
45	$this->azure = $azure;	24✔
46	$this->job = $job;	24✔
47	$this->queue = $queue;	24✔
48	$this->container = $container;	24✔
49	$this->connectionName = $connectionName;	24✔
50	}
51
52	/**
53	* Delete the job from the queue.
54	*/
55	public function delete(): void
56	{
57	parent::delete();	2✔
58	$this->azure->deleteMessage($this->queue, $this->job->getMessageId(), $this->job->getPopReceipt());	2✔
59	}
60
61	/**
62	* Release the job back into the queue.
63	*
64	* @param int $delay
65	*/
66	public function release($delay = 0): void
67	{
68	parent::release($delay);	2✔
69	$this->azure->updateMessage($this->queue, $this->job->getMessageId(), $this->job->getPopReceipt(), null,	2✔
70	$delay);	2✔
71	}
72
73	/**
74	* Get the number of times the job has been attempted.
75	*/
76	public function attempts(): int
77	{
78	return $this->job->getDequeueCount();	2✔
79	}
80
81	/**
82	* Get the IoC container instance.
83	*/
84	public function getContainer(): Container
85	{
86	return $this->container;	2✔
87	}
88
89	/**
90	* Get the underlying Azure client instance.
91	*/
92	public function getAzure(): IQueue
93	{
94	return $this->azure;	2✔
95	}
96
97	/**
98	* Get the underlying raw Azure job.
99	*/
100	public function getAzureJob(): QueueMessage
101	{
102	return $this->job;	2✔
103	}
104
105	/**
106	* Get the job ID
107	*/
108	public function getJobId(): int
109	{
110	return $this->job->getMessageId();	2✔
111	}
112
113	/**
114	* Get the raw body string for the job.
115	*/
116	public function getRawBody(): string
117	{
118	return $this->job->getMessageText();	2✔
119	}
120	}

squigg / azure-queue-laravel / 6e9da035-ea78-453b-a56d-5a8c77f86def

Source File Press 'n' to go to next uncovered line, 'b' for previous

Source File
Press 'n' to go to next uncovered line, 'b' for previous