PhpCfdi\RfcLinc\DataGateway\Pdo\RfcLogGateway

Complexity

Total Complexity

7

Size/Duplication

Total Lines	44
Duplicated Lines	0 %

Test Coverage

Coverage

100%

Importance

Changes

0

5 Methods

Rating	Name	Duplication	Size	Complexity
A	insert()	0	9	1
A	byRfc()	0	8	2
A	openStatementByRfc()	0	5	1
A	eachByRfc()	0	5	2
A	createRfcLogFromArray()	0	6	1

<?php

declare(strict_types=1);

namespace PhpCfdi\RfcLinc\DataGateway\Pdo;

use PDO;
use PDOStatement;
use PhpCfdi\RfcLinc\DataGateway\RfcLogGatewayInterface;
use PhpCfdi\RfcLinc\Domain\RfcLog;
use PhpCfdi\RfcLinc\Domain\VersionDate;

class RfcLogGateway extends AbstractPdoGateway implements RfcLogGatewayInterface
{
    public function eachByRfc(string $rfc)
    {
        $stmt = $this->openStatementByRfc($rfc);
        while (false !== $values = $stmt->fetch(PDO::FETCH_ASSOC)) {
            yield $this->createRfcLogFromArray($values);
        }
    }

    public function byRfc(string $rfc): array
    {
        $list = [];
        $stmt = $this->openStatementByRfc($rfc);
        while (false !== $values = $stmt->fetch(PDO::FETCH_ASSOC)) {
            $list[] = $this->createRfcLogFromArray($values);
        }
        return $list;
    }

    public function insert(RfcLog $rfcLog)
    {
        $query = 'insert into rfclogs (version, rfc, action)'
            . ' values (:version, :rfc, :action);';
        $this->executePrepared($query, [
            'version' => $rfcLog->date()->timestamp(),
            'rfc' => $rfcLog->rfc(),
            'action' => $rfcLog->action(),
        ], 'Cannot insert into rfc logs list');
    }

    private function openStatementByRfc(string $rfc): PDOStatement
    {
        $query = 'select version, rfc, action from rfclogs'
            . ' where (rfc = :rfc) order by version';
        return $this->executePrepared($query, ['rfc' => $rfc], 'Cannot get logs from rfc list');
    }

    private function createRfcLogFromArray(array $values): RfcLog
    {
        return new RfcLog(
            VersionDate::createFromTimestamp((int) $values['version']),
            (string) $values['rfc'],
            (int) $values['action']
        );
    }
}