src/Request.php


1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95

<?php

namespace GeminiFoundation;

class Request
{
  protected string $scheme;
  protected string $host;
  protected string $path;
  protected array $query;
  protected ?ClientCertificate $clientCertificate;

  public function __construct(string $url, ?ClientCertificate $clientCertificate = null)
  {
    $requestUrl = parse_url($url);

    $this->scheme = $requestUrl['scheme'];
    $this->host = $requestUrl['host'];
    $this->path = $requestUrl['path'] ?? '/';

    $this->query = [];
    if (isset($requestUrl['query'])) {
      foreach (explode('&', $requestUrl['query']) as $queryString) {
        $query = explode('=', $queryString);

        if (empty($query[1])) {
          $this->query['input'] = $query[0];
        } else {
          $this->query[$query[0]] = $query[1];
        }
      }
    }

    $this->clientCertificate = $clientCertificate;
  }

  /**
   * @param resource $resource
   */
  public static function fromResource($resource): static
  {
    $request = Request::fromString(fread($resource, 1024));

    $clientCertificate = null;
    $streamParams = stream_context_get_params($resource);
    $peerCertificate = $streamParams['options']['ssl']['peer_certificate'] ?? null;
    if ($peerCertificate) {
      $clientCertificate = new ClientCertificate($peerCertificate);
      $request->setClientCertificate($clientCertificate);
    }

    return $request;
  }

  public static function fromString(string $string): static
  {
    $requestUrl = explode("\r\n", $string)[0] ?? '';

    return new Request($requestUrl);
  }

  public function getPath(): string
  {
    return $this->path;
  }

  public function getQuery(): array
  {
    return $this->query;
  }

  public function get(string $key): mixed
  {
    return $this->query[$key] ?? null;
  }

  public function set(string $key, string $value): self
  {
    $this->query[$key] = $value;

    return $this;
  }

  public function getClientCertificate(): ?ClientCertificate
  {
    return $this->clientCertificate;
  }

  public function setClientCertificate(ClientCertificate $clientCertificate): self
  {
    $this->clientCertificate = $clientCertificate;

    return $this;
  }
}