Unlock 30% off on Manual Testing Annual Plans this Holiday Season.

Copied to Clipboard!

How to use shunt method of generator class

Best Atoum code snippet using generator.shunt

FileAdapter.php

Source:FileAdapter.php

...38        });39    }40    public function testFileAdapterDeleteQueue()41    {42        $this->mockGenerator->shuntParentClassCalls();43        $mockFs = new \mock\Symfony\Component\Filesystem\Filesystem;44        $this->mockGenerator->unshuntParentClassCalls();45        $mockFinder = new \mock\Symfony\Component\Finder\Finder;46        $this->mockGenerator->orphanize('__construct');47        $mockLockHandlerFactory = new \mock\Symfony\Component\Lock\Factory;48        $this->calling($mockFs)->exists = true;49        $this->calling($mockLockHandlerFactory)->createLock = function ($repository) {50            $mockLockHandler = new \mock\Symfony\Component\Lock\LockInterface;51            $mockLockHandler->getMockController()->acquire = true;52            return $mockLockHandler;53        };54        $fileAdapter = new \ReputationVIP\QueueClient\Adapter\FileAdapter('/tmp/test/', null, $mockFs, $mockFinder, $mockLockHandlerFactory);55        $this->given($fileAdapter)56            ->class($fileAdapter->deleteQueue('testQueue'))->hasInterface('\ReputationVIP\QueueClient\Adapter\AdapterInterface');57    }58    public function testFileAdapterDeleteQueueWithEmptyQueueName()59    {60        $this->mockGenerator->shuntParentClassCalls();61        $mockFs = new \mock\Symfony\Component\Filesystem\Filesystem;62        $this->mockGenerator->unshuntParentClassCalls();63        $mockFinder = new \mock\Symfony\Component\Finder\Finder;64        $this->mockGenerator->orphanize('__construct');65        $mockLockHandlerFactory = new \mock\Symfony\Component\Lock\Factory;66        $this->calling($mockFs)->exists = true;67        $fileAdapter = new \ReputationVIP\QueueClient\Adapter\FileAdapter('/tmp/test/', null, $mockFs, $mockFinder, $mockLockHandlerFactory);68        $this->exception(function () use ($fileAdapter) {69            $fileAdapter->deleteQueue('');70        });71    }72    public function testFileAdapterDeleteQueueWithNoQueueFile()73    {74        $this->mockGenerator->shuntParentClassCalls();75        $mockFs = new \mock\Symfony\Component\Filesystem\Filesystem;76        $this->mockGenerator->unshuntParentClassCalls();77        $mockFinder = new \mock\Symfony\Component\Finder\Finder;78        $this->mockGenerator->orphanize('__construct');79        $mockLockHandlerFactory = new \mock\Symfony\Component\Lock\Factory;80        $this->calling($mockFs)->exists = false;81        $this->calling($mockLockHandlerFactory)->createLock = function ($repository) {82            $mockLockHandler = new \mock\Symfony\Component\Lock\LockInterface;83            $mockLockHandler->getMockController()->acquire = true;84            return $mockLockHandler;85        };86        $fileAdapter = new \ReputationVIP\QueueClient\Adapter\FileAdapter('/tmp/test/', null, $mockFs, $mockFinder, $mockLockHandlerFactory);87        $this->exception(function () use ($fileAdapter) {88            $fileAdapter->deleteQueue('testQueue');89        });90    }91    public function testFileAdapterDeleteQueueWithLockFailed()92    {93        $this->mockGenerator->shuntParentClassCalls();94        $mockFs = new \mock\Symfony\Component\Filesystem\Filesystem;95        $this->mockGenerator->unshuntParentClassCalls();96        $mockFinder = new \mock\Symfony\Component\Finder\Finder;97        $this->mockGenerator->orphanize('__construct');98        $mockLockHandlerFactory = new \mock\Symfony\Component\Lock\Factory;99        $this->calling($mockFs)->exists = true;100        $this->calling($mockLockHandlerFactory)->createLock = function ($repository) {101            $mockLockHandler = new \mock\Symfony\Component\Lock\LockInterface;102            $mockLockHandler->getMockController()->acquire = false;103            return $mockLockHandler;104        };105        $fileAdapter = new \ReputationVIP\QueueClient\Adapter\FileAdapter('/tmp/test/', null, $mockFs, $mockFinder, $mockLockHandlerFactory);106        $this->exception(function () use ($fileAdapter) {107            $fileAdapter->deleteQueue('testQueue');108        });109    }110    public function testFileAdapterCreateQueue()111    {112        $this->mockGenerator->shuntParentClassCalls();113        $mockFs = new \mock\Symfony\Component\Filesystem\Filesystem;114        $this->mockGenerator->unshuntParentClassCalls();115        $mockFinder = new \mock\Symfony\Component\Finder\Finder;116        $this->mockGenerator->orphanize('__construct');117        $mockLockHandlerFactory = new \mock\Symfony\Component\Lock\Factory;118        $mockLockHandlerFactory->getMockController()->createLock = function ($repository) {119            $mockLockHandler = new \mock\Symfony\Component\Lock\LockInterface;120            $mockLockHandler->getMockController()->acquire = true;121            return $mockLockHandler;122        };123        $fileAdapter = new \ReputationVIP\QueueClient\Adapter\FileAdapter('/tmp/test/', null, $mockFs, $mockFinder, $mockLockHandlerFactory);124        $mockFs->getMockController()->exists = false;125        $this->given($fileAdapter)126            ->class($fileAdapter->createQueue('testQueue'))->hasInterface('\ReputationVIP\QueueClient\Adapter\AdapterInterface');127    }128    public function testFileAdapterCreateQueueWithFsException()129    {130        $this->mockGenerator->shuntParentClassCalls();131        $mockFs = new \mock\Symfony\Component\Filesystem\Filesystem;132        $this->mockGenerator->unshuntParentClassCalls();133        $mockFinder = new \mock\Symfony\Component\Finder\Finder;134        $this->mockGenerator->orphanize('__construct');135        $mockLockHandlerFactory = new \mock\Symfony\Component\Lock\Factory;136        $mockLockHandlerFactory->getMockController()->createLock = function ($repository) {137            $mockLockHandler = new \mock\Symfony\Component\Lock\LockInterface;138            $mockLockHandler->getMockController()->acquire = true;139            return $mockLockHandler;140        };141        $mockFs->getMockController()->exists = false;142        $mockFs->getMockController()->dumpFile = function ($repository) {143            throw new \Exception('test exception');144        };145        $fileAdapter = new \ReputationVIP\QueueClient\Adapter\FileAdapter('/tmp/test/', null, $mockFs, $mockFinder, $mockLockHandlerFactory);146        $this->exception(function () use ($fileAdapter) {147            $fileAdapter->createQueue('testQueue');148        });149    }150    public function testFileAdapterCreateQueueWithLockFailed()151    {152        $this->mockGenerator->shuntParentClassCalls();153        $mockFs = new \mock\Symfony\Component\Filesystem\Filesystem;154        $this->mockGenerator->unshuntParentClassCalls();155        $mockFinder = new \mock\Symfony\Component\Finder\Finder;156        $this->mockGenerator->orphanize('__construct');157        $mockLockHandlerFactory = new \mock\Symfony\Component\Lock\Factory;158        $mockLockHandlerFactory->getMockController()->createLock = function ($repository) {159            $mockLockHandler = new \mock\Symfony\Component\Lock\LockInterface;160            $mockLockHandler->getMockController()->acquire = false;161            return $mockLockHandler;162        };163        $fileAdapter = new \ReputationVIP\QueueClient\Adapter\FileAdapter('/tmp/test/', null, $mockFs, $mockFinder, $mockLockHandlerFactory);164        $mockFs->getMockController()->exists = false;165        $this->exception(function () use ($fileAdapter) {166            $fileAdapter->createQueue('testQueue');167        });168    }169    public function testFileAdapterCreateQueueWithEmptyQueueName()170    {171        $this->mockGenerator->shuntParentClassCalls();172        $mockFs = new \mock\Symfony\Component\Filesystem\Filesystem;173        $this->mockGenerator->unshuntParentClassCalls();174        $mockFinder = new \mock\Symfony\Component\Finder\Finder;175        $this->mockGenerator->orphanize('__construct');176        $mockLockHandlerFactory = new \mock\Symfony\Component\Lock\Factory;177        $this->calling($mockFs)->exists = true;178        $fileAdapter = new \ReputationVIP\QueueClient\Adapter\FileAdapter('/tmp/test/', null, $mockFs, $mockFinder, $mockLockHandlerFactory);179        $this->exception(function () use ($fileAdapter) {180            $fileAdapter->createQueue('');181        });182    }183    public function testFileAdapterCreateQueueWithExistingQueue()184    {185        $this->mockGenerator->shuntParentClassCalls();186        $mockFs = new \mock\Symfony\Component\Filesystem\Filesystem;187        $this->mockGenerator->unshuntParentClassCalls();188        $mockFinder = new \mock\Symfony\Component\Finder\Finder;189        $this->mockGenerator->orphanize('__construct');190        $mockLockHandlerFactory = new \mock\Symfony\Component\Lock\Factory;191        $mockFs->getMockController()->exists = true;192        $fileAdapter = new \ReputationVIP\QueueClient\Adapter\FileAdapter('/tmp/test/', null, $mockFs, $mockFinder, $mockLockHandlerFactory);193        $this->exception(function () use ($fileAdapter) {194            $fileAdapter->createQueue('testQueue');195        });196    }197    public function testFileAdapterCreateQueueWithSpaceIngQueueName()198    {199        $this->mockGenerator->shuntParentClassCalls();200        $mockFs = new \mock\Symfony\Component\Filesystem\Filesystem;201        $this->mockGenerator->unshuntParentClassCalls();202        $mockFinder = new \mock\Symfony\Component\Finder\Finder;203        $this->mockGenerator->orphanize('__construct');204        $mockLockHandlerFactory = new \mock\Symfony\Component\Lock\Factory;205        $mockFs->getMockController()->exists = false;206        $fileAdapter = new \ReputationVIP\QueueClient\Adapter\FileAdapter('/tmp/test/', null, $mockFs, $mockFinder, $mockLockHandlerFactory);207        $this->exception(function () use ($fileAdapter) {208            $fileAdapter->createQueue('test Queue');209        });210    }211    public function testFileAdapterPurgeQueue()212    {213        $this->mockGenerator->shuntParentClassCalls();214        $mockFs = new \mock\Symfony\Component\Filesystem\Filesystem;215        $this->mockGenerator->unshuntParentClassCalls();216        $mockFinder = new \mock\Symfony\Component\Finder\Finder;217        $this->mockGenerator->orphanize('__construct');218        $mockLockHandlerFactory = new \mock\Symfony\Component\Lock\Factory;219        $priorityHandler = new ThreeLevelPriorityHandler();220        $mockFs->getMockController()->exists = true;221        $mockLockHandlerFactory->getMockController()->createLock = function ($repository) {222            $mockLockHandler = new \mock\Symfony\Component\Lock\LockInterface;223            $mockLockHandler->getMockController()->acquire = true;224            return $mockLockHandler;225        };226        $mockFinder->getMockController()->getIterator = function () use ($priorityHandler) {227            $files = [];228            $priorities = $priorityHandler->getAll();229            foreach ($priorities as $priority) {230                $files[] = 'testQueue' . \ReputationVIP\QueueClient\Adapter\FileAdapter::PRIORITY_SEPARATOR . $priority->getName() . '.' . \ReputationVIP\QueueClient\Adapter\FileAdapter::QUEUE_FILE_EXTENSION;231            }232            $mocksSplFileInfo = [];233            foreach ($files as $file) {234                $mockSplFileInfo = new \mock\Symfony\Component\Finder\SplFileInfo('', '', '');235                $mockSplFileInfo->getMockController()->getExtension = function () {236                    return \ReputationVIP\QueueClient\Adapter\FileAdapter::QUEUE_FILE_EXTENSION;237                };238                $mockSplFileInfo->getMockController()->getRelativePathname = function () use ($file) {239                    return $file;240                };241                $mockSplFileInfo->getMockController()->getPathname = function () use ($file) {242                    return '/tmp/test/' . $file;243                };244                $mockSplFileInfo->getMockController()->getContents = function () use ($file) {245                    return '{"queue":[]}';246                };247                $mocksSplFileInfo[] = $mockSplFileInfo;248            }249            return new ArrayIterator($mocksSplFileInfo);250        };251        $fileAdapter = new \ReputationVIP\QueueClient\Adapter\FileAdapter('/tmp/test/', $priorityHandler, $mockFs, $mockFinder, $mockLockHandlerFactory);252        $this->given($fileAdapter)253            ->class($fileAdapter->purgeQueue('testQueue'))->hasInterface('\ReputationVIP\QueueClient\Adapter\AdapterInterface');254    }255    public function testFileAdapterPurgeQueueWithNoQueueFile()256    {257        $this->mockGenerator->shuntParentClassCalls();258        $mockFs = new \mock\Symfony\Component\Filesystem\Filesystem;259        $this->mockGenerator->unshuntParentClassCalls();260        $mockFinder = new \mock\Symfony\Component\Finder\Finder;261        $this->mockGenerator->orphanize('__construct');262        $mockLockHandlerFactory = new \mock\Symfony\Component\Lock\Factory;263        $mockFs->getMockController()->exists = false;264        $FileAdapter = new \ReputationVIP\QueueClient\Adapter\FileAdapter('/tmp/test/', null, $mockFs, $mockFinder, $mockLockHandlerFactory);265        $this->exception(function () use ($FileAdapter) {266            $FileAdapter->purgeQueue('testQueue');267        });268    }269    public function testFileAdapterPurgeQueueWithEmptyQueueName()270    {271        $this->mockGenerator->shuntParentClassCalls();272        $mockFs = new \mock\Symfony\Component\Filesystem\Filesystem;273        $this->mockGenerator->unshuntParentClassCalls();274        $mockFinder = new \mock\Symfony\Component\Finder\Finder;275        $this->mockGenerator->orphanize('__construct');276        $mockLockHandlerFactory = new \mock\Symfony\Component\Lock\Factory;277        $fileAdapter = new \ReputationVIP\QueueClient\Adapter\FileAdapter('/tmp/test/', null, $mockFs, $mockFinder, $mockLockHandlerFactory);278        $this->exception(function () use ($fileAdapter) {279            $fileAdapter->purgeQueue('');280        });281    }282    public function testFileAdapterPurgeQueueWithLockFailed()283    {284        $this->mockGenerator->shuntParentClassCalls();285        $mockFs = new \mock\Symfony\Component\Filesystem\Filesystem;286        $this->mockGenerator->unshuntParentClassCalls();287        $mockFinder = new \mock\Symfony\Component\Finder\Finder;288        $this->mockGenerator->orphanize('__construct');289        $mockLockHandlerFactory = new \mock\Symfony\Component\Lock\Factory;290        $mockFs->getMockController()->exists = true;291        $mockLockHandlerFactory->getMockController()->createLock = function ($repository) {292            $mockLockHandler = new \mock\Symfony\Component\Lock\LockInterface;293            $mockLockHandler->getMockController()->acquire = false;294            return $mockLockHandler;295        };296        $fileAdapter = new \ReputationVIP\QueueClient\Adapter\FileAdapter('/tmp/test/', null, $mockFs, $mockFinder, $mockLockHandlerFactory);297        $this->exception(function () use ($fileAdapter) {298            $fileAdapter->purgeQueue('testQueue');299        });300    }301    public function testFileAdapterPurgeQueueWithEmptyQueueContent()302    {303        $this->mockGenerator->shuntParentClassCalls();304        $mockFs = new \mock\Symfony\Component\Filesystem\Filesystem;305        $this->mockGenerator->unshuntParentClassCalls();306        $mockFinder = new \mock\Symfony\Component\Finder\Finder;307        $this->mockGenerator->orphanize('__construct');308        $mockLockHandlerFactory = new \mock\Symfony\Component\Lock\Factory;309        $priorityHandler = new ThreeLevelPriorityHandler();310        $mockFs->getMockController()->exists = true;311        $mockLockHandlerFactory->getMockController()->createLock = function ($repository) {312            $mockLockHandler = new \mock\Symfony\Component\Lock\LockInterface;313            $mockLockHandler->getMockController()->acquire = true;314            return $mockLockHandler;315        };316        $mockFinder->getMockController()->getIterator = function () use ($priorityHandler) {317            $files = [];318            $priorities = $priorityHandler->getAll();319            foreach ($priorities as $priority) {320                $files[] = 'testQueue' . \ReputationVIP\QueueClient\Adapter\FileAdapter::PRIORITY_SEPARATOR . $priority->getName() . '.' . \ReputationVIP\QueueClient\Adapter\FileAdapter::QUEUE_FILE_EXTENSION;321            }322            $mocksSplFileInfo = [];323            foreach ($files as $file) {324                $mockSplFileInfo = new \mock\Symfony\Component\Finder\SplFileInfo('', '', '');325                $mockSplFileInfo->getMockController()->getExtension = function () {326                    return \ReputationVIP\QueueClient\Adapter\FileAdapter::QUEUE_FILE_EXTENSION;327                };328                $mockSplFileInfo->getMockController()->getRelativePathname = function () use ($file) {329                    return $file;330                };331                $mockSplFileInfo->getMockController()->getPathname = function () use ($file) {332                    return '/tmp/test/' . $file;333                };334                $mockSplFileInfo->getMockController()->getContents = function () use ($file) {335                    return '';336                };337                $mocksSplFileInfo[] = $mockSplFileInfo;338            }339            return new ArrayIterator($mocksSplFileInfo);340        };341        $fileAdapter = new \ReputationVIP\QueueClient\Adapter\FileAdapter('/tmp/test/', $priorityHandler, $mockFs, $mockFinder, $mockLockHandlerFactory);342        $this->exception(function () use ($fileAdapter) {343            $fileAdapter->purgeQueue('testQueue');344        });345    }346    public function testFileAdapterPurgeQueueWithBadQueueContent()347    {348        $this->mockGenerator->shuntParentClassCalls();349        $mockFs = new \mock\Symfony\Component\Filesystem\Filesystem;350        $this->mockGenerator->unshuntParentClassCalls();351        $mockFinder = new \mock\Symfony\Component\Finder\Finder;352        $this->mockGenerator->orphanize('__construct');353        $mockLockHandlerFactory = new \mock\Symfony\Component\Lock\Factory;354        $priorityHandler = new ThreeLevelPriorityHandler();355        $mockFs->getMockController()->exists = true;356        $mockLockHandlerFactory->getMockController()->createLock = function ($repository) {357            $mockLockHandler = new \mock\Symfony\Component\Lock\LockInterface;358            $mockLockHandler->getMockController()->acquire = true;359            return $mockLockHandler;360        };361        $mockFinder->getMockController()->getIterator = function () use ($priorityHandler) {362            $files = [];363            $priorities = $priorityHandler->getAll();364            foreach ($priorities as $priority) {365                $files[] = 'testQueue' . \ReputationVIP\QueueClient\Adapter\FileAdapter::PRIORITY_SEPARATOR . $priority->getName() . '.' . \ReputationVIP\QueueClient\Adapter\FileAdapter::QUEUE_FILE_EXTENSION;366            }367            $mocksSplFileInfo = [];368            foreach ($files as $file) {369                $mockSplFileInfo = new \mock\Symfony\Component\Finder\SplFileInfo('', '', '');370                $mockSplFileInfo->getMockController()->getExtension = function () {371                    return \ReputationVIP\QueueClient\Adapter\FileAdapter::QUEUE_FILE_EXTENSION;372                };373                $mockSplFileInfo->getMockController()->getRelativePathname = function () use ($file) {374                    return $file;375                };376                $mockSplFileInfo->getMockController()->getPathname = function () use ($file) {377                    return '/tmp/test/' . $file;378                };379                $mockSplFileInfo->getMockController()->getContents = function () use ($file) {380                    return '{"bad":[]}';381                };382                $mocksSplFileInfo[] = $mockSplFileInfo;383            }384            return new ArrayIterator($mocksSplFileInfo);385        };386        $fileAdapter = new \ReputationVIP\QueueClient\Adapter\FileAdapter('/tmp/test/', $priorityHandler, $mockFs, $mockFinder, $mockLockHandlerFactory);387        $this->exception(function () use ($fileAdapter) {388            $fileAdapter->purgeQueue('testQueue');389        });390    }391    public function testFileAdapterIsEmptyWithEmptyQueue()392    {393        $this->mockGenerator->shuntParentClassCalls();394        $mockFs = new \mock\Symfony\Component\Filesystem\Filesystem;395        $this->mockGenerator->unshuntParentClassCalls();396        $mockFinder = new \mock\Symfony\Component\Finder\Finder;397        $this->mockGenerator->orphanize('__construct');398        $mockLockHandlerFactory = new \mock\Symfony\Component\Lock\Factory;399        $priorityHandler = new ThreeLevelPriorityHandler();400        $mockFs->getMockController()->exists = true;401        $mockLockHandlerFactory->getMockController()->createLock = function ($repository) {402            $mockLockHandler = new \mock\Symfony\Component\Lock\LockInterface;403            $mockLockHandler->getMockController()->acquire = true;404            return $mockLockHandler;405        };406        $mockFinder->getMockController()->getIterator = function () use ($priorityHandler) {407            $files = [];408            $priorities = $priorityHandler->getAll();409            foreach ($priorities as $priority) {410                $files[] = 'testQueue' . \ReputationVIP\QueueClient\Adapter\FileAdapter::PRIORITY_SEPARATOR . $priority->getName() . '.' . \ReputationVIP\QueueClient\Adapter\FileAdapter::QUEUE_FILE_EXTENSION;411            }412            $mocksSplFileInfo = [];413            foreach ($files as $file) {414                $mockSplFileInfo = new \mock\Symfony\Component\Finder\SplFileInfo('', '', '');415                $mockSplFileInfo->getMockController()->getExtension = function () {416                    return \ReputationVIP\QueueClient\Adapter\FileAdapter::QUEUE_FILE_EXTENSION;417                };418                $mockSplFileInfo->getMockController()->getRelativePathname = function () use ($file) {419                    return $file;420                };421                $mockSplFileInfo->getMockController()->getPathname = function () use ($file) {422                    return '/tmp/test/' . $file;423                };424                $mockSplFileInfo->getMockController()->getContents = function () use ($file) {425                    return '{"queue":[]}';426                };427                $mocksSplFileInfo[] = $mockSplFileInfo;428            }429            return new ArrayIterator($mocksSplFileInfo);430        };431        $fileAdapter = new \ReputationVIP\QueueClient\Adapter\FileAdapter('/tmp/test/', $priorityHandler, $mockFs, $mockFinder, $mockLockHandlerFactory);432        $this433            ->given($fileAdapter)434            ->boolean($fileAdapter->isEmpty('testQueue'))435            ->isTrue();436    }437    public function testFileAdapterIsEmptyWithNoEmptyQueue()438    {439        $this->mockGenerator->shuntParentClassCalls();440        $mockFs = new \mock\Symfony\Component\Filesystem\Filesystem;441        $this->mockGenerator->unshuntParentClassCalls();442        $mockFinder = new \mock\Symfony\Component\Finder\Finder;443        $this->mockGenerator->orphanize('__construct');444        $mockLockHandlerFactory = new \mock\Symfony\Component\Lock\Factory;445        $priorityHandler = new ThreeLevelPriorityHandler();446        $mockFs->getMockController()->exists = true;447        $mockLockHandlerFactory->getMockController()->createLock = function ($repository) {448            $mockLockHandler = new \mock\Symfony\Component\Lock\LockInterface;449            $mockLockHandler->getMockController()->acquire = true;450            return $mockLockHandler;451        };452        $mockFinder->getMockController()->getIterator = function () use ($priorityHandler) {453            $files = [];454            $priorities = $priorityHandler->getAll();455            foreach ($priorities as $priority) {456                $files[] = 'testQueue' . \ReputationVIP\QueueClient\Adapter\FileAdapter::PRIORITY_SEPARATOR . $priority->getName() . '.' . \ReputationVIP\QueueClient\Adapter\FileAdapter::QUEUE_FILE_EXTENSION;457            }458            $mocksSplFileInfo = [];459            foreach ($files as $file) {460                $mockSplFileInfo = new \mock\Symfony\Component\Finder\SplFileInfo('', '', '');461                $mockSplFileInfo->getMockController()->getExtension = function () { return \ReputationVIP\QueueClient\Adapter\FileAdapter::QUEUE_FILE_EXTENSION; };462                $mockSplFileInfo->getMockController()->getRelativePathname = function () use($file) { return $file; };463                $mockSplFileInfo->getMockController()->getPathname = function () use($file) { return '/tmp/test/' . $file; };464                $mockSplFileInfo->getMockController()->getContents = function () use($file) { return '{"queue":[{"id":"testQueue-HIGH559f77704e87c5.40358915","time-in-flight":null, "delayed-until":null,"time-in-flight":null, "delayed-until":null,"Body":"s:12:\"Test message\";"}]}'; };465                $mocksSplFileInfo[] = $mockSplFileInfo;466            }467            return new ArrayIterator($mocksSplFileInfo);468        };469        $fileAdapter = new \ReputationVIP\QueueClient\Adapter\FileAdapter('/tmp/test/', $priorityHandler, $mockFs, $mockFinder, $mockLockHandlerFactory);470        $this471            ->given($fileAdapter)472            ->boolean($fileAdapter->isEmpty('testQueue'))473            ->isFalse();474    }475    public function testFileAdapterIsEmptyWithEmptyQueueName()476    {477        $this->mockGenerator->shuntParentClassCalls();478        $mockFs = new \mock\Symfony\Component\Filesystem\Filesystem;479        $this->mockGenerator->unshuntParentClassCalls();480        $mockFinder = new \mock\Symfony\Component\Finder\Finder;481        $this->mockGenerator->orphanize('__construct');482        $mockLockHandlerFactory = new \mock\Symfony\Component\Lock\Factory;483        $mockFs->getMockController()->exists = true;484        $fileAdapter = new \ReputationVIP\QueueClient\Adapter\FileAdapter('/tmp/test/', null, $mockFs, $mockFinder, $mockLockHandlerFactory);485        $this->exception(function () use ($fileAdapter) {486            $fileAdapter->isEmpty('');487        });488    }489    public function testFileAdapterIsEmptyWithNoQueueFile()490    {491        $this->mockGenerator->shuntParentClassCalls();492        $mockFs = new \mock\Symfony\Component\Filesystem\Filesystem;493        $this->mockGenerator->unshuntParentClassCalls();494        $mockFinder = new \mock\Symfony\Component\Finder\Finder;495        $this->mockGenerator->orphanize('__construct');496        $mockLockHandlerFactory = new \mock\Symfony\Component\Lock\Factory;497        $mockFs->getMockController()->exists = false;498        $fileAdapter = new \ReputationVIP\QueueClient\Adapter\FileAdapter('/tmp/test/', null, $mockFs, $mockFinder, $mockLockHandlerFactory);499        $this->exception(function () use ($fileAdapter) {500            $fileAdapter->isEmpty('testQueue');501        });502    }503    public function testFileAdapterIsEmptyWithEmptyQueueContent()504    {505        $this->mockGenerator->shuntParentClassCalls();506        $mockFs = new \mock\Symfony\Component\Filesystem\Filesystem;507        $this->mockGenerator->unshuntParentClassCalls();508        $mockFinder = new \mock\Symfony\Component\Finder\Finder;509        $this->mockGenerator->orphanize('__construct');510        $mockLockHandlerFactory = new \mock\Symfony\Component\Lock\Factory;511        $priorityHandler = new ThreeLevelPriorityHandler();512        $mockFs->getMockController()->exists = true;513        $mockLockHandlerFactory->getMockController()->createLock = function ($repository) {514            $mockLockHandler = new \mock\Symfony\Component\Lock\LockInterface;515            $mockLockHandler->getMockController()->acquire = true;516            return $mockLockHandler;517        };518        $mockFinder->getMockController()->getIterator = function () use ($priorityHandler) {519            $files = [];520            $priorities = $priorityHandler->getAll();521            foreach ($priorities as $priority) {522                $files[] = 'testQueue' . \ReputationVIP\QueueClient\Adapter\FileAdapter::PRIORITY_SEPARATOR . $priority->getName() . '.' . \ReputationVIP\QueueClient\Adapter\FileAdapter::QUEUE_FILE_EXTENSION;523            }524            $mocksSplFileInfo = [];525            foreach ($files as $file) {526                $mockSplFileInfo = new \mock\Symfony\Component\Finder\SplFileInfo('', '', '');527                $mockSplFileInfo->getMockController()->getExtension = function () {528                    return \ReputationVIP\QueueClient\Adapter\FileAdapter::QUEUE_FILE_EXTENSION;529                };530                $mockSplFileInfo->getMockController()->getRelativePathname = function () use ($file) {531                    return $file;532                };533                $mockSplFileInfo->getMockController()->getPathname = function () use ($file) {534                    return '/tmp/test/' . $file;535                };536                $mockSplFileInfo->getMockController()->getContents = function () use ($file) {537                    return '';538                };539                $mocksSplFileInfo[] = $mockSplFileInfo;540            }541            return new ArrayIterator($mocksSplFileInfo);542        };543        $fileAdapter = new \ReputationVIP\QueueClient\Adapter\FileAdapter('/tmp/test/', $priorityHandler, $mockFs, $mockFinder, $mockLockHandlerFactory);544        $this->exception(function () use ($fileAdapter) {545            $fileAdapter->isEmpty('testQueue');546        });547    }548    public function testFileAdapterIsEmptyWithBadQueueContent()549    {550        $this->mockGenerator->shuntParentClassCalls();551        $mockFs = new \mock\Symfony\Component\Filesystem\Filesystem;552        $this->mockGenerator->unshuntParentClassCalls();553        $mockFinder = new \mock\Symfony\Component\Finder\Finder;554        $this->mockGenerator->orphanize('__construct');555        $mockLockHandlerFactory = new \mock\Symfony\Component\Lock\Factory;556        $priorityHandler = new ThreeLevelPriorityHandler();557        $mockFs->getMockController()->exists = true;558        $mockLockHandlerFactory->getMockController()->createLock = function ($repository) {559            $mockLockHandler = new \mock\Symfony\Component\Lock\LockInterface;560            $mockLockHandler->getMockController()->acquire = true;561            return $mockLockHandler;562        };563        $mockFinder->getMockController()->getIterator = function () use ($priorityHandler) {564            $files = [];565            $priorities = $priorityHandler->getAll();566            foreach ($priorities as $priority) {567                $files[] = 'testQueue' . \ReputationVIP\QueueClient\Adapter\FileAdapter::PRIORITY_SEPARATOR . $priority->getName() . '.' . \ReputationVIP\QueueClient\Adapter\FileAdapter::QUEUE_FILE_EXTENSION;568            }569            $mocksSplFileInfo = [];570            foreach ($files as $file) {571                $mockSplFileInfo = new \mock\Symfony\Component\Finder\SplFileInfo('', '', '');572                $mockSplFileInfo->getMockController()->getExtension = function () {573                    return \ReputationVIP\QueueClient\Adapter\FileAdapter::QUEUE_FILE_EXTENSION;574                };575                $mockSplFileInfo->getMockController()->getRelativePathname = function () use ($file) {576                    return $file;577                };578                $mockSplFileInfo->getMockController()->getPathname = function () use ($file) {579                    return '/tmp/test/' . $file;580                };581                $mockSplFileInfo->getMockController()->getContents = function () use ($file) {582                    return '{"bad":[]}';583                };584                $mocksSplFileInfo[] = $mockSplFileInfo;585            }586            return new ArrayIterator($mocksSplFileInfo);587        };588        $fileAdapter = new \ReputationVIP\QueueClient\Adapter\FileAdapter('/tmp/test/', $priorityHandler, $mockFs, $mockFinder, $mockLockHandlerFactory);589        $this->exception(function () use ($fileAdapter) {590            $fileAdapter->isEmpty('testQueue');591        });592    }593    public function testFileAdapterListQueues()594    {595        $this->mockGenerator->shuntParentClassCalls();596        $mockFs = new \mock\Symfony\Component\Filesystem\Filesystem;597        $this->mockGenerator->unshuntParentClassCalls();598        $mockFinder = new \mock\Symfony\Component\Finder\Finder;599        $this->mockGenerator->orphanize('__construct');600        $mockLockHandlerFactory = new \mock\Symfony\Component\Lock\Factory;601        $priorityHandler = new ThreeLevelPriorityHandler();602        $mockFinder->getMockController()->getIterator = function () use ($priorityHandler) {603            $files = [];604            $priorities = $priorityHandler->getAll();605            foreach ($priorities as $priority) {606                $files[] = 'testOneQueue' . \ReputationVIP\QueueClient\Adapter\FileAdapter::PRIORITY_SEPARATOR . $priority->getName() . '.' . \ReputationVIP\QueueClient\Adapter\FileAdapter::QUEUE_FILE_EXTENSION;607                $files[] = 'prefixTestTwoQueue' . \ReputationVIP\QueueClient\Adapter\FileAdapter::PRIORITY_SEPARATOR . $priority->getName() . '.' . \ReputationVIP\QueueClient\Adapter\FileAdapter::QUEUE_FILE_EXTENSION;608                $files[] = 'testTwoQueue' . \ReputationVIP\QueueClient\Adapter\FileAdapter::PRIORITY_SEPARATOR . $priority->getName() . '.' . \ReputationVIP\QueueClient\Adapter\FileAdapter::QUEUE_FILE_EXTENSION;609                $files[] = 'testThreeQueue' . \ReputationVIP\QueueClient\Adapter\FileAdapter::PRIORITY_SEPARATOR . $priority->getName() . '.' . \ReputationVIP\QueueClient\Adapter\FileAdapter::QUEUE_FILE_EXTENSION;610            }611            $mocksSplFileInfo = [];612            foreach ($files as $file) {613                $mockSplFileInfo = new \mock\Symfony\Component\Finder\SplFileInfo('', '', '');614                $mockSplFileInfo->getMockController()->getExtension = function () {615                    return \ReputationVIP\QueueClient\Adapter\FileAdapter::QUEUE_FILE_EXTENSION;616                };617                $mockSplFileInfo->getMockController()->getRelativePathname = function () use ($file) {618                    return $file;619                };620                $mocksSplFileInfo[] = $mockSplFileInfo;621            }622            return new ArrayIterator($mocksSplFileInfo);623        };624        $fileAdapter = new \ReputationVIP\QueueClient\Adapter\FileAdapter('/tmp/test/', $priorityHandler, $mockFs, $mockFinder, $mockLockHandlerFactory);625        $this626            ->given($fileAdapter)627            ->array($fileAdapter->listQueues())628            ->containsValues(['testOneQueue', 'testTwoQueue', 'testThreeQueue']);629    }630    public function testFileAdapterListQueuesWithPrefix()631    {632        $this->mockGenerator->shuntParentClassCalls();633        $mockFs = new \mock\Symfony\Component\Filesystem\Filesystem;634        $this->mockGenerator->unshuntParentClassCalls();635        $mockFinder = new \mock\Symfony\Component\Finder\Finder;636        $this->mockGenerator->orphanize('__construct');637        $mockLockHandlerFactory = new \mock\Symfony\Component\Lock\Factory;638        $priorityHandler = new ThreeLevelPriorityHandler();639        $mockFinder->getMockController()->getIterator = function () use ($priorityHandler) {640            $files = [];641            $priorities = $priorityHandler->getAll();642            foreach ($priorities as $priority) {643                $files[] = 'testOneQueue' . \ReputationVIP\QueueClient\Adapter\FileAdapter::PRIORITY_SEPARATOR . $priority->getName() . '.' . \ReputationVIP\QueueClient\Adapter\FileAdapter::QUEUE_FILE_EXTENSION;644                $files[] = 'prefixTestTwoQueue' . \ReputationVIP\QueueClient\Adapter\FileAdapter::PRIORITY_SEPARATOR . $priority->getName() . '.' . \ReputationVIP\QueueClient\Adapter\FileAdapter::QUEUE_FILE_EXTENSION;645                $files[] = 'testTwoQueue' . \ReputationVIP\QueueClient\Adapter\FileAdapter::PRIORITY_SEPARATOR . $priority->getName() . '.' . \ReputationVIP\QueueClient\Adapter\FileAdapter::QUEUE_FILE_EXTENSION;646                $files[] = 'prefixTestOneQueue' . \ReputationVIP\QueueClient\Adapter\FileAdapter::PRIORITY_SEPARATOR . $priority->getName() . '.' . \ReputationVIP\QueueClient\Adapter\FileAdapter::QUEUE_FILE_EXTENSION;647            }648            $mocksSplFileInfo = [];649            foreach ($files as $file) {650                $mockSplFileInfo = new \mock\Symfony\Component\Finder\SplFileInfo('', '', '');651                $mockSplFileInfo->getMockController()->getExtension = function () {652                    return \ReputationVIP\QueueClient\Adapter\FileAdapter::QUEUE_FILE_EXTENSION;653                };654                $mockSplFileInfo->getMockController()->getRelativePathname = function () use ($file) {655                    return $file;656                };657                $mocksSplFileInfo[] = $mockSplFileInfo;658            }659            return new ArrayIterator($mocksSplFileInfo);660        };661        $fileAdapter = new \ReputationVIP\QueueClient\Adapter\FileAdapter('/tmp/test/', $priorityHandler, $mockFs, $mockFinder, $mockLockHandlerFactory);662        $this663            ->given($fileAdapter)664            ->array($fileAdapter->listQueues('prefix'))665            ->containsValues(['prefixTestOneQueue', 'prefixTestTwoQueue']);666    }667    public function testFileAdapterListQueuesWithEmptyQueue()668    {669        $this->mockGenerator->shuntParentClassCalls();670        $mockFs = new \mock\Symfony\Component\Filesystem\Filesystem;671        $this->mockGenerator->unshuntParentClassCalls();672        $mockFinder = new \mock\Symfony\Component\Finder\Finder;673        $this->mockGenerator->orphanize('__construct');674        $mockLockHandlerFactory = new \mock\Symfony\Component\Lock\Factory;675        $mockFinder->getMockController()->getIterator = function () {676            return new ArrayIterator([]);677        };678        $fileAdapter = new \ReputationVIP\QueueClient\Adapter\FileAdapter('/tmp/test/', null, $mockFs, $mockFinder, $mockLockHandlerFactory);679        $this680            ->given($fileAdapter)681            ->array($fileAdapter->listQueues())682            ->isEmpty();683    }684    public function testFileAdapterAddMessage()685    {686        $this->mockGenerator->shuntParentClassCalls();687        $mockFs = new \mock\Symfony\Component\Filesystem\Filesystem;688        $this->mockGenerator->unshuntParentClassCalls();689        $mockFinder = new \mock\Symfony\Component\Finder\Finder;690        $this->mockGenerator->orphanize('__construct');691        $mockLockHandlerFactory = new \mock\Symfony\Component\Lock\Factory;692        $priorityHandler = new ThreeLevelPriorityHandler();693        $mockFs->getMockController()->exists = true;694        $mockLockHandlerFactory->getMockController()->createLock = function ($repository) {695            $mockLockHandler = new \mock\Symfony\Component\Lock\LockInterface;696            $mockLockHandler->getMockController()->acquire = true;697            return $mockLockHandler;698        };699        $mockFinder->getMockController()->getIterator = function () use ($priorityHandler) {700            $files = [];701            $priorities = $priorityHandler->getAll();702            foreach ($priorities as $priority) {703                $files[] = 'testQueue' . \ReputationVIP\QueueClient\Adapter\FileAdapter::PRIORITY_SEPARATOR . $priority->getName() . '.' . \ReputationVIP\QueueClient\Adapter\FileAdapter::QUEUE_FILE_EXTENSION;704            }705            $mocksSplFileInfo = [];706            foreach ($files as $file) {707                $mockSplFileInfo = new \mock\Symfony\Component\Finder\SplFileInfo('', '', '');708                $mockSplFileInfo->getMockController()->getExtension = function () {709                    return \ReputationVIP\QueueClient\Adapter\FileAdapter::QUEUE_FILE_EXTENSION;710                };711                $mockSplFileInfo->getMockController()->getRelativePathname = function () use ($file) {712                    return $file;713                };714                $mockSplFileInfo->getMockController()->getPathname = function () use ($file) {715                    return '/tmp/test/' . $file;716                };717                $mockSplFileInfo->getMockController()->getContents = function () use ($file) {718                    return '{"queue":[]}';719                };720                $mocksSplFileInfo[] = $mockSplFileInfo;721            }722            return new ArrayIterator($mocksSplFileInfo);723        };724        $FileAdapter = new \ReputationVIP\QueueClient\Adapter\FileAdapter('/tmp/test/', $priorityHandler, $mockFs, $mockFinder, $mockLockHandlerFactory);725        $this->given($FileAdapter)726            ->class($FileAdapter->addMessage('testQueue', 'test Message one'))->hasInterface('\ReputationVIP\QueueClient\Adapter\AdapterInterface');727    }728    public function testFileAdapterAddMessageWithDelay()729    {730        $mockFs = new \mock\Symfony\Component\Filesystem\Filesystem;731        $mockFinder = new \mock\Symfony\Component\Finder\Finder;732        $this->mockGenerator->orphanize('__construct');733        $mockLockHandlerFactory = new \mock\Symfony\Component\Lock\Factory;734        $priorityHandler = new ThreeLevelPriorityHandler();735        $fileAdapter = new \ReputationVIP\QueueClient\Adapter\FileAdapter('/tmp/test/', $priorityHandler, $mockFs, $mockFinder, $mockLockHandlerFactory);736        $mockFs->getMockController()->exists = true;737        $mockLockHandlerFactory->getMockController()->createLock = function($repository) {738            $mockLockHandler = new \mock\Symfony\Component\Lock\LockInterface;739            $mockLockHandler->getMockController()->acquire = true;740            return $mockLockHandler;741        };742        $mockFinder->getMockController()->getIterator = function () use ($priorityHandler) {743            $files = [];744            $priorities = $priorityHandler->getAll();745            foreach ($priorities as $priority) {746                $files[] = 'testQueue'.\ReputationVIP\QueueClient\Adapter\FileAdapter::PRIORITY_SEPARATOR.$priority->getName().'.'.\ReputationVIP\QueueClient\Adapter\FileAdapter::QUEUE_FILE_EXTENSION;747            }748            $mocksSplFileInfo = [];749            foreach ($files as $file) {750                $mockSplFileInfo = new \mock\Symfony\Component\Finder\SplFileInfo('', '', '');751                $mockSplFileInfo->getMockController()->getExtension = function () { return \ReputationVIP\QueueClient\Adapter\FileAdapter::QUEUE_FILE_EXTENSION; };752                $mockSplFileInfo->getMockController()->getRelativePathname = function () use($file) { return $file; };753                $mockSplFileInfo->getMockController()->getPathname = function () use($file) { return '/tmp/test/' . $file; };754                $mockSplFileInfo->getMockController()->getContents = function () use($file) { return '{"queue":[]}'; };755                $mocksSplFileInfo[] = $mockSplFileInfo;756            }757            return new ArrayIterator($mocksSplFileInfo);758        };759        $fileAdapter = $fileAdapter->addMessage('testQueue', 'test Message one', null, 1);760        sleep(1);761        $this->given($fileAdapter)762            ->class($fileAdapter)->hasInterface('\ReputationVIP\QueueClient\Adapter\AdapterInterface');763    }764    public function testFileAdapterAddMessageWithEmptyQueueName()765    {766        $this->mockGenerator->shuntParentClassCalls();767        $mockFs = new \mock\Symfony\Component\Filesystem\Filesystem;768        $this->mockGenerator->unshuntParentClassCalls();769        $mockFinder = new \mock\Symfony\Component\Finder\Finder;770        $this->mockGenerator->orphanize('__construct');771        $mockLockHandlerFactory = new \mock\Symfony\Component\Lock\Factory;772        $fileAdapter = new \ReputationVIP\QueueClient\Adapter\FileAdapter('/tmp/test/', null, $mockFs, $mockFinder, $mockLockHandlerFactory);773        $this->exception(function () use ($fileAdapter) {774            $fileAdapter->addMessage('', '');775        });776    }777    public function testFileAdapterAddMessageWithNoQueueFile()778    {779        $this->mockGenerator->shuntParentClassCalls();780        $mockFs = new \mock\Symfony\Component\Filesystem\Filesystem;781        $this->mockGenerator->unshuntParentClassCalls();782        $mockFinder = new \mock\Symfony\Component\Finder\Finder;783        $this->mockGenerator->orphanize('__construct');784        $mockLockHandlerFactory = new \mock\Symfony\Component\Lock\Factory;785        $mockFs->getMockController()->exists = false;786        $fileAdapter = new \ReputationVIP\QueueClient\Adapter\FileAdapter('/tmp/test/', null, $mockFs, $mockFinder, $mockLockHandlerFactory);787        $this->exception(function () use ($fileAdapter) {788            $fileAdapter->addMessage('testQueue', 'test Message one');789        });790    }791    public function testFileAdapterAddMessageWithEmptyMessage()792    {793        $this->mockGenerator->shuntParentClassCalls();794        $mockFs = new \mock\Symfony\Component\Filesystem\Filesystem;795        $this->mockGenerator->unshuntParentClassCalls();796        $mockFinder = new \mock\Symfony\Component\Finder\Finder;797        $this->mockGenerator->orphanize('__construct');798        $mockLockHandlerFactory = new \mock\Symfony\Component\Lock\Factory;799        $mockFs->getMockController()->exists = true;800        $mockLockHandlerFactory->getMockController()->createLock = function ($repository) {801            $mockLockHandler = new \mock\Symfony\Component\Lock\LockInterface;802            $mockLockHandler->getMockController()->acquire = true;803            return $mockLockHandler;804        };805        $fileAdapter = new \ReputationVIP\QueueClient\Adapter\FileAdapter('/tmp/test/', null, $mockFs, $mockFinder, $mockLockHandlerFactory);806        $this->exception(function () use ($fileAdapter) {807            $fileAdapter->addMessage('testQueue', '');808        });809    }810    public function testFileAdapterAddMessageLockFailed()811    {812        $this->mockGenerator->shuntParentClassCalls();813        $mockFs = new \mock\Symfony\Component\Filesystem\Filesystem;814        $this->mockGenerator->unshuntParentClassCalls();815        $mockFinder = new \mock\Symfony\Component\Finder\Finder;816        $this->mockGenerator->orphanize('__construct');817        $mockLockHandlerFactory = new \mock\Symfony\Component\Lock\Factory;818        $mockFs->getMockController()->exists = true;819        $mockLockHandlerFactory->getMockController()->createLock = function ($repository) {820            $mockLockHandler = new \mock\Symfony\Component\Lock\LockInterface;821            $mockLockHandler->getMockController()->acquire = false;822            return $mockLockHandler;823        };824        $fileAdapter = new \ReputationVIP\QueueClient\Adapter\FileAdapter('/tmp/test/', null, $mockFs, $mockFinder, $mockLockHandlerFactory);825        $this->exception(function () use ($fileAdapter) {826            $fileAdapter->addMessage('testQueue', 'test message');827        });828    }829    public function testFileAdapterAddMessageWithEmptyQueueContent()830    {831        $this->mockGenerator->shuntParentClassCalls();832        $mockFs = new \mock\Symfony\Component\Filesystem\Filesystem;833        $this->mockGenerator->unshuntParentClassCalls();834        $mockFinder = new \mock\Symfony\Component\Finder\Finder;835        $this->mockGenerator->orphanize('__construct');836        $mockLockHandlerFactory = new \mock\Symfony\Component\Lock\Factory;837        $priorityHandler = new ThreeLevelPriorityHandler();838        $mockFs->getMockController()->exists = true;839        $mockLockHandlerFactory->getMockController()->createLock = function ($repository) {840            $mockLockHandler = new \mock\Symfony\Component\Lock\LockInterface;841            $mockLockHandler->getMockController()->acquire = true;842            return $mockLockHandler;843        };844        $mockFinder->getMockController()->getIterator = function () use ($priorityHandler) {845            $files = [];846            $priorities = $priorityHandler->getAll();847            foreach ($priorities as $priority) {848                $files[] = 'testQueue' . \ReputationVIP\QueueClient\Adapter\FileAdapter::PRIORITY_SEPARATOR . $priority->getName() . '.' . \ReputationVIP\QueueClient\Adapter\FileAdapter::QUEUE_FILE_EXTENSION;849            }850            $mocksSplFileInfo = [];851            foreach ($files as $file) {852                $mockSplFileInfo = new \mock\Symfony\Component\Finder\SplFileInfo('', '', '');853                $mockSplFileInfo->getMockController()->getExtension = function () {854                    return \ReputationVIP\QueueClient\Adapter\FileAdapter::QUEUE_FILE_EXTENSION;855                };856                $mockSplFileInfo->getMockController()->getRelativePathname = function () use ($file) {857                    return $file;858                };859                $mockSplFileInfo->getMockController()->getPathname = function () use ($file) {860                    return '/tmp/test/' . $file;861                };862                $mockSplFileInfo->getMockController()->getContents = function () use ($file) {863                    return '';864                };865                $mocksSplFileInfo[] = $mockSplFileInfo;866            }867            return new ArrayIterator($mocksSplFileInfo);868        };869        $fileAdapter = new \ReputationVIP\QueueClient\Adapter\FileAdapter('/tmp/test/', $priorityHandler, $mockFs, $mockFinder, $mockLockHandlerFactory);870        $this->exception(function () use ($fileAdapter) {871            $fileAdapter->addMessage('testQueue', 'test message');872        });873    }874    public function testFileAdapterAddMessageWithBadQueueContent()875    {876        $this->mockGenerator->shuntParentClassCalls();877        $mockFs = new \mock\Symfony\Component\Filesystem\Filesystem;878        $this->mockGenerator->unshuntParentClassCalls();879        $mockFinder = new \mock\Symfony\Component\Finder\Finder;880        $this->mockGenerator->orphanize('__construct');881        $mockLockHandlerFactory = new \mock\Symfony\Component\Lock\Factory;882        $priorityHandler = new ThreeLevelPriorityHandler();883        $mockFs->getMockController()->exists = true;884        $mockLockHandlerFactory->getMockController()->createLock = function ($repository) {885            $mockLockHandler = new \mock\Symfony\Component\Lock\LockInterface;886            $mockLockHandler->getMockController()->acquire = true;887            return $mockLockHandler;888        };889        $mockFinder->getMockController()->getIterator = function () use ($priorityHandler) {890            $files = [];891            $priorities = $priorityHandler->getAll();892            foreach ($priorities as $priority) {893                $files[] = 'testQueue' . \ReputationVIP\QueueClient\Adapter\FileAdapter::PRIORITY_SEPARATOR . $priority->getName() . '.' . \ReputationVIP\QueueClient\Adapter\FileAdapter::QUEUE_FILE_EXTENSION;894            }895            $mocksSplFileInfo = [];896            foreach ($files as $file) {897                $mockSplFileInfo = new \mock\Symfony\Component\Finder\SplFileInfo('', '', '');898                $mockSplFileInfo->getMockController()->getExtension = function () {899                    return \ReputationVIP\QueueClient\Adapter\FileAdapter::QUEUE_FILE_EXTENSION;900                };901                $mockSplFileInfo->getMockController()->getRelativePathname = function () use ($file) {902                    return $file;903                };904                $mockSplFileInfo->getMockController()->getPathname = function () use ($file) {905                    return '/tmp/test/' . $file;906                };907                $mockSplFileInfo->getMockController()->getContents = function () use ($file) {908                    return '{"bad":[]}';909                };910                $mocksSplFileInfo[] = $mockSplFileInfo;911            }912            return new ArrayIterator($mocksSplFileInfo);913        };914        $fileAdapter = new \ReputationVIP\QueueClient\Adapter\FileAdapter('/tmp/test/', $priorityHandler, $mockFs, $mockFinder, $mockLockHandlerFactory);915        $this->exception(function () use ($fileAdapter) {916            $fileAdapter->addMessage('testQueue', 'test message');917        });918    }919    public function testFileAdapterGetNumberMessagesWithEmptyQueueName()920    {921        $this->mockGenerator->shuntParentClassCalls();922        $mockFs = new \mock\Symfony\Component\Filesystem\Filesystem;923        $this->mockGenerator->unshuntParentClassCalls();924        $mockFinder = new \mock\Symfony\Component\Finder\Finder;925        $this->mockGenerator->orphanize('__construct');926        $mockLockHandlerFactory = new \mock\Symfony\Component\Lock\Factory;927        $fileAdapter = new \ReputationVIP\QueueClient\Adapter\FileAdapter('/tmp/test/', null, $mockFs, $mockFinder, $mockLockHandlerFactory);928        $this->exception(function () use ($fileAdapter) {929            $fileAdapter->getNumberMessages('');930        });931    }932    public function testFileAdapterGetNumberMessagesWithNoQueueFile()933    {934        $this->mockGenerator->shuntParentClassCalls();935        $mockFs = new \mock\Symfony\Component\Filesystem\Filesystem;936        $this->mockGenerator->unshuntParentClassCalls();937        $mockFinder = new \mock\Symfony\Component\Finder\Finder;938        $this->mockGenerator->orphanize('__construct');939        $mockLockHandlerFactory = new \mock\Symfony\Component\Lock\Factory;940        $mockFs->getMockController()->exists = false;941        $fileAdapter = new \ReputationVIP\QueueClient\Adapter\FileAdapter('/tmp/test/', null, $mockFs, $mockFinder, $mockLockHandlerFactory);942        $this->exception(function () use ($fileAdapter) {943            $fileAdapter->getNumberMessages('testQueue');944        });945    }946    public function testFileAdapterGetNumberMessagesLockFailed()947    {948        $this->mockGenerator->shuntParentClassCalls();949        $mockFs = new \mock\Symfony\Component\Filesystem\Filesystem;950        $this->mockGenerator->unshuntParentClassCalls();951        $mockFinder = new \mock\Symfony\Component\Finder\Finder;952        $this->mockGenerator->orphanize('__construct');953        $mockLockHandlerFactory = new \mock\Symfony\Component\Lock\Factory;954        $mockFs->getMockController()->exists = true;955        $mockLockHandlerFactory->getMockController()->createLock = function ($repository) {956            $mockLockHandler = new \mock\Symfony\Component\Lock\LockInterface;957            $mockLockHandler->getMockController()->acquire = false;958            return $mockLockHandler;959        };960        $fileAdapter = new \ReputationVIP\QueueClient\Adapter\FileAdapter('/tmp/test/', null, $mockFs, $mockFinder, $mockLockHandlerFactory);961        $this->exception(function () use ($fileAdapter) {962            $fileAdapter->getNumberMessages('testQueue');963        });964    }965    public function testFileAdapterGetNumberMessagesWithEmptyQueueContent()966    {967        $this->mockGenerator->shuntParentClassCalls();968        $mockFs = new \mock\Symfony\Component\Filesystem\Filesystem;969        $this->mockGenerator->unshuntParentClassCalls();970        $mockFinder = new \mock\Symfony\Component\Finder\Finder;971        $this->mockGenerator->orphanize('__construct');972        $mockLockHandlerFactory = new \mock\Symfony\Component\Lock\Factory;973        $priorityHandler = new ThreeLevelPriorityHandler();974        $mockFs->getMockController()->exists = true;975        $mockLockHandlerFactory->getMockController()->createLock = function ($repository) {976            $mockLockHandler = new \mock\Symfony\Component\Lock\LockInterface;977            $mockLockHandler->getMockController()->acquire = true;978            return $mockLockHandler;979        };980        $mockFinder->getMockController()->getIterator = function () use ($priorityHandler) {981            $files = [];982            $priorities = $priorityHandler->getAll();983            foreach ($priorities as $priority) {984                $files[] = 'testQueue' . \ReputationVIP\QueueClient\Adapter\FileAdapter::PRIORITY_SEPARATOR . $priority->getName() . '.' . \ReputationVIP\QueueClient\Adapter\FileAdapter::QUEUE_FILE_EXTENSION;985            }986            $mocksSplFileInfo = [];987            foreach ($files as $file) {988                $mockSplFileInfo = new \mock\Symfony\Component\Finder\SplFileInfo('', '', '');989                $mockSplFileInfo->getMockController()->getExtension = function () {990                    return \ReputationVIP\QueueClient\Adapter\FileAdapter::QUEUE_FILE_EXTENSION;991                };992                $mockSplFileInfo->getMockController()->getRelativePathname = function () use ($file) {993                    return $file;994                };995                $mockSplFileInfo->getMockController()->getPathname = function () use ($file) {996                    return '/tmp/test/' . $file;997                };998                $mockSplFileInfo->getMockController()->getContents = function () use ($file) {999                    return '';1000                };1001                $mocksSplFileInfo[] = $mockSplFileInfo;1002            }1003            return new ArrayIterator($mocksSplFileInfo);1004        };1005        $fileAdapter = new \ReputationVIP\QueueClient\Adapter\FileAdapter('/tmp/test/', $priorityHandler, $mockFs, $mockFinder, $mockLockHandlerFactory);1006        $this->exception(function () use ($fileAdapter) {1007            $fileAdapter->getNumberMessages('testQueue');1008        });1009    }1010    public function testFileAdapterGetNumberMessagesWithBadQueueContent()1011    {1012        $this->mockGenerator->shuntParentClassCalls();1013        $mockFs = new \mock\Symfony\Component\Filesystem\Filesystem;1014        $this->mockGenerator->unshuntParentClassCalls();1015        $mockFinder = new \mock\Symfony\Component\Finder\Finder;1016        $this->mockGenerator->orphanize('__construct');1017        $mockLockHandlerFactory = new \mock\Symfony\Component\Lock\Factory;1018        $priorityHandler = new ThreeLevelPriorityHandler();1019        $mockFs->getMockController()->exists = true;1020        $mockLockHandlerFactory->getMockController()->createLock = function ($repository) {1021            $mockLockHandler = new \mock\Symfony\Component\Lock\LockInterface;1022            $mockLockHandler->getMockController()->acquire = true;1023            return $mockLockHandler;1024        };1025        $mockFinder->getMockController()->getIterator = function () use ($priorityHandler) {1026            $files = [];1027            $priorities = $priorityHandler->getAll();1028            foreach ($priorities as $priority) {1029                $files[] = 'testQueue' . \ReputationVIP\QueueClient\Adapter\FileAdapter::PRIORITY_SEPARATOR . $priority->getName() . '.' . \ReputationVIP\QueueClient\Adapter\FileAdapter::QUEUE_FILE_EXTENSION;1030            }1031            $mocksSplFileInfo = [];1032            foreach ($files as $file) {1033                $mockSplFileInfo = new \mock\Symfony\Component\Finder\SplFileInfo('', '', '');1034                $mockSplFileInfo->getMockController()->getExtension = function () {1035                    return \ReputationVIP\QueueClient\Adapter\FileAdapter::QUEUE_FILE_EXTENSION;1036                };1037                $mockSplFileInfo->getMockController()->getRelativePathname = function () use ($file) {1038                    return $file;1039                };1040                $mockSplFileInfo->getMockController()->getPathname = function () use ($file) {1041                    return '/tmp/test/' . $file;1042                };1043                $mockSplFileInfo->getMockController()->getContents = function () use ($file) {1044                    return '{"bad":[]}';1045                };1046                $mocksSplFileInfo[] = $mockSplFileInfo;1047            }1048            return new ArrayIterator($mocksSplFileInfo);1049        };1050        $fileAdapter = new \ReputationVIP\QueueClient\Adapter\FileAdapter('/tmp/test/', $priorityHandler, $mockFs, $mockFinder, $mockLockHandlerFactory);1051        $this->exception(function () use ($fileAdapter) {1052            $fileAdapter->getNumberMessages('testQueue');1053        });1054    }1055    public function testFileAdapterGetNumberMessages()1056    {1057        $this->mockGenerator->shuntParentClassCalls();1058        $mockFs = new \mock\Symfony\Component\Filesystem\Filesystem;1059        $this->mockGenerator->unshuntParentClassCalls();1060        $mockFinder = new \mock\Symfony\Component\Finder\Finder;1061        $this->mockGenerator->orphanize('__construct');1062        $mockLockHandlerFactory = new \mock\Symfony\Component\Lock\Factory;1063        $priorityHandler = new ThreeLevelPriorityHandler();1064        $mockFs->getMockController()->exists = true;1065        $mockLockHandlerFactory->getMockController()->createLock = function ($repository) {1066            $mockLockHandler = new \mock\Symfony\Component\Lock\LockInterface;1067            $mockLockHandler->getMockController()->acquire = true;1068            return $mockLockHandler;1069        };1070        $mockFinder->getMockController()->getIterator = function () use ($priorityHandler) {1071            $files = [];1072            $priorities = $priorityHandler->getAll();1073            foreach ($priorities as $priority) {1074                $files[] = 'testQueue' . \ReputationVIP\QueueClient\Adapter\FileAdapter::PRIORITY_SEPARATOR . $priority->getName() . '.' . \ReputationVIP\QueueClient\Adapter\FileAdapter::QUEUE_FILE_EXTENSION;1075            }1076            $mocksSplFileInfo = [];1077            foreach ($files as $file) {1078                $mockSplFileInfo = new \mock\Symfony\Component\Finder\SplFileInfo('', '', '');1079                $mockSplFileInfo->getMockController()->getExtension = function () { return \ReputationVIP\QueueClient\Adapter\FileAdapter::QUEUE_FILE_EXTENSION; };1080                $mockSplFileInfo->getMockController()->getRelativePathname = function () use($file) { return $file; };1081                $mockSplFileInfo->getMockController()->getPathname = function () use($file) { return '/tmp/test/' . $file; };1082                $mockSplFileInfo->getMockController()->getContents = function () use($file) { return '{"queue":[{"id":"testQueue-HIGH559f77704e87c5.40358915","time-in-flight":null, "delayed-until":null,"delayed-until":null,"Body":"s:12:\"Test message\";"},{"id":"testQueue-HIGH559f9a97733a01.98514574","time-in-flight":null, "delayed-until":null,"Body":"s:16:\"test message two\";"}]}'; };1083                $mocksSplFileInfo[] = $mockSplFileInfo;1084            }1085            return new ArrayIterator($mocksSplFileInfo);1086        };1087        $fileAdapter = new \ReputationVIP\QueueClient\Adapter\FileAdapter('/tmp/test/', $priorityHandler, $mockFs, $mockFinder, $mockLockHandlerFactory);1088        $this->given($fileAdapter)1089            ->integer($fileAdapter->getNumberMessages('testQueue'))->isEqualTo(6);1090    }1091    public function testFileAdapterGetMessagesWithEmptyQueueName()1092    {1093        $this->mockGenerator->shuntParentClassCalls();1094        $mockFs = new \mock\Symfony\Component\Filesystem\Filesystem;1095        $this->mockGenerator->unshuntParentClassCalls();1096        $mockFinder = new \mock\Symfony\Component\Finder\Finder;1097        $this->mockGenerator->orphanize('__construct');1098        $mockLockHandlerFactory = new \mock\Symfony\Component\Lock\Factory;1099        $fileAdapter = new \ReputationVIP\QueueClient\Adapter\FileAdapter('/tmp/test/', null, $mockFs, $mockFinder, $mockLockHandlerFactory);1100        $this->exception(function () use ($fileAdapter) {1101            $fileAdapter->getMessages('', 1);1102        });1103    }1104    public function testFileAdapterGetMessagesWithNoQueueFile()1105    {1106        $this->mockGenerator->shuntParentClassCalls();1107        $mockFs = new \mock\Symfony\Component\Filesystem\Filesystem;1108        $this->mockGenerator->unshuntParentClassCalls();1109        $mockFinder = new \mock\Symfony\Component\Finder\Finder;1110        $this->mockGenerator->orphanize('__construct');1111        $mockLockHandlerFactory = new \mock\Symfony\Component\Lock\Factory;1112        $mockFs->getMockController()->exists = false;1113        $fileAdapter = new \ReputationVIP\QueueClient\Adapter\FileAdapter('/tmp/test/', null, $mockFs, $mockFinder, $mockLockHandlerFactory);1114        $this->exception(function () use ($fileAdapter) {1115            $fileAdapter->getMessages('testQueue', 1);1116        });1117    }1118    public function testFileAdapterAddMessagesWithNoNumericNbrMsg()1119    {1120        $this->mockGenerator->shuntParentClassCalls();1121        $mockFs = new \mock\Symfony\Component\Filesystem\Filesystem;1122        $this->mockGenerator->unshuntParentClassCalls();1123        $mockFinder = new \mock\Symfony\Component\Finder\Finder;1124        $this->mockGenerator->orphanize('__construct');1125        $mockLockHandlerFactory = new \mock\Symfony\Component\Lock\Factory;1126        $mockFs->getMockController()->exists = true;1127        $mockLockHandlerFactory->getMockController()->createLock = function ($repository) {1128            $mockLockHandler = new \mock\Symfony\Component\Lock\LockInterface;1129            $mockLockHandler->getMockController()->acquire = true;1130            return $mockLockHandler;1131        };1132        $fileAdapter = new \ReputationVIP\QueueClient\Adapter\FileAdapter('/tmp/test/', null, $mockFs, $mockFinder, $mockLockHandlerFactory);1133        $this->exception(function () use ($fileAdapter) {1134            $fileAdapter->getMessages('testQueue', 'toto');1135        });1136    }1137    public function testFileAdapterGetMessagesWithNotValidNumericNbrMsg()1138    {1139        $this->mockGenerator->shuntParentClassCalls();1140        $mockFs = new \mock\Symfony\Component\Filesystem\Filesystem;1141        $this->mockGenerator->unshuntParentClassCalls();1142        $mockFinder = new \mock\Symfony\Component\Finder\Finder;1143        $this->mockGenerator->orphanize('__construct');1144        $mockLockHandlerFactory = new \mock\Symfony\Component\Lock\Factory;1145        $mockFs->getMockController()->exists = true;1146        $mockLockHandlerFactory->getMockController()->createLock = function ($repository) {1147            $mockLockHandler = new \mock\Symfony\Component\Lock\LockInterface;1148            $mockLockHandler->getMockController()->acquire = true;1149            return $mockLockHandler;1150        };1151        $fileAdapter = new \ReputationVIP\QueueClient\Adapter\FileAdapter('/tmp/test/', null, $mockFs, $mockFinder, $mockLockHandlerFactory);1152        $this->exception(function () use ($fileAdapter) {1153            $fileAdapter->getMessages('testQueue', -5);1154        });1155        $this->exception(function () use ($fileAdapter) {1156            $fileAdapter->getMessages('testQueue', (\ReputationVIP\QueueClient\Adapter\FileAdapter::MAX_NB_MESSAGES + 1));1157        });1158    }1159    public function testFileAdapterGetMessagesLockFailed()1160    {1161        $this->mockGenerator->shuntParentClassCalls();1162        $mockFs = new \mock\Symfony\Component\Filesystem\Filesystem;1163        $this->mockGenerator->unshuntParentClassCalls();1164        $mockFinder = new \mock\Symfony\Component\Finder\Finder;1165        $this->mockGenerator->orphanize('__construct');1166        $mockLockHandlerFactory = new \mock\Symfony\Component\Lock\Factory;1167        $mockFs->getMockController()->exists = true;1168        $mockLockHandlerFactory->getMockController()->createLock = function ($repository) {1169            $mockLockHandler = new \mock\Symfony\Component\Lock\LockInterface;1170            $mockLockHandler->getMockController()->acquire = false;1171            return $mockLockHandler;1172        };1173        $fileAdapter = new \ReputationVIP\QueueClient\Adapter\FileAdapter('/tmp/test/', null, $mockFs, $mockFinder, $mockLockHandlerFactory);1174        $this->exception(function () use ($fileAdapter) {1175            $fileAdapter->getMessages('testQueue');1176        });1177    }1178    public function testFileAdapterGetMessagesWithEmptyQueueContent()1179    {1180        $this->mockGenerator->shuntParentClassCalls();1181        $mockFs = new \mock\Symfony\Component\Filesystem\Filesystem;1182        $this->mockGenerator->unshuntParentClassCalls();1183        $mockFinder = new \mock\Symfony\Component\Finder\Finder;1184        $this->mockGenerator->orphanize('__construct');1185        $mockLockHandlerFactory = new \mock\Symfony\Component\Lock\Factory;1186        $priorityHandler = new ThreeLevelPriorityHandler();1187        $mockFs->getMockController()->exists = true;1188        $mockLockHandlerFactory->getMockController()->createLock = function ($repository) {1189            $mockLockHandler = new \mock\Symfony\Component\Lock\LockInterface;1190            $mockLockHandler->getMockController()->acquire = true;1191            return $mockLockHandler;1192        };1193        $mockFinder->getMockController()->getIterator = function () use ($priorityHandler) {1194            $files = [];1195            $priorities = $priorityHandler->getAll();1196            foreach ($priorities as $priority) {1197                $files[] = 'testQueue' . \ReputationVIP\QueueClient\Adapter\FileAdapter::PRIORITY_SEPARATOR . $priority->getName() . '.' . \ReputationVIP\QueueClient\Adapter\FileAdapter::QUEUE_FILE_EXTENSION;1198            }1199            $mocksSplFileInfo = [];1200            foreach ($files as $file) {1201                $mockSplFileInfo = new \mock\Symfony\Component\Finder\SplFileInfo('', '', '');1202                $mockSplFileInfo->getMockController()->getExtension = function () {1203                    return \ReputationVIP\QueueClient\Adapter\FileAdapter::QUEUE_FILE_EXTENSION;1204                };1205                $mockSplFileInfo->getMockController()->getRelativePathname = function () use ($file) {1206                    return $file;1207                };1208                $mockSplFileInfo->getMockController()->getPathname = function () use ($file) {1209                    return '/tmp/test/' . $file;1210                };1211                $mockSplFileInfo->getMockController()->getContents = function () use ($file) {1212                    return '';1213                };1214                $mocksSplFileInfo[] = $mockSplFileInfo;1215            }1216            return new ArrayIterator($mocksSplFileInfo);1217        };1218        $fileAdapter = new \ReputationVIP\QueueClient\Adapter\FileAdapter('/tmp/test/', $priorityHandler, $mockFs, $mockFinder, $mockLockHandlerFactory);1219        $this->exception(function () use ($fileAdapter) {1220            $fileAdapter->getMessages('testQueue');1221        });1222    }1223    public function testFileAdapterGetMessagesWithBadQueueContent()1224    {1225        $this->mockGenerator->shuntParentClassCalls();1226        $mockFs = new \mock\Symfony\Component\Filesystem\Filesystem;1227        $this->mockGenerator->unshuntParentClassCalls();1228        $mockFinder = new \mock\Symfony\Component\Finder\Finder;1229        $this->mockGenerator->orphanize('__construct');1230        $mockLockHandlerFactory = new \mock\Symfony\Component\Lock\Factory;1231        $priorityHandler = new ThreeLevelPriorityHandler();1232        $mockFs->getMockController()->exists = true;1233        $mockLockHandlerFactory->getMockController()->createLock = function ($repository) {1234            $mockLockHandler = new \mock\Symfony\Component\Lock\LockInterface;1235            $mockLockHandler->getMockController()->acquire = true;1236            return $mockLockHandler;1237        };1238        $mockFinder->getMockController()->getIterator = function () use ($priorityHandler) {1239            $files = [];1240            $priorities = $priorityHandler->getAll();1241            foreach ($priorities as $priority) {1242                $files[] = 'testQueue' . \ReputationVIP\QueueClient\Adapter\FileAdapter::PRIORITY_SEPARATOR . $priority->getName() . '.' . \ReputationVIP\QueueClient\Adapter\FileAdapter::QUEUE_FILE_EXTENSION;1243            }1244            $mocksSplFileInfo = [];1245            foreach ($files as $file) {1246                $mockSplFileInfo = new \mock\Symfony\Component\Finder\SplFileInfo('', '', '');1247                $mockSplFileInfo->getMockController()->getExtension = function () {1248                    return \ReputationVIP\QueueClient\Adapter\FileAdapter::QUEUE_FILE_EXTENSION;1249                };1250                $mockSplFileInfo->getMockController()->getRelativePathname = function () use ($file) {1251                    return $file;1252                };1253                $mockSplFileInfo->getMockController()->getPathname = function () use ($file) {1254                    return '/tmp/test/' . $file;1255                };1256                $mockSplFileInfo->getMockController()->getContents = function () use ($file) {1257                    return '{"bad":[]}';1258                };1259                $mocksSplFileInfo[] = $mockSplFileInfo;1260            }1261            return new ArrayIterator($mocksSplFileInfo);1262        };1263        $fileAdapter = new \ReputationVIP\QueueClient\Adapter\FileAdapter('/tmp/test/', $priorityHandler, $mockFs, $mockFinder, $mockLockHandlerFactory);1264        $this->exception(function () use ($fileAdapter) {1265            $fileAdapter->getMessages('testQueue');1266        });1267    }1268    public function testFileAdapterGetMessages()1269    {1270        $this->mockGenerator->shuntParentClassCalls();1271        $mockFs = new \mock\Symfony\Component\Filesystem\Filesystem;1272        $this->mockGenerator->unshuntParentClassCalls();1273        $mockFinder = new \mock\Symfony\Component\Finder\Finder;1274        $this->mockGenerator->orphanize('__construct');1275        $mockLockHandlerFactory = new \mock\Symfony\Component\Lock\Factory;1276        $priorityHandler = new ThreeLevelPriorityHandler();1277        $mockFs->getMockController()->exists = true;1278        $mockLockHandlerFactory->getMockController()->createLock = function ($repository) {1279            $mockLockHandler = new \mock\Symfony\Component\Lock\LockInterface;1280            $mockLockHandler->getMockController()->acquire = true;1281            return $mockLockHandler;1282        };1283        $mockFinder->getMockController()->getIterator = function () use ($priorityHandler) {1284            $files = [];1285            $priorities = $priorityHandler->getAll();1286            foreach ($priorities as $priority) {1287                $files[] = 'testQueue' . \ReputationVIP\QueueClient\Adapter\FileAdapter::PRIORITY_SEPARATOR . $priority->getName() . '.' . \ReputationVIP\QueueClient\Adapter\FileAdapter::QUEUE_FILE_EXTENSION;1288            }1289            $mocksSplFileInfo = [];1290            foreach ($files as $file) {1291                $mockSplFileInfo = new \mock\Symfony\Component\Finder\SplFileInfo('', '', '');1292                $mockSplFileInfo->getMockController()->getExtension = function () { return \ReputationVIP\QueueClient\Adapter\FileAdapter::QUEUE_FILE_EXTENSION; };1293                $mockSplFileInfo->getMockController()->getRelativePathname = function () use($file) { return $file; };1294                $mockSplFileInfo->getMockController()->getPathname = function () use($file) { return '/tmp/test/' . $file; };1295                $mockSplFileInfo->getMockController()->getContents = function () use($file) { return '{"queue":[{"id":"testQueue-HIGH559f77704e87c5.40358915","time-in-flight":null, "delayed-until":null,"Body":"s:12:\"Test message\";"},{"id":"testQueue-HIGH559f9a97733a01.98514574","time-in-flight":null, "delayed-until":null,"Body":"s:16:\"test message two\";"}]}'; };1296                $mocksSplFileInfo[] = $mockSplFileInfo;1297            }1298            return new ArrayIterator($mocksSplFileInfo);1299        };1300        $fileAdapter = new \ReputationVIP\QueueClient\Adapter\FileAdapter('/tmp/test/', $priorityHandler, $mockFs, $mockFinder, $mockLockHandlerFactory);1301        $this->given($fileAdapter)1302            ->array($fileAdapter->GetMessages('testQueue', 6));1303        $this->given($fileAdapter)1304            ->array($fileAdapter->GetMessages('testQueue', 8));1305    }1306    public function testFileAdapterDeleteMessageWithEmptyQueueName()1307    {1308        $this->mockGenerator->shuntParentClassCalls();1309        $mockFs = new \mock\Symfony\Component\Filesystem\Filesystem;1310        $this->mockGenerator->unshuntParentClassCalls();1311        $mockFinder = new \mock\Symfony\Component\Finder\Finder;1312        $this->mockGenerator->orphanize('__construct');1313        $mockLockHandlerFactory = new \mock\Symfony\Component\Lock\Factory;1314        $fileAdapter = new \ReputationVIP\QueueClient\Adapter\FileAdapter('/tmp/test/', null, $mockFs, $mockFinder, $mockLockHandlerFactory);1315        $this->exception(function () use ($fileAdapter) {1316            $fileAdapter->deleteMessage('', []);1317        });1318    }1319    public function testFileAdapterDeleteMessageWithNoQueueFile()1320    {1321        $this->mockGenerator->shuntParentClassCalls();1322        $mockFs = new \mock\Symfony\Component\Filesystem\Filesystem;1323        $this->mockGenerator->unshuntParentClassCalls();1324        $mockFinder = new \mock\Symfony\Component\Finder\Finder;1325        $this->mockGenerator->orphanize('__construct');1326        $mockLockHandlerFactory = new \mock\Symfony\Component\Lock\Factory;1327        $priorityHandler = new ThreeLevelPriorityHandler();1328        $mockFs->getMockController()->exists = false;1329        $fileAdapter = new \ReputationVIP\QueueClient\Adapter\FileAdapter('/tmp/test/', $priorityHandler, $mockFs, $mockFinder, $mockLockHandlerFactory);1330        $this->exception(function () use ($fileAdapter, $priorityHandler) {1331            $fileAdapter->deleteMessage('testQueue', ['id' => 'testQueue-HIGH559f77704e87c5.40358915', 'priority' => $priorityHandler->getHighest()->getLevel()]);1332        });1333    }1334    public function testFileAdapterDeleteMessageWithNoMessage()1335    {1336        $this->mockGenerator->shuntParentClassCalls();1337        $mockFs = new \mock\Symfony\Component\Filesystem\Filesystem;1338        $this->mockGenerator->unshuntParentClassCalls();1339        $mockFinder = new \mock\Symfony\Component\Finder\Finder;1340        $this->mockGenerator->orphanize('__construct');1341        $mockLockHandlerFactory = new \mock\Symfony\Component\Lock\Factory;1342        $mockFs->getMockController()->exists = false;1343        $fileAdapter = new \ReputationVIP\QueueClient\Adapter\FileAdapter('/tmp/test/', null, $mockFs, $mockFinder, $mockLockHandlerFactory);1344        $this->exception(function () use ($fileAdapter) {1345            $fileAdapter->deleteMessage('testQueue', []);1346        });1347    }1348    public function testFileAdapterDeleteMessageWithNoIdField()1349    {1350        $this->mockGenerator->shuntParentClassCalls();1351        $mockFs = new \mock\Symfony\Component\Filesystem\Filesystem;1352        $this->mockGenerator->unshuntParentClassCalls();1353        $mockFinder = new \mock\Symfony\Component\Finder\Finder;1354        $this->mockGenerator->orphanize('__construct');1355        $mockLockHandlerFactory = new \mock\Symfony\Component\Lock\Factory;1356        $priorityHandler = new ThreeLevelPriorityHandler();1357        $mockFs->getMockController()->exists = true;1358        $FileAdapter = new \ReputationVIP\QueueClient\Adapter\FileAdapter('/tmp/test/', $priorityHandler, $mockFs, $mockFinder, $mockLockHandlerFactory);1359        $this->exception(function () use ($FileAdapter, $priorityHandler) {1360            $FileAdapter->deleteMessage('testQueue', ['priority' => $priorityHandler->getHighest()->getLevel()]);1361        });1362    }1363    public function testFileAdapterDeleteMessageWithNotPriorityField()1364    {1365        $this->mockGenerator->shuntParentClassCalls();1366        $mockFs = new \mock\Symfony\Component\Filesystem\Filesystem;1367        $this->mockGenerator->unshuntParentClassCalls();1368        $mockFinder = new \mock\Symfony\Component\Finder\Finder;1369        $this->mockGenerator->orphanize('__construct');1370        $mockLockHandlerFactory = new \mock\Symfony\Component\Lock\Factory;1371        $mockFs->getMockController()->exists = true;1372        $fileAdapter = new \ReputationVIP\QueueClient\Adapter\FileAdapter('/tmp/test/', null, $mockFs, $mockFinder, $mockLockHandlerFactory);1373        $this->exception(function () use ($fileAdapter) {1374            $fileAdapter->deleteMessage('testQueue', ['id' => 'testQueue-HIGH559f77704e87c5.40358915']);1375        });1376    }1377    public function testFileAdapterDeleteMessageWithBadMessageType()1378    {1379        $this->mockGenerator->shuntParentClassCalls();1380        $mockFs = new \mock\Symfony\Component\Filesystem\Filesystem;1381        $this->mockGenerator->unshuntParentClassCalls();1382        $mockFinder = new \mock\Symfony\Component\Finder\Finder;1383        $this->mockGenerator->orphanize('__construct');1384        $mockLockHandlerFactory = new \mock\Symfony\Component\Lock\Factory;1385        $mockFs->getMockController()->exists = true;1386        $fileAdapter = new \ReputationVIP\QueueClient\Adapter\FileAdapter('/tmp/test/', null, $mockFs, $mockFinder, $mockLockHandlerFactory);1387        $this->exception(function () use ($fileAdapter) {1388            $fileAdapter->deleteMessage('testQueue', 'message');1389        });1390    }1391    public function testFileAdapterDeleteMessageLockFailed()1392    {1393        $this->mockGenerator->shuntParentClassCalls();1394        $mockFs = new \mock\Symfony\Component\Filesystem\Filesystem;1395        $this->mockGenerator->unshuntParentClassCalls();1396        $mockFinder = new \mock\Symfony\Component\Finder\Finder;1397        $this->mockGenerator->orphanize('__construct');1398        $mockLockHandlerFactory = new \mock\Symfony\Component\Lock\Factory;1399        $priorityHandler = new ThreeLevelPriorityHandler();1400        $mockFs->getMockController()->exists = true;1401        $mockLockHandlerFactory->getMockController()->createLock = function ($repository) {1402            $mockLockHandler = new \mock\Symfony\Component\Lock\LockInterface;1403            $mockLockHandler->getMockController()->acquire = false;1404            return $mockLockHandler;1405        };1406        $fileAdapter = new \ReputationVIP\QueueClient\Adapter\FileAdapter('/tmp/test/', $priorityHandler, $mockFs, $mockFinder, $mockLockHandlerFactory);1407        $this->exception(function () use ($fileAdapter, $priorityHandler) {1408            $fileAdapter->deleteMessage('testQueue', ['id' => 'testQueue-HIGH559f77704e87c5.40358915', 'priority' => $priorityHandler->getHighest()->getLevel()]);1409        });1410    }1411    public function testFileAdapterDeleteMessageWithEmptyQueueContent()1412    {1413        $this->mockGenerator->shuntParentClassCalls();1414        $mockFs = new \mock\Symfony\Component\Filesystem\Filesystem;1415        $this->mockGenerator->unshuntParentClassCalls();1416        $mockFinder = new \mock\Symfony\Component\Finder\Finder;1417        $this->mockGenerator->orphanize('__construct');1418        $mockLockHandlerFactory = new \mock\Symfony\Component\Lock\Factory;1419        $priorityHandler = new ThreeLevelPriorityHandler();1420        $mockFs->getMockController()->exists = true;1421        $mockLockHandlerFactory->getMockController()->createLock = function ($repository) {1422            $mockLockHandler = new \mock\Symfony\Component\Lock\LockInterface;1423            $mockLockHandler->getMockController()->acquire = true;1424            return $mockLockHandler;1425        };1426        $mockFinder->getMockController()->getIterator = function () use ($priorityHandler) {1427            $files = [];1428            $priorities = $priorityHandler->getAll();1429            foreach ($priorities as $priority) {1430                $files[] = 'testQueue' . \ReputationVIP\QueueClient\Adapter\FileAdapter::PRIORITY_SEPARATOR . $priority->getName() . '.' . \ReputationVIP\QueueClient\Adapter\FileAdapter::QUEUE_FILE_EXTENSION;1431            }1432            $mocksSplFileInfo = [];1433            foreach ($files as $file) {1434                $mockSplFileInfo = new \mock\Symfony\Component\Finder\SplFileInfo('', '', '');1435                $mockSplFileInfo->getMockController()->getExtension = function () {1436                    return \ReputationVIP\QueueClient\Adapter\FileAdapter::QUEUE_FILE_EXTENSION;1437                };1438                $mockSplFileInfo->getMockController()->getRelativePathname = function () use ($file) {1439                    return $file;1440                };1441                $mockSplFileInfo->getMockController()->getPathname = function () use ($file) {1442                    return '/tmp/test/' . $file;1443                };1444                $mockSplFileInfo->getMockController()->getContents = function () use ($file) {1445                    return '';1446                };1447                $mocksSplFileInfo[] = $mockSplFileInfo;1448            }1449            return new ArrayIterator($mocksSplFileInfo);1450        };1451        $fileAdapter = new \ReputationVIP\QueueClient\Adapter\FileAdapter('/tmp/test/', $priorityHandler, $mockFs, $mockFinder, $mockLockHandlerFactory);1452        $this->exception(function () use ($fileAdapter, $priorityHandler) {1453            $fileAdapter->deleteMessage('testQueue', ['id' => 'testQueue-HIGH559f77704e87c5.40358915', 'priority' => $priorityHandler->getHighest()->getLevel()]);1454        });1455    }1456    public function testFileAdapterDeleteMessageWithBadQueueContent()1457    {1458        $this->mockGenerator->shuntParentClassCalls();1459        $mockFs = new \mock\Symfony\Component\Filesystem\Filesystem;1460        $this->mockGenerator->unshuntParentClassCalls();1461        $mockFinder = new \mock\Symfony\Component\Finder\Finder;1462        $this->mockGenerator->orphanize('__construct');1463        $mockLockHandlerFactory = new \mock\Symfony\Component\Lock\Factory;1464        $priorityHandler = new ThreeLevelPriorityHandler();1465        $mockFs->getMockController()->exists = true;1466        $mockLockHandlerFactory->getMockController()->createLock = function ($repository) {1467            $mockLockHandler = new \mock\Symfony\Component\Lock\LockInterface;1468            $mockLockHandler->getMockController()->acquire = true;1469            return $mockLockHandler;1470        };1471        $mockFinder->getMockController()->getIterator = function () use ($priorityHandler) {1472            $files = [];1473            $priorities = $priorityHandler->getAll();1474            foreach ($priorities as $priority) {1475                $files[] = 'testQueue' . \ReputationVIP\QueueClient\Adapter\FileAdapter::PRIORITY_SEPARATOR . $priority->getName() . '.' . \ReputationVIP\QueueClient\Adapter\FileAdapter::QUEUE_FILE_EXTENSION;1476            }1477            $mocksSplFileInfo = [];1478            foreach ($files as $file) {1479                $mockSplFileInfo = new \mock\Symfony\Component\Finder\SplFileInfo('', '', '');1480                $mockSplFileInfo->getMockController()->getExtension = function () {1481                    return \ReputationVIP\QueueClient\Adapter\FileAdapter::QUEUE_FILE_EXTENSION;1482                };1483                $mockSplFileInfo->getMockController()->getRelativePathname = function () use ($file) {1484                    return $file;1485                };1486                $mockSplFileInfo->getMockController()->getPathname = function () use ($file) {1487                    return '/tmp/test/' . $file;1488                };1489                $mockSplFileInfo->getMockController()->getContents = function () use ($file) {1490                    return '{"bad":[]}';1491                };1492                $mocksSplFileInfo[] = $mockSplFileInfo;1493            }1494            return new ArrayIterator($mocksSplFileInfo);1495        };1496        $fileAdapter = new \ReputationVIP\QueueClient\Adapter\FileAdapter('/tmp/test/', $priorityHandler, $mockFs, $mockFinder, $mockLockHandlerFactory);1497        $this->exception(function () use ($fileAdapter, $priorityHandler) {1498            $fileAdapter->deleteMessage('testQueue', ['id' => 'testQueue-HIGH559f77704e87c5.40358915', 'priority' => $priorityHandler->getHighest()->getLevel()]);1499        });1500    }1501    public function testFileAdapterDeleteMessage()1502    {1503        $this->mockGenerator->shuntParentClassCalls();1504        $mockFs = new \mock\Symfony\Component\Filesystem\Filesystem;1505        $this->mockGenerator->unshuntParentClassCalls();1506        $mockFinder = new \mock\Symfony\Component\Finder\Finder;1507        $this->mockGenerator->orphanize('__construct');1508        $mockLockHandlerFactory = new \mock\Symfony\Component\Lock\Factory;1509        $priorityHandler = new ThreeLevelPriorityHandler();1510        $mockFs->getMockController()->exists = true;1511        $mockLockHandlerFactory->getMockController()->createLock = function ($repository) {1512            $mockLockHandler = new \mock\Symfony\Component\Lock\LockInterface;1513            $mockLockHandler->getMockController()->acquire = true;1514            return $mockLockHandler;1515        };1516        $mockFinder->getMockController()->getIterator = function () use ($priorityHandler) {1517            $files = [];1518            $priorities = $priorityHandler->getAll();1519            foreach ($priorities as $priority) {1520                $files[] = 'testQueue' . \ReputationVIP\QueueClient\Adapter\FileAdapter::PRIORITY_SEPARATOR . $priority->getName() . '.' . \ReputationVIP\QueueClient\Adapter\FileAdapter::QUEUE_FILE_EXTENSION;1521            }1522            $mocksSplFileInfo = [];1523            foreach ($files as $file) {1524                $mockSplFileInfo = new \mock\Symfony\Component\Finder\SplFileInfo('', '', '');1525                $mockSplFileInfo->getMockController()->getExtension = function () { return \ReputationVIP\QueueClient\Adapter\FileAdapter::QUEUE_FILE_EXTENSION; };1526                $mockSplFileInfo->getMockController()->getRelativePathname = function () use($file) { return $file; };1527                $mockSplFileInfo->getMockController()->getPathname = function () use($file) { return '/tmp/test/' . $file; };1528                $mockSplFileInfo->getMockController()->getContents = function () use($file) { return '{"queue":[{"id":"testQueue-HIGH559f77704e87c5.40358915","time-in-flight":null, "delayed-until":null,"Body":"s:12:\"Test message\";"},{"id":"testQueue-HIGH559f9a97733a01.98514574","time-in-flight":null, "delayed-until":null,"Body":"s:16:\"test message two\";"}]}'; };1529                $mocksSplFileInfo[] = $mockSplFileInfo;1530            }1531            return new ArrayIterator($mocksSplFileInfo);1532        };1533        $fileAdapter = new \ReputationVIP\QueueClient\Adapter\FileAdapter('/tmp/test/', $priorityHandler, $mockFs, $mockFinder, $mockLockHandlerFactory);1534        $this->given($fileAdapter)1535            ->class($fileAdapter->deleteMessage('testQueue', array('id' => 'testQueue-HIGH559f77704e87c5.40358915', 'priority' => $priorityHandler->getHighest()->getLevel())))->hasInterface('\ReputationVIP\QueueClient\Adapter\AdapterInterface');1536    }1537    public function testFileAdapterRenameQueueWithEmptyParameter()1538    {1539        $this->mockGenerator->shuntParentClassCalls();1540        $mockFs = new \mock\Symfony\Component\Filesystem\Filesystem;1541        $this->mockGenerator->unshuntParentClassCalls();1542        $mockFinder = new \mock\Symfony\Component\Finder\Finder;1543        $this->mockGenerator->orphanize('__construct');1544        $mockLockHandlerFactory = new \mock\Symfony\Component\Lock\Factory;1545        $fileAdapter = new \ReputationVIP\QueueClient\Adapter\FileAdapter('/tmp/test/', null, $mockFs, $mockFinder, $mockLockHandlerFactory);1546        $this->exception(function () use ($fileAdapter) {1547            $fileAdapter->renameQueue('', 'newTestQueue');1548        });1549        $this->exception(function () use ($fileAdapter) {1550            $fileAdapter->renameQueue('testQueue', '');1551        });1552    }1553    public function testFileAdapterRenameQueue()1554    {1555        $this->mockGenerator->shuntParentClassCalls();1556        $mockFs = new \mock\Symfony\Component\Filesystem\Filesystem;1557        $this->mockGenerator->unshuntParentClassCalls();1558        $mockFinder = new \mock\Symfony\Component\Finder\Finder;1559        $this->mockGenerator->orphanize('__construct');1560        $mockLockHandlerFactory = new \mock\Symfony\Component\Lock\Factory;1561        $priorityHandler = new ThreeLevelPriorityHandler();1562        $mockFs->getMockController()->exists = function ($queue) {1563            if (strstr($queue, 'new')) {1564                return false;1565            }1566            return true;1567        };1568        $mockLockHandlerFactory->getMockController()->createLock = function ($repository) {1569            $mockLockHandler = new \mock\Symfony\Component\Lock\LockInterface;1570            $mockLockHandler->getMockController()->acquire = true;1571            return $mockLockHandler;1572        };1573        $mockFinder->getMockController()->getIterator = function () use ($priorityHandler) {1574            $files = [];1575            $priorities = $priorityHandler->getAll();1576            foreach ($priorities as $priority) {1577                $files[] = 'testQueue' . \ReputationVIP\QueueClient\Adapter\FileAdapter::PRIORITY_SEPARATOR . $priority->getName() . '.' . \ReputationVIP\QueueClient\Adapter\FileAdapter::QUEUE_FILE_EXTENSION;1578            }1579            $mocksSplFileInfo = [];1580            foreach ($files as $file) {1581                $mockSplFileInfo = new \mock\Symfony\Component\Finder\SplFileInfo('', '', '');1582                $mockSplFileInfo->getMockController()->getExtension = function () { return \ReputationVIP\QueueClient\Adapter\FileAdapter::QUEUE_FILE_EXTENSION; };1583                $mockSplFileInfo->getMockController()->getRelativePathname = function () use($file) { return $file; };1584                $mockSplFileInfo->getMockController()->getPathname = function () use($file) { return '/tmp/test/' . $file; };1585                $mockSplFileInfo->getMockController()->getContents = function () use($file) { return '{"queue":[{"id":"testQueue-HIGH559f77704e87c5.40358915","time-in-flight":null, "delayed-until":null,"Body":"s:12:\"Test message\";"},{"id":"testQueue-HIGH559f9a97733a01.98514574","time-in-flight":null, "delayed-until":null,"Body":"s:16:\"test message two\";"}]}'; };1586                $mocksSplFileInfo[] = $mockSplFileInfo;1587            }1588            return new ArrayIterator($mocksSplFileInfo);1589        };1590        $fileAdapter = new \ReputationVIP\QueueClient\Adapter\FileAdapter('/tmp/test/', $priorityHandler, $mockFs, $mockFinder, $mockLockHandlerFactory);1591        $this->given($fileAdapter)1592            ->class($fileAdapter->renameQueue('testQueue', 'newTestQueue'))->hasInterface('\ReputationVIP\QueueClient\Adapter\AdapterInterface');1593    }1594    public function testFileAdapterGetPriorityHandler()1595    {1596        $this->mockGenerator->shuntParentClassCalls();1597        $mockFs = new \mock\Symfony\Component\Filesystem\Filesystem;1598        $this->mockGenerator->unshuntParentClassCalls();1599        $mockFinder = new \mock\Symfony\Component\Finder\Finder;1600        $this->mockGenerator->orphanize('__construct');1601        $mockLockHandlerFactory = new \mock\Symfony\Component\Lock\Factory;1602        $fileAdapter = new \ReputationVIP\QueueClient\Adapter\FileAdapter('/tmp/test/', null, $mockFs, $mockFinder, $mockLockHandlerFactory);1603        $this->given($fileAdapter)1604            ->class($fileAdapter->getPriorityHandler())->hasInterface('\ReputationVIP\QueueClient\PriorityHandler\PriorityHandlerInterface');1605    }1606}...

SQSAdapter.php

Source:SQSAdapter.php

...6{7    public function testSQSAdapterAddMessageWithEmptyQueueName()8    {9        $this->mockGenerator->orphanize('__construct');10        $this->mockGenerator->shuntParentClassCalls();11        $mockSqsClient = new \mock\Aws\Sqs\SqsClient;12        $sqsAdapter = new \ReputationVIP\QueueClient\Adapter\SQSAdapter($mockSqsClient);13        $this->exception(function() use($sqsAdapter) {14            $sqsAdapter->addMessage('', '');15        });16    }17    public function testSQSAdapterAddMessageWithEmptyMessage()18    {19        $this->mockGenerator->orphanize('__construct');20        $this->mockGenerator->shuntParentClassCalls();21        $mockSqsClient = new \mock\Aws\Sqs\SqsClient;22        $sqsAdapter = new \ReputationVIP\QueueClient\Adapter\SQSAdapter($mockSqsClient);23        $this->exception(function() use($sqsAdapter) {24            $sqsAdapter->addMessage('testQueue', '');25        });26    }27    public function testSQSAdapterAddMessageWithSqsException()28    {29        $this->mockGenerator->orphanize('__construct');30        $this->mockGenerator->shuntParentClassCalls();31        $mockSqsClient = new \mock\Aws\Sqs\SqsClient;32        $mockQueueUrlModel = new \mock\Guzzle\Service\Resource\Model;33        $sqsAdapter = new \ReputationVIP\QueueClient\Adapter\SQSAdapter($mockSqsClient);34        $this->mockGenerator->orphanize('__construct');35        $this->mockGenerator->shuntParentClassCalls();36        $sqsException = new \mock\Aws\Sqs\Exception\SqsException;37        $mockSqsClient->getMockController()->getQueueUrl = function () use($mockQueueUrlModel) {38            return $mockQueueUrlModel;39        };40        $mockSqsClient->getMockController()->sendMessage = function () use ($sqsException) {41            throw $sqsException;42        };43        $this->exception(function() use($sqsAdapter) {44            $sqsAdapter->addMessage('testQueue', 'test message');45        });46    }47    public function testSQSAdapterAddMessage()48    {49        $this->mockGenerator->orphanize('__construct');50        $this->mockGenerator->shuntParentClassCalls();51        $mockSqsClient = new \mock\Aws\Sqs\SqsClient;52        $mockQueueUrlModel = new \mock\Guzzle\Service\Resource\Model;53        $sqsAdapter = new \ReputationVIP\QueueClient\Adapter\SQSAdapter($mockSqsClient);54        $mockSqsClient->getMockController()->getQueueUrl = function () use($mockQueueUrlModel) {55            return $mockQueueUrlModel;56        };57        $mockSqsClient->getMockController()->sendMessage = function () {58        };59        $this->given($sqsAdapter)60            ->class($sqsAdapter->addMessage('testQueue', 'test message'))->hasInterface('\ReputationVIP\QueueClient\Adapter\AdapterInterface');61    }62    public function testSQSAdapterAddMessages()63    {64        $this->mockGenerator->orphanize('__construct');65        $this->mockGenerator->shuntParentClassCalls();66        $mockSqsClient = new \mock\Aws\Sqs\SqsClient;67        $mockQueueUrlModel = new \mock\Guzzle\Service\Resource\Model;68        $sqsAdapter = new \ReputationVIP\QueueClient\Adapter\SQSAdapter($mockSqsClient);69        $mockSqsClient->getMockController()->getQueueUrl = function () use($mockQueueUrlModel) {70            return $mockQueueUrlModel;71        };72        $mockSqsClient->getMockController()->sendMessageBatch = function () {};73        $this74            ->if($mockSqsClient)75            ->and($sqsAdapter->addMessages('testQueue', array_fill(0, 11, 'test message')))76            ->mock($mockSqsClient)77                ->call('sendMessageBatch')->twice();78    }79    public function testSQSAdapterAddMessagesWithEmptyMessage()80    {81        $this->mockGenerator->orphanize('__construct');82        $this->mockGenerator->shuntParentClassCalls();83        $mockSqsClient = new \mock\Aws\Sqs\SqsClient;84        $sqsAdapter = new \ReputationVIP\QueueClient\Adapter\SQSAdapter($mockSqsClient);85        $this->exception(function() use($sqsAdapter) {86            $sqsAdapter->addMessages('testQueue', ['test message', '']);87        });88    }89    public function testSQSAdapterAddMessagesWithEmptyQueueName()90    {91        $this->mockGenerator->orphanize('__construct');92        $this->mockGenerator->shuntParentClassCalls();93        $mockSqsClient = new \mock\Aws\Sqs\SqsClient;94        $sqsAdapter = new \ReputationVIP\QueueClient\Adapter\SQSAdapter($mockSqsClient);95        $this->exception(function() use($sqsAdapter) {96            $sqsAdapter->addMessages('', ['']);97        });98    }99    public function testSQSAdapterAddMessagesWithSqsException()100    {101        $this->mockGenerator->orphanize('__construct');102        $this->mockGenerator->shuntParentClassCalls();103        $mockSqsClient = new \mock\Aws\Sqs\SqsClient;104        $mockQueueUrlModel = new \mock\Guzzle\Service\Resource\Model;105        $sqsAdapter = new \ReputationVIP\QueueClient\Adapter\SQSAdapter($mockSqsClient);106        $this->mockGenerator->orphanize('__construct');107        $this->mockGenerator->shuntParentClassCalls();108        $sqsException = new \mock\Aws\Sqs\Exception\SqsException;109        $mockSqsClient->getMockController()->getQueueUrl = function () use($mockQueueUrlModel) {110            return $mockQueueUrlModel;111        };112        $mockSqsClient->getMockController()->sendMessageBatch = function () use ($sqsException) {113            throw $sqsException;114        };115        $this->exception(function() use($sqsAdapter) {116            $sqsAdapter->addMessages('testQueue', array_fill(0, 11, 'test message'));117        });118    }119    public function testSQSAdapterGetMessagesWithEmptyQueueName()120    {121        $this->mockGenerator->orphanize('__construct');122        $this->mockGenerator->shuntParentClassCalls();123        $mockSqsClient = new \mock\Aws\Sqs\SqsClient;124        $sqsAdapter = new \ReputationVIP\QueueClient\Adapter\SQSAdapter($mockSqsClient);125        $this->exception(function() use($sqsAdapter) {126            $sqsAdapter->getMessages('');127        });128    }129    public function testSQSAdapterGetMessagesWithBadMessageNumber()130    {131        $this->mockGenerator->orphanize('__construct');132        $this->mockGenerator->shuntParentClassCalls();133        $mockSqsClient = new \mock\Aws\Sqs\SqsClient;134        $sqsAdapter = new \ReputationVIP\QueueClient\Adapter\SQSAdapter($mockSqsClient);135        $this->exception(function() use($sqsAdapter) {136            $sqsAdapter->getMessages('testQueue', 'BadNumber');137        });138        $this->exception(function() use($sqsAdapter) {139            $sqsAdapter->getMessages('testQueue', 0);140        });141        $this->exception(function() use($sqsAdapter) {142            $sqsAdapter->getMessages('testQueue', \ReputationVIP\QueueClient\Adapter\SQSAdapter::MAX_NB_MESSAGES + 1);143        });144    }145    public function testSQSAdapterGetMessagesWithNoMessage()146    {147        $this->mockGenerator->orphanize('__construct');148        $this->mockGenerator->shuntParentClassCalls();149        $mockSqsClient = new \mock\Aws\Sqs\SqsClient;150        $mockQueueUrlModel = new \mock\Guzzle\Service\Resource\Model;151        $sqsAdapter = new \ReputationVIP\QueueClient\Adapter\SQSAdapter($mockSqsClient);152        $mockSqsClient->getMockController()->getQueueUrl = function () use($mockQueueUrlModel) {153            return $mockQueueUrlModel;154        };155        $mockQueueUrlModel->getMockController()->get = function () use($mockQueueUrlModel) {156            return null;157        };158        $mockSqsClient->getMockController()->receiveMessage = function () use($mockQueueUrlModel) {159            return $mockQueueUrlModel;160        };161        $this->given($sqsAdapter)162            ->array($sqsAdapter->getMessages('testQueue', 5))->isEmpty();163    }164    public function testSQSAdapterGetMessagesWithSqsException()165    {166        $this->mockGenerator->orphanize('__construct');167        $this->mockGenerator->shuntParentClassCalls();168        $mockSqsClient = new \mock\Aws\Sqs\SqsClient;169        $mockQueueUrlModel = new \mock\Guzzle\Service\Resource\Model;170        $sqsAdapter = new \ReputationVIP\QueueClient\Adapter\SQSAdapter($mockSqsClient);171        $this->mockGenerator->orphanize('__construct');172        $this->mockGenerator->shuntParentClassCalls();173        $sqsException = new \mock\Aws\Sqs\Exception\SqsException;174        $mockSqsClient->getMockController()->getQueueUrl = function () use($mockQueueUrlModel) {175            return $mockQueueUrlModel;176        };177        $mockSqsClient->getMockController()->receiveMessage = function () use ($sqsException) {178            throw $sqsException;179        };180        $this->exception(function() use($sqsAdapter) {181            $sqsAdapter->getMessages('testQueue');182        });183    }184    public function testSQSAdapterGetMessages()185    {186        $this->mockGenerator->orphanize('__construct');187        $this->mockGenerator->shuntParentClassCalls();188        $mockSqsClient = new \mock\Aws\Sqs\SqsClient;189        $mockQueueUrlModel = new \mock\Guzzle\Service\Resource\Model;190        $priorityHandler = new ThreeLevelPriorityHandler();191        $sqsAdapter = new \ReputationVIP\QueueClient\Adapter\SQSAdapter($mockSqsClient, $priorityHandler);192        $mockSqsClient->getMockController()->getQueueUrl = function () use($mockQueueUrlModel) {193            return $mockQueueUrlModel;194        };195        $mockQueueUrlModel->getMockController()->get = function () use($mockQueueUrlModel) {196            return [['Body' => serialize('test message one')], ['Body' => serialize('test message two')]];197        };198        $mockSqsClient->getMockController()->receiveMessage = function () use($mockQueueUrlModel) {199            return $mockQueueUrlModel;200        };201        $this->given($sqsAdapter)202            ->array($sqsAdapter->getMessages('testQueue', 6))->hasSize(6);203    }204    public function testSQSAdapterDeleteMessageWithEmptyQueueName()205    {206        $this->mockGenerator->orphanize('__construct');207        $this->mockGenerator->shuntParentClassCalls();208        $mockSqsClient = new \mock\Aws\Sqs\SqsClient;209        $sqsAdapter = new \ReputationVIP\QueueClient\Adapter\SQSAdapter($mockSqsClient);210        $this->exception(function() use($sqsAdapter) {211            $sqsAdapter->deleteMessage('', []);212        });213    }214    public function testSQSAdapterDeleteMessageWithEmptyMessage()215    {216        $this->mockGenerator->orphanize('__construct');217        $this->mockGenerator->shuntParentClassCalls();218        $mockSqsClient = new \mock\Aws\Sqs\SqsClient;219        $sqsAdapter = new \ReputationVIP\QueueClient\Adapter\SQSAdapter($mockSqsClient);220        $this->exception(function() use($sqsAdapter) {221            $sqsAdapter->deleteMessage('testQueue', []);222        });223    }224    public function testSQSAdapterDeleteMessageWithBadMessage()225    {226        $this->mockGenerator->orphanize('__construct');227        $this->mockGenerator->shuntParentClassCalls();228        $mockSqsClient = new \mock\Aws\Sqs\SqsClient;229        $sqsAdapter = new \ReputationVIP\QueueClient\Adapter\SQSAdapter($mockSqsClient);230        $this->exception(function() use($sqsAdapter) {231            $sqsAdapter->deleteMessage('testQueue', 'Bad message');232        });233    }234    public function testSQSAdapterDeleteMessageWithNoMessageReceiptHandle()235    {236        $this->mockGenerator->orphanize('__construct');237        $this->mockGenerator->shuntParentClassCalls();238        $mockSqsClient = new \mock\Aws\Sqs\SqsClient;239        $priorityHandler = new ThreeLevelPriorityHandler();240        $sqsAdapter = new \ReputationVIP\QueueClient\Adapter\SQSAdapter($mockSqsClient, $priorityHandler);241        $this->exception(function() use($sqsAdapter, $priorityHandler) {242            $sqsAdapter->deleteMessage('testQueue', ['priority' => $priorityHandler->getHighest()]);243        });244    }245    public function testSQSAdapterDeleteMessageWithNoMessagePriority()246    {247        $this->mockGenerator->orphanize('__construct');248        $this->mockGenerator->shuntParentClassCalls();249        $mockSqsClient = new \mock\Aws\Sqs\SqsClient;250        $sqsAdapter = new \ReputationVIP\QueueClient\Adapter\SQSAdapter($mockSqsClient);251        $this->exception(function() use($sqsAdapter) {252            $sqsAdapter->deleteMessage('testQueue', ['ReceiptHandle' => 'testReceiptHandle']);253        });254    }255    public function testSQSAdapterDeleteMessageWithSqsException()256    {257        $this->mockGenerator->orphanize('__construct');258        $this->mockGenerator->shuntParentClassCalls();259        $mockSqsClient = new \mock\Aws\Sqs\SqsClient;260        $mockQueueUrlModel = new \mock\Guzzle\Service\Resource\Model;261        $priorityHandler = new ThreeLevelPriorityHandler();262        $sqsAdapter = new \ReputationVIP\QueueClient\Adapter\SQSAdapter($mockSqsClient, $priorityHandler);263        $this->mockGenerator->orphanize('__construct');264        $this->mockGenerator->shuntParentClassCalls();265        $sqsException = new \mock\Aws\Sqs\Exception\SqsException;266        $mockSqsClient->getMockController()->getQueueUrl = function () use($mockQueueUrlModel) {267            return $mockQueueUrlModel;268        };269        $mockQueueUrlModel->getMockController()->get = function () use($mockQueueUrlModel) {270            return null;271        };272        $mockSqsClient->getMockController()->deleteMessage = function () use ($sqsException) {273            throw $sqsException;274        };275        $this->exception(function() use($sqsAdapter, $priorityHandler) {276            $sqsAdapter->deleteMessage('testQueue', ['priority' => $priorityHandler->getHighest()->getLevel(), 'ReceiptHandle' => 'testReceiptHandle']);277        });278    }279    public function testSQSAdapterDeleteMessage()280    {281        $this->mockGenerator->orphanize('__construct');282        $this->mockGenerator->shuntParentClassCalls();283        $mockSqsClient = new \mock\Aws\Sqs\SqsClient;284        $mockQueueUrlModel = new \mock\Guzzle\Service\Resource\Model;285        $priorityHandler = new ThreeLevelPriorityHandler();286        $sqsAdapter = new \ReputationVIP\QueueClient\Adapter\SQSAdapter($mockSqsClient);287        $mockSqsClient->getMockController()->getQueueUrl = function () use($mockQueueUrlModel) {288            return $mockQueueUrlModel;289        };290        $mockQueueUrlModel->getMockController()->get = function () use($mockQueueUrlModel) {291            return null;292        };293        $mockSqsClient->getMockController()->deleteMessage = function () use($mockQueueUrlModel) {294            return null;295        };296        $this->given($sqsAdapter)297            ->class($sqsAdapter->deleteMessage('testQueue', ['priority' => $priorityHandler->getHighest()->getLevel(), 'ReceiptHandle' => 'testReceiptHandle']))->hasInterface('\ReputationVIP\QueueClient\Adapter\AdapterInterface');298    }299    public function testSQSAdapterIsEmptyWithEmptyQueueName()300    {301        $this->mockGenerator->orphanize('__construct');302        $this->mockGenerator->shuntParentClassCalls();303        $mockSqsClient = new \mock\Aws\Sqs\SqsClient;304        $sqsAdapter = new \ReputationVIP\QueueClient\Adapter\SQSAdapter($mockSqsClient);305        $this->exception(function() use($sqsAdapter) {306            $sqsAdapter->isEmpty('');307        });308    }309    public function testSQSAdapterIsEmptyWithEmptyQueue()310    {311        $this->mockGenerator->orphanize('__construct');312        $this->mockGenerator->shuntParentClassCalls();313        $mockSqsClient = new \mock\Aws\Sqs\SqsClient;314        $mockQueueUrlModel = new \mock\Guzzle\Service\Resource\Model;315        $sqsAdapter = new \ReputationVIP\QueueClient\Adapter\SQSAdapter($mockSqsClient);316        $mockSqsClient->getMockController()->getQueueUrl = function () use($mockQueueUrlModel) {317            return $mockQueueUrlModel;318        };319        $mockQueueUrlModel->getMockController()->get = function () use($mockQueueUrlModel) {320            return [['name' => 'ApproximateNumberOfMessages', 'value' => 0]];321        };322        $mockSqsClient->getMockController()->getQueueAttributes = function () use($mockQueueUrlModel) {323            return $mockQueueUrlModel;324        };325        $this->given($sqsAdapter)326            ->boolean($sqsAdapter->isEmpty('testQueue'))->IsTrue();327    }328    public function testSQSAdapterIsEmptyWithSqsException()329    {330        $this->mockGenerator->orphanize('__construct');331        $this->mockGenerator->shuntParentClassCalls();332        $mockSqsClient = new \mock\Aws\Sqs\SqsClient;333        $mockQueueUrlModel = new \mock\Guzzle\Service\Resource\Model;334        $sqsAdapter = new \ReputationVIP\QueueClient\Adapter\SQSAdapter($mockSqsClient);335        $this->mockGenerator->orphanize('__construct');336        $this->mockGenerator->shuntParentClassCalls();337        $sqsException = new \mock\Aws\Sqs\Exception\SqsException;338        $mockSqsClient->getMockController()->getQueueUrl = function () use($mockQueueUrlModel) {339            return $mockQueueUrlModel;340        };341        $mockSqsClient->getMockController()->getQueueAttributes = function () use ($sqsException) {342            throw $sqsException;343        };344        $this->exception(function() use($sqsAdapter) {345            $sqsAdapter->isEmpty('testQueue');346        });347    }348    public function testSQSAdapterIsEmpty()349    {350        $this->mockGenerator->orphanize('__construct');351        $this->mockGenerator->shuntParentClassCalls();352        $mockSqsClient = new \mock\Aws\Sqs\SqsClient;353        $mockQueueUrlModel = new \mock\Guzzle\Service\Resource\Model;354        $sqsAdapter = new \ReputationVIP\QueueClient\Adapter\SQSAdapter($mockSqsClient);355        $mockSqsClient->getMockController()->getQueueUrl = function () use($mockQueueUrlModel) {356            return $mockQueueUrlModel;357        };358        $mockQueueUrlModel->getMockController()->get = function () use($mockQueueUrlModel) {359            return ['ApproximateNumberOfMessages' => 6];360        };361        $mockSqsClient->getMockController()->getQueueAttributes = function () use($mockQueueUrlModel) {362            return $mockQueueUrlModel;363        };364        $this->given($sqsAdapter)365            ->boolean($sqsAdapter->isEmpty('testQueue'))->IsFalse();366    }367    public function testSQSAdapterGetNumberMessagesWithEmptyQueueName()368    {369        $this->mockGenerator->orphanize('__construct');370        $this->mockGenerator->shuntParentClassCalls();371        $mockSqsClient = new \mock\Aws\Sqs\SqsClient;372        $sqsAdapter = new \ReputationVIP\QueueClient\Adapter\SQSAdapter($mockSqsClient);373        $this->exception(function() use($sqsAdapter) {374            $sqsAdapter->getNumberMessages('');375        });376    }377    public function testSQSAdapterGetNumberMessagesWithEmptyQueue()378    {379        $this->mockGenerator->orphanize('__construct');380        $this->mockGenerator->shuntParentClassCalls();381        $mockSqsClient = new \mock\Aws\Sqs\SqsClient;382        $mockQueueUrlModel = new \mock\Guzzle\Service\Resource\Model;383        $sqsAdapter = new \ReputationVIP\QueueClient\Adapter\SQSAdapter($mockSqsClient);384        $mockSqsClient->getMockController()->getQueueUrl = function () use($mockQueueUrlModel) {385            return $mockQueueUrlModel;386        };387        $mockQueueUrlModel->getMockController()->get = function () use($mockQueueUrlModel) {388            return [['name' => 'ApproximateNumberOfMessages', 'value' => 0]];389        };390        $mockSqsClient->getMockController()->getQueueAttributes = function () use($mockQueueUrlModel) {391            return $mockQueueUrlModel;392        };393        $this->given($sqsAdapter)394            ->integer($sqsAdapter->getNumberMessages('testQueue'))->IsEqualTo(0);395    }396    public function testSQSAdapterGetNumberMessagesWithSqsException()397    {398        $this->mockGenerator->orphanize('__construct');399        $this->mockGenerator->shuntParentClassCalls();400        $mockSqsClient = new \mock\Aws\Sqs\SqsClient;401        $mockQueueUrlModel = new \mock\Guzzle\Service\Resource\Model;402        $sqsAdapter = new \ReputationVIP\QueueClient\Adapter\SQSAdapter($mockSqsClient);403        $this->mockGenerator->orphanize('__construct');404        $this->mockGenerator->shuntParentClassCalls();405        $sqsException = new \mock\Aws\Sqs\Exception\SqsException;406        $mockSqsClient->getMockController()->getQueueUrl = function () use($mockQueueUrlModel) {407            return $mockQueueUrlModel;408        };409        $mockSqsClient->getMockController()->getQueueAttributes = function () use ($sqsException) {410            throw $sqsException;411        };412        $this->exception(function() use($sqsAdapter) {413            $sqsAdapter->getNumberMessages('testQueue');414        });415    }416    public function testSQSAdapterGetNumberMessages()417    {418        $this->mockGenerator->orphanize('__construct');419        $this->mockGenerator->shuntParentClassCalls();420        $mockSqsClient = new \mock\Aws\Sqs\SqsClient;421        $mockQueueUrlModel = new \mock\Guzzle\Service\Resource\Model;422        $priorityHandler =new ThreeLevelPriorityHandler();423        $sqsAdapter = new \ReputationVIP\QueueClient\Adapter\SQSAdapter($mockSqsClient, $priorityHandler);424        $mockSqsClient->getMockController()->getQueueUrl = function () use($mockQueueUrlModel) {425            return $mockQueueUrlModel;426        };427        $mockQueueUrlModel->getMockController()->get = function () use($mockQueueUrlModel) {428            return ['ApproximateNumberOfMessages' => 6];429        };430        $mockSqsClient->getMockController()->getQueueAttributes = function () use($mockQueueUrlModel) {431            return $mockQueueUrlModel;432        };433        $this->given($sqsAdapter)434            ->integer($sqsAdapter->getNumberMessages('testQueue'))->IsEqualTo(18);435    }436    public function testSQSAdapterDeleteQueueWithEmptyQueueName()437    {438        $this->mockGenerator->orphanize('__construct');439        $this->mockGenerator->shuntParentClassCalls();440        $mockSqsClient = new \mock\Aws\Sqs\SqsClient;441        $sqsAdapter = new \ReputationVIP\QueueClient\Adapter\SQSAdapter($mockSqsClient);442        $this->exception(function() use($sqsAdapter) {443            $sqsAdapter->deleteQueue('');444        });445    }446    public function testSQSAdapterDeleteQueueWithSqsException()447    {448        $this->mockGenerator->orphanize('__construct');449        $this->mockGenerator->shuntParentClassCalls();450        $mockSqsClient = new \mock\Aws\Sqs\SqsClient;451        $mockQueueUrlModel = new \mock\Guzzle\Service\Resource\Model;452        $sqsAdapter = new \ReputationVIP\QueueClient\Adapter\SQSAdapter($mockSqsClient);453        $this->mockGenerator->orphanize('__construct');454        $this->mockGenerator->shuntParentClassCalls();455        $sqsException = new \mock\Aws\Sqs\Exception\SqsException;456        $mockSqsClient->getMockController()->getQueueUrl = function () use($mockQueueUrlModel) {457            return $mockQueueUrlModel;458        };459        $mockSqsClient->getMockController()->deleteQueue = function () use ($sqsException) {460            throw $sqsException;461        };462        $this->exception(function() use($sqsAdapter) {463            $sqsAdapter->deleteQueue('testQueue');464        });465    }466    public function testSQSAdapterDeleteQueue()467    {468        $this->mockGenerator->orphanize('__construct');469        $this->mockGenerator->shuntParentClassCalls();470        $mockSqsClient = new \mock\Aws\Sqs\SqsClient;471        $mockQueueUrlModel = new \mock\Guzzle\Service\Resource\Model;472        $sqsAdapter = new \ReputationVIP\QueueClient\Adapter\SQSAdapter($mockSqsClient);473        $mockSqsClient->getMockController()->getQueueUrl = function () use($mockQueueUrlModel) {474            return $mockQueueUrlModel;475        };476        $mockQueueUrlModel->getMockController()->get = function () use($mockQueueUrlModel) {477            return null;478        };479        $mockSqsClient->getMockController()->deleteQueue = function () use($mockQueueUrlModel) {480            return $mockQueueUrlModel;481        };482        $this->given($sqsAdapter)483            ->class($sqsAdapter->deleteQueue('testQueue'))->hasInterface('\ReputationVIP\QueueClient\Adapter\AdapterInterface');484    }485    public function testSQSAdapterCreateQueueWithEmptyQueueName()486    {487        $this->mockGenerator->orphanize('__construct');488        $this->mockGenerator->shuntParentClassCalls();489        $mockSqsClient = new \mock\Aws\Sqs\SqsClient;490        $sqsAdapter = new \ReputationVIP\QueueClient\Adapter\SQSAdapter($mockSqsClient);491        $this->exception(function() use($sqsAdapter) {492            $sqsAdapter->createQueue('');493        });494    }495    public function testSQSAdapterCreateQueueWithSqsException()496    {497        $this->mockGenerator->orphanize('__construct');498        $this->mockGenerator->shuntParentClassCalls();499        $mockSqsClient = new \mock\Aws\Sqs\SqsClient;500        $mockQueueUrlModel = new \mock\Guzzle\Service\Resource\Model;501        $sqsAdapter = new \ReputationVIP\QueueClient\Adapter\SQSAdapter($mockSqsClient);502        $this->mockGenerator->orphanize('__construct');503        $this->mockGenerator->shuntParentClassCalls();504        $sqsException = new \mock\Aws\Sqs\Exception\SqsException;505        $mockSqsClient->getMockController()->getQueueUrl = function () use($mockQueueUrlModel) {506            return $mockQueueUrlModel;507        };508        $mockSqsClient->getMockController()->createQueue = function () use ($sqsException) {509            throw $sqsException;510        };511        $this->exception(function() use($sqsAdapter) {512            $sqsAdapter->createQueue('testQueue');513        });514    }515    public function testSQSAdapterCreateQueue()516    {517        $this->mockGenerator->orphanize('__construct');518        $this->mockGenerator->shuntParentClassCalls();519        $mockSqsClient = new \mock\Aws\Sqs\SqsClient;520        $mockQueueUrlModel = new \mock\Guzzle\Service\Resource\Model;521        $sqsAdapter = new \ReputationVIP\QueueClient\Adapter\SQSAdapter($mockSqsClient);522        $mockSqsClient->getMockController()->getQueueUrl = function () use($mockQueueUrlModel) {523            return $mockQueueUrlModel;524        };525        $mockQueueUrlModel->getMockController()->get = function () use($mockQueueUrlModel) {526            return null;527        };528        $mockSqsClient->getMockController()->createQueue = function () use($mockQueueUrlModel) {529            return $mockQueueUrlModel;530        };531        $this->given($sqsAdapter)532            ->class($sqsAdapter->createQueue('testQueue'))->hasInterface('\ReputationVIP\QueueClient\Adapter\AdapterInterface');533    }534    public function testSQSAdapterPurgeQueueWithEmptyQueueName()535    {536        $this->mockGenerator->orphanize('__construct');537        $this->mockGenerator->shuntParentClassCalls();538        $mockSqsClient = new \mock\Aws\Sqs\SqsClient;539        $sqsAdapter = new \ReputationVIP\QueueClient\Adapter\SQSAdapter($mockSqsClient);540        $this->exception(function() use($sqsAdapter) {541            $sqsAdapter->purgeQueue('');542        });543    }544    public function testSQSAdapterPurgeQueueWithSqsException()545    {546        $this->mockGenerator->orphanize('__construct');547        $this->mockGenerator->shuntParentClassCalls();548        $mockSqsClient = new \mock\Aws\Sqs\SqsClient;549        $mockQueueUrlModel = new \mock\Guzzle\Service\Resource\Model;550        $sqsAdapter = new \ReputationVIP\QueueClient\Adapter\SQSAdapter($mockSqsClient);551        $this->mockGenerator->orphanize('__construct');552        $this->mockGenerator->shuntParentClassCalls();553        $sqsException = new \mock\Aws\Sqs\Exception\SqsException;554        $mockSqsClient->getMockController()->getQueueUrl = function () use($mockQueueUrlModel) {555            return $mockQueueUrlModel;556        };557        $mockSqsClient->getMockController()->purgeQueue = function () use ($sqsException) {558            throw $sqsException;559        };560        $this->exception(function() use($sqsAdapter) {561            $sqsAdapter->purgeQueue('testQueue');562        });563    }564    public function testSQSAdapterPurgeQueue()565    {566        $this->mockGenerator->orphanize('__construct');567        $this->mockGenerator->shuntParentClassCalls();568        $mockSqsClient = new \mock\Aws\Sqs\SqsClient;569        $mockQueueUrlModel = new \mock\Guzzle\Service\Resource\Model;570        $sqsAdapter = new \ReputationVIP\QueueClient\Adapter\SQSAdapter($mockSqsClient);571        $mockSqsClient->getMockController()->getQueueUrl = function () use($mockQueueUrlModel) {572            return $mockQueueUrlModel;573        };574        $mockQueueUrlModel->getMockController()->get = function () use($mockQueueUrlModel) {575            return null;576        };577        $mockSqsClient->getMockController()->purgeQueue = function () use($mockQueueUrlModel) {578            return $mockQueueUrlModel;579        };580        $this->given($sqsAdapter)581            ->class($sqsAdapter->purgeQueue('testQueue'))->hasInterface('\ReputationVIP\QueueClient\Adapter\AdapterInterface');582    }583    public function testSQSAdapterListQueuesWithPrefix()584    {585        $this->mockGenerator->orphanize('__construct');586        $this->mockGenerator->shuntParentClassCalls();587        $mockSqsClient = new \mock\Aws\Sqs\SqsClient;588        $mockQueueUrlModel = new \mock\Guzzle\Service\Resource\Model;589        $priorityHandler = new ThreeLevelPriorityHandler();590        $sqsAdapter = new \ReputationVIP\QueueClient\Adapter\SQSAdapter($mockSqsClient, $priorityHandler);591        $mockSqsClient->getMockController()->getQueueUrl = function () use($mockQueueUrlModel) {592            return $mockQueueUrlModel;593        };594        $mockQueueUrlModel->getMockController()->get = function () use($mockQueueUrlModel) {595            return ['prefixTestQueueOne-HIGH', 'prefixTestQueueOne-MID', 'prefixTestQueueOne-LOW', 'prefixTestQueueTwo-HIGH', 'prefixTestQueueTwo-MID', 'prefixTestQueueTwo-LOW'];596        };597        $mockSqsClient->getMockController()->listQueues = function () use($mockQueueUrlModel) {598            return $mockQueueUrlModel;599        };600        $this->given($sqsAdapter)601            ->array($sqsAdapter->listQueues('prefix'))->containsValues(['prefixTestQueueOne', 'prefixTestQueueTwo']);602    }603    public function testSQSAdapterListQueuesWithSqsException()604    {605        $this->mockGenerator->orphanize('__construct');606        $this->mockGenerator->shuntParentClassCalls();607        $mockSqsClient = new \mock\Aws\Sqs\SqsClient;608        $mockQueueUrlModel = new \mock\Guzzle\Service\Resource\Model;609        $sqsAdapter = new \ReputationVIP\QueueClient\Adapter\SQSAdapter($mockSqsClient);610        $this->mockGenerator->orphanize('__construct');611        $this->mockGenerator->shuntParentClassCalls();612        $sqsException = new \mock\Aws\Sqs\Exception\SqsException;613        $mockSqsClient->getMockController()->getQueueUrl = function () use($mockQueueUrlModel) {614            return $mockQueueUrlModel;615        };616        $mockSqsClient->getMockController()->listQueues = function () use ($sqsException) {617            throw $sqsException;618        };619        $this->exception(function() use($sqsAdapter) {620            $sqsAdapter->listQueues();621        });622    }623    public function testSQSAdapterListQueues()624    {625        $this->mockGenerator->orphanize('__construct');626        $this->mockGenerator->shuntParentClassCalls();627        $mockSqsClient = new \mock\Aws\Sqs\SqsClient;628        $mockQueueUrlModel = new \mock\Guzzle\Service\Resource\Model;629        $priorityHandler = new ThreeLevelPriorityHandler();630        $sqsAdapter = new \ReputationVIP\QueueClient\Adapter\SQSAdapter($mockSqsClient, $priorityHandler);631        $mockSqsClient->getMockController()->getQueueUrl = function () use($mockQueueUrlModel) {632            return $mockQueueUrlModel;633        };634        $mockQueueUrlModel->getMockController()->get = function () use($mockQueueUrlModel) {635            return ['testQueueOne-HIGH', 'testQueueOne-MID', 'testQueueOne-LOW', 'prefixTestQueueOne-HIGH', 'prefixTestQueueOne-MID', 'prefixTestQueueOne-LOW', 'prefixTestQueueTwo-HIGH', 'prefixTestQueueTwo-MID', 'prefixTestQueueTwo-LOW'];636        };637        $mockSqsClient->getMockController()->listQueues = function () use($mockQueueUrlModel) {638            return $mockQueueUrlModel;639        };640        $this->given($sqsAdapter)641            ->array($sqsAdapter->listQueues())->containsValues(['testQueueOne', 'prefixTestQueueOne', 'prefixTestQueueTwo']);642    }643    public function testSQSAdapterRenameQueueWithEmptySourceQueueName()644    {645        $this->mockGenerator->orphanize('__construct');646        $this->mockGenerator->shuntParentClassCalls();647        $mockSqsClient = new \mock\Aws\Sqs\SqsClient;648        $sqsAdapter = new \ReputationVIP\QueueClient\Adapter\SQSAdapter($mockSqsClient);649        $this->exception(function() use($sqsAdapter) {650            $sqsAdapter->renameQueue('', 'targetQueue');651        });652    }653    public function testSQSAdapterRenameQueueWithEmptyTargetQueueName()654    {655        $this->mockGenerator->orphanize('__construct');656        $this->mockGenerator->shuntParentClassCalls();657        $mockSqsClient = new \mock\Aws\Sqs\SqsClient;658        $sqsAdapter = new \ReputationVIP\QueueClient\Adapter\SQSAdapter($mockSqsClient);659        $this->exception(function() use($sqsAdapter) {660            $sqsAdapter->renameQueue('sourceQueue', '');661        });662    }663    public function testSQSAdapterRenameQueue()664    {665        $this->mockGenerator->orphanize('__construct');666        $this->mockGenerator->shuntParentClassCalls();667        $mockSqsClient = new \mock\Aws\Sqs\SqsClient;668        $mockQueueUrlModel = new \mock\Guzzle\Service\Resource\Model;669        $priorityHandler = new ThreeLevelPriorityHandler();670        $sqsAdapter = new \ReputationVIP\QueueClient\Adapter\SQSAdapter($mockSqsClient, $priorityHandler);671        $mockSqsClient->getMockController()->getQueueUrl = function () use($mockQueueUrlModel) {672            return $mockQueueUrlModel;673        };674        $mockSqsClient->getMockController()->listQueues = function () use($mockQueueUrlModel) {675            return $mockQueueUrlModel;676        };677        $mockSqsClient->getMockController()->sendMessage = function () use($mockQueueUrlModel) {678        };679        $mockQueueUrlModel->getMockController()->get = function ($attr) use($mockQueueUrlModel, $priorityHandler) {680            if ($attr === 'Messages')681            {682                static $i = true;683                if ($i) {684                    $i = false;685                    return [['priority' => $priorityHandler->getHighest(), 'ReceiptHandle' => 'testReceiptHandle', 'Body' => serialize('test message one')], ['priority' => $priorityHandler->getHighest(), 'ReceiptHandle' => 'testReceiptHandle', 'Body' => serialize('test message two')]];686                } else {687                    $i = true;688                    return [];689                }690            }691            return null;692        };693        $mockSqsClient->getMockController()->receiveMessage = function () use($mockQueueUrlModel) {694            return $mockQueueUrlModel;695        };696        $mockSqsClient->getMockController()->deleteMessage = function () use($mockQueueUrlModel) {697        };698        $mockSqsClient->getMockController()->createQueue = function () use($mockQueueUrlModel) {699        };700        $mockSqsClient->getMockController()->deleteQueue = function () use($mockQueueUrlModel) {701        };702        $this->given($sqsAdapter)703            ->class($sqsAdapter->renameQueue('sourceQueue', 'targetQueue'))->hasInterface('\ReputationVIP\QueueClient\Adapter\AdapterInterface');704    }705    public function testSQSAdapterGetPrioritiesHandler()706    {707        $this->mockGenerator->orphanize('__construct');708        $this->mockGenerator->shuntParentClassCalls();709        $mockSqsClient = new \mock\Aws\Sqs\SqsClient;710        $mockQueueUrlModel = new \mock\Guzzle\Service\Resource\Model;711        $sqsAdapter = new \ReputationVIP\QueueClient\Adapter\SQSAdapter($mockSqsClient);712        $mockSqsClient->getMockController()->getQueueUrl = function () use($mockQueueUrlModel) {713            return $mockQueueUrlModel;714        };715        $mockQueueUrlModel->getMockController()->get = function () use($mockQueueUrlModel) {716            return null;717        };718        $mockSqsClient->getMockController()->purgeQueue = function () use($mockQueueUrlModel) {719            return $mockQueueUrlModel;720        };721        $this->given($sqsAdapter)722            ->class($sqsAdapter->getPriorityHandler())->hasInterface('\ReputationVIP\QueueClient\PriorityHandler\PriorityHandlerInterface');723    }724    public function testMalformedMessageException()725    {726        $this->mockGenerator->orphanize('__construct');727        $this->mockGenerator->shuntParentClassCalls();728        $mockSqsClient = new \mock\Aws\Sqs\SqsClient;729        $mockQueueUrlModel = new \mock\Guzzle\Service\Resource\Model;730        $priorityHandler = new ThreeLevelPriorityHandler();731        $sqsAdapter = new \ReputationVIP\QueueClient\Adapter\SQSAdapter($mockSqsClient, $priorityHandler);732        $mockSqsClient->getMockController()->getQueueUrl = function () use($mockQueueUrlModel) {733            return $mockQueueUrlModel;734        };735        $mockQueueUrlModel->getMockController()->get = function () use($mockQueueUrlModel) {736            return [['Body' => 'test message one']];737        };738        $mockSqsClient->getMockController()->receiveMessage = function () use($mockQueueUrlModel) {739            return $mockQueueUrlModel;740        };741        $this->exception(function() use($sqsAdapter) {...

Event.php

Source:Event.php

...7{8    public function testConstruct()9    {10        $this11            ->if($this->mockGenerator->shuntParentClassCalls())12            ->and($request = new \mock\Philip\IRC\Request($raw = uniqid()))13            ->then14                ->object($object = new TestedClass($request))->isInstanceOf('\\Philip\\IRC\\Event')15                ->array($object->getMatches())->isEmpty()16                ->array($object->getResponses())->isEmpty()17        ;18    }19    public function testSetMatches()20    {21        $this22            ->if($this->mockGenerator->shuntParentClassCalls())23            ->and($request = new \mock\Philip\IRC\Request($raw = uniqid()))24            ->and($object = new TestedClass($request))25            ->and($matches = array(uniqid(), uniqid()))26            ->then27                ->object($object->setMatches($matches))->isIdenticalTo($object)28                ->array($object->getMatches())->isEqualTo($matches)29        ;30    }31    public function testGetMatches()32    {33        $this34            ->if($this->mockGenerator->shuntParentClassCalls())35            ->and($request = new \mock\Philip\IRC\Request($raw = uniqid()))36            ->and($object = new TestedClass($request))37            ->and($matches = array(uniqid(), uniqid()))38            ->then39                ->array($object->getMatches())->isEqualTo(array())40            ->if($object->setMatches($matches))41            ->then42                ->array($object->getMatches())->isEqualTo($matches)43        ;44    }45    public function testGetRequest()46    {47        $this48            ->if($this->mockGenerator->shuntParentClassCalls())49            ->and($request = new \mock\Philip\IRC\Request($raw = uniqid()))50            ->and($object = new TestedClass($request))51            ->then52                ->object($object->getRequest())->isIdenticalTo($request)53        ;54    }55    public function testAddResponse()56    {57        $this58            ->if($this->mockGenerator->shuntParentClassCalls())59            ->and($request = new \mock\Philip\IRC\Request($raw = uniqid()))60            ->and($response = new \Philip\IRC\Response(uniqid()))61            ->and($object = new TestedClass($request))62            ->then63                ->object($object->addResponse($response))->isIdenticalTo($object)64                ->array($object->getResponses())->isEqualTo(array($response))65            ->if($otherResponse = new \Philip\IRC\Response(uniqid()))66            ->and($object->addResponse($otherResponse))67            ->then68                ->array($object->getResponses())->isEqualTo(array($response, $otherResponse))69        ;70    }71    public function testGetResponses()72    {73        $this74            ->if($this->mockGenerator->shuntParentClassCalls())75            ->and($request = new \mock\Philip\IRC\Request($raw = uniqid()))76            ->and($object = new TestedClass($request))77            ->and($matches = array(uniqid(), uniqid()))78            ->then79                ->array($object->getResponses())->isEmpty()80            ->if($response = new \Philip\IRC\Response(uniqid()))81            ->and($object->addResponse($response))82            ->then83                ->array($object->getResponses())->isEqualTo(array($response))84            ->if($otherResponse = new \Philip\IRC\Response(uniqid()))85            ->and($object->addResponse($otherResponse))86            ->then87                ->array($object->getResponses())->isEqualTo(array($response, $otherResponse))88        ;...

shunt

Using AI Code Generation

1$generator = new Generator();2$generator->setShunt(true);3$generator->generate();4$generator = new Generator();5$generator->generate();6setShunt($bool)7getShunt()8generate()

shunt

Using AI Code Generation

1$gen = new Generator();2$gen->shunt($a,$b);3$gen->parallel($a,$b);4$gen->series($a,$b);5class Generator{6function shunt($a,$b){7$z = $a+$b;8echo "Shunt method of calculation is ".$z;9}10function parallel($a,$b){11$z = (1/$a)+(1/$b);12echo "Parallel method of calculation is ".$z;13}14function series($a,$b){15$z = $a*$b;16echo "Series method of calculation is ".$z;17}18}19PHP | Convert string to array using explode() function20PHP | Convert string to array using str_split() function

shunt

Using AI Code Generation

1require_once("generator.php");2$gen = new generator;3$gen->shunt("1.php");4require_once("generator.php");5$gen = new generator;6$gen->shunt("2.php");7require_once("generator.php");8$gen = new generator;9$gen->shunt("3.php");10require_once("generator.php");11$gen = new generator;12$gen->shunt("4.php");13require_once("generator.php");14$gen = new generator;15$gen->shunt("5.php");16require_once("generator.php");17$gen = new generator;18$gen->shunt("6.php");19require_once("generator.php");20$gen = new generator;21$gen->shunt("7.php");22require_once("generator.php");23$gen = new generator;24$gen->shunt("8.php");25require_once("generator.php");26$gen = new generator;27$gen->shunt("9.php");28require_once("generator.php");29$gen = new generator;30$gen->shunt("10.php");31require_once("generator.php");32$gen = new generator;33$gen->shunt("11.php");34require_once("generator.php");35$gen = new generator;36$gen->shunt("12.php");

shunt

Using AI Code Generation

1require_once 'Generator.php';2$gen = new Generator();3$gen->setShunt(1);4$gen->setShunt(2);5$gen->setShunt(3);6$gen->setShunt(4);7$gen->setShunt(5);8$gen->setShunt(6);9$gen->setShunt(7);10$gen->setShunt(8);11$gen->setShunt(9);12$gen->setShunt(10);13$gen->setShunt(11);14$gen->setShunt(12);15$gen->setShunt(13);16$gen->setShunt(14);17$gen->setShunt(15);18$gen->setShunt(16);19$gen->setShunt(17);20$gen->setShunt(18);21$gen->setShunt(19);22$gen->setShunt(20);23$gen->setShunt(21);24$gen->setShunt(22);25$gen->setShunt(23);26$gen->setShunt(24);27$gen->setShunt(25);28$gen->setShunt(26);29$gen->setShunt(27);30$gen->setShunt(28);31$gen->setShunt(29);32$gen->setShunt(30);33$gen->setShunt(31);34$gen->setShunt(32);35$gen->setShunt(33);36$gen->setShunt(34);37$gen->setShunt(35);38$gen->setShunt(36);39$gen->setShunt(37);40$gen->setShunt(38);41$gen->setShunt(39);42$gen->setShunt(40);43$gen->setShunt(41);44$gen->setShunt(42);45$gen->setShunt(43);46$gen->setShunt(44);47$gen->setShunt(45);48$gen->setShunt(46);49$gen->setShunt(47);50$gen->setShunt(48);51$gen->setShunt(49);52$gen->setShunt(50);53$gen->setShunt(51);54$gen->setShunt(52);55$gen->setShunt(

shunt

Using AI Code Generation

1$gen = new Generator();2$gen->shunt();3$gen = new Generator();4$gen->useGenerator();5$gen = new Generator();6$gen->useGenerator();7$gen = new Generator();8$gen->useGenerator();9$gen = new Generator();10$gen->useGenerator();11$gen = new Generator();12$gen->useGenerator();13$gen = new Generator();14$gen->useGenerator();15$gen = new Generator();16$gen->useGenerator();17$gen = new Generator();18$gen->useGenerator();19$gen = new Generator();20$gen->useGenerator();21$gen = new Generator();22$gen->useGenerator();23$gen = new Generator();24$gen->useGenerator();25$gen = new Generator();26$gen->useGenerator();27$gen = new Generator();28$gen->useGenerator();29$gen = new Generator();30$gen->useGenerator();31$gen = new Generator();32$gen->useGenerator();

shunt

Using AI Code Generation

1include("generator.php");2$gen=new generator();3$gen->shunt(1,100);4echo $gen->result;51. shunt($min,$max)62. shuffle($min,$max)73. random($min,$max)

shunt

Using AI Code Generation

1$gen = new Generator();2$gen->shunt($array);3foreach($gen as $value)4{5    echo $value;6}7$gen = new Generator();8$gen->rewind($array);9foreach($gen as $value)10{11    echo $value;12}13$gen = new Generator();14$gen->rewind($array);15for($i = 0; $i < count($array); $i++)16{17    echo $gen->current();18    $gen->next();19}20$gen = new Generator();21$gen->rewind($array);22$i = 0;23while($i < count($array))24{25    echo $gen->current();26    $gen->next();27    $i++;28}29$gen = new Generator();30$gen->rewind($array);31$i = 0;32{33    echo $gen->current();34    $gen->next();35    $i++;36}while($i < count($array));37$gen = new Generator();38$gen->rewind($array);39$i = 0;40{41    echo $gen->current();42    $gen->next();43    $i++;44}while($i < count($array));45$gen = new Generator();46$gen->rewind($array);47$i = 0;48{49    echo $gen->current();50    $gen->next();51    $i++;52}while($i < count($array));

shunt

Using AI Code Generation

1include 'generator.php';2$gen = new generator();3$gen->shunt();4$gen->write();5include '1.html';6class generator{7    public function shunt(){8    }9    public function write(){10    }11}12include 'generator.php';13$gen = new generator();14$gen->shunt();15$gen->write();16include '3.html';17class generator{18    public function shunt(){19    }20    public function write(){21    }22}

Automation Testing Tutorials

Learn to execute automation testing from scratch with LambdaTest Learning Hub. Right from setting up the prerequisites to run your first automation test, to following best practices and diving deeper into advanced test scenarios. LambdaTest Learning Hubs compile a list of step-by-step guides to help you be proficient with different test automation frameworks i.e. Selenium, Cypress, TestNG etc.