[GitHubAE] Update to 1.1.4-51868c0a30cf979b021c18dc01550582 from 1.1.4-3c30b4654b8763c53887fef2aad3304a

Detected Schema changes:

Author: WyriHaximus

etc/openapi-client-generator.state

@@ -4,10 +4,20 @@
 
 namespace ApiClients\Client\GitHubAE\Operation\Actions;
 
+use ApiClients\Client\GitHubAE\Hydrator;
+use ApiClients\Client\GitHubAE\Schema;
+use cebe\openapi\Reader;
+use League\OpenAPIValidation\Schema\SchemaValidator;
 use Psr\Http\Message\RequestInterface;
 use Psr\Http\Message\ResponseInterface;
 use RingCentral\Psr7\Request;
+use RuntimeException;
+use Rx\Observable;
+use Rx\Scheduler\ImmediateScheduler;
+use Throwable;
 
+use function explode;
+use function json_decode;
 use function str_replace;
 
 final class ListRunnerApplicationsForOrg
@@ -19,7 +29,7 @@ final class ListRunnerApplicationsForOrg
     /**The organization name. The name is not case sensitive. **/
     private string $org;
 
-    public function __construct(string $org)
+    public function __construct(private readonly SchemaValidator $responseSchemaValidator, private readonly Hydrator\Operation\Orgs\Org\Actions\Runners\Downloads $hydrator, string $org)
     {
         $this->org = $org;
     }
@@ -29,8 +39,37 @@ public function createRequest(): RequestInterface
         return new Request(self::METHOD, str_replace(['{org}'], [$this->org], self::PATH));
     }
 
-    public function createResponse(ResponseInterface $response): ResponseInterface
+    /** @return Observable<Schema\RunnerApplication> */
+    public function createResponse(ResponseInterface $response): Observable
     {
-        return $response;
+        $code          = $response->getStatusCode();
+        [$contentType] = explode(';', $response->getHeaderLine('Content-Type'));
+        switch ($contentType) {
+            case 'application/json':
+                $body = json_decode($response->getBody()->getContents(), true);
+                switch ($code) {
+                    /**
+                     * Response
+                     **/
+                    case 200:
+                        return Observable::fromArray($body, new ImmediateScheduler())->map(function (array $body): Schema\RunnerApplication {
+                            $error = new RuntimeException();
+                            try {
+                                $this->responseSchemaValidator->validate($body, Reader::readFromJson(Schema\RunnerApplication::SCHEMA_JSON, '\\cebe\\openapi\\spec\\Schema'));
+
+                                return $this->hydrator->hydrateObject(Schema\RunnerApplication::class, $body);
+                            } catch (Throwable $error) {
+                                goto items_application_json_two_hundred_aaaaa;
+                            }
+
+                            items_application_json_two_hundred_aaaaa:
+                            throw $error;
+                        });
+                }
+
+                break;
+        }
+
+        throw new RuntimeException('Unable to find matching response code and content type');
     }
 }

src/Client.php

@@ -4,10 +4,20 @@
 
 namespace ApiClients\Client\GitHubAE\Operation\Actions;
 
+use ApiClients\Client\GitHubAE\Hydrator;
+use ApiClients\Client\GitHubAE\Schema;
+use cebe\openapi\Reader;
+use League\OpenAPIValidation\Schema\SchemaValidator;
 use Psr\Http\Message\RequestInterface;
 use Psr\Http\Message\ResponseInterface;
 use RingCentral\Psr7\Request;
+use RuntimeException;
+use Rx\Observable;
+use Rx\Scheduler\ImmediateScheduler;
+use Throwable;
 
+use function explode;
+use function json_decode;
 use function str_replace;
 
 final class ListRunnerApplicationsForRepo
@@ -21,7 +31,7 @@ final class ListRunnerApplicationsForRepo
     /**The name of the repository without the `.git` extension. The name is not case sensitive. **/
     private string $repo;
 
-    public function __construct(string $owner, string $repo)
+    public function __construct(private readonly SchemaValidator $responseSchemaValidator, private readonly Hydrator\Operation\Repos\Owner\Repo\Actions\Runners\Downloads $hydrator, string $owner, string $repo)
     {
         $this->owner = $owner;
         $this->repo  = $repo;
@@ -32,8 +42,37 @@ public function createRequest(): RequestInterface
         return new Request(self::METHOD, str_replace(['{owner}', '{repo}'], [$this->owner, $this->repo], self::PATH));
     }
 
-    public function createResponse(ResponseInterface $response): ResponseInterface
+    /** @return Observable<Schema\RunnerApplication> */
+    public function createResponse(ResponseInterface $response): Observable
     {
-        return $response;
+        $code          = $response->getStatusCode();
+        [$contentType] = explode(';', $response->getHeaderLine('Content-Type'));
+        switch ($contentType) {
+            case 'application/json':
+                $body = json_decode($response->getBody()->getContents(), true);
+                switch ($code) {
+                    /**
+                     * Response
+                     **/
+                    case 200:
+                        return Observable::fromArray($body, new ImmediateScheduler())->map(function (array $body): Schema\RunnerApplication {
+                            $error = new RuntimeException();
+                            try {
+                                $this->responseSchemaValidator->validate($body, Reader::readFromJson(Schema\RunnerApplication::SCHEMA_JSON, '\\cebe\\openapi\\spec\\Schema'));
+
+                                return $this->hydrator->hydrateObject(Schema\RunnerApplication::class, $body);
+                            } catch (Throwable $error) {
+                                goto items_application_json_two_hundred_aaaaa;
+                            }
+
+                            items_application_json_two_hundred_aaaaa:
+                            throw $error;
+                        });
+                }
+
+                break;
+        }
+
+        throw new RuntimeException('Unable to find matching response code and content type');
     }
 }