<?php
/**
 * Copyright since 2014 Waynet Sp. z o.o.
 * PrestaShop is an International Registered Trademark & Property of PrestaShop SA
 *
 * NOTICE OF LICENSE
 *
 * This source file is subject to the Open Software License (OSL 3.0)
 * that is bundled with this package in the file LICENSE.md.
 * It is also available through the world-wide-web at this URL:
 * https://opensource.org/licenses/OSL-3.0
 * If you did not receive a copy of the license and are unable to
 * obtain it through the world-wide-web, please send an email
 * to kontakt@waynet.pl so we can send you a copy immediately.
 *
 * DISCLAIMER
 *
 * Do not edit or add to this file if you wish to upgrade PrestaShop to newer
 * versions in the future. If you wish to customize PrestaShop for your
 * needs please refer to https://devdocs.prestashop-project.org/ for more information.
 *
 * @author    Waynet Sp. z o.o. <kontakt@waynet.pl>
 * @copyright since 2014 Waynet Sp. z o.o.
 * @license   https://opensource.org/licenses/OSL-3.0 Open Software License (OSL 3.0)
 */

declare(strict_types=1);

namespace Waynet\Security\Api;

use Psr\Http\Client\ClientInterface;
use Psr\Http\Message\RequestFactoryInterface;
use Psr\Http\Message\RequestInterface;
use Psr\Http\Message\ResponseInterface;
use Psr\Http\Message\StreamFactoryInterface;
use Psr\Http\Message\UriInterface;
use Waynet\OAuth2\Client\Exception\JsonException;
use Waynet\OAuth2\Client\Http\DecodeJsonResponseTrait;
use Waynet\Security\Api\Exception\HydraException;
use Waynet\Security\Api\Exception\ResourceNotFoundException;
use Waynet\Security\Api\Resource\HydraCollection;
use Waynet\Security\Api\Resource\Report;
use Waynet\Security\Http\Exception\HttpException;

class ApiClient
{
    use DecodeJsonResponseTrait;

    private $httpClient;
    private $requestFactory;
    private $streamFactory;

    public function __construct(
        ClientInterface $httpClient,
        RequestFactoryInterface $requestFactory,
        StreamFactoryInterface $streamFactory
    ) {
        $this->httpClient = $httpClient;
        $this->requestFactory = $requestFactory;
        $this->streamFactory = $streamFactory;
    }

    public function getLastReport(): ?Report
    {
        $request = $this->createRequest('GET', 'reports/last');

        try {
            $response = $this->sendRequest($request);
        } catch (ResourceNotFoundException $exception) {
            return null;
        }

        $data = $this->decodeJsonResponse($response);

        return Report::cast($data);
    }

    /**
     * @return HydraCollection<Report>
     */
    public function getReports(): HydraCollection
    {
        return new HydraCollection($this, Report::class, 'reports');
    }

    public function getCollection(string $uri): array
    {
        $request = $this->createRequest('GET', $uri);
        $response = $this->sendRequest($request);

        return $this->decodeJsonResponse($response);
    }

    public function patch(string $uri, array $data): array
    {
        $request = $this->createRequest('PATCH', $uri, $data);
        $response = $this->sendRequest($request);

        return $this->decodeJsonResponse($response);
    }

    public function sendRequest(RequestInterface $request): ResponseInterface
    {
        $response = $this->httpClient->sendRequest($request);

        if (300 <= $statusCode = $response->getStatusCode()) {
            try {
                $data = $this->decodeJsonResponse($response);
                if ('hydra:Error' === ($data['@type'] ?? null)) {
                    throw HydraException::create($data, $statusCode);
                }
            } catch (JsonException $exception) {
                // ignore decoding errors
            }

            throw HttpException::create($request, $response);
        }

        return $response;
    }

    /**
     * @param UriInterface|string $uri
     */
    public function createRequest(string $method, $uri, array $payload = []): RequestInterface
    {
        $request = $this->requestFactory
            ->createRequest($method, $uri)
            ->withHeader('Accept', 'application/ld+json');

        if (!$payload) {
            return $request;
        }

        $body = $this->streamFactory->createStream(json_encode($payload));
        $contentType = 'PATCH' === $method ? 'application/merge-patch+json' : 'application/ld+json';

        return $request
            ->withBody($body)
            ->withHeader('Content-Type', $contentType);
    }
}