WIP Client

Author: WyriHaximus

examples/conditions-async.php

@@ -0,0 +1,17 @@
+<?php
+
+use ApiClients\Client\WeatherUnderground\AsyncClient;
+use ApiClients\Client\WeatherUnderground\Resource\ConditionInterface;
+use React\EventLoop\Factory;
+use function ApiClients\Foundation\resource_pretty_print;
+
+require dirname(__DIR__) . DIRECTORY_SEPARATOR . 'vendor/autoload.php';
+
+$loop = Factory::create();
+$client = AsyncClient::create($loop, require 'resolve_token.php');
+
+$client->conditions('Broek_op_Langedijk')->done(function (ConditionInterface $user) {
+    resource_pretty_print($user);
+});
+
+$loop->run();

examples/resolve_token.php

@@ -0,0 +1,10 @@
+<?php
+
+$keyFile = dirname(__DIR__) . DIRECTORY_SEPARATOR . 'token.php';
+
+if (!file_exists($keyFile)) {
+    echo 'No key file find, copy token.sample.php to token.php and add a token from https://github.com/settings/tokens to run examples.', PHP_EOL;
+    exit(1);
+}
+
+return require $keyFile;

src/ApiSettings.php

@@ -0,0 +1,43 @@
+<?php declare(strict_types=1);
+
+namespace ApiClients\Client\WeatherUnderground;
+
+use ApiClients\Foundation\Hydrator\Options as HydratorOptions;
+use ApiClients\Foundation\Options as FoundationOptions;
+use ApiClients\Foundation\Transport\Middleware\JsonDecodeMiddleware;
+use ApiClients\Foundation\Transport\Middleware\JsonEncodeMiddleware;
+use ApiClients\Foundation\Transport\Options as TransportOptions;
+use ApiClients\Foundation\Transport\UserAgentStrategies;
+use function ApiClients\Foundation\options_merge;
+
+final class ApiSettings
+{
+    const NAMESPACE = 'ApiClients\\Client\\WeatherUnderground\\Resource';
+
+    const TRANSPORT_OPTIONS = [
+        FoundationOptions::HYDRATOR_OPTIONS => [
+            HydratorOptions::NAMESPACE => self::NAMESPACE,
+            HydratorOptions::NAMESPACE_DIR => __DIR__ . DIRECTORY_SEPARATOR . 'Resource' . DIRECTORY_SEPARATOR,
+        ],
+        FoundationOptions::TRANSPORT_OPTIONS => [
+            TransportOptions::HOST => 'api.wunderground.com',
+            TransportOptions::MIDDLEWARE => [
+                JsonDecodeMiddleware::class,
+                JsonEncodeMiddleware::class,
+            ],
+            TransportOptions::USER_AGENT_STRATEGY => UserAgentStrategies::PACKAGE_VERSION,
+            TransportOptions::PACKAGE => 'api-clients/weather-underground',
+        ],
+    ];
+
+    public static function getOptions(
+        string $token,
+        array $suppliedOptions,
+        string $suffix
+    ): array {
+        $options = options_merge(self::TRANSPORT_OPTIONS, $suppliedOptions);
+        $options[FoundationOptions::TRANSPORT_OPTIONS][TransportOptions::PATH] = '/api/' . $token . '/';
+        $options[FoundationOptions::HYDRATOR_OPTIONS][HydratorOptions::NAMESPACE_SUFFIX] = $suffix;
+        return $options;
+    }
+}

src/AsyncClient.php

@@ -0,0 +1,49 @@
+<?php declare(strict_types=1);
+
+namespace ApiClients\Client\WeatherUnderground;
+
+use ApiClients\Client\WeatherUnderground\CommandBus\Command;
+use ApiClients\Foundation\ClientInterface;
+use ApiClients\Foundation\Factory;
+use React\EventLoop\LoopInterface;
+use React\Promise\PromiseInterface;
+use Rx\Observable;
+use function ApiClients\Tools\Rx\unwrapObservableFromPromise;
+use function React\Promise\resolve;
+
+final class AsyncClient
+{
+    /**
+     * @var ClientInterface
+     */
+    private $client;
+
+    /**
+     * @param LoopInterface $loop
+     * @param string $token
+     * @param array $options
+     * @return AsyncClient
+     */
+    public static function create(
+        LoopInterface $loop,
+        string $token,
+        array $options = []
+    ): self {
+        $options = ApiSettings::getOptions($token, $options, 'Async');
+        $client = Factory::create($loop, $options);
+        return new self($client);
+    }
+
+    /**
+     * @param ClientInterface $client
+     */
+    private function __construct(ClientInterface $client)
+    {
+        $this->client = $client;
+    }
+
+    public function conditions(string $location): PromiseInterface
+    {
+        return $this->client->handle(new Command\ConditionsCommand($location));
+    }
+}

src/AuthenticationInterface.php

@@ -0,0 +1,8 @@
+<?php declare(strict_types=1);
+
+namespace ApiClients\Client\WeatherUnderground;
+
+interface AuthenticationInterface
+{
+    public function getOptions(): array;
+}

src/Client.php

@@ -0,0 +1,35 @@
+<?php declare(strict_types=1);
+
+namespace ApiClients\Client\WeatherUnderground;
+
+use ApiClients\Client\WeatherUnderground\Resource\UserInterface;
+use React\EventLoop\Factory;
+use React\EventLoop\LoopInterface;
+use function Clue\React\Block\await;
+
+final class Client
+{
+    /**
+     * @var LoopInterface
+     */
+    private $loop;
+
+    /**
+     * @var AsyncClient
+     */
+    private $client;
+
+    public function __construct(AuthenticationInterface $auth)
+    {
+        $this->loop = Factory::create();
+        $this->client = AsyncClient::create($this->loop, $auth);
+    }
+
+    public function user(string $user): UserInterface
+    {
+        return await(
+            $this->client->user($user),
+            $this->loop
+        );
+    }
+}

src/CommandBus/Command/ConditionsCommand.php

@@ -0,0 +1,32 @@
+<?php declare(strict_types=1);
+
+namespace ApiClients\Client\WeatherUnderground\CommandBus\Command;
+
+use WyriHaximus\Tactician\CommandHandler\Annotations\Handler;
+
+/**
+ * @Handler("ApiClients\Client\WeatherUnderground\CommandBus\Handler\ConditionsHandler")
+ */
+final class ConditionsCommand
+{
+    /**
+     * @var string
+     */
+    private $location;
+
+    /**
+     * @param string $location
+     */
+    public function __construct(string $location = '')
+    {
+        $this->location = $location;
+    }
+
+    /**
+     * @return string
+     */
+    public function getLocation(): string
+    {
+        return $this->location;
+    }
+}

src/CommandBus/Handler/ConditionsHandler.php

@@ -0,0 +1,41 @@
+<?php declare(strict_types=1);
+
+namespace ApiClients\Client\WeatherUnderground\CommandBus\Handler;
+
+use ApiClients\Client\WeatherUnderground\CommandBus\Command\ConditionsCommand;
+use ApiClients\Client\WeatherUnderground\Resource\ConditionInterface;
+use ApiClients\Tools\Services\Client\FetchAndHydrateService;
+use React\Promise\PromiseInterface;
+use function React\Promise\resolve;
+use function WyriHaximus\React\futureFunctionPromise;
+
+final class ConditionsHandler
+{
+    /**
+     * @var FetchAndHydrateService
+     */
+    private $service;
+
+    /**
+     * @param FetchAndHydrateService $service
+     */
+    public function __construct(FetchAndHydrateService $service)
+    {
+        $this->service = $service;
+    }
+
+    /**
+     * Fetch the given repository and hydrate it
+     *
+     * @param ConditionsCommand $command
+     * @return PromiseInterface
+     */
+    public function handle(ConditionsCommand $command): PromiseInterface
+    {
+        return $this->service->handle(
+            'conditions/q/' . $command->getLocation() . '.json',
+            'current_observation',
+            ConditionInterface::HYDRATE_CLASS
+        );
+    }
+}

src/Resource/Async/Condition.php

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

src/Resource/Async/EmptyCondition.php

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