<?php
/*
 *  @author MST1122
 *  @email: sikandartariq25@gmail.com
 */

namespace DoubleBreak\Spapi\Helper;


use DoubleBreak\Spapi\ASECryptoStream;
use GuzzleHttp\Client;
use GuzzleHttp\Psr7\Request;

class Feeder
{
    /**
     * @param $payload : Response from createFeedDocument Function. e.g.: response['payload']
     * @param $contentType : Content type used during createFeedDocument function call.
     * @param $feedContentFilePath : Path to file that contain data to be uploaded.
     * @return string
     * @throws \Exception
     * @throws \GuzzleHttp\Exception\GuzzleException
     */
    public function uploadFeedDocument($payload, $contentType, $feedContentFilePath)
    {
        $key = null;
        $initializationVector = null;
        $feedUploadUrl = $payload['url'];

        // check if encryption in required
        if (isset($payload['encryptionDetails'])) {
            $key = $payload['encryptionDetails']['key'];
            $initializationVector = $payload['encryptionDetails']['initializationVector'];

            // base64 decode before using in encryption
            $initializationVector = base64_decode($initializationVector, true);
            $key = base64_decode($key, true);
        }

        // get file to upload
        $fileResourceType = gettype($feedContentFilePath);

        // resource or string ? make it to a string
        if ($fileResourceType == 'resource') {
            $file_content = stream_get_contents($feedContentFilePath);
        } else {
            $file_content = file_get_contents($feedContentFilePath);
        }

        // utf8 !
        $file_content = utf8_encode($file_content);

        if (!is_null($key)) {
            // encrypt string and get value as base64 encoded string
            $file_content = ASECryptoStream::encrypt($file_content, $key, $initializationVector);
        }

        // my http client
        $client = new Client(['exceptions' => false]);

        $request = new Request(
        // PUT!
            'PUT',
            // predefined url
            $feedUploadUrl,
            // content type equal to content type from response createFeedDocument-operation
            array('Content-Type' => $contentType),
            // resource File
            $file_content
        );

        $response = $client->send($request);
        $HTTPStatusCode = $response->getStatusCode();

        if ($HTTPStatusCode == 200) {
            return 'Done';
        } else {
            return $response->getBody()->getContents();
        }
    }

    /**
     * @param $payload : Response from getFeedDocument Function. e.g.: response['payload']
     * @return array : Feed Processing Report.
     */
    public function downloadFeedProcessingReport($payload)
    {
        $key = null;
        $initializationVector = null;
        $feedUploadUrl = $payload['url'];

        // check if decryption in required
        if (isset($payload['encryptionDetails'])) {
            $key = $payload['encryptionDetails']['key'];
            $initializationVector = $payload['encryptionDetails']['initializationVector'];

            // base64 decode before using in encryption
            $initializationVector = base64_decode($initializationVector, true);
            $key = base64_decode($key, true);
        }

        $feedDownloadUrl = $payload['url'];

        if (!is_null($key)) {
            $feed_processing_report_content = ASECryptoStream::decrypt(file_get_contents($feedDownloadUrl), $key, $initializationVector);
        } else {
            $feed_processing_report_content = file_get_contents($feedDownloadUrl);
        }

        if(isset($payload['compressionAlgorithm']) && $payload['compressionAlgorithm']=='GZIP') {
            $feed_processing_report_content = gzdecode($feed_processing_report_content);
        }

        // check if report content is json encoded or not
        if ($this->isJson($feed_processing_report_content) == true) {
            $json = $feed_processing_report_content;
        } else {
            $feed_processing_report_content = preg_replace('/\s+/S', " ", $feed_processing_report_content);
            $xml = simplexml_load_string($feed_processing_report_content);
            $json = json_encode($xml);
        }

        return json_decode($json, TRUE);
    }

    public function isJson($string) {
        json_decode($string);
        return json_last_error() === JSON_ERROR_NONE;
    }
}