Converted coroutines to fibers (first pass: tests passing, mutants escaping).

Author: Bilge

.github/workflows/CI.yml .github/workflows/Tests.yml.github/workflows/CI.yml renamed to .github/workflows/Tests.yml

@@ -1,8 +1,11 @@
-name: CI
+name: Tests
 
 on:
   push:
   pull_request:
+  workflow_dispatch:
+  schedule:
+    - cron: 0 6 * * *
 
 jobs:
   Test:
@@ -12,16 +15,14 @@ jobs:
       fail-fast: false
       matrix:
         php:
-          - 7.3
-          - 7.4
-          - 8.0
           - 8.1
+          - 8.2
         dependencies:
           - hi
           - lo
 
     steps:
-      - uses: actions/checkout@v2
+      - uses: actions/checkout@v3
 
       - name: Setup PHP ${{ matrix.php }}
         uses: shivammathur/setup-php@v2
@@ -34,7 +35,7 @@ jobs:
 
       - name: Cache dependencies
         id: composer-cache
-        uses: actions/cache@v2
+        uses: actions/cache@v3
         with:
           path: vendor
           key: php-${{ matrix.php }}-${{ matrix.dependencies }}-${{ hashFiles('composer.json') }}
@@ -51,9 +52,7 @@ jobs:
         run: |
           curl -Os https://uploader.codecov.io/latest/linux/codecov
           chmod +x codecov
-          ./codecov -t $CODECOV_TOKEN
-        env:
-          COVERALLS_REPO_TOKEN: ${{ secrets.CODECOV_TOKEN }}
+          ./codecov
 
       - name: Run mutation tests
         run: |

README.md

@@ -5,7 +5,7 @@ Porter <img src="https://github.com/ScriptFUSION/Porter/blob/master/docs/images/
 [![Latest version][Version image]][Releases]
 [![Total downloads][Downloads image]][Downloads]
 [![Build status][Build image]][Build]
-[![Mutation score][MSI image]][Build]
+[![Mutation score][MSI image]][MSI report]
 [![Test coverage][Coverage image]][Coverage]
 
 ### Scalable and durable data imports for publishing and consuming APIs
@@ -527,6 +527,7 @@ Porter is published under the open source GNU Lesser General Public License v3.0
   [Build]: http://travis-ci.com/ScriptFUSION/Porter
   [Build image]: https://travis-ci.com/ScriptFUSION/Porter.svg?branch=master "Build status"
   [MSI image]: https://badge.stryker-mutator.io/github.com/ScriptFUSION/Porter/master
+  [MSI report]: https://dashboard.stryker-mutator.io/github.com/ScriptFUSION/Porter/master
   [Coverage]: https://codecov.io/gh/ScriptFUSION/Porter
   [Coverage image]: https://codecov.io/gh/ScriptFUSION/Porter/branch/master/graphs/badge.svg "Test coverage"
 

composer.json

@@ -9,23 +9,20 @@
   ],
   "license": "LGPL-3.0",
   "require": {
-    "php": "^7.3|^8",
-    "amphp/amp": "^2",
-    "async/throttle": "^3",
+    "php": "^8.1",
+    "amphp/amp": "^3-beta.9",
+    "async/throttle": "^4",
     "psr/cache": "^1",
     "psr/container": "^1",
-    "scriptfusion/retry": "^2.1|^3",
+    "revolt/event-loop": "^0.2",
+    "scriptfusion/retry": "^4",
     "scriptfusion/retry-exception-handlers": "^1.2",
     "scriptfusion/static-class": "^1"
   },
   "require-dev": {
-    "amphp/phpunit-util": "^1.1",
-    "infection/infection": ">=0.18,<0.26",
-    "justinrainbow/json-schema": "^5.2.10",
+    "infection/infection": ">=0.26,<0.27",
     "mockery/mockery": "^1.4.2",
-    "phpunit/php-code-coverage": "^9.2.5",
-    "phpunit/phpunit": "^9.5.13",
-    "thecodingmachine/safe": "^1.3.3"
+    "phpunit/phpunit": "^9.5.23"
   },
   "suggest" : {
     "connectors/http": "Provides an HTTP connector for Porter providers.",

src/Collection/AsyncFilteredRecords.php

@@ -3,13 +3,11 @@
 
 namespace ScriptFUSION\Porter\Collection;
 
-use Amp\Iterator;
-
 class AsyncFilteredRecords extends AsyncRecordCollection
 {
     private $filter;
 
-    public function __construct(Iterator $records, AsyncRecordCollection $previousCollection, callable $filter)
+    public function __construct(\Iterator $records, AsyncRecordCollection $previousCollection, callable $filter)
     {
         parent::__construct($records, $previousCollection);
 

src/Collection/AsyncPorterRecords.php

@@ -3,14 +3,13 @@
 
 namespace ScriptFUSION\Porter\Collection;
 
-use Amp\Iterator;
 use ScriptFUSION\Porter\Specification\AsyncImportSpecification;
 
 class AsyncPorterRecords extends AsyncRecordCollection
 {
-    private $specification;
+    private AsyncImportSpecification $specification;
 
-    public function __construct(Iterator $records, AsyncImportSpecification $specification)
+    public function __construct(AsyncRecordCollection $records, AsyncImportSpecification $specification)
     {
         parent::__construct($records, $records);
 

src/Collection/AsyncProviderRecords.php

@@ -3,18 +3,13 @@
 
 namespace ScriptFUSION\Porter\Collection;
 
-use Amp\Iterator;
 use ScriptFUSION\Porter\Provider\Resource\AsyncResource;
 
 class AsyncProviderRecords extends AsyncRecordCollection
 {
-    private $resource;
-
-    public function __construct(Iterator $records, AsyncResource $resource)
+    public function __construct(\Iterator $records, private readonly AsyncResource $resource)
     {
         parent::__construct($records);
-
-        $this->resource = $resource;
     }
 
     public function getResource(): AsyncResource

src/Collection/AsyncRecordCollection.php

@@ -3,42 +3,7 @@
 
 namespace ScriptFUSION\Porter\Collection;
 
-use Amp\Iterator;
-use Amp\Promise;
-
-abstract class AsyncRecordCollection implements Iterator
+abstract class AsyncRecordCollection extends RecordCollection
 {
-    private $records;
-
-    private $previousCollection;
-
-    public function __construct(Iterator $records, self $previousCollection = null)
-    {
-        $this->records = $records;
-        $this->previousCollection = $previousCollection;
-    }
-
-    public function advance(): Promise
-    {
-        return $this->records->advance();
-    }
-
-    public function getCurrent(): array
-    {
-        return $this->records->getCurrent();
-    }
-
-    public function getPreviousCollection(): ?self
-    {
-        return $this->previousCollection;
-    }
-
-    public function findFirstCollection(): ?self
-    {
-        do {
-            $previous = $nextPrevious ?? $this->getPreviousCollection();
-        } while ($previous && $nextPrevious = $previous->getPreviousCollection());
-
-        return $previous ?: $this;
-    }
+    // Intentionally empty. TODO: Remove in next version.
 }

src/Collection/CountableAsyncProviderRecords.php

@@ -3,14 +3,13 @@
 
 namespace ScriptFUSION\Porter\Collection;
 
-use Amp\Iterator;
 use ScriptFUSION\Porter\Provider\Resource\AsyncResource;
 
 class CountableAsyncProviderRecords extends AsyncProviderRecords implements \Countable
 {
     use CountableRecordsTrait;
 
-    public function __construct(Iterator $records, int $count, AsyncResource $resource)
+    public function __construct(\Iterator $records, int $count, AsyncResource $resource)
     {
         parent::__construct($records, $resource);
 

src/Collection/CountableRecordsTrait.php

@@ -5,8 +5,7 @@
 
 trait CountableRecordsTrait
 {
-    /** @var int */
-    private $count;
+    private int $count;
 
     public function count(): int
     {

src/Collection/PorterRecords.php

@@ -7,7 +7,7 @@
 
 class PorterRecords extends RecordCollection
 {
-    private $specification;
+    private ImportSpecification $specification;
 
     public function __construct(RecordCollection $records, ImportSpecification $specification)
     {