User events

Author: WyriHaximus

examples/user-events-async.php

@@ -0,0 +1,25 @@
+<?php declare(strict_types=1);
+use ApiClients\Client\Github\AsyncClient;
+use ApiClients\Client\Github\Resource\Async\Event;
+use ApiClients\Client\Github\Resource\Async\User;
+use React\EventLoop\Factory;
+use function ApiClients\Foundation\resource_pretty_print;
+use function ApiClients\Tools\Rx\unwrapObservableFromPromise;
+
+require dirname(__DIR__) . DIRECTORY_SEPARATOR . 'vendor/autoload.php';
+
+$loop = Factory::create();
+
+$client = AsyncClient::create($loop, require 'resolve_token.php');
+
+unwrapObservableFromPromise($client->user($argv[1] ?? 'php-api-clients')->then(function (User $user) use ($argv) {
+    resource_pretty_print($user);
+
+    return $user->events();
+}))->subscribe(function (Event $event) {
+    resource_pretty_print($event);
+}, 'display_throwable');
+
+$loop->run();
+
+displayState($client->getRateLimitState());

src/CommandBus/Command/User/EventsCommand.php

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

src/CommandBus/Handler/User/EventsHandler.php

@@ -0,0 +1,50 @@
+<?php declare(strict_types=1);
+
+namespace ApiClients\Client\Github\CommandBus\Handler\User;
+
+use ApiClients\Client\Github\CommandBus\Command\User\EventsCommand;
+use ApiClients\Client\Github\Resource\EventInterface;
+use ApiClients\Client\Github\Service\IteratePagesService;
+use ApiClients\Foundation\Hydrator\Hydrator;
+use React\Promise\PromiseInterface;
+use function ApiClients\Tools\Rx\observableFromArray;
+use function React\Promise\resolve;
+
+final class EventsHandler
+{
+    /**
+     * @var IteratePagesService
+     */
+    private $service;
+
+    /**
+     * @var Hydrator
+     */
+    private $hydrator;
+
+    /**
+     * @param IteratePagesService $service
+     * @param Hydrator            $hydrator
+     */
+    public function __construct(IteratePagesService $service, Hydrator $hydrator)
+    {
+        $this->service = $service;
+        $this->hydrator = $hydrator;
+    }
+
+    /**
+     * @param  EventsCommand    $command
+     * @return PromiseInterface
+     */
+    public function handle(EventsCommand $command): PromiseInterface
+    {
+        return resolve(
+            $this->service->iterate('users/' . $command->getLogin() . '/events')
+                ->flatMap(function ($events) {
+                    return observableFromArray($events);
+                })->map(function ($event) {
+                    return $this->hydrator->hydrate(EventInterface::HYDRATE_CLASS, $event);
+                })
+        );
+    }
+}

src/Resource/Async/EmptyEvent.php

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

src/Resource/Async/EmptyRepositorySimple.php

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

src/Resource/Async/Event.php

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

src/Resource/Async/RepositorySimple.php

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

src/Resource/Async/User.php

@@ -3,6 +3,7 @@
 namespace ApiClients\Client\Github\Resource\Async;
 
 use ApiClients\Client\Github\CommandBus\Command\RefreshCommand;
+use ApiClients\Client\Github\CommandBus\Command\User\EventsCommand;
 use ApiClients\Client\Github\CommandBus\Command\User\OrganizationsCommand;
 use ApiClients\Client\Github\CommandBus\Command\User\RepositoriesCommand;
 use ApiClients\Client\Github\CommandBus\Command\User\RepositoryCommand;
@@ -40,4 +41,11 @@ public function organizations(): ObservableInterface
             new OrganizationsCommand($this->login())
         ));
     }
+
+    public function events(): ObservableInterface
+    {
+        return unwrapObservableFromPromise($this->handleCommand(
+            new EventsCommand($this->login())
+        ));
+    }
 }

src/Resource/EmptyEvent.php

@@ -0,0 +1,65 @@
+<?php declare(strict_types=1);
+
+namespace ApiClients\Client\Github\Resource;
+
+use ApiClients\Foundation\Resource\EmptyResourceInterface;
+use DateTimeInterface;
+
+abstract class EmptyEvent implements EventInterface, EmptyResourceInterface
+{
+    /**
+     * @return int
+     */
+    public function id(): int
+    {
+        return null;
+    }
+
+    /**
+     * @return string
+     */
+    public function type(): string
+    {
+        return null;
+    }
+
+    /**
+     * @return User
+     */
+    public function actor(): User
+    {
+        return null;
+    }
+
+    /**
+     * @return RepositorySimple
+     */
+    public function repo(): RepositorySimple
+    {
+        return null;
+    }
+
+    /**
+     * @return array
+     */
+    public function payload(): array
+    {
+        return null;
+    }
+
+    /**
+     * @return bool
+     */
+    public function public(): bool
+    {
+        return null;
+    }
+
+    /**
+     * @return DateTimeInterface
+     */
+    public function createdAt(): DateTimeInterface
+    {
+        return null;
+    }
+}

src/Resource/EmptyRepositorySimple.php

@@ -0,0 +1,32 @@
+<?php declare(strict_types=1);
+
+namespace ApiClients\Client\Github\Resource;
+
+use ApiClients\Foundation\Resource\EmptyResourceInterface;
+
+abstract class EmptyRepositorySimple implements RepositorySimpleInterface, EmptyResourceInterface
+{
+    /**
+     * @return int
+     */
+    public function id(): int
+    {
+        return null;
+    }
+
+    /**
+     * @return string
+     */
+    public function name(): string
+    {
+        return null;
+    }
+
+    /**
+     * @return string
+     */
+    public function url(): string
+    {
+        return null;
+    }
+}