<?php

namespace Webkul\Magento2Bundle\Step;

use Symfony\Component\EventDispatcher\EventDispatcherInterface;
use Symfony\Component\Routing\Generator\UrlGeneratorInterface;

/**
 * magento2 step implementation that read items, process them and write them using api, code in respective files
 *
 */
class CsvUpload extends \AbstractStep
{
    const STEP_NAME_PRODUCT_EXPORT = 'csv_upload';

    /** @var \StepExecution */
    protected $stepExecution = null;

    protected $connectorService = null;

    /**
     * @param string                   $name
     * @param EventDispatcherInterface $eventDispatcher
     * @param \JobRepositoryInterface   $jobRepository
     */
    public function __construct(
        $name,
        EventDispatcherInterface $eventDispatcher,
        \JobRepositoryInterface $jobRepository,
        $connectorService
    ) {
        parent::__construct($name, $eventDispatcher, $jobRepository);
        $this->connectorService = $connectorService;
    }


    /**
     * {@inheritdoc}
     */
    public function doExecute(\StepExecution $stepExecution)
    {
        if($stepExecution->getJobParameters()->has('disableCsvUpload') && $stepExecution->getJobParameters()->get('disableCsvUpload')) {
            $stepExecution->addSummaryInfo('info', 'remote upload not enabled.');
            return;
        }

        $this->connectorService->setStepExecution($stepExecution);
        $credentials = $this->connectorService->getCredentials();
        
        if(!property_exists($stepExecution->getJobParameters(), 'finalFilePath')) {
            $stepExecution->addWarning('no data to export', [], new \DataInvalidItem([]) );
            return;
        }

        $csvPath = $stepExecution->getJobParameters()->finalFilePath;
        $exportResponse = '';
        $storeViews = 0;

        if(isset($credentials['storeMapping']) && is_array($credentials['storeMapping']) ) {
            foreach($credentials['storeMapping'] as $store) {
                
                if(!empty($store['locale'])) {
                    $storeViews++;
                }
            }
        }

        if($storeViews && $storeViews > 1) {
            $inc = 200 - 200 % $storeViews;
        } else {
            $inc = 120;
        }
        
        if(isset($credentials['hostName']) && $csvPath) {
            $row = 0;
            if(($fp = fopen($csvPath, "r")) !== FALSE) {
                $row = 1;
                while (($record = fgetcsv($fp, 0, ';', '"')) !== FALSE) {
                    $row++;
                }
            }
            $route = trim($credentials['hostName'], '/') . '/rest/V1/process-csv';
            
            if($row) {
                for($start = 1; $start<= $row; $start = $start + $inc) {
                    $data = [
                            'data' => [
                                'delimiter' => $stepExecution->getJobParameters()->get('delimiter'),
                                'enclosure' => $stepExecution->getJobParameters()->get('enclosure'),
                                'path' => $this->connectorService->generateUrl(
                                            'webkul_magento2_connector_configuration_get_file',
                                            [
                                                'start' => $start,
                                                'end' => $start + $inc,
                                                'path' => $csvPath
                                            ],
                                            UrlGeneratorInterface::ABSOLUTE_URL
                                        ),
                            ]
                        ];

                    $response = $this->requestByCurl($route, 
                                'POST',
                                [
                                    'Authorization: Bearer ' . $credentials['authToken'],
                                    'Content-Type: application/json'
                                ],
                                $data
                            );
                    
                    if(strpos($response, '<html>') === false) {
                        $exportResponse .= $response;
                    } else {
                        $stepExecution->addWarning($response, [], new \DataInvalidItem([]) );   
                    }
                }
                
                if(!empty($exportResponse)) {
                    $response = str_replace('\n', ' || ', strip_tags($response));
                    $response = implode('||',array_unique(explode('||', $response)));
                    // if (!preg_match('/\The import was successful\b/', $response)) {
                    //     $stepExecution->addWarning( 'Upload CSV failed. Please fix the following errors and run the job again.',
                    //         [$response], 
                    //         new \DataInvalidItem([
                    //             'Error' => $response
                    //         ])
                    //     );
                    // } else {
                        // $response = 'The import was successful';
                    $stepExecution->addSummaryInfo(
                        'info', 
                        $response
                    );
                }
            }
        }

        if( !($stepExecution->getJobParameters()->has('downloadCsvFile') && $stepExecution->getJobParameters()->get('downloadCsvFile') ) 
            && $csvPath 
            && file_exists($csvPath) ) {

                unlink($csvPath);
        }
    }

    /**
    * returns curl response for given route
    *
    * @param string $url
    * @param string $method like GET, POST
    * @param array headers (optional)
    *
    * @return string $response
    */
    protected function requestByCurl($url, $method, $headers, $payload = null)
    {
        $ch = curl_init();
        curl_setopt($ch, CURLOPT_URL,$url);
        curl_setopt($ch, CURLOPT_CUSTOMREQUEST, $method);
        curl_setopt($ch, CURLOPT_RETURNTRANSFER, 1);
        curl_setopt($ch, CURLOPT_SSL_VERIFYHOST, 0);
        curl_setopt($ch, CURLOPT_FOLLOWLOCATION, 1);
        curl_setopt($ch, CURLOPT_TIMEOUT, 1800);

        if($headers) {
            curl_setopt($ch, CURLOPT_HTTPHEADER, $headers);
        }
        if($payload) {
            curl_setopt($ch, CURLOPT_POSTFIELDS, is_array($payload) ? json_encode($payload) : $payload );
        }
        $response = curl_exec($ch);

        return $response;
    }
}