hiqdev\hiart\Command

Complexity

Total Complexity

10

Size/Duplication

Total Lines	93
Duplicated Lines	0 %

Coupling/Cohesion

Components	1
Dependencies	5

Test Coverage

Coverage

40%

Importance

Changes	9
Bugs	2	Features	3

9 Methods

Rating	Name	Duplication	Size	Complexity
A	insert()	0	10	2
A	get()	0	4	1
A	mget()	0	6	1
A	exists()	0	4	1
A	delete()	0	4	1
A	update()	0	6	1
A	perform()	0	4	1
A	getList()	0	8	1
A	search()	0	8	1

<?php

/*
 * Tools to use API as ActiveRecord for Yii2
 *
 * @link      https://github.com/hiqdev/yii2-hiart
 * @package   yii2-hiart
 * @license   BSD-3-Clause
 * @copyright Copyright (c) 2015-2016, HiQDev (http://hiqdev.com/)
 */

namespace hiqdev\hiart;

use yii\base\Component;
use yii\helpers\ArrayHelper;
use yii\helpers\Inflector;
use yii\helpers\Json;

/**
 * The Command class implements the API for accessing REST API.
 */
class Command extends Component
{
    /**
     * @var Connection
     */
    public $db;
    /**
     * @var string|array the indexes to execute the query on. Defaults to null meaning all indexes
     */
    public $index;
    /**
     * @var string|array the types to execute the query on. Defaults to null meaning all types
     */
    public $type;
    /**
     * @var array list of arrays or json strings that become parts of a query
     */
    public $queryParts = [];

    /**
     * Sends a request to the _search API and returns the result.
     * @param array $options
     * @throws ErrorResponseException
     * @return mixed
     */
    public function search($options = [])
    {
        $url     = $this->index . Inflector::id2camel(ArrayHelper::remove($options, 'scenario', 'search'));
        $query   = $this->queryParts;
        $options = array_merge($query, $options);

        return $this->db->post($url, $options);
    }

    public function getList($options = [])
    {
        $options = array_merge($this->queryParts, $options);
        $command = $this->index . 'GetList';
        $result  = $this->db->post($command, $options);

        return $result;
    }

    public function insert($action, $data, $id = null, $options = [])
    {
        $options = array_merge($data, $options);

        if ($id !== null) {
            return $this->db->put($action . 'Update', array_merge($options, ['id' => $id]));
        } else {
            return $this->db->post($action . 'Create', $options);
        }
    }

    public function get($modelName, $primaryKey, $options)
    {
        return $this->db->post($modelName . 'GetInfo', ArrayHelper::merge(['id' => $primaryKey], $options));
    }

    public function mget($index, $type, $ids, $options = [])
    {
        $body = Json::encode(['ids' => array_values($ids)]);

        return $this->db->post([$index, $type, '_mget'], $options, $body);

array($index, $type, '_mget') is of type array<integer,?,{"0":"?","1":"?","2":"string"}>, but the function expects a string.

    }

    public function exists($index, $type, $id)
    {
        return $this->db->head([$index, $type, $id]);

array($index, $type, $id) is of type array<integer,?,{"0":"?","1":"?","2":"?"}>, but the function expects a string.

    }

    public function delete($index, $id, $options = [])
    {
        return $this->db->delete($index . 'Delete', array_merge($options, ['id' => $id]));
    }

    public function update($index, $id, $data, $options = [])
    {
        $options['id'] = $id;

        return $this->db->put($index . 'Update', array_merge($data, $options));
    }

    /**
     * @param $action
     * @param mixed $body request parameters
     * @return mixed
     */
    public function perform($action, $body = [])
    {
        return $this->db->post($action, [], $body);
    }
}