Wandu\Q\Adapter\BeanstalkdAdapter

Complexity

Total Complexity

10

Size/Duplication

Total Lines	59
Duplicated Lines	0 %

Coupling/Cohesion

Components	1
Dependencies	2

Test Coverage

Coverage

0%

Importance

Changes

0

5 Methods

Rating	Name	Duplication	Size	Complexity
A	__construct()	0	5	1
B	flush()	0	12	5
A	send()	0	4	1
A	receive()	0	8	2
A	remove()	0	5	1

<?php
namespace Wandu\Q\Adapter;

use Pheanstalk\Exception\ServerException;
use Pheanstalk\PheanstalkInterface;
use Wandu\Q\Contracts\Adapter;

class BeanstalkdAdapter implements Adapter
{
    /** @var \Pheanstalk\PheanstalkInterface */
    protected $client;
    
    /** @var string */
    protected $channel;
    
    public function __construct(PheanstalkInterface $client, string $channel = "default")
    {
        $this->client = $client;
        $this->channel = $channel;
    }

    /**
     * {@inheritdoc}
     */
    public function flush()
    {
        $client = $this->client->useTube($this->channel);
        try {
            while ($client->delete($client->peekDelayed())) {}

This while loop is empty and can be removed.

        } catch (ServerException $e) {

Consider adding a comment why this CATCH block is empty.

        }
        try {
            while ($client->delete($client->peekReady())) {}

This while loop is empty and can be removed.

        } catch (ServerException $e) {

Consider adding a comment why this CATCH block is empty.

        }
    }

    /**
     * {@inheritdoc}
     */
    public function send(string $payload)
    {
        $this->client->useTube($this->channel)->put($payload);
    }

    /**
     * {@inheritdoc}
     */
    public function receive()
    {
        try {
            return new BeanstalkdJob($this->client->watch($this->channel)->peekReady());
        } catch (ServerException $e) {
            return null;
        }
    }

    /**
     * {@inheritdoc}
     */
    public function remove($job)
    {
        /** @var \Wandu\Q\Adapter\BeanstalkdJob $job */
        return $this->client->delete($job->getJob());
    }
}