Merge pull request #80 from php-api-clients/iterate-over-checks

Iterate over checks

Author: WyriHaximus

composer.json

@@ -51,6 +51,10 @@
     "sort-packages": true,
     "platform": {
       "php": "7.3.3"
+    },
+    "allow-plugins": {
+      "ocramius/package-versions": true,
+      "localheinz/composer-normalize": true
     }
   },
   "extra": {

src/CommandBus/Handler/Repository/Commit/ChecksHandler.php

@@ -3,35 +3,33 @@
 namespace ApiClients\Client\Github\CommandBus\Handler\Repository\Commit;
 
 use ApiClients\Client\Github\CommandBus\Command\Repository\Commit\ChecksCommand;
-use ApiClients\Client\Github\CommandBus\Command\Repository\Commit\StatusesCommand;
 use ApiClients\Client\Github\Resource\Repository\Commit\CheckInterface;
-use ApiClients\Client\Github\Resource\Repository\Commit\StatusInterface;
 use ApiClients\Client\Github\Service\IteratePagesService;
 use ApiClients\Foundation\Hydrator\Hydrator;
-use ApiClients\Tools\Services\Client\FetchAndIterateService;
 use function ApiClients\Tools\Rx\observableFromArray;
 use React\Promise\PromiseInterface;
 use function React\Promise\resolve;
+use function igorw\get_in;
 
 final class ChecksHandler
 {
     /**
-     * @var FetchAndIterateService
+     * @var IteratePagesService
      */
-    private $fetchAndIterateService;
+    private $iteratePagesService;
 
     /**
      * @var Hydrator
      */
     private $hydrator;
 
     /**
-     * @param FetchAndIterateService $fetchAndIterateService
+     * @param IteratePagesService $iteratePagesService
      * @param Hydrator            $hydrator
      */
-    public function __construct(FetchAndIterateService $fetchAndIterateService, Hydrator $hydrator)
+    public function __construct(IteratePagesService $iteratePagesService, Hydrator $hydrator)
     {
-        $this->fetchAndIterateService = $fetchAndIterateService;
+        $this->iteratePagesService = $iteratePagesService;
         $this->hydrator = $hydrator;
     }
 
@@ -42,11 +40,12 @@ public function __construct(FetchAndIterateService $fetchAndIterateService, Hydr
     public function handle(ChecksCommand $command): PromiseInterface
     {
         return resolve(
-            $this->fetchAndIterateService->iterate(
-                $command->getCommit()->url() . '/check-runs',
-                'check_runs',
-                CheckInterface::HYDRATE_CLASS
-            )
+            $this->iteratePagesService->iterate($command->getCommit()->url() . '/check-runs',)
+                ->flatMap(function ($checkRuns) {
+                    return observableFromArray(get_in($checkRuns, ['check_runs'], []));
+                })->map(function ($checkRun) {
+                    return $this->hydrator->hydrate(CheckInterface::HYDRATE_CLASS, $checkRun);
+                })
         );
     }
 }