Kwkm\MkLiveStatusClient\LqlObject

Complexity

Total Complexity

35

Size/Duplication

Total Lines	218
Duplicated Lines	0 %

Coupling/Cohesion

Components	1
Dependencies	0

Test Coverage

Coverage

98%

Importance

Changes	5
Bugs	1	Features	1

19 Methods

Rating	Name	Duplication	Size	Complexity
A	__construct()	0	4	1
A	reset()	0	11	1
A	build()	0	13	1
A	getColumnsField()	0	8	2
A	getQueriesFiled()	0	8	2
A	getOutputFormatFiled()	0	8	2
A	appendNoValueQuery()	0	4	1
A	appendArrayQuery()	0	4	1
A	formatEnding()	0	8	2
A	setTable()	0	8	2
A	setColumns()	0	7	2
A	appendColumns()	0	7	2
A	appendStringQuery()	0	7	2
A	appendIntegerQuery()	0	7	2
A	appendParameter()	0	9	3
A	setHeader()	0	11	3
A	setOutputFormat()	0	7	2
A	setLimit()	0	7	2
A	setAuthUser()	0	7	2

<?php
namespace Kwkm\MkLiveStatusClient;

use \InvalidArgumentException;

/**
 * Class Lql Object
 *
 * @package Kwkm\MkLiveStatusClient
 * @author Takehiro Kawakami <take@kwkm.org>
 * @license MIT
 */
class LqlObject
{
    /**
     * Lql query
     * @var array
     */
    protected $queries;

    /**
     * Acquisition table
     * @var string
     */
    protected $table;

    /**
     * Header
     * @var string
     */
    protected $headers;

    /**
     * Acquisition column
     * @var array
     */
    protected $columns;

    /**
     * Output Format type
     * @var string
     */
    protected $outputFormat;

    /**
     * Authentication username
     * @var string
     */
    protected $authUser;

    /**
     * Acquisition number
     * @var integer;
     */
    protected $limit;

    public function __construct()
    {
        $this->reset();
    }

    public function setTable($table)
    {
        if (!is_string($table)) {
            throw new InvalidArgumentException("Argument 1 must be a string.");
        }

        $this->table = trim($table);
    }

    public function setColumns($columns)
    {
        if (!is_array($columns)) {
            throw new InvalidArgumentException("Argument 1 must be an array.");
        }
        $this->columns = $columns;
    }

    public function appendColumns($column)
    {
        if (!is_string($column)) {
            throw new InvalidArgumentException("Argument 1 must be a string.");
        }
        $this->columns[] = trim($column);
    }

    public function appendArrayQuery(array $array)
    {
        $this->queries = array_merge($this->queries, $array);
    }

    public function appendStringQuery($name, $value)
    {
        if (!is_string($value)) {
            throw new InvalidArgumentException("Argument 1 must be a string.");
        }
        $this->queries[] = sprintf("%s: %s\n", $name, trim($value));
    }

    public function appendIntegerQuery($name, $value)
    {
        if (!is_int($value)) {
            throw new InvalidArgumentException("Argument 1 must be an integer.");
        }
        $this->queries[] = sprintf("%s: %d\n", $name, $value);
    }

    public function appendNoValueQuery($name)
    {
        $this->queries[] = sprintf("%s:\n", $name);
    }

    public function appendParameter($parameter)
    {
        if (!is_string($parameter)) {
            throw new InvalidArgumentException("Argument 1 must be a string.");
        }
        if (trim($parameter) !== "") {
            $this->queries[] = $this->formatEnding($parameter);
        }
    }

    public function setHeader($boolean)
    {
        if (!is_bool($boolean)) {
            throw new InvalidArgumentException("Argument 1 must be a boolean.");
        }
        if ($boolean === true) {
            $this->headers = "ColumnHeaders: on\n";
        } else {
            $this->headers = "ColumnHeaders: off\n";
        }
    }

    public function setOutputFormat($outputFormat)
    {
        if (!is_string($outputFormat)) {
            throw new InvalidArgumentException("Argument 1 must be a string.");
        }
        $this->outputFormat = sprintf("OutputFormat: %s\n", $outputFormat);
    }

    public function setLimit($limit)
    {
        if (!is_int($limit)) {
            throw new InvalidArgumentException("Argument 1 must be an integer.");
        }
        $this->limit = sprintf("Limit: %d\n", $limit);
    }

    public function setAuthUser($authUser)
    {
        if (!is_string($authUser)) {
            throw new InvalidArgumentException("Argument 1 must be a string.");
        }
        $this->authUser = sprintf("AuthUser: %s\n", trim($authUser));
    }

    /**
     * 初期化
     *
     * @return \Kwkm\MkLiveStatusClient\Lql
     */
    public function reset()
    {
        $this->queries = array();
        $this->table = null;
        $this->columns = array();
        $this->authUser = '';
        $this->limit = '';

        $this->setHeader(true);
        $this->setOutputFormat('json');
    }

    /**
     * 終端の改行文字の付与
     * @param string $string 改行文字を付与する文字列
     * @return string           改行文字が付与された文字列
     */
    protected function formatEnding($string)
    {
        if ($string[strlen($string) - 1] !== "\n") {
            $string .= "\n";
        }

        return $string;
    }

    public function build()
    {
        $request = sprintf("GET %s\n", $this->table)
            . $this->getColumnsField()
            . $this->getQueriesFiled()
            . $this->getOutputFormatFiled()
            . $this->authUser
            . $this->limit
            . "ResponseHeader: fixed16\n"
            . "\n";

        return $request;
    }

    private function getColumnsField()
    {
        if (count($this->columns) !== 0) {
            return sprintf("Columns: %s\n", implode(' ', $this->columns)) . $this->headers;
        }

        return '';
    }

    private function getQueriesFiled()
    {
        if (!is_null($this->queries)) {
            return implode('', $this->queries);
        }

        return '';
    }

    private function getOutputFormatFiled()
    {
        if (!is_null($this->outputFormat)) {
            return $this->outputFormat;
        }

        return '';
    }
}