library/lab_exchange_api.php

   1 <?php
   2 // Copyright (C) 2010 Maviq <info@maviq.com>
   3 //
   4 // This program is free software; you can redistribute it and/or
   5 // modify it under the terms of the GNU General Public License
   6 // as published by the Free Software Foundation; either version 2
   7 // of the License, or (at your option) any later version.
   8 //
   9     if(!extension_loaded("curl"))
  10         throw(new Exception(
  11             "Curl extension is required"));
  12
  13     class LabExchangeClient {
  14
  15         protected $Endpoint;
  16         protected $SiteId;
  17         protected $Token;
  18
  19         public function __construct($siteId, $token, $endpoint)
  20         {
  21             $this->SiteId = $siteId;
  22             $this->Token = $token;
  23             $this->Endpoint = $endpoint;
  24
  25         }
  26
  27         public function sendRequest($path, $method="GET", $vars=array())
  28         {
  29
  30             echo "Path: {$path}\n";
  31
  32             $encoded = "";
  33             foreach($vars as $key=>$value)
  34                 $encoded .= "$key=".urlencode($value)."&";
  35             $encoded = substr($encoded, 0, -1);
  36             $tmpfile = "";
  37             $fp = null;
  38
  39             // Construct full url.
  40             $url = "{$this->Endpoint}/$path";
  41
  42             echo "Url: {$url}\n";
  43
  44             // If GET and vars, append them.
  45             if($method == "GET")
  46                 $url .= (false === strpos($path, '?')?"?":"&").$encoded;
  47
  48             // Initialize a new curl object.
  49             $curl = curl_init($url);
  50             curl_setopt($curl, CURLOPT_SSL_VERIFYPEER, false);
  51             curl_setopt($curl, CURLOPT_SSL_VERIFYHOST, false);
  52             curl_setopt($curl, CURLOPT_RETURNTRANSFER, true);
  53             switch(strtoupper($method)) {
  54                 case "GET":
  55                     curl_setopt($curl, CURLOPT_HTTPGET, true);
  56                     break;
  57                 case "POST":
  58                     curl_setopt($curl, CURLOPT_POST, true);
  59                     curl_setopt($curl, CURLOPT_POSTFIELDS, $encoded);
  60                     break;
  61                 case "PUT":
  62                     // curl_setopt($curl, CURLOPT_PUT, TRUE);
  63                     curl_setopt($curl, CURLOPT_POSTFIELDS, $encoded);
  64                     curl_setopt($curl, CURLOPT_CUSTOMREQUEST, "PUT");
  65                     file_put_contents($tmpfile = tempnam("/tmp", "put_"),
  66                         $encoded);
  67                     curl_setopt($curl, CURLOPT_INFILE, $fp = fopen($tmpfile,
  68                         'r'));
  69                     curl_setopt($curl, CURLOPT_INFILESIZE,
  70                         filesize($tmpfile));
  71                     break;
  72                 case "DELETE":
  73                     curl_setopt($curl, CURLOPT_CUSTOMREQUEST, "DELETE");
  74                     break;
  75                 default:
  76                     throw(new Exception("Unknown method $method"));
  77                     break;
  78             }
  79
  80             // Send credentials.
  81             curl_setopt($curl, CURLOPT_USERPWD,
  82                 $pwd = "{$this->SiteId}:{$this->Token}");
  83
  84             // Do the request. If FALSE, then an exception occurred.
  85             if(false === ($result = curl_exec($curl)))
  86                 throw(new Exception(
  87                     "Curl failed with error " . curl_error($curl)));
  88
  89             // Get result code.
  90             $responseCode = curl_getinfo($curl, CURLINFO_HTTP_CODE);
  91
  92             // Unlink tmpfiles.
  93             if($fp)
  94                 fclose($fp);
  95             if(strlen($tmpfile))
  96                 unlink($tmpfile);
  97
  98             return new RestResponse($url, $result, $responseCode);
  99         }
 100
 101     }
 102
 103     class RestResponse {
 104
 105         public $ResponseText;
 106         public $ResponseXml;
 107         public $HttpStatus;
 108         public $Url;
 109         public $QueryString;
 110         public $IsError;
 111         public $ErrorMessage;
 112
 113         public function __construct($url, $text, $status)
 114         {
 115             preg_match('/([^?]+)\??(.*)/', $url, $matches);
 116             $this->Url = $matches[1];
 117             $this->QueryString = $matches[2];
 118             $this->ResponseText = $text;
 119             $this->HttpStatus = $status;
 120             if($this->HttpStatus != 204)
 121                 $this->ResponseXml = @simplexml_load_string($text);
 122
 123             if($this->IsError = ($status >= 400))
 124                 $this->ErrorMessage =
 125                     (string)$this->ResponseXml->RestException->Message;
 126
 127         }
 128
 129     }
 130
 131 ?>
 132