Pheanstalk\Command\PeekCommand

Complexity

Total Complexity

12

Size/Duplication

Total Lines	75
Duplicated Lines	0 %

Test Coverage

Coverage

64.29%

Importance

Changes	1
Bugs	0	Features	0

6 Methods

Rating	Name	Duplication	Size	Complexity
A	constructResponse()	0	7	1
A	getFilters()	0	4	1
A	getGroup()	0	3	1
B	parseResponse()	0	22	7
A	getAction()	0	3	1
A	getResponseParser()	0	3	1

<?php

namespace Pheanstalk\Command;

use Pheanstalk\Exception;
use Pheanstalk\Response;
use Pheanstalk\ResponseParser;

/**
 * The 'peek', 'peek-ready', 'peek-delayed' and 'peek-buried' commands.
 *
 * The peek commands let the client inspect a job in the system. There are four
 * variations. All but the first (peek) operate only on the currently used tube.
 *
 * @author  Paul Annesley
 * @package Pheanstalk
 * @license http://www.opensource.org/licenses/mit-license.php
 */
class PeekCommand extends AbstractCommand implements ResponseParser
{

    /**
     * @inheritDoc
     */
    public function getGroup(): string
    {
        return 'status';
    }

    /**
     * @inheritDoc
     */
    public function getAction(): string
    {
        return 'query';
    }

    /**
     * @inheritDoc
     */
    public function getFilters(): array
    {
        return [
            'type' => "workflows"
        ];
    }

    /**
     * @inheritDoc
     */
    public function getResponseParser()
    {
        return $this;
    }

    /**
     * @param string $responseLine
     * @param string $responseData
     *
     * @return array
     * @throws Exception\ServerException
     */
    public function parseResponse($responseLine, $responseData)
    {
        unset($responseData['@attributes']);
        if (!isset($responseData['workflow'])) {
            return false;

The expression return false returns the type false which is incompatible with the documented return type array.

        }
        $responseData = $responseData['workflow'];
        if (isset($responseData['@attributes'])) {
            return $this->constructResponse($responseData['@attributes']);
        }
        $responseData = array_column($responseData, '@attributes');
        $mostRecent = [];
        foreach ($responseData as $date) {
            $curDate = strtotime($date['start_time']);
            if (!isset($mostRecent['start_time']) || $curDate < strtotime($mostRecent['start_time'])) {
                $mostRecent = $date;
            }
        }
        if (empty($responseData)) {
            return $this->parseResponse($responseLine, $responseData);
        }
        return $this->constructResponse($mostRecent);
    }

    protected function constructResponse($response)
    {
        return [
            Response::RESPONSE_FOUND,
            [
                'id'      => (int) $response['id'],
                'jobdata' => $response,
            ]
        ];
    }
}