ChampsLibres\WopiLib\Discovery\WopiDiscovery

Complexity

Total Complexity

22

Size/Duplication

Total Lines	125
Duplicated Lines	0 %

Test Coverage

Coverage

89.47%

Importance

Changes	4
Bugs	0	Features	1

6 Methods

Rating	Name	Duplication	Size	Complexity
A	discover()	0	16	2
A	__construct()	0	8	1
B	discoverExtension()	0	31	8
A	getCapabilities()	0	9	1
A	request()	0	12	2
B	discoverMimeType()	0	30	8

<?php

/**
 * For the full copyright and license information, please view
 * the LICENSE file that was distributed with this source code.
 */

declare(strict_types=1);

namespace ChampsLibres\WopiLib\Discovery;

use ChampsLibres\WopiLib\Configuration\WopiConfigurationInterface;
use Exception;
use loophp\psr17\Psr17Interface;
use Psr\Http\Client\ClientInterface;
use Psr\Http\Message\ResponseInterface;
use SimpleXMLElement;

use const JSON_THROW_ON_ERROR;

final class WopiDiscovery implements WopiDiscoveryInterface
{
    private ClientInterface $client;

    private WopiConfigurationInterface $configuration;

    private Psr17Interface $psr17;

    public function __construct(
        WopiConfigurationInterface $configuration,
        ClientInterface $client,
        Psr17Interface $psr17
    ) {
        $this->configuration = $configuration;
        $this->client = $client;
        $this->psr17 = $psr17;
    }

    public function discoverExtension(string $extension): array
    {
        $extensions = [];

        /** @var false|SimpleXMLElement[]|null $apps */
        $apps = $this->discover()->xpath('//net-zone/app');

        if (false === $apps || null === $apps) {
            throw new Exception();
        }

        foreach ($apps as $app) {
            /** @var false|SimpleXMLElement[]|null $actions */
            $actions = $app->xpath(sprintf("action[@ext='%s']", $extension));

            if (false === $actions || null === $actions) {
                continue;
            }

            foreach ($actions as $action) {
                $actionAttributes = $action->attributes() ?: [];

                $extensions[] = array_merge(
                    (array) reset($actionAttributes),
                    ['name' => (string) $app['name']],
                    ['favIconUrl' => (string) $app['favIconUrl']]
                );
            }
        }

        return $extensions;
    }

    public function discoverMimeType(string $mimeType): array
    {
        $mimeTypes = [];

        /** @var false|SimpleXMLElement[]|null $apps */
        $apps = $this->discover()->xpath(sprintf("//net-zone/app[@name='%s']", $mimeType));

        if (false === $apps || null === $apps) {
            throw new Exception();
        }

        foreach ($apps as $app) {
            /** @var false|SimpleXMLElement[]|null $actions */
            $actions = $app->xpath('action');

            if (false === $actions || null === $actions) {
                continue;
            }

            foreach ($actions as $action) {
                $actionAttributes = $action->attributes() ?: [];

                $mimeTypes[] = array_merge(
                    (array) reset($actionAttributes),
                    ['name' => (string) $app['name']],
                );
            }
        }

        return $mimeTypes;
    }

    public function getCapabilities(): array
    {
        $capabilities = $this->discover()->xpath("//net-zone/app[@name='Capabilities']");

        return json_decode(
            (string) $this->request((string) $capabilities[0]->action['urlsrc'])->getBody(),
            true,
            512,
            JSON_THROW_ON_ERROR
        );
    }

    private function discover(): SimpleXMLElement
    {
        $simpleXmlElement = simplexml_load_string(
            (string) $this
                ->request(
                    sprintf('%s/%s', $this->configuration['server'], 'hosting/discovery')
                )
                ->getBody()
        );

        if (false === $simpleXmlElement) {
            // TODO
            throw new Exception('Unable to parse XML.');
        }

        return $simpleXmlElement;
    }

    private function request(string $url): ResponseInterface
    {
        $response = $this
            ->client
            ->sendRequest($this->psr17->createRequest('GET', $url));

        if (200 !== $response->getStatusCode()) {
            // TODO
            throw new Exception('Invalid status code');
        }

        return $response;
    }
}