Thruster\Component\Dns\RecordCache

Complexity

Total Complexity

12

Size/Duplication

Total Lines	74
Duplicated Lines	0 %

Coupling/Cohesion

Components	1
Dependencies	6

Importance

Changes	1
Bugs	0	Features	0

7 Methods

Rating	Name	Duplication	Size	Complexity
A	__construct()	0	5	1
A	lookup()	0	18	4
A	storeResponseMessage()	0	6	2
A	expire()	0	4	1
A	storeRecord()	0	14	2
A	serializeQueryToIdentity()	0	4	1
A	serializeRecordToIdentity()	0	4	1

<?php

namespace Thruster\Component\Dns;

use Thruster\Component\Promise\FulfilledPromise;
use Thruster\Component\Promise\RejectedPromise;

/**
 * Class RecordCache
 *
 * @package Thruster\Component\Dns
 * @author  Aurimas Niekis <aurimas@niekis.lt>
 */
class RecordCache
{
    /**
     * @var RecordBag[]
     */
    private $records;

    /**
     * @var int
     */
    private $expiredAt;

    public function __construct()
    {
        $this->records     = [];
        $this->expirations = [];

The property expirations does not exist. Did you maybe forget to declare it?

    }

    public function lookup(Query $query)
    {
        $id = $this->serializeQueryToIdentity($query);

        $expiredAt = $this->expiredAt;

        if (false === isset($this->records[$id])) {
            return new RejectedPromise();
        }

        $recordBag = $this->records[$id];

        if (null !== $expiredAt && $expiredAt <= $query->getCurrentTime()) {
            return new RejectedPromise();
        }

        return new FulfilledPromise($recordBag->all());
    }

    public function storeResponseMessage($currentTime, Message $message)
    {
        foreach ($message->answers as $record) {
            $this->storeRecord($currentTime, $record);
        }
    }

    public function expire($currentTime)
    {
        $this->expiredAt = $currentTime;
    }

    private function storeRecord($currentTime, Record $record)
    {
        $id = $this->serializeRecordToIdentity($record);

        if (isset($this->records[$id])) {
            $recordBag = $this->records[$id];
        } else {
            $recordBag = new RecordBag();
        }

        $recordBag->set($currentTime, $record);

        $this->records[$id] = $recordBag;
    }

    private function serializeQueryToIdentity(Query $query)
    {
        return $query->getName() . ':' . $query->getType() . ':' . $query->getClass();
    }

    private function serializeRecordToIdentity(Record $record)
    {
        return $record->getName() . ':' . $record->getType() . ':' . $record->getClass();
    }
}