Added async collection tests for accessor methods.

Author: Bilge

composer.json

@@ -1,6 +1,6 @@
 {
   "name": "scriptfusion/porter",
-  "description": "Scalable and efficient data import abstraction for APIs.",
+  "description": "Scalable and durable data import abstraction for APIs.",
   "authors": [
     {
       "name": "Bilge",

infection.json

@@ -11,7 +11,7 @@
     "logs": {
         "text": "infection.log",
         "badge": {
-            "branch": "5.0"
+            "branch": "master"
         }
     },
     "mutators": {

test/Integration/PorterSyncTest.php

@@ -27,6 +27,7 @@
 use ScriptFUSION\Retry\FailingTooHardException;
 use ScriptFUSIONTest\MockFactory;
 use ScriptFUSIONTest\Stubs\TestRecoverableException;
+use ScriptFUSIONTest\Stubs\TestRecoverableExceptionHandler;
 
 final class PorterSyncTest extends PorterTest
 {
@@ -235,6 +236,8 @@ public function testDerivedRecoverableException(): void
     public function testDefaultTries(): void
     {
         $this->arrangeConnectorException(new TestRecoverableException);
+        // Speed up test by circumventing exponential backoff default handler.
+        $this->specification->setRecoverableExceptionHandler(new TestRecoverableExceptionHandler);
 
         $this->expectException(FailingTooHardException::class);
         $this->expectExceptionMessage((string)ImportSpecification::DEFAULT_FETCH_ATTEMPTS);

test/Unit/Collection/AsyncFilteredRecordsTest.php

@@ -0,0 +1,29 @@
+<?php
+declare(strict_types=1);
+
+namespace ScriptFUSIONTest\Unit\Collection;
+
+use Amp\Iterator;
+use PHPUnit\Framework\TestCase;
+use ScriptFUSION\Porter\Collection\AsyncFilteredRecords;
+use ScriptFUSION\Porter\Collection\AsyncRecordCollection;
+
+/**
+ * @see AsyncFilteredRecords
+ */
+final class AsyncFilteredRecordsTest extends TestCase
+{
+    /**
+     * Tests that the filter passed at construction time is the same as that retrieved from the accessor method.
+     */
+    public function testGetResource(): void
+    {
+        $records = new AsyncFilteredRecords(
+            \Mockery::mock(Iterator::class),
+            \Mockery::mock(AsyncRecordCollection::class),
+            $callable = [$this, __FUNCTION__]
+        );
+
+        self::assertSame($callable, $records->getFilter());
+    }
+}

test/Unit/Collection/AsyncPorterRecordsTest.php

@@ -0,0 +1,28 @@
+<?php
+declare(strict_types=1);
+
+namespace ScriptFUSIONTest\Unit\Collection;
+
+use PHPUnit\Framework\TestCase;
+use ScriptFUSION\Porter\Collection\AsyncPorterRecords;
+use ScriptFUSION\Porter\Collection\AsyncRecordCollection;
+use ScriptFUSION\Porter\Specification\AsyncImportSpecification;
+
+/**
+ * @see AsyncPorterRecords
+ */
+final class AsyncPorterRecordsTest extends TestCase
+{
+    /**
+     * Tests that the specification passed at construction time is the same as that retrieved from the accessor method.
+     */
+    public function testGetSpecification(): void
+    {
+        $records = new AsyncPorterRecords(
+            \Mockery::mock(AsyncRecordCollection::class),
+            $specification = \Mockery::mock(AsyncImportSpecification::class)
+        );
+
+        self::assertSame($specification, $records->getSpecification());
+    }
+}

test/Unit/Collection/AsyncProviderRecordsTest.php

@@ -0,0 +1,29 @@
+<?php
+declare(strict_types=1);
+
+namespace ScriptFUSIONTest\Unit\Collection;
+
+use Amp\Iterator;
+use PHPUnit\Framework\TestCase;
+use ScriptFUSION\Porter\Collection\AsyncProviderRecords;
+use ScriptFUSION\Porter\Collection\ProviderRecords;
+use ScriptFUSION\Porter\Provider\Resource\AsyncResource;
+
+/**
+ * @see ProviderRecords
+ */
+final class AsyncProviderRecordsTest extends TestCase
+{
+    /**
+     * Tests that the resource passed at construction time is the same as that retrieved from the accessor method.
+     */
+    public function testGetResource(): void
+    {
+        $records = new AsyncProviderRecords(
+            \Mockery::mock(Iterator::class),
+            $resource = \Mockery::mock(AsyncResource::class)
+        );
+
+        self::assertSame($resource, $records->getResource());
+    }
+}

test/Unit/Collection/PorterRecordsTest.php

@@ -8,9 +8,15 @@
 use ScriptFUSION\Porter\Collection\RecordCollection;
 use ScriptFUSION\Porter\Specification\ImportSpecification;
 
+/**
+ * @see PorterRecords
+ */
 final class PorterRecordsTest extends TestCase
 {
-    public function test(): void
+    /**
+     * Tests that the specification passed at construction time is the same as that retrieved from the accessor method.
+     */
+    public function testGetSpecification(): void
     {
         $records = new PorterRecords(
             \Mockery::mock(RecordCollection::class),

test/Unit/Collection/ProviderRecordsTest.php

@@ -7,9 +7,15 @@
 use ScriptFUSION\Porter\Collection\ProviderRecords;
 use ScriptFUSION\Porter\Provider\Resource\ProviderResource;
 
+/**
+ * @see ProviderRecords
+ */
 final class ProviderRecordsTest extends TestCase
 {
-    public function test(): void
+    /**
+     * Tests that the resource passed at construction time is the same as that retrieved from the accessor method.
+     */
+    public function testGetResource(): void
     {
         $records = new ProviderRecords(
             \Mockery::mock(\Iterator::class),