Merge pull request #64 from php-api-clients/fetch-milestones

Fetch milestones

Author: WyriHaximus

examples/user-repositories-milestones-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->milestones()->subscribe(function (Repository\Milestone $milestone) {
+        resource_pretty_print($milestone);
+        $milestone->refresh()->then(function (Repository\Milestone $milestone) {
+            resource_pretty_print($milestone);
+        });
+    }, function ($error) {
+        echo (string)$error;
+    });
+})->done(null, 'display_throwable');
+
+$loop->run();
+
+displayState($client->getRateLimitState());

src/CommandBus/Command/Repository/MilestonesCommand.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\MilestonesHandler")
+ */
+final class MilestonesCommand
+{
+    /**
+     * @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/MilestonesHandler.php

@@ -0,0 +1,52 @@
+<?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\Resource\Repository\BranchInterface;
+use ApiClients\Client\Github\Resource\Repository\MilestoneInterface;
+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 MilestonesHandler
+{
+    /**
+     * @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  MilestonesCommand  $command
+     * @return PromiseInterface
+     */
+    public function handle(MilestonesCommand $command): PromiseInterface
+    {
+        return resolve(
+            $this->iteratePagesService->iterate('repos/' . $command->getFullName() . '/milestones')
+                ->flatMap(function ($milestones) {
+                    return observableFromArray($milestones);
+                })->map(function ($milestone) {
+                    return $this->hydrator->hydrate(MilestoneInterface::HYDRATE_CLASS, $milestone);
+                })
+        );
+    }
+}

src/Resource/Async/Repository.php

@@ -16,6 +16,7 @@
 use ApiClients\Client\Github\CommandBus\Command\Repository\DetailedCommitCommand;
 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\RefCommand;
 use ApiClients\Client\Github\CommandBus\Command\Repository\RefsCommand;
 use ApiClients\Client\Github\CommandBus\Command\Repository\ReleasesCommand;
@@ -130,6 +131,13 @@ public function webHooks(): ObservableInterface
         ));
     }
 
+    public function milestones(): ObservableInterface
+    {
+        return unwrapObservableFromPromise($this->handleCommand(
+            new MilestonesCommand($this->fullName())
+        ));
+    }
+
     public function addWebHook(
         string $name,
         array $config,

src/Resource/Async/Repository/EmptyMilestone.php

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

src/Resource/Async/Repository/Milestone.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\Milestone as BaseMilestone;
+use React\Promise\PromiseInterface;
+
+class Milestone extends BaseMilestone
+{
+    public function refresh(): PromiseInterface
+    {
+        return $this->handleCommand(new RefreshCommand($this));
+    }
+}

src/Resource/Repository/EmptyMilestone.php

@@ -0,0 +1,80 @@
+<?php declare(strict_types=1);
+
+namespace ApiClients\Client\Github\Resource\Repository;
+
+use ApiClients\Foundation\Resource\EmptyResourceInterface;
+
+abstract class EmptyMilestone implements MilestoneInterface, EmptyResourceInterface
+{
+    /**
+     * @return int
+     */
+    public function id(): int
+    {
+        return null;
+    }
+
+    /**
+     * @return int
+     */
+    public function number(): int
+    {
+        return null;
+    }
+
+    /**
+     * @return string
+     */
+    public function state(): string
+    {
+        return null;
+    }
+
+    /**
+     * @return string
+     */
+    public function title(): string
+    {
+        return null;
+    }
+
+    /**
+     * @return string
+     */
+    public function description(): string
+    {
+        return null;
+    }
+
+    /**
+     * @return User
+     */
+    public function creator(): User
+    {
+        return null;
+    }
+
+    /**
+     * @return int
+     */
+    public function openIssues(): int
+    {
+        return null;
+    }
+
+    /**
+     * @return int
+     */
+    public function closedIssues(): int
+    {
+        return null;
+    }
+
+    /**
+     * @return string
+     */
+    public function url(): string
+    {
+        return null;
+    }
+}

src/Resource/Repository/Milestone.php

@@ -0,0 +1,133 @@
+<?php declare(strict_types=1);
+
+namespace ApiClients\Client\Github\Resource\Repository;
+
+use ApiClients\Foundation\Hydrator\Annotation\EmptyResource;
+use ApiClients\Foundation\Hydrator\Annotation\Nested;
+use ApiClients\Foundation\Resource\AbstractResource;
+
+/**
+ * @Nested(
+ *     creator="User"
+ * )
+ * @EmptyResource("Repository\EmptyMilestone")
+ */
+abstract class Milestone extends AbstractResource implements MilestoneInterface
+{
+    /**
+     * @var int
+     */
+    protected $id;
+
+    /**
+     * @var int
+     */
+    protected $number;
+
+    /**
+     * @var string
+     */
+    protected $state;
+
+    /**
+     * @var string
+     */
+    protected $title;
+
+    /**
+     * @var string
+     */
+    protected $description;
+
+    /**
+     * @var User
+     */
+    protected $creator;
+
+    /**
+     * @var int
+     */
+    protected $open_issues;
+
+    /**
+     * @var int
+     */
+    protected $closed_issues;
+
+    /**
+     * @var string
+     */
+    protected $url;
+
+    /**
+     * @return int
+     */
+    public function id(): int
+    {
+        return $this->id;
+    }
+
+    /**
+     * @return int
+     */
+    public function number(): int
+    {
+        return $this->number;
+    }
+
+    /**
+     * @return string
+     */
+    public function state(): string
+    {
+        return $this->state;
+    }
+
+    /**
+     * @return string
+     */
+    public function title(): string
+    {
+        return $this->title;
+    }
+
+    /**
+     * @return string
+     */
+    public function description(): string
+    {
+        return $this->description;
+    }
+
+    /**
+     * @return User
+     */
+    public function creator(): User
+    {
+        return $this->creator;
+    }
+
+    /**
+     * @return int
+     */
+    public function openIssues(): int
+    {
+        return $this->open_issues;
+    }
+
+    /**
+     * @return int
+     */
+    public function closedIssues(): int
+    {
+        return $this->closed_issues;
+    }
+
+    /**
+     * @return string
+     */
+    public function url(): string
+    {
+        return $this->url;
+    }
+}