Maphper\DataSource\Mock

Complexity

Total Complexity

21

Size/Duplication

Total Lines	71
Duplicated Lines	0 %

Importance

Changes

0

10 Methods

Rating	Name	Duplication	Size	Complexity
A	__construct()	0	3	2
A	getPrimaryKey()	0	2	1
A	findById()	0	2	2
A	getErrors()	0	2	1
B	getOrderFunction()	0	14	5
A	deleteByField()	0	2	2
A	deleteById()	0	2	1
A	save()	0	10	2
A	findByField()	0	10	4
A	findAggregate()	0	2	1

<?php
namespace Maphper\DataSource;
use Maphper\Maphper;
class Mock implements \Maphper\DataSource {
    private $data;
    private $id;

    public function __construct(\ArrayObject $data, $id) {
        $this->data = $data;
        $this->id = is_array($id) ? $id : [$id];
    }

    public function getPrimaryKey() {
        return $this->id;
    }

    public function findById($id) {
        return isset($this->data[$id]) ? (array)$this->data[$id] : [];
    }

    public function findByField(array $fields, $options = []) {
        $arrayFilter = new \Maphper\Lib\ArrayFilter(iterator_to_array($this->data->getIterator()));
        $filteredArray = $arrayFilter->filter($fields);
        if (isset($options['order'])) {
            list($columns, $order) = explode(' ', $options['order']);
            usort($filteredArray, $this->getOrderFunction($order, $columns));
        }
        if (isset($options['offset'])) $filteredArray = array_slice($filteredArray, $options['offset']);
        if (isset($options['limit'])) $filteredArray = array_slice($filteredArray, 0, $options['limit']);
        return $filteredArray;
    }

  	public function findAggregate($function, $field, $group = null, array $criteria = [], array $options = []) {
        return $function($this->findByField($criteria));
    }

  	public function deleteById($id) {
        unset($this->data[$id]);
    }

  	public function deleteByField(array $fields, array $options) {
        foreach ($this->findByField($fields, $options) as $val) unset($this->data[$val->{$this->id[0]}]);
    }

    public function save($data) {
        if (isset($data->{$this->id[0]})) {
            $id = $data->{$this->id[0]};
        }
        else {
            $id = count($this->data);
            $data->{$this->id[0]} = $id;
        }

        $this->data[$id] = (object)array_merge($this->findById($id), (array)$data);
    }

    public function getErrors() {
        return [];
    }

    private function getOrderFunction($order, $columns) {
        return function($a, $b) use ($order, $columns) {
          foreach (explode(',', $columns) as $column) {
            $aColumn = $a->$column;
            $bColumn = $b->$column;
            if ($aColumn === $bColumn) {
              $sortVal = 0;
              continue;
            }
            else $sortVal = ($aColumn < $bColumn) ? -1 : 1;
            break;
          }
          if ($order === 'desc') return -$sortVal;

The variable $sortVal seems to be defined by a foreach iteration on line 63. Are you sure the iterator is never empty, otherwise this variable is not defined?

          else return $sortVal;
        };
    }
}