<?php
namespace Tinify;
class CurlMockException extends Exception {
}
class CurlMock {
private static $default_version = array(
"version_number" => 471808,
"version" => "7.51.0",
"features" => 951197,
);
private static $urls = array();
private static $requests = array();
private static $version = array();
public $options = array();
public $response;
public $closed = false;
public static function version_info() {
return self::$version;
}
public static function set_version_info_key($key, $value) {
self::$version[$key] = $value;
}
public static function register($url, $request, $response = NULL) {
if (!$response) {
$response = $request;
$request = NULL;
}
if (!isset(self::$urls[$url])) {
self::$urls[$url] = array();
}
array_push(self::$urls[$url], array($request, $response));
}
public static function reset() {
self::$requests = array();
self::$urls = array();
self::$version = self::$default_version;
}
public static function last_has($key) {
$lastReq = self::$requests[count(self::$requests) - 1];
return array_key_exists($key, $lastReq->options);
}
public static function last($key = null) {
$lastReq = self::$requests[count(self::$requests) - 1];
if ($key) {
return $lastReq->options[$key];
} else {
return $lastReq;
}
}
public function close() {
$this->closed = true;
}
public function exec() {
if ($this->closed) {
throw new CurlMockException("Curl already closed");
}
array_push(self::$requests, $this);
$queue = &self::$urls[$this->options[CURLOPT_URL]];
list($this->request, $this->response) = $queue[0];
/* Keep last request as fallback. */
if (count($queue) > 1) array_shift($queue);
if ($this->request) {
if ($this->request["body"]) {
if ($this->options[CURLOPT_POSTFIELDS] != $this->request["body"]) {
throw new Exception("Body '" . $this->options[CURLOPT_POSTFIELDS] .
"' does not match expected '" . $this->request["body"] . "'");
}
}
}
if (isset($this->response["headers"])) {
$headers = "";
foreach ($this->response["headers"] as $header => $value) {
$headers .= $header . ": " . $value . "\r\n";
}
$this->response["headers"] = $headers . "\r\n";
} else {
$this->response["headers"] = "\r\n";
}
if (!isset($this->response["body"])) {
$this->response["body"] = "";
}
if (array_key_exists("return", $this->response)) {
return $this->response["return"];
} else if (isset($this->response["status"])) {
return $this->response["headers"] . $this->response["body"];
} else {
return false;
}
}
public function setopt_array($array) {
if ($this->closed) {
throw new CurlMockException("Curl already closed");
}
foreach ($array as $key => $value) {
$this->options[$key] = $value;
}
}
public function setopt($key, $value) {
if ($this->closed) {
throw new CurlMockException("Curl already closed");
}
$this->options[$key] = $value;
}
public function getinfo($key) {
if ($this->closed) {
throw new CurlMockException("Curl already closed");
}
switch ($key) {
case CURLINFO_HTTP_CODE:
return isset($this->response["status"]) ? $this->response["status"] : 0;
case CURLINFO_HEADER_SIZE:
return strlen($this->response["headers"]);
default:
throw new Exception("Bad key $key");
}
}
public function error() {
if ($this->closed) {
throw new CurlMockException("Curl already closed");
}
return $this->response["error"];
}
public function errno() {
if ($this->closed) {
throw new CurlMockException("Curl already closed");
}
return $this->response["errno"];
}
}
function curl_version() {
return CurlMock::version_info();
}
function curl_init() {
return new CurlMock();
}
function curl_exec($mock) {
return $mock->exec();
}
function curl_close($mock) {
$mock->close();
}
function curl_setopt_array($mock, $array) {
return $mock->setopt_array($array);
}
function curl_setopt($mock, $key, $value) {
return $mock->setopt($key, $value);
}
function curl_getinfo($mock, $key) {
return $mock->getinfo($key);
}
function curl_error($mock) {
return $mock->error();
}
function curl_errno($mock) {
return $mock->errno();
}