Added unit tests for default recoverable exception handlers.

Author: Bilge

test/Unit/Connector/Recoverable/ExponentialAsyncDelayRecoverableExceptionHandlerTest.php

@@ -0,0 +1,46 @@
+<?php
+declare(strict_types=1);
+
+namespace ScriptFUSIONTest\Unit\Connector\Recoverable;
+
+use Amp\PHPUnit\AsyncTestCase;
+use ScriptFUSION\Porter\Connector\Recoverable\ExponentialAsyncDelayRecoverableExceptionHandler;
+use ScriptFUSIONTest\Stubs\TestRecoverableException;
+
+/**
+ * @see ExponentialAsyncDelayRecoverableExceptionHandler
+ */
+final class ExponentialAsyncDelayRecoverableExceptionHandlerTest extends AsyncTestCase
+{
+    /** @var ExponentialAsyncDelayRecoverableExceptionHandler */
+    private $handler;
+
+    /** @var TestRecoverableException */
+    private $exception;
+
+    protected function setUp(): void
+    {
+        parent::setUp();
+
+        $this->handler = new ExponentialAsyncDelayRecoverableExceptionHandler;
+        $this->handler->initialize();
+        $this->exception = new TestRecoverableException;
+    }
+
+    /**
+     * Tests that when the handler is invoked, each delay is longer than the last.
+     */
+    public function testDelay(): \Generator
+    {
+        for ($i = $previousDuration = 0; $i < 4; ++$i) {
+            $start = microtime(true);
+            yield ($this->handler)($this->exception);
+            $duration = microtime(true) - $start;
+
+            self::assertGreaterThan($previousDuration, $duration);
+            $previousDuration = $duration;
+        }
+
+        self::assertGreaterThan(.8, $previousDuration);
+    }
+}

test/Unit/Connector/Recoverable/ExponentialSleepRecoverableExceptionHandlerTest.php

@@ -0,0 +1,46 @@
+<?php
+declare(strict_types=1);
+
+namespace ScriptFUSIONTest\Unit\Connector\Recoverable;
+
+use ScriptFUSION\Porter\Connector\Recoverable\ExponentialSleepRecoverableExceptionHandler;
+use PHPUnit\Framework\TestCase;
+use ScriptFUSIONTest\Stubs\TestRecoverableException;
+
+/**
+ * @see ExponentialSleepRecoverableExceptionHandler
+ */
+final class ExponentialSleepRecoverableExceptionHandlerTest extends TestCase
+{
+    /** @var ExponentialSleepRecoverableExceptionHandler */
+    private $handler;
+
+    /** @var TestRecoverableException */
+    private $exception;
+
+    protected function setUp(): void
+    {
+        parent::setUp();
+
+        $this->handler = new ExponentialSleepRecoverableExceptionHandler;
+        $this->handler->initialize();
+        $this->exception = new TestRecoverableException;
+    }
+
+    /**
+     * Tests that when the handler is invoked, each delay is longer than the last.
+     */
+    public function testDelay(): void
+    {
+        for ($i = $previousDuration = 0; $i < 4; ++$i) {
+            $start = microtime(true);
+            ($this->handler)($this->exception);
+            $duration = microtime(true) - $start;
+
+            self::assertGreaterThan($previousDuration, $duration);
+            $previousDuration = $duration;
+        }
+
+        self::assertGreaterThan(.8, $previousDuration);
+    }
+}

test/Unit/Connector/FetchExceptionHandler/StatelessRecoverableExceptionHandlerTest.php renamed to test/Unit/Connector/Recoverable/StatelessRecoverableExceptionHandlerTest.php

@@ -1,7 +1,7 @@
 <?php
 declare(strict_types=1);
 
-namespace ScriptFUSIONTest\Unit\Connector\FetchExceptionHandler;
+namespace ScriptFUSIONTest\Unit\Connector\Recoverable;
 
 use PHPUnit\Framework\TestCase;
 use ScriptFUSION\Porter\Connector\Recoverable\StatelessRecoverableExceptionHandler;