Skip to content

Instantly share code, notes, and snippets.

@krisanalfa
Created June 6, 2017 05:00
Show Gist options
  • Save krisanalfa/335fc1b99e811ee018ee157e5206eed9 to your computer and use it in GitHub Desktop.
Save krisanalfa/335fc1b99e811ee018ee157e5206eed9 to your computer and use it in GitHub Desktop.
Tiny Guzzle Wrapper
<?php
namespace Alpha;
use GuzzleHttp\Client;
class Wrapper
{
protected static $client;
public static function __callStatic($method, $args)
{
return Request::new(static::client())->{$method}(...$args);
}
public static function client()
{
return static::$client ?: static::$client = new Client;
}
}
class Request
{
public function __construct($client)
{
$this->client = $client;
$this->bodyFormat = 'json';
$this->options = [
'http_errors' => false,
];
}
public static function new(...$args)
{
return new self(...$args);
}
public function asJson()
{
return $this->bodyFormat('json')->contentType('application/json');
}
public function asFormParams()
{
return $this->bodyFormat('form_params')->contentType('application/x-www-form-urlencoded');
}
public function bodyFormat($format)
{
return tap($this, function ($request) use ($format) {
$this->bodyFormat = $format;
});
}
public function contentType($contentType)
{
return $this->withHeaders(['Content-Type' => $contentType]);
}
public function accept($header)
{
return $this->withHeaders(['Accept' => $header]);
}
public function withHeaders($headers)
{
return tap($this, function ($request) use ($headers) {
return $this->options = array_merge_recursive($this->options, [
'headers' => $headers
]);
});
}
public function get($url, $queryParams = [])
{
return $this->send('GET', $url, [
'query' => $queryParams,
]);
}
public function post($url, $params = [])
{
return $this->send('POST', $url, [
$this->bodyFormat => $params,
]);
}
public function patch($url, $params = [])
{
return $this->send('PATCH', $url, [
$this->bodyFormat => $params,
]);
}
public function put($url, $params = [])
{
return $this->send('PUT', $url, [
$this->bodyFormat => $params,
]);
}
public function delete($url, $params = [])
{
return $this->send('DELETE', $url, [
$this->bodyFormat => $params,
]);
}
public function send($method, $url, $options)
{
return new Response($this->client->request($method, $url, $this->mergeOptions([
'query' => $this->parseQueryParams($url),
], $options)));
}
protected function mergeOptions(...$options)
{
return array_merge_recursive($this->options, ...$options);
}
protected function parseQueryParams($url)
{
return tap([], function (&$query) use ($url) {
parse_str(parse_url($url, PHP_URL_QUERY), $query);
});
}
}
class Response
{
public function __construct($response)
{
$this->response = $response;
}
public function body()
{
return (string) $this->response->getBody();
}
public function json($asArray = true)
{
return json_decode($this->response->getBody(), $asArray);
}
public function header($header, $asArray = false)
{
return $this->response->getHeader($header, $asArray);
}
public function headers()
{
return $this->response->getHeaders();
}
public function status()
{
return $this->response->getStatusCode();
}
public function __call($method, $args)
{
return $this->response->{$method}(...$args);
}
}
function tap($value, $callback)
{
$callback($value);
return $value;
}
// Usage:
// $response = Wrapper::get('http://api.company.tld/login', [
// 'email' => '[email protected]',
// 'password' => 's3cr3t',
// ]);
// $data = $response->json();
Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment