Graze\WipotecCheckweigherClient\Client

Complexity

Total Complexity

6

Size/Duplication

Total Lines	69
Duplicated Lines	0 %

Test Coverage

Coverage

88%

Importance

Changes	2
Bugs	0	Features	0

5 Methods

Rating	Name	Duplication	Size	Complexity
A	__construct()	0	7	1
A	sendRequest()	0	14	2
A	setReadTimeout()	0	3	1
A	factory()	0	9	1
A	connect()	0	3	1

<?php

namespace Graze\WipotecCheckweigherClient;

use Graze\WipotecCheckweigherClient\Request\RequestInterface;
use Graze\WipotecCheckweigherClient\Response\ResponseGeneric;
use Graze\TelnetClient\InterpretAsCommand;
use Graze\TelnetClient\TelnetClient;
use Graze\TelnetClient\TelnetClientInterface;
use Socket\Raw\Factory as SocketFactory;

class Client implements ClientInterface
{
    // The checkweigher telnet interface doesn't actually have a prompt however we need an identifier to distinguish
    // error responses, this is explicitly passed instead of using the default error prompt in case it changes.
    const PROMPT_ERROR = 'ERROR';

    /** @var TelnetClientInterface */
    protected $telnetClient;

    /**
     * @param TelnetClientInterface $telnetClient
     */
    public function __construct(TelnetClientInterface $telnetClient)
    {
        $this->telnetClient = $telnetClient;

        // Set a limit to the number of bytes to read per request, this should hopefully prevent infinite loops if the
        // prompt is never returned. 1000 bytes should be plenty.
        $this->telnetClient->setMaxBytesRead(1000);
    }

    /**
     * @param string $dsn
     * @param float|null $timeout
     */
    public function connect($dsn, $timeout = null)
    {
        $this->telnetClient->connect($dsn, null, self::PROMPT_ERROR, '', $timeout);

The call to Graze\TelnetClient\TelnetClientInterface::connect() has too many arguments starting with $timeout.

    }

    /**
     * @param float $timeout
     */
    public function setReadTimeout($timeout)
    {
        $this->telnetClient->setReadTimeout($timeout);
    }

    /**
     * @param RequestInterface $request
     */
    public function sendRequest(RequestInterface $request)
    {
        $telnetResponse = $this->telnetClient->execute($request->getXml());

        // Use a specific response class if it exists.
        // e.g. with Request/RequestReadStatus try to use Response/ResponseReadStatus.
        $responseClassName = str_replace('Request', 'Response', get_class($request));
        if (!class_exists($responseClassName)) {
            $responseClassName = ResponseGeneric::class;
        }

        $response = new $responseClassName($telnetResponse);

        return $response;
    }

    /**
     * @return Client
     */
    public static function factory()
    {
        $telnetClient = new TelnetClient(
            new SocketFactory(),
            new TelnetPromptMatcher(self::PROMPT_ERROR),
            new InterpretAsCommand()
        );

        return new static($telnetClient);
    }
}