hiqdev\php\billing\price\ProgressivePriceThresholds

Complexity

Total Complexity

13

Size/Duplication

Total Lines	82
Duplicated Lines	0 %

Importance

Changes	1
Bugs	0	Features	0

7 Methods

Rating	Name	Duplication	Size	Complexity
A	get()	0	4	1
A	add()	0	5	1
A	prepareThresholds()	0	7	2
A	__construct()	0	8	2
A	checkUnit()	0	13	3
A	appendThresholds()	0	3	1
A	checkCurrency()	0	14	3

<?php

declare(strict_types=1);

namespace hiqdev\php\billing\price;

use hiqdev\php\units\Quantity;
use InvalidArgumentException;
use Money\Money;

final class ProgressivePriceThresholds
{
    /** @var ProgressivePriceThreshold[] */
   private array $thresholds;

    /**
     * @param ProgressivePriceThreshold[] $thresholds
     */
   public function __construct(array $thresholds)
   {
       foreach ($thresholds as $threshold) {
           $this->add(ProgressivePriceThreshold::createFromScalar(
                   $threshold['price'],
                   $threshold['currency'],
                   $threshold['quantity'],
                   $threshold['unit'],
               )
           );
       }
   }

   public function add(ProgressivePriceThreshold $threshold): void
   {
      $this->checkCurrency($threshold->price());
      $this->checkUnit($threshold->quantity());
      $this->appendThresholds($threshold);
   }

    public function get(): array
    {
        $this->prepareThresholds();
        return $this->thresholds;
    }

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

    private function checkCurrency(Money $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 with threshold currency %s is not valid to other threshold currency %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 with threshold unit %s is not convertible to other threshold unit %s",
                $last->quantity()->getUnit()->getName(),
                $prepaid->getUnit()->getName()
            ));
        }
    }

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