AzuraCast/src/Webhook/Connector/MatomoAnalytics.php

<?php

declare(strict_types=1);

namespace App\Webhook\Connector;

use App\Entity\Api\NowPlaying\NowPlaying;
use App\Entity\Repository\ListenerRepository;
use App\Entity\Station;
use App\Entity\StationWebhook;
use App\Http\RouterInterface;
use App\Utilities\Urls;
use GuzzleHttp\Client;
use Psr\Http\Message\UriInterface;

final class MatomoAnalytics extends AbstractConnector
{
    public function __construct(
        Client $httpClient,
        private readonly RouterInterface $router,
        private readonly ListenerRepository $listenerRepo
    ) {
        parent::__construct($httpClient);
    }

    protected function webhookShouldTrigger(StationWebhook $webhook, array $triggers = []): bool
    {
        return true;
    }

    /**
     * @inheritDoc
     */
    public function dispatch(
        Station $station,
        StationWebhook $webhook,
        NowPlaying $np,
        array $triggers
    ): void {
        $config = $webhook->getConfig();

        if (empty($config['matomo_url']) || empty($config['site_id'])) {
            throw $this->incompleteConfigException($webhook);
        }

        // Get listen URLs for each mount point.
        $radioPort = $station->getFrontendConfig()->getPort();

        $baseUri = $this->router->getBaseUrl();

        $mountUrls = [];
        $mountNames = [];
        foreach ($station->getMounts() as $mount) {
            $mountUrl = $baseUri->withPath('/radio/' . $radioPort . $mount->getName());
            $mountUrls[$mount->getId()] = (string)$mountUrl;
            $mountNames[$mount->getId()] = (string)$mount;
        }

        $remoteUrls = [];
        $remoteNames = [];
        foreach ($station->getRemotes() as $remote) {
            $remoteUrl = $baseUri->withPath('/radio/remote' . $remote->getMount());
            $remoteUrls[$remote->getId()] = (string)$remoteUrl;
            $remoteNames[$remote->getId()] = (string)$remote;
        }

        // Build Matomo URI
        $apiUrl = Urls::parseUserUrl(
            $config['matomo_url'],
            'Matomo Analytics URL',
        )->withPath('/matomo.php');

        $apiToken = $config['token'] ?? null;

        $stationName = $station->getName();

        // Get all current listeners
        $liveListeners = $this->listenerRepo->iterateLiveListenersArray($station);
        $webhookLastSent = (int)$webhook->getMetadataKey($webhook::LAST_SENT_TIMESTAMP_KEY, 0);

        $i = 0;
        $entries = [];

        foreach ($liveListeners as $listener) {
            $listenerUrl = null;
            $streamName = 'Stream';

            if (!empty($listener['mount_id'])) {
                $listenerUrl = $mountUrls[$listener['mount_id']] ?? null;
                $streamName = $mountNames[$listener['mount_id']] ?? $streamName;
            } elseif (!empty($listener['remote_id'])) {
                $listenerUrl = $remoteUrls[$listener['remote_id']] ?? null;
                $streamName = $remoteNames[$listener['remote_id']] ?? $streamName;
            }

            if (null === $listenerUrl) {
                continue;
            }

            $entry = [
                'idsite' => (int)$config['site_id'],
                'rec' => 1,
                'action_name' => 'Listeners / ' . $stationName . ' / ' . $streamName,
                'url' => $listenerUrl,
                'rand' => random_int(10000, 99999),
                'apiv' => 1,
                'ua' => $listener['listener_user_agent'],
                'cid' => substr($listener['listener_hash'], 0, 16),
            ];

            // If this listener is already registered, this is a "ping" update.
            if ($listener['timestamp_start'] < $webhookLastSent) {
                $entry['ping'] = 1;
            }

            if (!empty($apiToken)) {
                $entry['cip'] = $listener['listener_ip'];
            }

            $entries[] = $entry;
            $i++;

            if (100 === $i) {
                $this->sendBatch($webhook, $apiUrl, $apiToken, $entries);
                $entries = [];
                $i = 0;
            }
        }

        $this->sendBatch($webhook, $apiUrl, $apiToken, $entries);
    }

    private function sendBatch(
        StationWebhook $webhook,
        UriInterface $apiUrl,
        ?string $apiToken,
        array $entries
    ): void {
        if (empty($entries)) {
            return;
        }

        $jsonBody = [
            'requests' => array_map(static function ($row) {
                return '?' . http_build_query($row);
            }, $entries),
        ];

        if (!empty($apiToken)) {
            $jsonBody['token_auth'] = $apiToken;
        }

        $response = $this->httpClient->post($apiUrl, [
            'json' => $jsonBody,
        ]);

        $this->logHttpResponse(
            $webhook,
            $response,
            $jsonBody
        );
    }
}