alexpts / php-rate-limiter

src/Adapter/RedisAdapter.php

Indentation +42 added lines, -42 removed lines

@@ -8,46 +8,46 @@
 
 class RedisAdapter implements StoreInterface
 {
-	/** @var Redis */
-	protected $redis;
-
-	/**
-	 * @param Redis $redis - configured instance
-	 */
-	public function __construct(Redis $redis)
-	{
-		$this->redis = $redis;
-	}
-
-	public function get(string $key): int
-	{
-		return (int)$this->redis->get($key);
-	}
-
-	public function inc(string $key, int $ttl = 60): int
-	{
-		$value = $this->redis->incr($key);
-		if ($value === 1) {
-			$this->redis->expire($key, $ttl);
-		}
-
-		return $value;
-	}
-
-	public function reset(string $key): bool
-	{
-		return (bool)$this->redis->delete($key);
-	}
-
-	public function isExceeded(string $key, int $max): bool
-	{
-		$value = $this->get($key);
-		return $value >= $max;
-	}
-
-	public function ttl(string $key): ?int
-	{
-		$ttl = $this->redis->ttl($key);
-		return $ttl > 0 ? $ttl : null;
-	}
+    /** @var Redis */
+    protected $redis;
+
+    /**
+     * @param Redis $redis - configured instance
+     */
+    public function __construct(Redis $redis)
+    {
+        $this->redis = $redis;
+    }
+
+    public function get(string $key): int
+    {
+        return (int)$this->redis->get($key);
+    }
+
+    public function inc(string $key, int $ttl = 60): int
+    {
+        $value = $this->redis->incr($key);
+        if ($value === 1) {
+            $this->redis->expire($key, $ttl);
+        }
+
+        return $value;
+    }
+
+    public function reset(string $key): bool
+    {
+        return (bool)$this->redis->delete($key);
+    }
+
+    public function isExceeded(string $key, int $max): bool
+    {
+        $value = $this->get($key);
+        return $value >= $max;
+    }
+
+    public function ttl(string $key): ?int
+    {
+        $ttl = $this->redis->ttl($key);
+        return $ttl > 0 ? $ttl : null;
+    }
 }
\ No newline at end of file

Spacing +2 added lines, -2 removed lines

@@ -21,7 +21,7 @@ 
 
 	public function get(string $key): int
 	{
-		return (int)$this->redis->get($key);
+		return (int) $this->redis->get($key);
 	}
 
 	public function inc(string $key, int $ttl = 60): int
@@ -36,7 +36,7 @@ 
 
 	public function reset(string $key): bool
 	{
-		return (bool)$this->redis->delete($key);
+		return (bool) $this->redis->delete($key);
 	}
 
 	public function isExceeded(string $key, int $max): bool

src/Adapter/MemoryAdapter.php

Indentation +71 added lines, -71 removed lines

@@ -7,76 +7,76 @@
 
 class MemoryAdapter implements StoreInterface
 {
-	protected $cleanExpired = 30;
-	protected $lastClean = 0;
-
-	protected $store = [];
-	protected $ttlKeys = [];
-
-	public function get(string $key): int
-	{
-		$this->isNeedCleanExpired() && $this->cleanExpired();
-		return $this->store[$key] ?? 0;
-	}
-
-	public function __construct(int $cleanExpired = 30)
-	{
-		$this->cleanExpired = $cleanExpired;
-		$this->lastClean = time();
-	}
-
-	public function inc(string $key, int $ttl = 60): int
-	{
-		$value = $this->get($key);
-		$this->store[$key] = ++$value;
-
-		if ($value === 1) {
-			$this->ttlKeys[$key] = time() + $ttl;
-		}
-
-		return $value;
-	}
-
-	public function reset(string $key): bool
-	{
-		unset($this->store[$key], $this->ttlKeys[$key]);
-		return true;
-	}
-
-	public function isExceeded(string $key, int $max): bool
-	{
-		$value = $this->get($key);
-		return $value >= $max;
-	}
-
-	protected function isNeedCleanExpired(): bool
-	{
-		return ($this->lastClean + $this->cleanExpired) < time();
-	}
-
-	protected function cleanExpired(): void
-	{
-		$current = time();
-
-		array_filter($this->ttlKeys, function(int $time, string $key) use ($current) {
-			$isExpired = $time < $current;
-
-			if ($time < $current) {
-				unset($this->store[$key]);
-			}
-
-			return !$isExpired;
-		}, ARRAY_FILTER_USE_BOTH);
-	}
-
-	public function ttl(string $key): ?int
-	{
-		if (array_key_exists($key, $this->ttlKeys)) {
-			$ttl = $this->ttlKeys[$key] - time();
-			return $ttl > 0 ? $ttl : 0;
-		}
-
-		return null;
-	}
+    protected $cleanExpired = 30;
+    protected $lastClean = 0;
+
+    protected $store = [];
+    protected $ttlKeys = [];
+
+    public function get(string $key): int
+    {
+        $this->isNeedCleanExpired() && $this->cleanExpired();
+        return $this->store[$key] ?? 0;
+    }
+
+    public function __construct(int $cleanExpired = 30)
+    {
+        $this->cleanExpired = $cleanExpired;
+        $this->lastClean = time();
+    }
+
+    public function inc(string $key, int $ttl = 60): int
+    {
+        $value = $this->get($key);
+        $this->store[$key] = ++$value;
+
+        if ($value === 1) {
+            $this->ttlKeys[$key] = time() + $ttl;
+        }
+
+        return $value;
+    }
+
+    public function reset(string $key): bool
+    {
+        unset($this->store[$key], $this->ttlKeys[$key]);
+        return true;
+    }
+
+    public function isExceeded(string $key, int $max): bool
+    {
+        $value = $this->get($key);
+        return $value >= $max;
+    }
+
+    protected function isNeedCleanExpired(): bool
+    {
+        return ($this->lastClean + $this->cleanExpired) < time();
+    }
+
+    protected function cleanExpired(): void
+    {
+        $current = time();
+
+        array_filter($this->ttlKeys, function(int $time, string $key) use ($current) {
+            $isExpired = $time < $current;
+
+            if ($time < $current) {
+                unset($this->store[$key]);
+            }
+
+            return !$isExpired;
+        }, ARRAY_FILTER_USE_BOTH);
+    }
+
+    public function ttl(string $key): ?int
+    {
+        if (array_key_exists($key, $this->ttlKeys)) {
+            $ttl = $this->ttlKeys[$key] - time();
+            return $ttl > 0 ? $ttl : 0;
+        }
+
+        return null;
+    }
 
 }
\ No newline at end of file

src/RateLimitMiddleware.php

Indentation +53 added lines, -53 removed lines

@@ -10,67 +10,67 @@
 
 class RateLimitMiddleware implements MiddlewareInterface
 {
-	/** @var Limiter */
-	protected $limiter;
-	/** @var int */
-	protected $ttl = 60;
-	/** @var int */
-	protected $max = 60;
-	/** @var string */
-	protected $keyPrefix = 'limiter';
-	/** @var ResponseInterface */
-	protected $responseTooManyRequest = '';
-	/** @var string */
-	protected $keyAttr = 'client-ip';
+    /** @var Limiter */
+    protected $limiter;
+    /** @var int */
+    protected $ttl = 60;
+    /** @var int */
+    protected $max = 60;
+    /** @var string */
+    protected $keyPrefix = 'limiter';
+    /** @var ResponseInterface */
+    protected $responseTooManyRequest = '';
+    /** @var string */
+    protected $keyAttr = 'client-ip';
 
-	public function __construct(Limiter $limiter, ResponseInterface $response)
-	{
-		$this->limiter = $limiter;
-		$this->responseTooManyRequest = $response->withStatus(429, 'Too Many Requests');
-	}
+    public function __construct(Limiter $limiter, ResponseInterface $response)
+    {
+        $this->limiter = $limiter;
+        $this->responseTooManyRequest = $response->withStatus(429, 'Too Many Requests');
+    }
 
-	public function setKeyAttr(string $attr): void
-	{
-		$this->keyAttr = $attr;
-	}
+    public function setKeyAttr(string $attr): void
+    {
+        $this->keyAttr = $attr;
+    }
 
-	public function setKeyPrefix(string $keyPrefix): void
-	{
-		$this->keyPrefix = $keyPrefix;
-	}
+    public function setKeyPrefix(string $keyPrefix): void
+    {
+        $this->keyPrefix = $keyPrefix;
+    }
 
-	public function setMax(int $max): void
-	{
-		$this->max = $max;
-	}
+    public function setMax(int $max): void
+    {
+        $this->max = $max;
+    }
 
-	public function setTtl(int $ttl): void
-	{
-		$this->ttl = $ttl;
-	}
+    public function setTtl(int $ttl): void
+    {
+        $this->ttl = $ttl;
+    }
 
-	public function process(ServerRequestInterface $request, RequestHandlerInterface $next): ResponseInterface
-	{
-		$limiterKey = $this->getKey($request);
+    public function process(ServerRequestInterface $request, RequestHandlerInterface $next): ResponseInterface
+    {
+        $limiterKey = $this->getKey($request);
 
-		if ($this->limiter->isExceeded($limiterKey, $this->max)) {
-			return $this->responseTooManyRequest;
-		}
+        if ($this->limiter->isExceeded($limiterKey, $this->max)) {
+            return $this->responseTooManyRequest;
+        }
 
-		$response = $next->handle($request);
-		$this->limiter->inc($limiterKey, $this->ttl);
+        $response = $next->handle($request);
+        $this->limiter->inc($limiterKey, $this->ttl);
 
-		return $response;
-	}
+        return $response;
+    }
 
-	/**
-	 * @param ServerRequestInterface $request
-	 *
-	 * @return string
-	 */
-	protected function getKey(ServerRequestInterface $request): string
-	{
-		$key = $request->getAttribute($this->keyAttr);
-		return sprintf('%s.%s', $this->keyPrefix, $key);
-	}
+    /**
+     * @param ServerRequestInterface $request
+     *
+     * @return string
+     */
+    protected function getKey(ServerRequestInterface $request): string
+    {
+        $key = $request->getAttribute($this->keyAttr);
+        return sprintf('%s.%s', $this->keyPrefix, $key);
+    }
 }

src/Limiter.php

Indentation +32 added lines, -32 removed lines

@@ -5,36 +5,36 @@
 
 class Limiter
 {
-	/** @var StoreInterface */
-	protected $store;
-
-	public function __construct(StoreInterface $store)
-	{
-		$this->store = $store;
-	}
-
-	public function get(string $key): int
-	{
-		return $this->store->get($key);
-	}
-
-	public function inc(string $key, int $ttl = 60): int
-	{
-		return $this->store->inc($key, $ttl);
-	}
-
-	public function reset(string $key): bool
-	{
-		return $this->store->reset($key);
-	}
-
-	public function isExceeded(string $key, int $max): bool
-	{
-		return $this->store->isExceeded($key, $max);
-	}
-
-	public function ttl(string $key): ?int
-	{
-		return $this->store->ttl($key);
-	}
+    /** @var StoreInterface */
+    protected $store;
+
+    public function __construct(StoreInterface $store)
+    {
+        $this->store = $store;
+    }
+
+    public function get(string $key): int
+    {
+        return $this->store->get($key);
+    }
+
+    public function inc(string $key, int $ttl = 60): int
+    {
+        return $this->store->inc($key, $ttl);
+    }
+
+    public function reset(string $key): bool
+    {
+        return $this->store->reset($key);
+    }
+
+    public function isExceeded(string $key, int $max): bool
+    {
+        return $this->store->isExceeded($key, $max);
+    }
+
+    public function ttl(string $key): ?int
+    {
+        return $this->store->ttl($key);
+    }
 }

src/StoreInterface.php

Indentation +11 added lines, -11 removed lines

@@ -5,19 +5,19 @@
 
 interface StoreInterface
 {
-	public function get(string $key): int;
+    public function get(string $key): int;
 
-	/**
-	 * @param string $key
-	 * @param int $ttl
-	 *
-	 * @return int - new value
-	 */
-	public function inc(string $key, int $ttl = 60): int;
+    /**
+     * @param string $key
+     * @param int $ttl
+     *
+     * @return int - new value
+     */
+    public function inc(string $key, int $ttl = 60): int;
 
-	public function reset(string $key): bool;
+    public function reset(string $key): bool;
 
-	public function isExceeded(string $key, int $max): bool;
+    public function isExceeded(string $key, int $max): bool;
 
-	public function ttl(string $key): ?int;
+    public function ttl(string $key): ?int;
 }
\ No newline at end of file