Spike\Client\Worker\HttpWorker

Complexity

Total Complexity

5

Size/Duplication

Total Lines	45
Duplicated Lines	0 %

Coupling/Cohesion

Components	1
Dependencies	3

Importance

Changes

0

4 Methods

Rating	Name	Duplication	Size	Complexity
A	resolveTargetHost()	0	4	1
A	handleConnectLocalError()	0	6	1
A	makeErrorResponse()	0	8	2
A	support()	0	4	1

<?php

/*
 * This file is part of the slince/spike package.
 *
 * (c) Slince <taosikai@yeah.net>
 *
 * For the full copyright and license information, please view the LICENSE
 * file that was distributed with this source code.
 */

namespace Spike\Client\Worker;

use GuzzleHttp\Psr7;
use Spike\Common\Tunnel\HttpTunnel;
use Spike\Common\Tunnel\TunnelInterface;

class HttpWorker extends TcpWorker
{
    /**
     * {@inheritdoc}
     */
    public function resolveTargetHost()
    {
        return $this->tunnel->getForwardHost($this->tunnel->getProxyHost());

The method getProxyHost() does not seem to exist on object<Spike\Common\Tunnel\TcpTunnel>.

The method getForwardHost() does not seem to exist on object<Spike\Common\Tunnel\TcpTunnel>.

    }

    /**
     * {@inheritdoc}
     */
    public function handleConnectLocalError(\Exception $exception)
    {
        $response = $this->makeErrorResponse(500, $exception->getMessage());
        $this->proxyConnection->end(Psr7\str($response));
        $this->stop();
    }

    /**
     * Make an error psr7 response.
     *
     * @param int    $code
     * @param string $message
     *
     * @return Psr7\Response
     */
    protected function makeErrorResponse($code, $message)
    {
        $message = $message ?: sprintf('Cannot connect to "%s"', $this->resolveTargetHost());

        return new Psr7\Response($code, [
            'Content-Length' => strlen($message),
        ], $message);
    }

    /**
     * {@inheritdoc}
     */
    public static function support(TunnelInterface $tunnel)
    {
        $tunnel instanceof HttpTunnel;
    }
}