Merge pull request #65 from php-api-clients/pull-requests

Pull requests

Author: WyriHaximus

examples/user-repositories-pull-requests-async.php

@@ -0,0 +1,32 @@
+<?php declare(strict_types=1);
+use ApiClients\Client\Github\AsyncClient;
+use ApiClients\Client\Github\Resource\Async\Repository;
+use ApiClients\Client\Github\Resource\Async\User;
+use function ApiClients\Foundation\resource_pretty_print;
+use React\EventLoop\Factory;
+
+require \dirname(__DIR__) . \DIRECTORY_SEPARATOR . 'vendor/autoload.php';
+
+$loop = Factory::create();
+
+$client = AsyncClient::create($loop, require 'resolve_token.php');
+
+$client->user($argv[1] ?? 'php-api-clients')->then(function (User $user) use ($argv) {
+    resource_pretty_print($user);
+
+    return $user->repository($argv[2] ?? 'github');
+})->then(function (Repository $repository) {
+    resource_pretty_print($repository, 1, true);
+    $repository->pullRequests()->subscribe(function (Repository\PullRequest $pullRequest) {
+        resource_pretty_print($pullRequest);
+        $pullRequest->refresh()->then(function (Repository\PullRequest $pullRequest) {
+            resource_pretty_print($pullRequest);
+        });
+    }, function ($error) {
+        echo (string)$error;
+    });
+})->done(null, 'display_throwable');
+
+$loop->run();
+
+displayState($client->getRateLimitState());

src/CommandBus/Command/Repository/PullRequestsCommand.php

@@ -0,0 +1,32 @@
+<?php declare(strict_types=1);
+
+namespace ApiClients\Client\Github\CommandBus\Command\Repository;
+
+use WyriHaximus\Tactician\CommandHandler\Annotations\Handler;
+
+/**
+ * @Handler("ApiClients\Client\Github\CommandBus\Handler\Repository\PullRequestsHandler")
+ */
+final class PullRequestsCommand
+{
+    /**
+     * @var string
+     */
+    private $fullName;
+
+    /**
+     * @param string $fullName
+     */
+    public function __construct(string $fullName)
+    {
+        $this->fullName = $fullName;
+    }
+
+    /**
+     * @return string
+     */
+    public function getFullName(): string
+    {
+        return $this->fullName;
+    }
+}

src/CommandBus/Handler/Repository/PullRequestsHandler.php

@@ -0,0 +1,54 @@
+<?php declare(strict_types=1);
+
+namespace ApiClients\Client\Github\CommandBus\Handler\Repository;
+
+use ApiClients\Client\Github\CommandBus\Command\Repository\BranchesCommand;
+use ApiClients\Client\Github\CommandBus\Command\Repository\MilestonesCommand;
+use ApiClients\Client\Github\CommandBus\Command\Repository\PullRequestsCommand;
+use ApiClients\Client\Github\Resource\Repository\BranchInterface;
+use ApiClients\Client\Github\Resource\Repository\MilestoneInterface;
+use ApiClients\Client\Github\Resource\Repository\PullRequestInterface;
+use ApiClients\Client\Github\Service\IteratePagesService;
+use ApiClients\Foundation\Hydrator\Hydrator;
+use function ApiClients\Tools\Rx\observableFromArray;
+use React\Promise\PromiseInterface;
+use function React\Promise\resolve;
+
+final class PullRequestsHandler
+{
+    /**
+     * @var IteratePagesService
+     */
+    private $iteratePagesService;
+
+    /**
+     * @var Hydrator
+     */
+    private $hydrator;
+
+    /**
+     * @param IteratePagesService $iteratePagesService
+     * @param Hydrator            $hydrator
+     */
+    public function __construct(IteratePagesService $iteratePagesService, Hydrator $hydrator)
+    {
+        $this->iteratePagesService = $iteratePagesService;
+        $this->hydrator = $hydrator;
+    }
+
+    /**
+     * @param  PullRequestsCommand  $command
+     * @return PromiseInterface
+     */
+    public function handle(PullRequestsCommand $command): PromiseInterface
+    {
+        return resolve(
+            $this->iteratePagesService->iterate('repos/' . $command->getFullName() . '/pulls')
+                ->flatMap(function ($milestones) {
+                    return observableFromArray($milestones);
+                })->map(function ($milestone) {
+                    return $this->hydrator->hydrate(PullRequestInterface::HYDRATE_CLASS, $milestone);
+                })
+        );
+    }
+}

src/Resource/Async/Repository.php

@@ -17,6 +17,7 @@
 use ApiClients\Client\Github\CommandBus\Command\Repository\LabelsCommand;
 use ApiClients\Client\Github\CommandBus\Command\Repository\LanguagesCommand;
 use ApiClients\Client\Github\CommandBus\Command\Repository\MilestonesCommand;
+use ApiClients\Client\Github\CommandBus\Command\Repository\PullRequestsCommand;
 use ApiClients\Client\Github\CommandBus\Command\Repository\RefCommand;
 use ApiClients\Client\Github\CommandBus\Command\Repository\RefsCommand;
 use ApiClients\Client\Github\CommandBus\Command\Repository\ReleasesCommand;
@@ -138,6 +139,13 @@ public function milestones(): ObservableInterface
         ));
     }
 
+    public function pullRequests(): ObservableInterface
+    {
+        return unwrapObservableFromPromise($this->handleCommand(
+            new PullRequestsCommand($this->fullName())
+        ));
+    }
+
     public function addWebHook(
         string $name,
         array $config,

src/Resource/Async/Repository/EmptyPullRequest.php

@@ -0,0 +1,9 @@
+<?php declare(strict_types=1);
+
+namespace ApiClients\Client\Github\Resource\Async\Repository;
+
+use ApiClients\Client\Github\Resource\Repository\EmptyPullRequest as BaseEmptyPullRequest;
+
+class EmptyPullRequest extends BaseEmptyPullRequest
+{
+}

src/Resource/Async/Repository/PullRequest.php

@@ -0,0 +1,15 @@
+<?php declare(strict_types=1);
+
+namespace ApiClients\Client\Github\Resource\Async\Repository;
+
+use ApiClients\Client\Github\CommandBus\Command\RefreshCommand;
+use ApiClients\Client\Github\Resource\Repository\PullRequest as BasePullRequest;
+use React\Promise\PromiseInterface;
+
+class PullRequest extends BasePullRequest
+{
+    public function refresh(): PromiseInterface
+    {
+        return $this->handleCommand(new RefreshCommand($this));
+    }
+}

src/Resource/Async/Repository/PullRequest/EmptyRb.php

@@ -0,0 +1,9 @@
+<?php declare(strict_types=1);
+
+namespace ApiClients\Client\Github\Resource\Async\Repository\PullRequest;
+
+use ApiClients\Client\Github\Resource\Repository\PullRequest\EmptyRb as BaseEmptyRb;
+
+class EmptyRb extends BaseEmptyRb
+{
+}

src/Resource/Async/Repository/PullRequest/Rb.php

@@ -0,0 +1,13 @@
+<?php declare(strict_types=1);
+
+namespace ApiClients\Client\Github\Resource\Async\Repository\PullRequest;
+
+use ApiClients\Client\Github\Resource\Repository\PullRequest\Rb as BaseRb;
+
+class Rb extends BaseRb
+{
+    public function refresh(): Rb
+    {
+        throw new \Exception('TODO: create refresh method!');
+    }
+}