testcontainers-php/src/Wait/WaitForHttp.php

<?php

declare(strict_types=1);

namespace Testcontainers\Wait;

use Docker\Docker;
use Testcontainers\Exception\ContainerNotReadyException;

//TODO: not ready yet
class WaitForHttp implements WaitStrategy
{
    public const METHOD_GET = 'GET';
    public const METHOD_POST = 'POST';
    public const METHOD_PUT = 'PUT';
    public const METHOD_DELETE = 'DELETE';
    public const METHOD_HEAD = 'HEAD';
    public const METHOD_OPTIONS = 'OPTIONS';


    private string $method = 'GET';
    private string $path = '/';
    private int $statusCode = 200;
    private Docker $dockerClient;

    public function __construct(private int $port)
    {
        $this->dockerClient = Docker::create();
    }

    public static function make(int $port): self
    {
        return new WaitForHttp($port);
    }

    /**
     * @param WaitForHttp::METHOD_* $method
     */
    public function withMethod(string $method): self
    {
        $this->method = $method;

        return $this;
    }

    public function withPath(string $path): self
    {
        $this->path = $path;

        return $this;
    }

    public function withStatusCode(int $statusCode): self
    {
        $this->statusCode = $statusCode;

        return $this;
    }

    public function wait(string $id): void
    {
        $containerNetworks = $this->dockerClient->containerInspect($id)->getNetworkSettings()->getNetworks();
        $containerAddress = null;
        foreach ($containerNetworks as $network) {
            if ($network->getNetworkID() === $id) {
                $containerAddress = $network->getIpAddress();
                break;
            }
        }

        $ch = curl_init();
        curl_setopt($ch, CURLOPT_URL, sprintf('http://%s:%d%s', $containerAddress, $this->port, $this->path));
        curl_setopt($ch, CURLOPT_RETURNTRANSFER, true);
        curl_setopt($ch, CURLOPT_CUSTOMREQUEST, $this->method);
        curl_setopt($ch, CURLOPT_HEADER, true);
        curl_setopt($ch, CURLOPT_NOBODY, true);

        curl_exec($ch);

        if (curl_getinfo($ch, CURLINFO_HTTP_CODE) !== $this->statusCode) {
            throw new ContainerNotReadyException($id, new \RuntimeException('HTTP status code does not match'));
        }

        curl_close($ch);
    }
}