Skip to content
Snippets Groups Projects

Multi backend plugin

Merged Multi backend plugin
feat/multi-backend into main
Merged Lucas García requested to merge feat/multi-backend into main
Viewing commit 262b9416
Prev Next
Show latest version
1 file
+ 199
− 36
Compare changes
  • Side-by-side
  • Inline
includes/class-http-client.php
+ 199
− 36
@@ -3,13 +3,14 @@
namespace WPCT_HTTP;
use WP_Error;
use WP_Http;
require_once 'class-multipart.php';
class Http_Client
{
private const settings_defaults = [
'params' => [],
'params' => [],
'data' => [],
'headers' => [
'connection' => 'keep-alive',
@@ -19,29 +20,56 @@ class Http_Client
'files' => []
];
/**
* Fills request settings with defaults.
*
* @since 3.0.0
*
* @param array $settings Request settings.
* @return array Request settings with defaults.
*/
public static function req_settings($settings = [])
{
$settings = array_merge(Http_Client::settings_defaults, (array) $settings);
$settings['headers'] = Http_Client::req_headers($settings['headers']);
$settings['headers'] = Http_Client::req_headers($settings['headers']);
return $settings;
return $settings;
}
private static function add_query_str($url, $params)
{
$parsed = parse_url($url);
if (isset($parsed['query'])) {
parse_str($parsed['query'], $query);
$params = array_merge($query, $params);
$url = preg_replace('/?.*$/', '', $url);
}
/**
* Add query params to URLs.
*
* @since 3.0.0
*
* @param string $url Target URL.
* @param array $params Associative array with query params.
* @return string URL with query params.
*/
private static function add_query_str($url, $params)
{
$parsed = parse_url($url);
if (isset($parsed['query'])) {
parse_str($parsed['query'], $query);
$params = array_merge($query, $params);
$url = preg_replace('/?.*$/', '', $url);
}
return $url . '?'. http_build_query($params);
}
return $url . '?'. http_build_query($params);
}
/**
* Performs a GET request.
*
* @since 3.0.0
*
* @param string $url Target url.
* @param array $params Associative array with query params.
* @param array $headers Associative array with HTTP headers.
* @return array Responsive representation or WP_Error.
*/
public static function get($url, $params = [], $headers = [])
{
$url = Http_Client::add_query_str($url, $params);
$url = Http_Client::add_query_str($url, $params);
$args = [
'method' => 'GET',
'headers' => Http_Client::req_headers($headers, 'GET', $url)
@@ -49,6 +77,19 @@ class Http_Client
return Http_Client::do_request($url, $args);
}
/**
* Performs a POST request. Default content type is application/json, any other
* mimetype should be encoded before and passed in as string.
* If $files is defined and is array, content type switches to multipart/form-data.
*
* @sice 3.0.0
*
* @param string $url Target URL.
* @param array $data Associative array with the request payload.
* @param array $headers Associative array with HTTP headers.
* @param array $files Associative array with filename and paths.
* @return array Response representation or WP_Error.
*/
public static function post($url, $data, $headers, $files = null)
{
if (is_array($files)) {
@@ -65,6 +106,17 @@ class Http_Client
]);
}
/**
* Performs a POST request with multipart/form-data content type payload.
*
* @sice 3.0.0
*
* @param string $url Target URL.
* @param array $data Associative array with the request payload.
* @param array $files Associative array with filename and paths.
* @param array $headers Associative array with HTTP headers.
* @return array Response representation or WP_Error.
*/
public static function post_multipart($url, $data, $files, $headers)
{
$multipart = new Multipart();
@@ -92,11 +144,24 @@ class Http_Client
]);
}
/**
* Performs a PUT request. Default content type is application/json, any other
* mimetype should be encoded before and passed in as string.
* If $files is defined and is array, content type switches to multipart/form-data.
*
* @sice 3.0.0
*
* @param string $url Target URL.
* @param array $data Associative array with the request payload.
* @param array $headers Associative array with HTTP headers.
* @param array $files Associative array with filename and paths.
* @return array Response representation or WP_Error.
*/
public static function put($url, $data, $headers, $files = null)
{
if (is_array($files)) {
return Http_Client::put_multipart($url, $data, $files, $headers);
}
if (is_array($files)) {
return Http_Client::put_multipart($url, $data, $files, $headers);
}
$payload = is_string($data) ? $data : json_encode($data);
$headers = Http_Client::req_headers($headers, 'PUT', $url);
@@ -108,6 +173,17 @@ class Http_Client
]);
}
/**
* Performs a PUT request with multipart/form-data content type payload.
*
* @sice 3.0.0
*
* @param string $url Target URL.
* @param array $data Associative array with the request payload.
* @param array $files Associative array with filename and paths.
* @param array $headers Associative array with HTTP headers.
* @return array Response representation or WP_Error.
*/
private static function put_multipart($url, $data, $files, $headers)
{
$multipart = new Multipart();
@@ -132,19 +208,59 @@ class Http_Client
]);
}
/**
* Performs a DETELE request.
*
* @since 3.0.0
*
* @param string $url Target url.
* @param array $params Associative array with query params.
* @param array $headers Associative array with HTTP headers.
* @return array Responsive representation or WP_Error.
*/
public static function delete($url, $params, $headers)
{
$url = Http_Client::add_query_str($url, $params);
$url = Http_Client::add_query_str($url, $params);
return Http_Client::do_request($url, [
'method' => 'DELETE',
'headers' => Http_Client::req_headers($headers, 'DELETE', $url)
]);
}
/**
* Performs a request on top of WP_Http client
*
* @since 3.0.0
*
* @param string $url Target URL.
* @param array $args WP_Http::request arguments.
* @return array Response representation.
*/
private static function do_request($url, $args)
{
global $wp_version;
$args = array_merge(
[
'method' => 'POST',
'timeout' => 5,
'redirection' => 5,
'httpversion' => '1.0',
'user-agent' => 'WordPress/' . $wp_version . '; ' . home_url(),
'blocking' => true,
'headers' => [],
'cookies' => [],
'body' => null,
'compress' => false,
'decompress' => true,
'sslverify' => true,
'stream' => false,
'filename' => null
],
$args
);
$request = apply_filters('wpct_http_request_args', ['url' => $url, 'args' => $args]);
$response = wp_remote_request($url, $args);
$response = WP_Http::request($request['url'], $request['args']);
if (is_wp_error($response)) {
$response->add_data(['request' => $request]);
return $response;
@@ -164,15 +280,30 @@ class Http_Client
return $response;
}
private static function req_headers($headers)
{
return array_merge([
'host' => $_SERVER['HTTP_HOST'],
'referer' => $_SERVER['HTTP_REFERER'],
'accept-language' => Http_Client::get_locale()
], (array) $headers);
}
/**
* Add default headers to an array.
*
* @since 3.0.0
*
* @param array $headers Associative array with HTTP headers.
* @return array Associative array with HTTP headers.
*/
private static function req_headers($headers)
{
return array_merge([
'host' => $_SERVER['HTTP_HOST'],
'referer' => $_SERVER['HTTP_REFERER'],
'accept-language' => Http_Client::get_locale()
], (array) $headers);
}
/**
* Use wpct-i18n to get the current language locale.
*
* @since 2.0.4
*
* @return string ISO-2 locale representation.
*/
private static function get_locale()
{
$locale = apply_filters('wpct_i18n_current_language', null, 'locale');
@@ -184,30 +315,62 @@ class Http_Client
}
}
// Performs a get request to Odoo
/**
* Public function to perform a GET requests.
*
* @since 3.0.0
*
* @param string $url Target URL.
* @param array $settings Associative array with request settings.
* @return array Response representation or WP_Error.
*/
function wpct_http_get($url, $settings = [])
{
['params' => $params, 'headers' => $headers ] = Http_Client::req_settings($settings);
['params' => $params, 'headers' => $headers ] = Http_Client::req_settings($settings);
return Http_Client::get($url, $params, $headers);
}
// Performs a post request to Odoo
function wpct_http_post($url, $settings = []) //$data = [], $headers = [])
/**
* Public function to perform a POST requests.
*
* @since 3.0.0
*
* @param string $url Target URL.
* @param array $settings Associative array with request settings.
* @return array Response representation or WP_Error.
*/
function wpct_http_post($url, $settings = [])
{
['data' => $data, 'headers' => $headers, 'files' => $files ] = Http_Client::req_settings($settings);
['data' => $data, 'headers' => $headers, 'files' => $files ] = Http_Client::req_settings($settings);
return Http_Client::post($url, $data, $headers, $files);
}
// Performs a put request to Odoo
/**
* Public function to perform a PUT requests.
*
* @since 3.0.0
*
* @param string $url Target URL.
* @param array $settings Associative array with request settings.
* @return array Response representation or WP_Error.
*/
function wpct_http_put($url, $settings = [])
{
['data' => $data, 'headers' => $headers, 'files' => $files ] = Http_Client::req_settings($settings);
['data' => $data, 'headers' => $headers, 'files' => $files ] = Http_Client::req_settings($settings);
return Http_Client::put($url, $data, $headers, $files);
}
// Performs a delete request to Odoo
/**
* Public function to perform a DELETE requests.
*
* @since 3.0.0
*
* @param string $url Target URL.
* @param array $settings Associative array with request settings.
* @return array Response representation or WP_Error.
*/
function wpct_http_delete($url, $settings = [])
{
['params' => $params, 'headers' => $headers ] = Http_Client::req_settings($settings);
['params' => $params, 'headers' => $headers ] = Http_Client::req_settings($settings);
return Http_Client::delete($url, $params, $headers);
}