client-php/src/LogDbClient.php

<?php

namespace LogDb\Client;

class LogDbClient
{

    private mixed $socket = null;

    public function __destruct()
    {
        if (\is_resource($this->socket)) socket_close($this->socket);

    }

    public function __construct(
        private readonly string $server,
        private readonly string $type = 'http'
    )
    {
    }

    public function logEvent(LogEvent $event): void
    {
        switch ($this->type) {
            case 'http':
                $url = $this->server . "/api/logdb/v1/create-event";
                if (!str_starts_with($url, "http")) $url = "http://{$url}";
                $this->sendHttp(json_encode($event), $url);
                break;
            case 'udp':
                [$ip,$port] = explode(":", $this->server, 2);
                $this->sendUdp(json_encode($event), $ip, $port);
                break;
        }
    }

    public function logEventBatch(array $events): void
    {
        switch ($this->type) {
            case 'http':
                $url = $this->server . "/api/logdb/v1/create-event";
                if (!str_starts_with($url, "http")) $url = "http://{$url}";
                $this->sendHttp(json_encode($events), $url);
                break;
            case 'udp':
                // TODO set batch id, the server is unaware that this is a batch.
                foreach ($events as $event) {
                    if ($event instanceof LogEvent) {
                        [$ip,$port] = explode(":", $this->server, 2);
                        $this->sendUdp(json_encode($event), $ip, $port);
                    }
                }
                break;
        }
    }

    private function sendHttp(string $message, string $url): void
    {
        $context = stream_context_create([
            'http' => [
                'method' => 'POST',
                'header' => [
                    'content-type: application/json'
                ],
                'content' => $message
            ]
        ]);
        $response = file_get_contents($url, context:$context);
    }

    private function sendUdp(string $message, string $ip, int $port): void
    {
        $this->socket ??= socket_create(AF_INET, SOCK_DGRAM, SOL_UDP);
        $len = strlen($message);
        socket_sendto($this->socket, $message, $len, 0, $ip, $port);
    }
}