<?php

/*
 * This file is part of the Maestro Project.
 * Copyright (C) Compos Juliot
 */

namespace App\Infrastructure\Provider\ElementType;

use App\Application\Exception\SubException\UnprocessableEntityMaestroException;
use App\Infrastructure\Adapter\HttpClientInterface;
use App\Infrastructure\Adapter\Provider\ElementType\ElementTypeCollectInterface;
use Symfony\Component\DependencyInjection\ParameterBag\ParameterBagInterface;
use Symfony\Component\HttpFoundation\RequestStack;
use App\Application\Adapter\RespondInterface;

class Collect implements ElementTypeCollectInterface
{
    /** @var ParameterBagInterface */
    public $params;

    /** @var HttpClientInterface */
    public $httpClient;

    /** @var RequestStack */
    public $requestStack;

    /** @var RespondInterface */
    public $respondService;

    /** @var string */
    private $domain = "domain_pim";

    /** @var string */
    private $enabled = "pim_enabled";

    /** @var string */
    private $module = "PIM";

    /** @var string */
    private $keyModule = "params";

    /** @var string */
    private $methodModule = "get";

    /** @var string */
    private $token = "";

    public function __construct(
        HttpClientInterface $httpClient,
        ParameterBagInterface $params,
        RequestStack $requestStack,
        RespondInterface $respondService
    ) {
        $this->params = $params;
        $this->httpClient = $httpClient;
        $this->requestStack = $requestStack;
        $this->respondService = $respondService;
        $this->token = $this->requestStack->getCurrentRequest()->headers->get('x-auth-token');
    }

    public function list()
    {
        if ($this->params->get($this->enabled)) {
            $response = $this->httpClient->data(
                'GET',
                $this->params->get($this->domain) . '/element_type.json',
                [
                    'headers' => [
                        'x-auth-token' => $this->token,
                    ],
                ]
            );

            return $this->respondService->checkProviderResponse($response);
        } else {
            throw new UnprocessableEntityMaestroException($this->module, $this->keyModule, $this->methodModule);
        }
    }

    /**
     * @return mixed
     */
    public function read(int $elementTypeId)
    {
        if ($this->params->get($this->enabled)) {
            $response = $this->httpClient->data(
                'GET',
                $this->params->get($this->domain) . '/element_type/' . $elementTypeId . '.json',
                [
                    'headers' => [
                        'x-auth-token' => $this->token,
                    ],
                ]
            );

            return $this->respondService->checkProviderResponse($response);
        } else {
            throw new UnprocessableEntityMaestroException($this->module, $this->keyModule, $this->methodModule);
        }
    }

    public function readMultiple(array $idElementTypes)
    {
        if ($this->params->get($this->enabled)) {
            $response = $this->httpClient->data(
                'POST',
                $this->params->get($this->domain) . '/element_type/read/multiple.json',
                [
                    'headers' => [
                        'x-auth-token' => $this->token,
                    ],
                    'json' => [
                        'ids' => $idElementTypes,
                    ],
                ]
            );

            return $this->respondService->checkProviderResponse($response);
        } else {
            throw new UnprocessableEntityMaestroException($this->module, $this->keyModule, $this->methodModule);
        }
    }
}