123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139 |
- <?php
- namespace Illuminate\Tests\Cache;
- use Illuminate\Cache\RateLimiter;
- use Illuminate\Contracts\Cache\Repository as Cache;
- use Mockery as m;
- use PHPUnit\Framework\TestCase;
- class CacheRateLimiterTest extends TestCase
- {
- protected function tearDown(): void
- {
- m::close();
- }
- public function testTooManyAttemptsReturnTrueIfAlreadyLockedOut()
- {
- $cache = m::mock(Cache::class);
- $cache->shouldReceive('get')->once()->with('key', 0)->andReturn(1);
- $cache->shouldReceive('has')->once()->with('key:timer')->andReturn(true);
- $cache->shouldReceive('add')->never();
- $rateLimiter = new RateLimiter($cache);
- $this->assertTrue($rateLimiter->tooManyAttempts('key', 1));
- }
- public function testHitProperlyIncrementsAttemptCount()
- {
- $cache = m::mock(Cache::class);
- $cache->shouldReceive('add')->once()->with('key:timer', m::type('int'), 1)->andReturn(true);
- $cache->shouldReceive('add')->once()->with('key', 0, 1)->andReturn(true);
- $cache->shouldReceive('increment')->once()->with('key')->andReturn(1);
- $rateLimiter = new RateLimiter($cache);
- $rateLimiter->hit('key', 1);
- }
- public function testHitHasNoMemoryLeak()
- {
- $cache = m::mock(Cache::class);
- $cache->shouldReceive('add')->once()->with('key:timer', m::type('int'), 1)->andReturn(true);
- $cache->shouldReceive('add')->once()->with('key', 0, 1)->andReturn(false);
- $cache->shouldReceive('increment')->once()->with('key')->andReturn(1);
- $cache->shouldReceive('put')->once()->with('key', 1, 1);
- $rateLimiter = new RateLimiter($cache);
- $rateLimiter->hit('key', 1);
- }
- public function testRetriesLeftReturnsCorrectCount()
- {
- $cache = m::mock(Cache::class);
- $cache->shouldReceive('get')->once()->with('key', 0)->andReturn(3);
- $rateLimiter = new RateLimiter($cache);
- $this->assertEquals(2, $rateLimiter->retriesLeft('key', 5));
- }
- public function testClearClearsTheCacheKeys()
- {
- $cache = m::mock(Cache::class);
- $cache->shouldReceive('forget')->once()->with('key');
- $cache->shouldReceive('forget')->once()->with('key:timer');
- $rateLimiter = new RateLimiter($cache);
- $rateLimiter->clear('key');
- }
- public function testAvailableInReturnsPositiveValues()
- {
- $cache = m::mock(Cache::class);
- $cache->shouldReceive('get')->andReturn(now()->subSeconds(60)->getTimestamp(), null);
- $rateLimiter = new RateLimiter($cache);
- $this->assertTrue($rateLimiter->availableIn('key:timer') >= 0);
- $this->assertTrue($rateLimiter->availableIn('key:timer') >= 0);
- }
- public function testAttemptsCallbackReturnsTrue()
- {
- $cache = m::mock(Cache::class);
- $cache->shouldReceive('get')->once()->with('key', 0)->andReturn(0);
- $cache->shouldReceive('add')->once()->with('key:timer', m::type('int'), 1);
- $cache->shouldReceive('add')->once()->with('key', 0, 1)->andReturns(1);
- $cache->shouldReceive('increment')->once()->with('key')->andReturn(1);
- $executed = false;
- $rateLimiter = new RateLimiter($cache);
- $this->assertTrue($rateLimiter->attempt('key', 1, function () use (&$executed) {
- $executed = true;
- }, 1));
- $this->assertTrue($executed);
- }
- public function testAttemptsCallbackReturnsCallbackReturn()
- {
- $cache = m::mock(Cache::class);
- $cache->shouldReceive('get')->once()->with('key', 0)->andReturn(0);
- $cache->shouldReceive('add')->once()->with('key:timer', m::type('int'), 1);
- $cache->shouldReceive('add')->once()->with('key', 0, 1)->andReturns(1);
- $cache->shouldReceive('increment')->once()->with('key')->andReturn(1);
- $rateLimiter = new RateLimiter($cache);
- $this->assertEquals('foo', $rateLimiter->attempt('key', 1, function () {
- return 'foo';
- }, 1));
- }
- public function testAttemptsCallbackReturnsFalse()
- {
- $cache = m::mock(Cache::class);
- $cache->shouldReceive('get')->once()->with('key', 0)->andReturn(2);
- $cache->shouldReceive('has')->once()->with('key:timer')->andReturn(true);
- $executed = false;
- $rateLimiter = new RateLimiter($cache);
- $this->assertFalse($rateLimiter->attempt('key', 1, function () use (&$executed) {
- $executed = true;
- }, 1));
- $this->assertFalse($executed);
- }
- public function testKeysAreSanitizedFromUnicodeCharacters()
- {
- $cache = m::mock(Cache::class);
- $cache->shouldReceive('get')->once()->with('john', 0)->andReturn(1);
- $cache->shouldReceive('has')->once()->with('john:timer')->andReturn(true);
- $cache->shouldReceive('add')->never();
- $rateLimiter = new RateLimiter($cache);
- $this->assertTrue($rateLimiter->tooManyAttempts('jôhn', 1));
- }
- }
|