Brownie\BpmOnline\DataService\Contract\UpdateContract

Complexity

Total Complexity

13

Size/Duplication

Total Lines	131
Duplicated Lines	0 %

Test Coverage

Coverage

100%

Importance

Changes

0

7 Methods

Rating	Name	Duplication	Size	Complexity
A	addColumn()	0	4	1
A	__construct()	0	6	1
A	addFilter()	0	4	1
A	getFilters()	0	3	1
A	validate()	0	7	4
A	getResponse()	0	3	1
A	toArray()	0	31	4

<?php
/**
 * @category    Brownie/BpmOnline
 * @author      Brownie <oss.brownie@gmail.com>
 * @license     https://opensource.org/licenses/MIT
 */

namespace Brownie\BpmOnline\DataService\Contract;

use Brownie\BpmOnline\DataService\Contract;
use Brownie\BpmOnline\DataService\Column\ColumnExpression;
use Brownie\BpmOnline\DataService\Column\ColumnFilter;
use Brownie\BpmOnline\Exception\ValidateException;
use Brownie\BpmOnline\DataService\Response\UpdateContract as ResponseUpdateContract;


/**
 * UpdateContract Data Contract.
 */
class UpdateContract extends Contract
{

    /**
     * The collection of column values for the entry being added.
     *
     * @var array
     */
    private $dictionary = [];

    /**
     * Column filters.
     *
     * @var ColumnFilter[]
     */
    private $filters = [];

    /**
     * Sets the input values.
     *
     * @param string $rootSchemaName The name of the root schema object.
     */
    public function __construct($rootSchemaName)
    {
        parent::__construct([
            'rootSchemaName' => $rootSchemaName,
            'operationType' => Contract::UPDATE,
            'contractType' => Contract::UPDATE_QUERY,
        ]);
    }

    /**
     * Adding a query expression to a contract.
     *
     * @param string            $name               The name of the column.
     * @param ColumnExpression  $columnExpression   Query expression to the schema object.
     *
     * @return self
     */
    public function addColumn($name, ColumnExpression $columnExpression)
    {
        $this->dictionary[$name] = $columnExpression;
        return $this;
    }

    /**
     * Adding query filter to contract.
     *
     * @param ColumnFilter $columnFilter Column filter.
     *
     * @return self
     */
    public function addFilter(ColumnFilter $columnFilter)
    {
        $this->filters[] = $columnFilter;
        return $this;
    }

    /**
     * Returns filters.
     *
     * @return ColumnFilter[]
     */
    private function getFilters()
    {
        return $this->filters;
    }

    /**
     * Returns data as an associative array.
     *
     * @return array
     */
    public function toArray()
    {
        $dictionary = [];
        /**
         * @var ColumnExpression $columnExpression
         */
        foreach ($this->dictionary as $keyName => $columnExpression) {
            $dictionary[$keyName] = $columnExpression->toArray();
        }

        $data = [
            'RootSchemaName' => $this->getRootSchemaName(),
            'OperationType' => $this->getOperationType(),
            'IsForceUpdate' => false,
            'ColumnValues' => [
                'Items' => $dictionary
            ],
        ];

        if (!empty($this->getFilters())) {
            $items = [];
            foreach ($this->getFilters() as $key => $filter) {
                $items['index_' . $key] = $filter->toArray();
            }
            $data['Filters'] = [
                'FilterType' => ColumnFilter::FILTER_FILTER_GROUP,
                'Items' => $items
            ];
        }

        return $data;
    }

    /**
     * Validates contract data, throws an exception in case of an error.
     *
     * @throws ValidateException
     */
    public function validate()
    {
        if ((2 != $this->getOperationType()) || empty($this->getFilters())) {
            throw new ValidateException('Invalid contract arguments.');
        }
        foreach ($this->getFilters() as $filter) {
            $filter->validate();
        }
    }

    /**
     * Returns the response of the performance contract.
     *
     * @param string    $rawResponse    Raw response.
     *
     * @return ResponseUpdateContract
     */
    public function getResponse($rawResponse)
    {
        return new ResponseUpdateContract($rawResponse);
    }
}