<?php

declare(strict_types=1);

namespace App\Console;

use App\Controller\Api\ApiController;
use App\Model\ErrorsModel;
use App\Model\ProductosModel;
use GuzzleHttp\HandlerStack;
use GuzzleHttp\Middleware;
use Monolog\Handler\StreamHandler;
use Monolog\Logger;
use Mosaico\BigCommerce\BaseApiHandlerV3;
use Symfony\Component\Console\Attribute\AsCommand;
use Symfony\Component\Console\Command\Command;
use Symfony\Component\Console\Input\InputArgument;
use Symfony\Component\Console\Input\InputInterface;
use Symfony\Component\Console\Output\OutputInterface;

class CatalogProductDescriptionCommand extends Command
{
    protected function configure(): void
    {
        $this
            ->setName('catalog:product:description')
            ->setDescription('Update BigCommerce Product Description')
            ->setHelp('This command allows you update BigCommerce product description');
    }

    protected function execute(InputInterface $input, OutputInterface $output): int
    {
        new ApiController();
        $productosModel = new ProductosModel();
        $errorsModel = new ErrorsModel();
        $errorData = [];
        $httpMethod = 'PUT';
        $productos = (object) $productosModel->getProductUpdate();
        $array = [];

        if ($productos->num_rows > 0) :
            $client = new BaseApiHandlerV3();
            foreach ($productos->rows as $value) {

                $array = [
                    'description' => $value['description']
                ];

                try {
                    $handler = HandlerStack::create();
                    $tapMiddleware = Middleware::tap(function ($request) {
                        //echo $request->getBody() . "\r\n";
                    });
                    $response = $client->api()->request($httpMethod, 'catalog/products/' . $value['id_bigcommerce'], [
                        'headers' => [
                            'X-Auth-Token' => $client->token(),
                            'Accept' => 'application/json',
                        ],
                        'content-type' => 'application/json',
                        'json' => $array,
                        'handler' => $tapMiddleware($handler),
                    ]);
                    $body = $response->getBody();
                    $product = json_decode((string) $body, true);
                    //print_r($product);
                    //$product = $response->getBody();
                    //return 0;
                    if ($product) {
                        $productosModel->updateIsUpdate(
                            (int) $value['id_producto']
                        );
                        $this->logInfo([
                            'status' => $response->getStatusCode(),
                            'sku' => $value['sku'],
                            'id' => $value['id_bigcommerce'],
                        ]);
                    }
                    $output->writeln($value['id_producto'] . '-' . $value['sku']);
                } catch (\GuzzleHttp\Exception\ClientException $e) {
                    $response = $e->getResponse();
                    $error = json_decode((string) $response->getBody());
                    $error_string = '[' . date('y-m-d h:i:s') . '] updateProduct.ERROR: ' . (string) $response->getBody();
                    //$this->logError($error, $value);

                    $productosModel->updateStatusErrorBigcommerce(
                        (int) $value['id_producto'],
                        (int) 2,
                        (string) addslashes($error_string)
                    );

                    $output->writeln($error_string);

                    $arrayErrors = (array) $error->errors;
                    $errorData['id_api'] = 3;
                    $errorData['id_resource'] = $value['id_producto'];
                    $errorData['request_method'] = $httpMethod;
                    $errorData['status_code'] = $error->status;
                    $errorData['title'] = addslashes($error->title);
                    $errorData['detail'] = addslashes(array_key_first($arrayErrors) .
                    ' - ' . reset($arrayErrors));
                    $errorsModel->addResponseError($errorData);
                }
            }
        else :
            $output->writeln('No new data');
        endif;
        return 0;
    }

    public function logError(object $error, array $product): void
    {
        $log = new Logger('UpdateProductv3');
        $log->pushHandler(new StreamHandler(__DIR__ . '/../../logs/products/error.log', Logger::ERROR));

        $errors = (array) $error->errors;
        $log->error(
            ';status: ' . $error->status . ';',
            [
                'title' => $error->title,
                'id_producto' => $product['id_producto'],
                'nombre' => $product['nombre_producto'],
                'errors' => $errors,
            ]
        );
    }

    public function logInfo(array $info)
    {
        $log = new Logger('UpdateProductv3');
        $log->pushHandler(new StreamHandler(__DIR__ . '/../../logs/products/info.log', Logger::INFO));

        $log->info(
            'status: ' . $info['status'],
            [
                'Product Updated: ' . $info['sku'],
                'BigCommerce ID: ' . $info['id'],
            ]
        );
    }

    public function debugError(object $error, OutputInterface $output)
    {
        $output->writeln('error');
        $output->writeln($error->message);
        $output->writeln($error->details->conflict_reason);
        $output->writeln('errorEof');
    }
}