AlecRabbit\TradesAggregator

Complexity

Total Complexity

8

Size/Duplication

Total Lines	58
Duplicated Lines	0 %

Test Coverage

Coverage

94.12%

Importance

Changes

0

5 Methods

Rating	Name	Duplication	Size	Complexity
A	countTrade()	0	9	3
A	__construct()	0	6	2
A	volume()	0	3	1
A	trades()	0	3	1
A	avgPrice()	0	3	1

<?php
/**
 * User: alec
 * Date: 05.11.18
 * Time: 17:05
 */
declare(strict_types=1);

namespace AlecRabbit;

use AlecRabbit\Event\EventCounterDeprecated;
use AlecRabbit\Structures\Trade;

class TradesAggregator
{
    private const PERIODS = [
        P_01MIN => P_01MIN,
        P_03MIN => P_01MIN,
        P_05MIN => P_01MIN,
        P_15MIN => P_05MIN,
        P_30MIN => P_05MIN,
        P_45MIN => P_05MIN,
        P_01HOUR => P_15MIN,
        P_02HOUR => P_15MIN,
        P_03HOUR => P_15MIN,
        P_04HOUR => P_15MIN,
        P_01DAY => P_01HOUR,
    ];

    /** @var string */
    private $pair;

    /**@var EventCounterDeprecated[] */
    private $counters = [];

    /**
     * TradesCounter constructor.
     * @param string $pair
     */
    public function __construct(string $pair)
    {
        foreach (static::PERIODS as $length => $groupBy) {
            $this->counters[$length] = new EventCounterDeprecated($length, $groupBy);
        }
        $this->pair = $pair;
    }

    public function countTrade(Trade $trade): Trade
    {
        if ($this->pair !== $trade->pair) {
            throw new \RuntimeException('DataInconsistency'); // todo update message
        }
        foreach (static::PERIODS as $length => $groupBy) {
            $this->counters[$length]->addEvent($trade->timestamp);
        }
        return $trade;
    }

    public function trades(int $timePeriod): int
    {
        return $this->counters[$timePeriod]->getCalculatedEvents();
    }

    public function volume(int $timePeriod): float

The parameter $timePeriod is not used and could be removed.

    {
        return 0.1;
    }

    public function avgPrice(int $timePeriod): float

The parameter $timePeriod is not used and could be removed.

    {
        return 8500;
    }
}