View source
<?php
namespace Lockr;
use Lockr\Exception\LockrException;
use Lockr\Exception\LockrClientException;
use Lockr\Exception\LockrServerException;
class Lockr {
const VERSION = '0.1.0';
protected static $instance = null;
protected $partner;
public function __construct(PartnerInterface $partner) {
$this->partner = $partner;
}
public static function site() {
return new SiteClient(self::create());
}
public static function key() {
return new KeyClient(self::create());
}
public static function create(PartnerInterface $partner = null) {
if (null == static::$instance) {
if ($partner !== null) {
static::$instance = new static($partner);
}
else {
static::$instance = new static(new Partner());
}
}
return static::$instance;
}
public function get($uri) {
$uri = $this->partner
->getReadUri() . $uri;
return $this
->request('GET', $uri, $this->partner
->requestOptions());
}
public function head($uri) {
$uri = $this->partner
->getReadUri() . $uri;
return $this
->request('HEAD', $uri, $this->partner
->requestOptions());
}
public function post($uri, $data, $auth = null) {
$uri = $this->partner
->getAccountingUri() . $uri;
$options = $this->partner
->requestOptions();
$options['data'] = $data;
if (null !== $auth) {
$options['auth'] = $auth;
}
return $this
->request('POST', $uri, $options);
}
public function patch($uri, $data) {
$uri = $this->partner
->getWriteUri() . $uri;
$options = $this->partner
->requestOptions();
$options['data'] = $data;
return $this
->request('PATCH', $uri, $options);
}
public function delete($uri) {
$uri = $this->partner
->getWriteUri() . $uri;
return $this
->request('DELETE', $uri, $this->partner
->requestOptions());
}
protected function request($method, $uri, array $options = array()) {
$opts = array(
CURLOPT_FOLLOWLOCATION => true,
CURLOPT_RETURNTRANSFER => true,
CURLOPT_PORT => 443,
CURLOPT_CUSTOMREQUEST => $method,
CURLOPT_URL => $uri,
CURLOPT_HTTPHEADER => array(
'Content-Type:',
),
);
if (in_array($method, array(
'POST',
'PATCH',
))) {
$data = json_encode($options['data']);
$opts[CURLOPT_POSTFIELDS] = $data;
$opts[CURLOPT_HTTPHEADER] = array(
'Content-Type: application/json',
'Content-Length: ' . strlen($data),
);
}
if (isset($options['cert'])) {
$opts[CURLOPT_SSLCERT] = $options['cert'];
}
if (isset($options['auth'])) {
$opts[CURLOPT_USERPWD] = $options['auth'];
}
$ch = curl_init();
curl_setopt_array($ch, $opts);
$resp = curl_exec($ch);
$code = curl_getinfo($ch, CURLINFO_HTTP_CODE);
$body = json_decode($resp, true);
$json_error = json_last_error();
if ($code >= 400) {
if ($json_error !== JSON_ERROR_NONE) {
$body = array(
'title' => 'Unrecognized body',
'description' => $resp,
);
}
$this
->handleError($code, $body);
}
if (!$resp) {
return true;
}
if ($json_error !== JSON_ERROR_NONE) {
throw new LockrException(array(
'message' => $resp,
'code' => $code,
));
}
return $body;
}
public function handleError($code, $body) {
$title = isset($body['title']) ? $body['title'] : '';
$description = isset($body['description']) ? $body['description'] : '';
$params = array(
'title' => $title,
'description' => $description,
'message' => "[{$title}]: {$description}",
'code' => $code,
);
if ($code >= 500) {
throw new LockrServerException($params);
}
throw new LockrClientException($params);
}
}