JetPHPAPI.php

<?php
/** 
 * -----------------
 * Jet.com PHP Class
 * -----------------
 * Developed / Reformatted by Matt Gross (http://github.com/MatthewGross)
 * Forked / deriving from DSUGARMAN's code (https://gist.github.com/dsugarman/437c4c91aea86860ed13)
 * License: MIT (Please see https://github.com/MatthewGross/JetPHP)
 **/

/**
 * Example:
 * $jet->uploadFile($feed_type, $path);
 * $jet->processOrdersByStatus('ready');
 * $jet->apiPUT("/orders/".$JET_ORDER_ID."/acknowledge", $data);
 **/

class JetPHPAPI
{

    public $api_user_id = '';
    public $api_secret = '';
    public $merchant_id = '';
    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)
    {

        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->getToken())
        );
        curl_setopt($ch, CURLOPT_CUSTOMREQUEST, 'PUT');
        curl_setopt($ch, CURLOPT_POSTFIELDS, $request);
        $data = curl_exec($ch);

        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

        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!';
        }
    }

}