Manticoresearch\Response

Complexity

Total Complexity

29

Size/Duplication

Total Lines	157
Duplicated Lines	0 %

Importance

Changes	2
Bugs	0	Features	0

9 Methods

Rating	Name	Duplication	Size	Complexity
A	__construct()	0	9	2
A	getResponse()	0	17	6
A	stripBadUtf8()	0	3	2
A	setTransportInfo()	0	4	1
A	setTime()	0	4	1
A	getTime()	0	3	1
B	getError()	0	17	7
B	hasError()	0	12	8
A	getTransportInfo()	0	3	1

<?php


namespace Manticoresearch;

/**
 * Manticore response object
 *  Stores result array, time and errors
 * @category ManticoreSearch
 * @package ManticoreSearch
 * @author Adrian Nuta <adrian.nuta@manticoresearch.com>
 * @link https://manticoresearch.com
 */
use Manticoresearch\Exceptions\RuntimeException;

/**
 * Class Response
 * @package Manticoresearch
 */
class Response
{
    /**
     * execution time to get the response
     * @var integer|float
     */
    protected $time;

    /**
     * raw response as string
     * @var string
     */
    protected $string;

    /**
     * information about request
     * @var array
     */
    protected $transportInfo;

    protected $status;
    /**
     * response as array
     * @var array
     */
    protected $response;

    /**
     * additional params as array
     * @var array
     */
    protected $params;
    

    public function __construct($responseString, $status = null, $params = [])
    {
        if (is_array($responseString)) {
            $this->response = $responseString;
        } else {
            $this->string = $responseString;
        }
        $this->status = $status;
        $this->params = $params;
    }

    /*
     * Return response
     * @return array
     */
    public function getResponse()
    {
        if (null === $this->response) {
            $this->response = json_decode($this->string, true);
            if (json_last_error() !== JSON_ERROR_NONE) {
                if (json_last_error() === JSON_ERROR_UTF8 && $this->stripBadUtf8()) {
                    $this->response = json_decode(preg_replace('/[\x00-\x1F\x80-\xFF]/', '', $this->string), true);
                } else {
                    throw new RuntimeException('fatal error while trying to decode JSON response');
                }
            }

            if (empty($this->response)) {
                $this->response = [];
            }
        }
        return $this->response;
    }
    
    /**
     * check if strip_bad_utf8 as been set to true
     * @return boolean
     */
    private function stripBadUtf8()
    {
        return !empty($this->transportInfo['body']) && !empty($this->transportInfo['body']['strip_bad_utf8']);
    }

    /*
     * Check whenever response has error
     * @return bool
     */
    public function hasError()
    {
        $response = $this->getResponse();
        if (is_array($response)) {

The condition is_array($response) is always true.

            foreach ($response as $r) {
                if (isset($r['error']) && $r['error'] !== '') {
                    return true;
                }
            }
        }
        return (isset($response['error']) && $response['error'] !== '') ||
            (isset($response['errors']) && $response['errors'] !== false);
    }

    /*
     * Return error
     * @return false|string
     */
    public function getError()
    {
        $response = $this->getResponse();
        if (isset($response['error'])) {
            return json_encode($response['error'], true);

true of type true is incompatible with the type integer expected by parameter $flags of json_encode().

        } elseif (isset($response['errors'])) {
            return json_encode($response['errors'], true);
        } elseif (is_array($response)) {
            $errors = "";
            foreach ($response as $r) {
                if (isset($r['error']) && $r['error'] !== '') {
                    $errors .= json_encode($r['error'], true);
                }
            }
            return $errors;
        } else {
            return '';
        }
    }

    /*
     * set execution time
     * @param int|float $time
     * @return $this
     */
    public function setTime($time)
    {
        $this->time = $time;
        return $this;
    }

    /*
     * returns execution time
     * @return mixed
     */
    public function getTime()
    {
        return $this->time;
    }

    /**
     *  set request info
     * @param array $info
     * @return $this
     */
    public function setTransportInfo($info)
    {
        $this->transportInfo = $info;
        return $this;
    }

    /**
     * get request info
     * @return array
     */
    public function getTransportInfo()
    {
        return $this->transportInfo;
    }
}