JetPHPAPI

<?php
/**
 * Created by PhpStorm.
 * User: SelimReza
 * Date: 9/27/17
 * Time: 5:32 PM
 */

namespace App\Http\Helpers;


class JetPHPAPI
{

    #public $api_user_id = 'A8B9D0F42C2479BE19F829CAB43461FC57EFCA64'; // Test
    public $api_user_id = 'AC6E88D6688A778782A531A4302C280DE9064F69'; // Live
    #public $api_secret = 'cTMGxdy7oTyNf2zf6VP21B6yLvwfmli+DVVMTEX9RX+u'; // Test
    public $api_secret = 'CfhFsXuY9kJDvEUA3KqtjBkure+0CcEEy38DeOVxkN+R'; // Live
    public $merchant_id = 'cd0426a0d4ac4680a8ad586746db6942';
    public $api_prefix = 'https://merchant-api.jet.com/api/';

    private $api_token = '';
    private $api_token_ts = '';

    /**
     * Refresh Jet API token
     **/
    public function getNewToken()
    {
        $ch = curl_init($this->api_prefix . '/Token');
        curl_setopt($ch, CURLOPT_RETURNTRANSFER, 1);
        //If necessary add your ssl pem: curl_setopt($ch, CURLOPT_CAINFO,'/ssl/cacert.pem');
        $request = json_encode(array(
            "user" => $this->api_user_id,
            "pass" => $this->api_secret
        ));
        curl_setopt($ch, CURLOPT_POSTFIELDS, $request);
        curl_setopt($ch, CURLOPT_HTTPHEADER, array(
                'Content-Type: application/json',
                'Content-Length: ' . strlen($request))
        );
        $data = curl_exec($ch);
        curl_close($ch);
        if ($data = json_decode($data)) {
            if ($token = $data->id_token) {
                //SAVE $token SOMEWHERE and save last time you got a token
                $this->setToken($token);
                $this->setTokenTs(date('r'));
                return true;
            }
        }
        return false;
    }

    /*
     * Token saving and getting
     */
    private function setToken($token) {
        if(strlen($token) > 0)
            $this->api_token = $token;

        return false;
    }

    private function setTokenTs($token) {
        if(strlen($token) > 0)
            $this->api_token_ts = $token;

        return false;
    }

    private function getTokenTs() {
        if($this->api_token_ts == '')
            return $this->api_token_ts;

        return false;
    }

    private function getToken() {
        if($this->api_token == '')
            return $this->api_token;

        return false;
    }

    /**
     * Upload bulk file to Jet
     **/
    public function uploadFile($type, $path)
    {
        $data = $this->apiGET('files/uploadToken');
        $url = $data->url;
        $file_id = $data->jet_file_id;
        $this->apiFilePUT($url, $path, $file_id);
        $this->apiGET('files/uploaded', array("url" => $url, "file_type" => $type, "file_name" => basename($path) . ".gz"));
    }
    /**
     * PUT request to $url
     **/
    public function apiPUT($end_point, $request)
    {
        //generate new token
        $this->getNewToken();

        if (substr($end_point, 0, 1) === "/") $end_point = substr($end_point, 1);

        //get token if it has been over 9 hours since the last token
        //CHANGE THIS TO WHERE YOU SAVED THE TOKEN AND TS
        if (round((strtotime("now") - strtotime($this->getTokenTs())) / 3600, 1) > 9) $this->getNewToken();

        $api_call_data = array();
        $api_call_data["request_ts"] = date("r", strtotime("now"));

        $ch = curl_init($this->api_prefix . $end_point);
        curl_setopt($ch, CURLOPT_RETURNTRANSFER, 1);
        //If necessary add your ssl pem: curl_setopt($ch, CURLOPT_CAINFO,'/ssl/cacert.pem');
        /*$request = json_encode($request);
        curl_setopt($ch, CURLOPT_HTTPHEADER, array(
                'Content-Type: application/json',
                'Content-Length: ' . strlen($request),
                //CHANGE THIS TO WHERE YOU SAVED YOUR TOKEN
                'Authorization: Bearer ' . $this->api_token)
        );
        curl_setopt($ch, CURLOPT_CUSTOMREQUEST, 'PUT');
        curl_setopt($ch, CURLOPT_POSTFIELDS, $request);
        $data = curl_exec($ch);*/

        $data = $request;

        #print_r($data);
        #print "\n";

        echo(curl_error($ch));
        $httpcode = curl_getinfo($ch, CURLINFO_HTTP_CODE);
        curl_close($ch);
        $api_call_data["request_data"] = (string)var_export($request, true);
        $api_call_data["response_ts"] = date("r", strtotime("now"));
        $api_call_data["response_data"] = (string)var_export($data, true);
        $api_call_data["request_url"] = $this->api_prefix . $end_point;
        $api_call_data["service_type"] = "Jet";
        $api_call_data["status_code"] = $httpcode;
        //SAVE $api_call_data SOMEWHERE

        print_r($api_call_data);
        print "\n";

        #dd($api_call_data);
        #exit;

        return json_decode($data);
    }
    /**
     * PUT request to $url
     **/
    public function apiFilePUT($url, $path, $file_id = null)
    {
        //get token if it has been over 9 hours since the last token
        //CHANGE THIS TO WHERE YOU SAVED THE TOKEN AND TS
        if (round((strtotime("now") - strtotime($this->getTokenTs())) / 3600, 1) > 9) $this->getNewToken();
        $api_call_data = array();
        $api_call_data["request_ts"] = date("r", strtotime("now"));

        //gzip the data
        $file = file_get_contents($path);
        $gz_file = gzencode($file, 9);
        $g_path = $path . ".gz";
        $gfp = fopen($g_path, 'w+');
        fwrite($gfp, $gz_file);
        rewind($gfp);

        $ch = curl_init();
        curl_setopt($ch, CURLOPT_URL, $url);
        curl_setopt($ch, CURLOPT_PUT, 1);
        //If necessary add your ssl pem: curl_setopt($ch, CURLOPT_CAINFO,'/ssl/cacert.pem');
        curl_setopt($ch, CURLOPT_HTTPHEADER, array('x-ms-blob-type: BlockBlob'));
        curl_setopt($ch, CURLOPT_INFILE, $gfp);
        curl_setopt($ch, CURLOPT_INFILESIZE, filesize($g_path));
        curl_setopt($ch, CURLOPT_RETURNTRANSFER, 1);
        $data = curl_exec($ch);
        fclose($gfp);

        //delete the file / gzip file
        //unlink($path);
        unlink($g_path);

        $api_call_data["response_ts"] = date("r", strtotime("now"));
        $api_call_data["response_data"] = (string)var_export($data, true);
        $api_call_data["request_url"] = $url;
        $api_call_data["service_type"] = "Jet";
        $api_call_data["check_status"] = true;
        if ($file_id) $api_call_data["service_id"] = $file_id;
        //SAVE $api_call_data
        return $data;
    }
    /**
     * Jet API GET
     **/
    public function apiGET($end_point, $request = null)
    {
        if (substr($end_point, 0, 1) === "/") $end_point = substr($end_point, 1);
        //get token if it has been over 9 hours since the last token
        //CHANGE THIS TO WHERE YOU SAVED THE TOKEN AND TS
        if (round((strtotime("now") - strtotime($this->getTokenTs())) / 3600, 1) > 9) $this->getNewToken();
        $api_call_data = array();
        $api_call_data["request_ts"] = date("r", strtotime("now"));

        $ch = curl_init($this->api_prefix . $end_point);
        curl_setopt($ch, CURLOPT_RETURNTRANSFER, 1);
        curl_setopt($ch, CURLOPT_HTTPHEADER, array('Authorization: Bearer ' . $this->getToken()));
        //If necessary add your ssl pem: curl_setopt($ch, CURLOPT_CAINFO,'/ssl/cacert.pem');
        if ($request) {
            $request = json_encode($request);
            curl_setopt($ch, CURLOPT_POSTFIELDS, $request);
            $api_call_data["request_data"] = (string)var_export($request, true);
        }
        $data = utf8_encode(curl_exec($ch));
        echo(curl_error($ch));
        $httpcode = curl_getinfo($ch, CURLINFO_HTTP_CODE);
        curl_close($ch);

        $api_call_data["response_ts"] = date("r", strtotime("now"));
        $api_call_data["response_data"] = (string)var_export($data, true);
        $api_call_data["request_url"] = $this->api_prefix . $end_point;
        $api_call_data["service_type"] = "Jet";
        $api_call_data["status_code"] = $httpcode;
        //SAVE $api_call_data

        return json_decode($data);
    }

    /**
     * Poll for orders
     **/
    public function processOrdersByStatus($status)
    {
        $data = $this->apiGET("orders/$status");
        foreach ($data->order_urls as $end_point) {
            $this->processOrder($end_point);
        }
    }

    /**
     * Process Order
     **/
    public function processOrder($end_point)
    {
        $data = $this->apiGET($end_point);
        //STORE AND PROCESS $data
    }

    /**
     * Testing Access to the Jet.com API
     **/
    public function testAccess()
    {
        if($this->getNewToken()) {
            echo 'It worked!';
        }
        else {
            echo 'We could not get Jet.com api access!';
        }
    }

}