TreeHouse\IoBundle\Scrape\Crawler\Log\RedisRequestLogger

Complexity

Total Complexity

6

Size/Duplication

Total Lines	66
Duplicated Lines	0 %

Coupling/Cohesion

Components	1
Dependencies	0

Test Coverage

Coverage

95.45%

Importance

Changes

0

4 Methods

Rating	Name	Duplication	Size	Complexity
A	__construct()	0	5	1
A	getHashKey()	0	4	1
A	logRequest()	0	11	2
A	getRequestsSince()	0	14	2

<?php

namespace TreeHouse\IoBundle\Scrape\Crawler\Log;

class RedisRequestLogger implements RequestLoggerInterface
{
    /**
     * @var \Redis
     */
    protected $redis;

    /**
     * @var string
     */
    protected $key;

    /**
     * @param \Redis $redis
     * @param string $key
     */
    public function __construct(\Redis $redis, $key = 'crawler_requests')
    {
        $this->redis = $redis;
        $this->key = $key;
    }

    /**
     * @inheritdoc
     */
    public function logRequest($url, \DateTime $date = null)
    {
        if (null === $date) {
            $date = new \DateTime();
        }

        $timestamp = $date->getTimestamp();
        $hashKey = $this->getHashKey($timestamp, $url);

        $this->redis->zAdd($this->key, $timestamp, $hashKey);
    }

    /**
     * @inheritdoc
     */
    public function getRequestsSince(\DateTime $date = null)
    {
        $start = $date ? $date->getTimestamp() : '-inf';
        $end = time();

        return array_map(
            function ($hash) {
                list($timestamp, $url) = explode('#', $hash, 2);

                return [intval($timestamp), $url];
            },
            $this->redis->zRangeByScore($this->key, $start, $end)
        );
    }

    /**
     * @param int    $timestamp
     * @param string $url
     *
     * @return string
     */
    protected function getHashKey($timestamp, $url)
    {
        return sprintf('%d#%s', $timestamp, $url);
    }
}