<?php
/**
 * Created by PhpStorm.
 * User: Florian
 * Date: 21/12/2017
 * Time: 10:51
 */

/**
 * @param string $msg
 */
function cli_report_error($msg = "An error occured"){
    //todo call rest API
    $date = date('Y-m-d H:i:s');

    $line = $date." - ".$msg."".print_r($_SERVER['argv'],true).PHP_EOL;

    die($line);
}


function getLogFileName(){
    $scr = $_SERVER['SCRIPT_NAME'];
    $scr = str_replace(array('/','\\'),'',$scr);
    return $scr.'.log';
}

/**
 * @param $t
 * @return string
 */
function getTarget($t){
    $c = "http";

    if(str_contains('https',$t))
        $c .= 's';

    $d = "";

    preg_match_all("/http[s]{0,1}:\/\/([a-zA-Z0-9-.]{1,})\//", $t, $output_array);

    if(isset($output_array[1][0]))
        $d = $output_array[1][0];

    return $c.'://'.$d;
}

/**
 * @param $needle
 * @param $haystack
 * @return bool
 */
function str_contains($needle, $haystack){
    if (strpos($haystack, $needle) !== false) {
        return true;
    }
    return false;
}

/**
 * @param $guid
 * @param $state
 * @param $response
 * @param $args
 */
function changeProcessState($guid, $state, $response, $args){
    //var_dump('changeProcessState');
    if(!isset($args['url']))
        cli_report_error('missing return url');

    $url = $args['url'];

    $array = array(
        'guid'      => $guid,
        'state'     => $state,
        'response'  => $response
    );

    var_dump(rest_send_json($url,$array,'UPDATE',false));
}

/**
 * @param string $guid
 * @param string $filepath
 * @param array $args
 * @return mixed
 */
function replaceFileWithGuid($guid,$filepath, $args){
    if(!isset($args['url']))
        cli_report_error('missing return url');

    $url = $args['url'];
    if(str_contains('app_dev.php',$url))
        $urlTarget = "/app_dev.php/";
    else
        $urlTarget = "/";

    $urlTarget .= "public/api/worker/upload";

    $urlTargetBasis = getTarget($args['url']).$urlTarget;



    $array = array(
        'guid'          => $guid,
        'filepath'      => $filepath,
        'id'            => $args['user'],
    );


    return rest_send_json($urlTargetBasis,$array,'UPDATE');
}

/**
 * @param $url
 * @param $array
 * @param string $method
 * @param bool $jsonDecode
 * @return mixed
 */
function rest_send_json($url, $array, $method = "POST", $jsonDecode = true){
    $curl = curl_init($url);

    $data_string = json_encode($array);

    curl_setopt($curl, CURLOPT_CUSTOMREQUEST, $method);
    curl_setopt($curl, CURLOPT_POSTFIELDS, $data_string);
    curl_setopt($curl, CURLOPT_RETURNTRANSFER, true);
    curl_setopt($curl, CURLOPT_HTTPHEADER, array(
            'Content-Type: application/json',
            'Content-Length: ' . strlen($data_string))
    );


    $curl_response = curl_exec($curl);
    if ($curl_response === false) {
        $info = curl_getinfo($curl);
        curl_close($curl);
        die('error occured during curl exec. Additioanl info: ' . print_r($info,true));
    }
    curl_close($curl);
    if($method == 'UPDATE'){
        //var_dump($curl_response);
    }
    if($jsonDecode){
        $decoded = json_decode($curl_response,true);
        if (isset($decoded['error']) && $decoded['error'] === true) {
            cli_report_error($decoded['msg']);
        }
    } else {
        $decoded = $curl_response;
    }

    return $decoded;
}