CacheRateLimiterTest.php 4.9 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139
  1. <?php
  2. namespace Illuminate\Tests\Cache;
  3. use Illuminate\Cache\RateLimiter;
  4. use Illuminate\Contracts\Cache\Repository as Cache;
  5. use Mockery as m;
  6. use PHPUnit\Framework\TestCase;
  7. class CacheRateLimiterTest extends TestCase
  8. {
  9. protected function tearDown(): void
  10. {
  11. m::close();
  12. }
  13. public function testTooManyAttemptsReturnTrueIfAlreadyLockedOut()
  14. {
  15. $cache = m::mock(Cache::class);
  16. $cache->shouldReceive('get')->once()->with('key', 0)->andReturn(1);
  17. $cache->shouldReceive('has')->once()->with('key:timer')->andReturn(true);
  18. $cache->shouldReceive('add')->never();
  19. $rateLimiter = new RateLimiter($cache);
  20. $this->assertTrue($rateLimiter->tooManyAttempts('key', 1));
  21. }
  22. public function testHitProperlyIncrementsAttemptCount()
  23. {
  24. $cache = m::mock(Cache::class);
  25. $cache->shouldReceive('add')->once()->with('key:timer', m::type('int'), 1)->andReturn(true);
  26. $cache->shouldReceive('add')->once()->with('key', 0, 1)->andReturn(true);
  27. $cache->shouldReceive('increment')->once()->with('key')->andReturn(1);
  28. $rateLimiter = new RateLimiter($cache);
  29. $rateLimiter->hit('key', 1);
  30. }
  31. public function testHitHasNoMemoryLeak()
  32. {
  33. $cache = m::mock(Cache::class);
  34. $cache->shouldReceive('add')->once()->with('key:timer', m::type('int'), 1)->andReturn(true);
  35. $cache->shouldReceive('add')->once()->with('key', 0, 1)->andReturn(false);
  36. $cache->shouldReceive('increment')->once()->with('key')->andReturn(1);
  37. $cache->shouldReceive('put')->once()->with('key', 1, 1);
  38. $rateLimiter = new RateLimiter($cache);
  39. $rateLimiter->hit('key', 1);
  40. }
  41. public function testRetriesLeftReturnsCorrectCount()
  42. {
  43. $cache = m::mock(Cache::class);
  44. $cache->shouldReceive('get')->once()->with('key', 0)->andReturn(3);
  45. $rateLimiter = new RateLimiter($cache);
  46. $this->assertEquals(2, $rateLimiter->retriesLeft('key', 5));
  47. }
  48. public function testClearClearsTheCacheKeys()
  49. {
  50. $cache = m::mock(Cache::class);
  51. $cache->shouldReceive('forget')->once()->with('key');
  52. $cache->shouldReceive('forget')->once()->with('key:timer');
  53. $rateLimiter = new RateLimiter($cache);
  54. $rateLimiter->clear('key');
  55. }
  56. public function testAvailableInReturnsPositiveValues()
  57. {
  58. $cache = m::mock(Cache::class);
  59. $cache->shouldReceive('get')->andReturn(now()->subSeconds(60)->getTimestamp(), null);
  60. $rateLimiter = new RateLimiter($cache);
  61. $this->assertTrue($rateLimiter->availableIn('key:timer') >= 0);
  62. $this->assertTrue($rateLimiter->availableIn('key:timer') >= 0);
  63. }
  64. public function testAttemptsCallbackReturnsTrue()
  65. {
  66. $cache = m::mock(Cache::class);
  67. $cache->shouldReceive('get')->once()->with('key', 0)->andReturn(0);
  68. $cache->shouldReceive('add')->once()->with('key:timer', m::type('int'), 1);
  69. $cache->shouldReceive('add')->once()->with('key', 0, 1)->andReturns(1);
  70. $cache->shouldReceive('increment')->once()->with('key')->andReturn(1);
  71. $executed = false;
  72. $rateLimiter = new RateLimiter($cache);
  73. $this->assertTrue($rateLimiter->attempt('key', 1, function () use (&$executed) {
  74. $executed = true;
  75. }, 1));
  76. $this->assertTrue($executed);
  77. }
  78. public function testAttemptsCallbackReturnsCallbackReturn()
  79. {
  80. $cache = m::mock(Cache::class);
  81. $cache->shouldReceive('get')->once()->with('key', 0)->andReturn(0);
  82. $cache->shouldReceive('add')->once()->with('key:timer', m::type('int'), 1);
  83. $cache->shouldReceive('add')->once()->with('key', 0, 1)->andReturns(1);
  84. $cache->shouldReceive('increment')->once()->with('key')->andReturn(1);
  85. $rateLimiter = new RateLimiter($cache);
  86. $this->assertEquals('foo', $rateLimiter->attempt('key', 1, function () {
  87. return 'foo';
  88. }, 1));
  89. }
  90. public function testAttemptsCallbackReturnsFalse()
  91. {
  92. $cache = m::mock(Cache::class);
  93. $cache->shouldReceive('get')->once()->with('key', 0)->andReturn(2);
  94. $cache->shouldReceive('has')->once()->with('key:timer')->andReturn(true);
  95. $executed = false;
  96. $rateLimiter = new RateLimiter($cache);
  97. $this->assertFalse($rateLimiter->attempt('key', 1, function () use (&$executed) {
  98. $executed = true;
  99. }, 1));
  100. $this->assertFalse($executed);
  101. }
  102. public function testKeysAreSanitizedFromUnicodeCharacters()
  103. {
  104. $cache = m::mock(Cache::class);
  105. $cache->shouldReceive('get')->once()->with('john', 0)->andReturn(1);
  106. $cache->shouldReceive('has')->once()->with('john:timer')->andReturn(true);
  107. $cache->shouldReceive('add')->never();
  108. $rateLimiter = new RateLimiter($cache);
  109. $this->assertTrue($rateLimiter->tooManyAttempts('jôhn', 1));
  110. }
  111. }