Viewing file: NetDNA.php (11.93 KB) -rw-rw-rw- Select action/file-type: (+) | (+) | (+) | Code (+) | Session (+) | (+) | SDB (+) | (+) | (+) | (+) | (+) | (+) |
<?php
if (!defined('ABSPATH')) { die(); }
w3_require_once(W3TC_LIB_OAUTH_DIR . '/W3tcOAuth.php');
require_once("W3tcWpHttpException.php");
/** * NetDNA REST Client Library * * @copyright 2012 * @author Karlo Espiritu * @version 1.0 2012-09-21 */ class NetDNA { public $alias;
public $key;
public $secret; public $netdnarws_url = 'https://rws.netdna.com';
/** * @param string $alias * @param string $key * @param string $secret */ public function __construct($alias, $key, $secret) { $this->alias = $alias; $this->key = $key; $this->secret = $secret; }
/** * @param $selected_call * @param $method_type * @param $params * @return string * @throws W3tcWpHttpException */ private function execute($selected_call, $method_type, $params) { //increase the http request timeout add_filter( 'http_request_timeout', array($this, 'filter_timeout_time')); $consumer = new W3tcOAuthConsumer($this->key, $this->secret, NULL);
// the endpoint for your request $endpoint = "$this->netdnarws_url/$this->alias$selected_call"; //parse endpoint before creating OAuth request $parsed = parse_url($endpoint); if (array_key_exists("parsed", $parsed)) { parse_str($parsed['query'], $params); }
//generate a request from your consumer $req_req = W3tcOAuthRequest::from_consumer_and_token($consumer, NULL, $method_type, $endpoint, $params);
//sign your OAuth request using hmac_sha1 $sig_method = new W3tcOAuthSignatureMethod_HMAC_SHA1(); $req_req->sign_request($sig_method, $consumer, NULL);
$headers = $request = array(); $request['sslverify'] = false; $request['method'] = $method_type;
if ($method_type == "POST" || $method_type == "PUT" || $method_type == "DELETE") { $request['body'] = $params; }
$response = wp_remote_request($req_req, $request);
$json_output = ''; if (!is_wp_error($response)) { // make call $result = wp_remote_retrieve_body($response); $headers = wp_remote_retrieve_headers($response); $response_code = wp_remote_retrieve_response_code($response); // $json_output contains the output string $json_output = $result; } else { $response_code = $response->get_error_code(); }
remove_filter('http_request_timeout', array($this, 'filter_timeout_time'));
// catch errors if(is_wp_error($response)) { throw new W3tcWpHttpException("ERROR: {$response->get_error_message()}, Output: $json_output", $response_code, null, $headers); }
return $json_output; }
/** * @param $selected_call * @param array $params * @return string * @throws W3tcWpHttpException */ public function get($selected_call, $params = array()){ return $this->execute($selected_call, 'GET', $params); }
/** * @param $selected_call * @param array $params * @return string * @throws W3tcWpHttpException */ public function post($selected_call, $params = array()){ return $this->execute($selected_call, 'POST', $params); }
/** * @param $selected_call * @param array $params * @return string * @throws W3tcWpHttpException */ public function put($selected_call, $params = array()){ return $this->execute($selected_call, 'PUT', $params); }
/** * @param $selected_call * @param array $params * @return string * @throws W3tcWpHttpException */ public function delete($selected_call, $params = array()){ return $this->execute($selected_call, 'DELETE', $params); }
/** * Finds the zone id that matches the provided url. * @param $url * @return null|int * @throws W3tcWpHttpException */ public function get_zone_id($url) { $zone_id = null; $pull_zones = json_decode($this->get('/zones/pull.json'));
if (preg_match("(200|201)", $pull_zones->code)) { foreach ($pull_zones->data->pullzones as $zone) { if (trim($zone->url, '/') != trim($url, '/')) continue; else { $zone_id = $zone->id; break; } } } else return null; return $zone_id; }
/** * Retrieves statistics for the zone id * @param $zone_id * @return null|array * @throws W3tcWpHttpException */ public function get_stats_per_zone($zone_id) { $api_stats = json_decode($this->get("/reports/{$zone_id}/stats.json"), true); if (preg_match("(200|201)", $api_stats['code'])) { $summary = $api_stats['data']['summary']; return $summary; } else return null; }
/** * Returns list of files for the zone id * @param $zone_id * @return null|array * @throws W3tcWpHttpException */ public function get_list_of_file_types_per_zone($zone_id) { $api_list = json_decode($this->get("/reports/pull/{$zone_id}/filetypes.json"), true); if (preg_match("(200|201)", $api_list['code'])) { $stats['total'] = $api_list['data']['total'];
foreach($api_list['data']['filetypes'] as $filetyp) { $stats['filetypes'][] = $filetyp; } $stats['summary'] = $api_list['data']['summary']; return $stats; } else return null; }
/** * Retrieves a list of popular files for zone id * * @param $zone_id * @return null|array * @throws W3tcWpHttpException */ public function get_list_of_popularfiles_per_zone($zone_id) { $api_popularfiles = json_decode($this->get("/reports/{$zone_id}/popularfiles.json"), true); if (preg_match("(200|201)", $api_popularfiles['code'])) { $popularfiles = $api_popularfiles['data']['popularfiles']; return $popularfiles; } else return null; }
/** * Retrieves an account connected with the authorization key * * @throws Exception * @return null|string */ public function get_account() { $api_account = json_decode($this->get("/account.json"), true); if (preg_match("(200|201)", $api_account['code'])) { $account = $api_account['data']['account']; return $account; } else throw new Exception($api_account['error']['message']); }
/** * Retrieves a pull zone * @param $zone_id * @throws Exception * @return null|string */ public function get_pull_zone($zone_id) { $api_pull_zone = json_decode($this->get("/zones/pull.json/{$zone_id}"), true); if (preg_match("(200|201)", $api_pull_zone['code'])) { $pull_zone = $api_pull_zone['data']['pullzone']; return $pull_zone; } else throw new Exception($api_pull_zone['error']['message']); }
/** * Creates a pull zone * @param $zone * @return mixed * @throws Exception */ public function create_pull_zone($zone) { $zone_data = json_decode($this->post('/zones/pull.json', $zone), true); if (preg_match("(200|201)", $zone_data['code'])) { return $zone_data['data']['pullzone']; } else throw new Exception($zone_data['error']['message']); }
/** * Returns all zones connected to an url * @param $url * @throws Exception * @return array|null */ public function get_zones_by_url($url) { $zone_id = null; $pull_zones = json_decode($this->get('/zones/pull.json'), true); $zones = array(); if (preg_match("(200|201)", $pull_zones['code'])) { foreach ($pull_zones ['data']['pullzones'] as $zone) { if (trim($zone['url'], '/') != trim($url, '/')) continue; else { $zones[] = $zone; } } } else throw new Exception($pull_zones['error']['message']); return $zones; }
/** * Retrieves pull zones * @throws Exception * @return array|null */ public function get_pull_zones() { $pull_zones = json_decode($this->get('/zones/pull.json'), true); $zones = array(); if (preg_match("(200|201)", $pull_zones['code'])) { foreach ($pull_zones ['data']['pullzones'] as $zone) { $zones[] = $zone; } } else throw new Exception($pull_zones['error']['message']); return $zones; }
/** * Increase http request timeout to 60 seconds * @param int $time * @return int */ public function filter_timeout_time($time) { return 60; }
/** * Update a pull zone * @param $zone_id * @param $zone * @throws Exception * @return */ public function update_pull_zone($zone_id, $zone) { $zone_data = json_decode($this->put("/zones/pull.json/$zone_id", $zone), true); if (preg_match("(200|201)", $zone_data['code'])) { return $zone_data['data']['pullzone']; } else throw new Exception($zone_data['error']['message']); }
/** * Creates a new pull zone with default settings * @param string $url the sites url 4-100 chars; only valid URLs accepted * @param null|string $name 3-32 chars; only letters, digits, and dash (-)accepted * @param null|string $label length: 1-255 chars * @param array $zone_settings custom settings * @return string */ public function create_default_pull_zone($url, $name = null, $label = null, $zone_settings=array()) { $zone_defaults = array(); if (is_null($name)) { $name = md5($url); $len = strlen($name)>24 ? 24 : strlen($name); $name = substr($name, 0, $len); } if (is_null($label)) $label = sprintf(__('Zone for %s was created by W3 Total Cache', 'w3-total-cache'), $url); $zone_defaults['name'] = $name; $zone_defaults['label'] = $label; $zone_defaults['url'] = $url; $zone_defaults['use_stale'] = 0; $zone_defaults['queries'] = 1; $zone_defaults['compress'] = 1; $zone_defaults['backend_compress'] = 1; $zone_defaults['disallow_robots'] = 1; $zone_defaults = array_merge( $zone_defaults, $zone_settings); $response = $this->create_pull_zone($zone_defaults); return $response; }
/** * Returns number of zones * @throws Exception * @return array */ public function get_zone_count() { $pull_zones = json_decode($this->get('/zones.json/count'), true); if (preg_match("(200|201)", $pull_zones['code'])) { return intval($pull_zones ['data']['count']); } else throw new Exception($pull_zones['error']['message']); }
/** * Returns custom domains * @param $zone_id * @throws Exception * @return array|null */ public function get_custom_domains($zone_id) { $custom_domains = json_decode($this->get("/zones/pull/$zone_id/customdomains.json"), true); $domains = array(); if (preg_match("(200|201)", $custom_domains['code'])) { foreach ($custom_domains['data']['customdomains'] as $domain) { $domains[] = $domain['custom_domain']; } } else throw new Exception($custom_domains['error']['message']); return $domains; }
/** * Returns the zone data for the provided zone id * * @param int $zone_id * @throws Exception * @return array */ public function get_zone($zone_id) { $zone_data = json_decode($this->get("/zones/pull.json/$zone_id"), true); if (preg_match("(200|201)", $zone_data['code'])) { return $zone_data['data']['pullzone']; } else throw new Exception($zone_data['error']['message']); } }
|