hiqdev\php\billing\price\ProgressivePriceThresholdList

Complexity

Total Complexity

20

Size/Duplication

Total Lines	137
Duplicated Lines	0 %

Importance

Changes	1
Bugs	0	Features	0

12 Methods

Rating	Name	Duplication	Size	Complexity
A	jsonSerialize()	0	4	1
A	checkCanBeAdded()	0	4	1
A	checkUnit()	0	14	3
A	checkCurrency()	0	14	3
A	__construct()	0	9	3
A	get()	0	5	1
A	fromScalarsArray()	0	10	1
A	prepareThresholds()	0	7	2
A	least()	0	3	1
A	__toArray()	0	7	2
A	appendThresholds()	0	3	1
A	withAdded()	0	8	1

<?php

declare(strict_types=1);

namespace hiqdev\php\billing\price;

use hiqdev\php\billing\Money\MultipliedMoney;
use JsonSerializable;
use hiqdev\php\units\Quantity;
use InvalidArgumentException;

final class ProgressivePriceThresholdList implements JsonSerializable
{
    /** @var ProgressivePriceThreshold[] */
    private array $thresholds;

    /**
     * @param ProgressivePriceThreshold[] $thresholds
     */
    public function __construct(array $thresholds)
    {
        foreach ($thresholds as $threshold) {
            $this->checkCanBeAdded($threshold);
            $this->appendThresholds($threshold);
        }

        if (empty($this->thresholds)) {
            throw new InvalidArgumentException('Progressive price thresholds must not be empty');
        }
    }

    /**
     * @param array{
     *     price: numeric-string,
     *     currency: string,
     *     quantity: numeric-string,
     *     unit: string
     * } $thresholds
     */
    public static function fromScalarsArray(array $thresholds): self
    {
        return new self(array_map(function ($threshold) {
            return ProgressivePriceThreshold::createFromScalar(
                $threshold['price'],
                $threshold['currency'],
                $threshold['quantity'],
                $threshold['unit']
            );
        }, $thresholds));
    }

    private function checkCanBeAdded(ProgressivePriceThreshold $threshold): void
    {
        $this->checkCurrency($threshold->price());
        $this->checkUnit($threshold->quantity());
    }

    public function withAdded(ProgressivePriceThreshold $threshold): self
    {
        $this->checkCanBeAdded($threshold);

        $self = clone $this;
        $self->appendThresholds($threshold);

        return $self;
    }

    /**
     * @return ProgressivePriceThreshold[]
     */
    public function get(): array
    {
        $this->prepareThresholds();

        return $this->thresholds;
    }

    public function least(): ProgressivePriceThreshold
    {
        return $this->thresholds[0];
    }

    private function prepareThresholds(): void
    {
        usort($this->thresholds, function (ProgressivePriceThreshold $a, ProgressivePriceThreshold $b) {
            if ($b->quantity()->convert($a->quantity()->getUnit())->equals($a->quantity())) {
                return $b->price()->getAmount() <=> $a->price()->getAmount();
            }
            return $b->quantity()->convert($a->quantity()->getUnit())->getQuantity() <=> $a->quantity()->getQuantity();
        });
    }

    private function checkCurrency(MultipliedMoney $price): void
    {
        if (empty($this->thresholds)) {
            return;
        }

        $last = $this->thresholds[array_key_last($this->thresholds)];

        if (!$last->price()->getCurrency()->equals($price->getCurrency())) {
            throw new InvalidArgumentException(
                sprintf(
                    "Progressive price thresholds must have the same currency, last is %s, new is %s",
                    $last->price()->getCurrency()->getCode(),
                    $price->getCurrency()->getCode()
                )
            );
        }
    }

    private function checkUnit(Quantity $prepaid): void
    {
        if (empty($this->thresholds)) {
            return;
        }

        $last = $this->thresholds[array_key_last($this->thresholds)];

        if (!$last->quantity()->getUnit()->isConvertible($prepaid->getUnit())) {
            throw new InvalidArgumentException(
                sprintf(
                    "Progressive price thresholds must be of the same unit family, last is %s, new is %s",
                    $last->quantity()->getUnit()->getName(),
                    $prepaid->getUnit()->getName()
                )
            );
        }
    }

    private function appendThresholds(ProgressivePriceThreshold $threshold): void
    {
        $this->thresholds[] = $threshold;
    }

    public function __toArray(): array
    {
        $result = [];
        foreach ($this->thresholds as $threshold) {
            $result[] = $threshold->__toArray();
        }
        return $result;
    }

    #[\ReturnTypeWillChange]
    public function jsonSerialize()
    {
        return $this->thresholds;
    }
}