Release v0.9.0

src/App.php

@@ -33,6 +33,8 @@
 use Phenix\Exceptions\RuntimeError;
 use Phenix\Facades\Config;
 use Phenix\Facades\Route;
+use Phenix\Http\Client\HttpClient;
+use Phenix\Http\Client\HttpClientTestLogger;
 use Phenix\Http\Constants\Protocol;
 use Phenix\Http\ErrorHandler as AppErrorHandler;
 use Phenix\Http\ExceptionHandler as AppExceptionHandler;
@@ -91,6 +93,9 @@ public function setup(): void
             \Phenix\Runtime\Config::build(...)
         )->setShared(true);
 
+        self::$container->add(HttpClient::class);
+        self::$container->add(HttpClientTestLogger::class)->setShared(true);
+
         self::$container->add(Phenix::class)->addMethodCall('registerCommands');
 
         /** @var array $providers */

src/Cache/RateLimit/Middlewares/RateLimiter.php

@@ -55,10 +55,14 @@ public function handleRequest(Request $request, RequestHandler $next): Response
         $remaining = max(0, $perMinuteLimit - $current);
         $resetTime = time() + $this->rateLimiter->getTtl($clientIp);
 
-        $response->addHeader('x-ratelimit-limit', (string) $perMinuteLimit);
-        $response->addHeader('x-ratelimit-remaining', (string) $remaining);
-        $response->addHeader('x-ratelimit-reset', (string) $resetTime);
-        $response->addHeader('x-ratelimit-reset-after', (string) $this->rateLimiter->getTtl($clientIp));
+        if ($isCustom || ! $response->hasHeader('x-ratelimit-limit')) {
+            $response->replaceHeaders([
+                'x-ratelimit-limit' => (string) $perMinuteLimit,
+                'x-ratelimit-remaining' => (string) $remaining,
+                'x-ratelimit-reset' => (string) $resetTime,
+                'x-ratelimit-reset-after' => (string) $this->rateLimiter->getTtl($clientIp),
+            ]);
+        }
 
         return $response;
     }

src/Facades/File.php

@@ -14,6 +14,7 @@
  * @method static bool isDirectory(string $path)
  * @method static bool isFile(string $path)
  * @method static void createDirectory(string $path, int $mode = 0755)
+ * @method static void move(string $from, string $to)
  * @method static \Amp\File\File openFile(string $path, string $mode = 'w')
  * @method static int getCreationTime(string $path)
  * @method static int getModificationTime(string $path)

src/Facades/Http.php

@@ -0,0 +1,55 @@
+<?php
+
+declare(strict_types=1);
+
+namespace Phenix\Facades;
+
+use Mockery\Expectation;
+use Mockery\ExpectationInterface;
+use Mockery\HigherOrderMessage;
+use Phenix\App;
+use Phenix\Http\Client\HttpClient;
+use Phenix\Runtime\Facade;
+use Phenix\Testing\Mockery;
+
+/**
+ * @method static \Phenix\Http\Client\Response get(\Psr\Http\Message\UriInterface|string $url, array|null $queryParameters = null)
+ * @method static \Phenix\Http\Client\Response head(\Psr\Http\Message\UriInterface|string $url, array|null $queryParameters = null)
+ * @method static \Phenix\Http\Client\Response post(\Psr\Http\Message\UriInterface|string $url, \Amp\Http\Client\Form|\Phenix\Contracts\Arrayable|array|string $data = [])
+ * @method static \Phenix\Http\Client\Response put(\Psr\Http\Message\UriInterface|string $url, \Amp\Http\Client\Form|\Phenix\Contracts\Arrayable|array|string $data = [])
+ * @method static \Phenix\Http\Client\Response patch(\Psr\Http\Message\UriInterface|string $url, \Amp\Http\Client\Form|\Phenix\Contracts\Arrayable|array|string $data = [])
+ * @method static \Phenix\Http\Client\Response delete(\Psr\Http\Message\UriInterface|string $url, \Amp\Http\Client\Form|\Phenix\Contracts\Arrayable|array|string $data = [])
+ * @method static mixed stream(\Psr\Http\Message\UriInterface|string $url, \Closure|null $callback = null, array|null $queryParameters = null, int|null $bodySizeLimit = null, float|null $transferTimeout = null, \Phenix\Http\Constants\HttpMethod $method = \Phenix\Http\Constants\HttpMethod::GET, \Amp\Http\Client\Form|\Phenix\Contracts\Arrayable|array|string|null $data = null)
+ * @method static \Phenix\Http\Client\HttpClient withHeaders(array $headers)
+ * @method static \Phenix\Http\Client\HttpClient withClient(\Amp\Http\Client\HttpClient $client)
+ * @method static \Phenix\Http\Client\HttpClient withBasicAuth(string $username, string $password)
+ * @method static \Phenix\Http\Client\HttpClient withToken(string $token, string $type = 'Bearer')
+ * @method static \Phenix\Http\Client\HttpClient retry(int $times, \Closure|int $sleepMilliseconds = 0, callable|null $when = null)
+ * @method static \Phenix\Http\Client\HttpClient listen(\Amp\Http\Client\EventListener $eventListener)
+ * @method static \Phenix\Http\Client\HttpClient log(string $path)
+ * @method static \Phenix\Http\Client\HttpClient withTlsContext(\Amp\Socket\ClientTlsContext $tlsContext)
+ * @method static \Phenix\Http\Client\HttpClient withCertificate(string $certificate, string|null $key = null, string|null $ca = null, string|null $passphrase = null, string $peerName = '')
+ * @method static void fake(\Closure|null $response = null)
+ * @method static void fakeWhen(\Closure $condition, \Closure $response)
+ * @method static \Phenix\Data\Collection getRequestLog()
+ * @method static void resetRequestLog()
+ * @method static void resetFaking()
+ *
+ * @see \Phenix\Http\Client\HttpClient
+ */
+class Http extends Facade
+{
+    public static function getKeyName(): string
+    {
+        return HttpClient::class;
+    }
+
+    public static function expect(string $method): Expectation|ExpectationInterface|HigherOrderMessage
+    {
+        $mock = Mockery::mock(self::getKeyName())->shouldAllowMockingProtectedMethods()->makePartial();
+
+        App::fake(self::getKeyName(), $mock);
+
+        return $mock->shouldReceive($method);
+    }
+}

src/Filesystem/Contracts/File.php

@@ -17,4 +17,6 @@ public function isDirectory(string $path): bool;
     public function isFile(string $path): bool;
 
     public function createDirectory(string $path, int $mode = 0777): void;
+
+    public function move(string $from, string $to): void;
 }

src/Filesystem/File.php

@@ -51,6 +51,11 @@ public function createDirectory(string $path, int $mode = 0755): void
         $this->driver->createDirectory($path, $mode);
     }
 
+    public function move(string $from, string $to): void
+    {
+        $this->driver->move($from, $to);
+    }
+
     public function openFile(string $path, string $mode = 'w'): FileHandler
     {
         return $this->driver->openFile($path, $mode);

src/Http/Client/Concerns/CaptureRequests.php

@@ -0,0 +1,74 @@
+<?php
+
+declare(strict_types=1);
+
+namespace Phenix\Http\Client\Concerns;
+
+use Amp\Http\Client\Request;
+use Closure;
+use Phenix\App;
+use Phenix\Data\Collection;
+use Phenix\Http\Client\HttpClientTestLogger;
+use Phenix\Http\Client\Response;
+use Phenix\Http\Client\StreamResponse;
+
+trait CaptureRequests
+{
+    protected HttpClientTestLogger|null $requestLogger = null;
+
+    public function fake(Closure|null $response = null): void
+    {
+        if (App::isProduction()) {
+            return;
+        }
+
+        $this->getRequestLogger()->fake($response);
+    }
+
+    public function fakeWhen(Closure $condition, Closure $response): void
+    {
+        if (App::isProduction()) {
+            return;
+        }
+
+        $this->getRequestLogger()->fakeWhen($condition, $response);
+    }
+
+    /**
+     * @return Collection<Request>
+     */
+    public function getRequestLog(): Collection
+    {
+        return $this->getRequestLogger()->getRequestLog();
+    }
+
+    public function resetRequestLog(): void
+    {
+        $this->getRequestLogger()->resetRequestLog();
+    }
+
+    public function resetFaking(): void
+    {
+        $this->getRequestLogger()->resetFaking();
+    }
+
+    protected function getRequestLogger(): HttpClientTestLogger
+    {
+        return $this->requestLogger ??= App::make(HttpClientTestLogger::class);
+    }
+
+    protected function recordRequest(Request $request): void
+    {
+        $this->getRequestLogger()->record($request);
+    }
+
+    protected function getFakeResponse(Request $request): Response|null
+    {
+        return $this->getRequestLogger()->getFakeResponse($request, $this);
+    }
+
+    protected function getFakeStreamResponse(Request $request): StreamResponse|null
+    {
+        return $this->getRequestLogger()->getFakeStreamResponse($request, $this);
+    }
+}

src/Http/Client/Concerns/HasAuthorization.php

@@ -0,0 +1,27 @@
+<?php
+
+declare(strict_types=1);
+
+namespace Phenix\Http\Client\Concerns;
+
+use SensitiveParameter;
+
+trait HasAuthorization
+{
+    public function withBasicAuth(
+        string $username,
+        #[SensitiveParameter]
+        string $password
+    ): self {
+        $this->headers['Authorization'] = 'Basic ' . base64_encode("{$username}:{$password}");
+
+        return $this;
+    }
+
+    public function withToken(#[SensitiveParameter] string $token, string $type = 'Bearer'): self
+    {
+        $this->headers['Authorization'] = "{$type} {$token}";
+
+        return $this;
+    }
+}

src/Http/Client/Concerns/HasHttpStatus.php

@@ -0,0 +1,90 @@
+<?php
+
+declare(strict_types=1);
+
+namespace Phenix\Http\Client\Concerns;
+
+use Phenix\Http\Constants\HttpStatus;
+
+trait HasHttpStatus
+{
+    public function ok(): bool
+    {
+        return $this->hasStatus(HttpStatus::OK);
+    }
+
+    public function created(): bool
+    {
+        return $this->hasStatus(HttpStatus::CREATED);
+    }
+
+    public function accepted(): bool
+    {
+        return $this->hasStatus(HttpStatus::ACCEPTED);
+    }
+
+    public function noContent(): bool
+    {
+        return $this->hasStatus(HttpStatus::NO_CONTENT) && $this->body === '';
+    }
+
+    public function movedPermanently(): bool
+    {
+        return $this->hasStatus(HttpStatus::MOVED_PERMANENTLY);
+    }
+
+    public function found(): bool
+    {
+        return $this->hasStatus(HttpStatus::FOUND);
+    }
+
+    public function badRequest(): bool
+    {
+        return $this->hasStatus(HttpStatus::BAD_REQUEST);
+    }
+
+    public function unauthorized(): bool
+    {
+        return $this->hasStatus(HttpStatus::UNAUTHORIZED);
+    }
+
+    public function paymentRequired(): bool
+    {
+        return $this->hasStatus(HttpStatus::PAYMENT_REQUIRED);
+    }
+
+    public function forbidden(): bool
+    {
+        return $this->hasStatus(HttpStatus::FORBIDDEN);
+    }
+
+    public function notFound(): bool
+    {
+        return $this->hasStatus(HttpStatus::NOT_FOUND);
+    }
+
+    public function requestTimeout(): bool
+    {
+        return $this->hasStatus(HttpStatus::REQUEST_TIMEOUT);
+    }
+
+    public function conflict(): bool
+    {
+        return $this->hasStatus(HttpStatus::CONFLICT);
+    }
+
+    public function unprocessableEntity(): bool
+    {
+        return $this->hasStatus(HttpStatus::UNPROCESSABLE_ENTITY);
+    }
+
+    public function tooManyRequests(): bool
+    {
+        return $this->hasStatus(HttpStatus::TOO_MANY_REQUESTS);
+    }
+
+    private function hasStatus(HttpStatus $status): bool
+    {
+        return $this->status() === $status->value;
+    }
+}

src/Http/Client/Concerns/HasTls.php

@@ -0,0 +1,44 @@
+<?php
+
+declare(strict_types=1);
+
+namespace Phenix\Http\Client\Concerns;
+
+use Amp\Http\Client\Connection\DefaultConnectionFactory;
+use Amp\Http\Client\Connection\UnlimitedConnectionPool;
+use Amp\Socket\Certificate;
+use Amp\Socket\ClientTlsContext;
+use Amp\Socket\ConnectContext;
+use SensitiveParameter;
+
+trait HasTls
+{
+    public function withTlsContext(ClientTlsContext $tlsContext): self
+    {
+        $connectContext = (new ConnectContext())->withTlsContext($tlsContext);
+        $connectionFactory = new DefaultConnectionFactory(connectContext: $connectContext);
+
+        $this->builder = $this->builder->usingPool(new UnlimitedConnectionPool($connectionFactory));
+        $this->client = $this->builder->build();
+
+        return $this;
+    }
+
+    public function withCertificate(
+        string $certificate,
+        string|null $key = null,
+        string|null $ca = null,
+        #[SensitiveParameter]
+        string|null $passphrase = null,
+        string $peerName = ''
+    ): self {
+        $tlsContext = (new ClientTlsContext($peerName))
+            ->withCertificate(new Certificate($certificate, $key, $passphrase));
+
+        if ($ca !== null) {
+            $tlsContext = $tlsContext->withCaFile($ca);
+        }
+
+        return $this->withTlsContext($tlsContext);
+    }
+}

src/Http/Client/Constants/ProtocolVersion.php

@@ -0,0 +1,14 @@
+<?php
+
+declare(strict_types=1);
+
+namespace Phenix\Http\Client\Constants;
+
+enum ProtocolVersion: string
+{
+    case V1_0 = '1.0';
+
+    case V1_1 = '1.1';
+
+    case V2 = '2';
+}