<?php

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

namespace App\Infrastructure\Provider\Cdf;

use App\Infrastructure\Adapter\HttpClientInterface;
use App\Infrastructure\Adapter\Provider\Cdf\WorkflowInterface;
use Symfony\Component\DependencyInjection\ParameterBag\ParameterBagInterface;
use Symfony\Component\HttpFoundation\RequestStack;

class Workflow implements WorkflowInterface
{
    /** @var ParameterBagInterface */
    public $params;

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

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

    public function __construct(
        HttpClientInterface $httpClient,
        ParameterBagInterface $params,
        RequestStack $requestStack
    ) {
        $this->params = $params;
        $this->httpClient = $httpClient;
        $this->requestStack  = $requestStack;
    }

    /**
     * @return mixed
     */
    public function getWorkflows()
    {
        return $this->httpClient->data('GET', $this->params->get('domain_cdf') . '/workflow.json',
            [
                'headers' => [
                    'x-auth-token' => $this->requestStack->getCurrentRequest()->headers->get('x-auth-token'),
                ],
            ]
        );
    }

    /**
     * @return mixed
     */
    public function getWorkflow(int $workflow_id)
    {
        return $this->httpClient->data('GET', $this->params->get('domain_cdf') . '/configuration/' . $workflow_id . '.json',
            [
                'headers' => [
                    'x-auth-token' => $this->requestStack->getCurrentRequest()->headers->get('x-auth-token'),
                ],
            ]
        );
    }

    public function getPlaces(int $config)
    {
        $result = $this->httpClient->data('GET', $this->params->get('domain_cdf') . '/workflow/' . $config . '/places.json',
            [
                'headers' => [
                    'x-auth-token' => $this->requestStack->getCurrentRequest()->headers->get('x-auth-token'),
                ],
            ]
        );

        if (isset($result) && array_key_exists('data', $result) && (is_array($result['data']) || $result['data'])) {
            return $result['data'];
        } else {
            return $result;
        }
    }

    public function getUserPlaces(int $user_id)
    {
        return $this->httpClient->data('GET', $this->params->get('domain_cdf') . '/user/' . $user_id . '/places.json',
            [
                'headers' => [
                    'x-auth-token' => $this->requestStack->getCurrentRequest()->headers->get('x-auth-token'),
                ],
            ]
        );
    }

    public function getAllPlaces()
    {
        return $this->httpClient->data('GET', $this->params->get('domain_cdf') . '/workflows/places.json',
            [
                'headers' => [
                    'x-auth-token' => $this->requestStack->getCurrentRequest()->headers->get('x-auth-token'),
                ],
            ]
        );
    }

    public function getInfo()
    {
        $result = $this->httpClient->data('GET', $this->params->get('domain_cdf') . '/workflows/info.json',
            [
                'headers' => [
                    'x-auth-token' => "command",
                ],
            ]
        );

        return $result['data'];
    }
}