vipnytt\RobotsTxtParser\DelayHandler

Complexity

Total Complexity

8

Size/Duplication

Total Lines	113
Duplicated Lines	8.85 %

Coupling/Cohesion

Components	1
Dependencies	5

Importance

Changes	1
Bugs	0	Features	0

6 Methods

Rating	Name	Duplication	Size	Complexity
A	__construct()	0	4	1
A	client()	0	4	1
A	invalidate()	0	12	1
A	listQueue()	0	22	2
A	clean()	10	10	1
A	setup()	0	7	2

<?php
namespace vipnytt\RobotsTxtParser;

use PDO;
use vipnytt\RobotsTxtParser\Client\Delay\DelayHandlerClient;
use vipnytt\RobotsTxtParser\Client\Directives\DelayInterface;
use vipnytt\RobotsTxtParser\Exceptions\SQLException;
use vipnytt\RobotsTxtParser\Parser\UrlParser;
use vipnytt\RobotsTxtParser\SQL\SQLInterface;
use vipnytt\RobotsTxtParser\SQL\SQLTrait;

/**
 * Class DelayHandler
 *
 * @package vipnytt\RobotsTxtParser
 */
class DelayHandler implements SQLInterface
{
    use SQLTrait;
    use UrlParser;

    /**
     * Database connection
     * @var PDO
     */
    private $pdo;

    /**
     * DelayHandler constructor.
     *
     * @param PDO $pdo
     */
    public function __construct(PDO $pdo)
    {
        $this->pdo = $this->pdoInitialize($pdo);
    }

    /**
     * Client
     *
     * @param DelayInterface $client
     * @return DelayHandlerClient
     */
    public function client(DelayInterface $client)
    {
        return new DelayHandlerClient($this->pdo, $client->getBaseUri(), $client->getUserAgent(), $client->getValue());
    }

    /**
     * Invalidate delay
     *
     * @param string $baseUri
     * @param string $userAgent
     * @return bool
     */
    public function invalidate($baseUri, $userAgent)
    {
        $base = $this->urlBase($this->urlEncode($baseUri));
        $query = $this->pdo->prepare(<<<SQL
DELETE FROM robotstxt__delay0
WHERE base = :base AND userAgent = :useragent;
SQL
        );
        $query->bindParam(':base', $base, PDO::PARAM_INT);
        $query->bindParam(':useragent', $userAgent, PDO::PARAM_INT);
        return $query->execute();
    }

    /**
     * List all with queue
     *
     * @param int $minSec
     * @param int $limit
     * @return array
     */
    public function listQueue($minSec = 0, $limit = 100)
    {
        $query = $this->pdo->prepare(<<<SQL
SELECT
  base,
  userAgent,
  microTime / 1000000,
  lastDelay
FROM robotstxt__delay0
WHERE microTime > ((UNIX_TIMESTAMP(CURTIME(6)) + :minimum) * 1000000)
ORDER BY microTime DESC
LIMIT :rowlimit;
SQL
        );
        $query->bindParam(':minimum', $minSec, PDO::PARAM_INT);
        $query->bindParam(':rowlimit', $limit, PDO::PARAM_INT);
        $query->execute();
        if ($query->rowCount() > 0) {
            return $query->fetchAll(PDO::FETCH_ASSOC);
        }
        return [];
    }

    /**
     * Clean the delay table
     *
     * @param int $delay - in seconds
     * @return bool
     */
    public function clean($delay = 60)

This method seems to be duplicated in your project.

    {
        $query = $this->pdo->prepare(<<<SQL
DELETE FROM robotstxt__delay0
WHERE microTime < ((UNIX_TIMESTAMP() - :delay) * 1000000);
SQL
        );
        $query->bindParam(':delay', $delay, PDO::PARAM_INT);
        return $query->execute();
    }

    /**
     * Create SQL table
     *
     * @return bool
     * @throws SQLException
     */
    public function setup()

This method seems to be duplicated in your project.

    {
        if (!$this->createTable($this->pdo, self::TABLE_DELAY, file_get_contents(__DIR__ . '/SQL/delay.sql'))) {
            throw new SQLException('Unable to create table! Please read instructions at ' . self::README_SQL_DELAY);
        }
        return true;
    }
}