WS\Utils\Collections\Functions\Group\Group

Complexity

Total Complexity

17

Size/Duplication

Total Lines	82
Duplicated Lines	0 %

Test Coverage

Coverage

89.47%

Importance

Changes	5
Bugs	1	Features	0

12 Methods

Rating	Name	Duplication	Size	Complexity
A	count()	0	3	1
A	first()	0	3	1
A	addAggregator()	0	4	1
A	max()	0	3	1
A	min()	0	3	1
A	__invoke()	0	20	6
A	addToSet()	0	3	1
A	__construct()	0	3	1
A	last()	0	3	1
A	sum()	0	3	1
A	by()	0	3	1
A	avg()	0	3	1

<?php

namespace WS\Utils\Collections\Functions\Group;

use WS\Utils\Collections\Collection;
use WS\Utils\Collections\Functions\ObjectFunctions;

class Group
{

    private $key;
    private $aggregators;

    public function __construct(string $key)
    {
        $this->key = $key;
    }

    public function __invoke(Collection $collection)
    {
        $groupedResult = [];
        foreach ($collection as $element) {
            if (!$groupKey = ObjectFunctions::getPropertyValue($element, $this->key)) {
                continue;
            }
            $groupedResult[$groupKey][] = $element;
        }
        if (!$this->aggregators) {
            return $groupedResult;
        }
        $aggregatedResult = [];
        foreach ($groupedResult as $groupKey => $items) {
            foreach ($this->aggregators as $item) {
                [$destKey, $aggregator] = $item;
                $aggregatedResult[$groupKey][$destKey] = $aggregator($items);
            }
        }
        return $aggregatedResult;
    }

    public static function by(string $key): self
    {
        return new self($key);
    }

    public function sum(string $sourceKey, string $destKey = null): self
    {
        return $this->addAggregator($destKey ?? $sourceKey, new Aggregator\Sum($sourceKey));
    }

    public function min(string $sourceKey, string $destKey = null): self
    {
        return $this->addAggregator($destKey ?? $sourceKey, new Aggregator\Min($sourceKey));
    }

    public function max(string $sourceKey, string $destKey = null): self
    {
        return $this->addAggregator($destKey ?? $sourceKey, new Aggregator\Max($sourceKey));
    }

    public function avg(string $sourceKey, string $destKey = null): self
    {
        return $this->addAggregator($destKey ?? $sourceKey, new Aggregator\Avg($sourceKey));
    }

    public function addToSet(string $sourceKey, string $destKey = null): self
    {
        return $this->addAggregator($destKey ?? $sourceKey, new Aggregator\AddToSet($sourceKey));
    }

    public function first(string $sourceKey, string $destKey = null): self
    {
        return $this->addAggregator($destKey ?? $sourceKey, new Aggregator\First($sourceKey));
    }

    public function last(string $sourceKey, string $destKey = null): self
    {
        return $this->addAggregator($destKey ?? $sourceKey, new Aggregator\Last($sourceKey));
    }

    public function count(string $destKey): self
    {
        return $this->addAggregator($destKey, new Aggregator\Count());
    }

    public function addAggregator(string $destKey, callable $aggregator): self
    {
        $this->aggregators[] = [$destKey, $aggregator];
        return $this;
    }

}