<?php

[0] Fix | Delete

[1] Fix | Delete

/**

[2] Fix | Delete

* Cloud service cls

[3] Fix | Delete

*

[4] Fix | Delete

* @since 3.0

[5] Fix | Delete

*/

[6] Fix | Delete

[7] Fix | Delete

namespace LiteSpeed;

[8] Fix | Delete

[9] Fix | Delete

defined('WPINC') || exit();

[10] Fix | Delete

[11] Fix | Delete

class Cloud extends Base

[12] Fix | Delete

{

[13] Fix | Delete

const LOG_TAG = '❄️';

[14] Fix | Delete

const CLOUD_SERVER = 'https://api.quic.cloud';

[15] Fix | Delete

const CLOUD_IPS = 'https://quic.cloud/ips';

[16] Fix | Delete

const CLOUD_SERVER_DASH = 'https://my.quic.cloud';

[17] Fix | Delete

const CLOUD_SERVER_WP = 'https://wpapi.quic.cloud';

[18] Fix | Delete

[19] Fix | Delete

const SVC_D_NODES = 'd/nodes';

[20] Fix | Delete

const SVC_D_SYNC_CONF = 'd/sync_conf';

[21] Fix | Delete

const SVC_D_USAGE = 'd/usage';

[22] Fix | Delete

const SVC_D_SETUP_TOKEN = 'd/get_token';

[23] Fix | Delete

const SVC_D_DEL_CDN_DNS = 'd/del_cdn_dns';

[24] Fix | Delete

const SVC_PAGE_OPTM = 'page_optm';

[25] Fix | Delete

const SVC_CCSS = 'ccss';

[26] Fix | Delete

const SVC_UCSS = 'ucss';

[27] Fix | Delete

const SVC_VPI = 'vpi';

[28] Fix | Delete

const SVC_LQIP = 'lqip';

[29] Fix | Delete

const SVC_QUEUE = 'queue';

[30] Fix | Delete

const SVC_IMG_OPTM = 'img_optm';

[31] Fix | Delete

const SVC_HEALTH = 'health';

[32] Fix | Delete

const SVC_CDN = 'cdn';

[33] Fix | Delete

[34] Fix | Delete

const BM_IMG_OPTM_PRIO = 16;

[35] Fix | Delete

const BM_IMG_OPTM_JUMBO_GROUP = 32;

[36] Fix | Delete

const IMG_OPTM_JUMBO_GROUP = 1000;

[37] Fix | Delete

const IMG_OPTM_DEFAULT_GROUP = 200;

[38] Fix | Delete

[39] Fix | Delete

const IMGOPTM_TAKEN = 'img_optm-taken';

[40] Fix | Delete

[41] Fix | Delete

const TTL_NODE = 3; // Days before node expired

[42] Fix | Delete

const EXPIRATION_REQ = 300; // Seconds of min interval between two unfinished requests

[43] Fix | Delete

const EXPIRATION_TOKEN = 900; // Min intval to request a token 15m

[44] Fix | Delete

const TTL_IPS = 3; // Days for node ip list cache

[45] Fix | Delete

[46] Fix | Delete

const API_REPORT = 'wp/report';

[47] Fix | Delete

const API_NEWS = 'news';

[48] Fix | Delete

const API_VER = 'ver_check';

[49] Fix | Delete

const API_BETA_TEST = 'beta_test';

[50] Fix | Delete

[51] Fix | Delete

private static $CENTER_SVC_SET = array(

[52] Fix | Delete

self::SVC_D_NODES,

[53] Fix | Delete

self::SVC_D_SYNC_CONF,

[54] Fix | Delete

self::SVC_D_USAGE,

[55] Fix | Delete

// self::API_NEWS,

[56] Fix | Delete

self::API_REPORT,

[57] Fix | Delete

// self::API_VER,

[58] Fix | Delete

// self::API_BETA_TEST,

[59] Fix | Delete

self::SVC_D_SETUP_TOKEN,

[60] Fix | Delete

self::SVC_D_DEL_CDN_DNS,

[61] Fix | Delete

);

[62] Fix | Delete

[63] Fix | Delete

private static $WP_SVC_SET = array(self::API_NEWS, self::API_VER, self::API_BETA_TEST);

[64] Fix | Delete

[65] Fix | Delete

// No api key needed for these services

[66] Fix | Delete

private static $_PUB_SVC_SET = array(self::API_NEWS, self::API_REPORT, self::API_VER, self::API_BETA_TEST);

[67] Fix | Delete

[68] Fix | Delete

private static $_QUEUE_SVC_SET = array(self::SVC_UCSS, self::SVC_VPI);

[69] Fix | Delete

[70] Fix | Delete

public static $SERVICES_LOAD_CHECK = array(

[71] Fix | Delete

self::SVC_CCSS,

[72] Fix | Delete

// self::SVC_UCSS,

[73] Fix | Delete

// self::SVC_VPI,

[74] Fix | Delete

self::SVC_LQIP,

[75] Fix | Delete

self::SVC_HEALTH,

[76] Fix | Delete

);

[77] Fix | Delete

[78] Fix | Delete

public static $SERVICES = array(

[79] Fix | Delete

self::SVC_IMG_OPTM,

[80] Fix | Delete

self::SVC_PAGE_OPTM,

[81] Fix | Delete

self::SVC_CCSS,

[82] Fix | Delete

self::SVC_UCSS,

[83] Fix | Delete

self::SVC_VPI,

[84] Fix | Delete

self::SVC_LQIP,

[85] Fix | Delete

self::SVC_CDN,

[86] Fix | Delete

self::SVC_HEALTH,

[87] Fix | Delete

// self::SVC_QUEUE,

[88] Fix | Delete

);

[89] Fix | Delete

[90] Fix | Delete

const TYPE_CLEAR_PROMO = 'clear_promo';

[91] Fix | Delete

const TYPE_REDETECT_CLOUD = 'redetect_cloud';

[92] Fix | Delete

const TYPE_CLEAR_CLOUD = 'clear_cloud';

[93] Fix | Delete

const TYPE_GEN_KEY = 'gen_key';

[94] Fix | Delete

const TYPE_LINK = 'link';

[95] Fix | Delete

const TYPE_SYNC_USAGE = 'sync_usage';

[96] Fix | Delete

[97] Fix | Delete

private $_setup_token;

[98] Fix | Delete

protected $_summary;

[99] Fix | Delete

[100] Fix | Delete

/**

[101] Fix | Delete

* Init

[102] Fix | Delete

*

[103] Fix | Delete

* @since 3.0

[104] Fix | Delete

*/

[105] Fix | Delete

public function __construct()

[106] Fix | Delete

{

[107] Fix | Delete

$this->_setup_token = $this->conf(self::O_QC_TOKEN);

[108] Fix | Delete

$this->_summary = self::get_summary();

[109] Fix | Delete

}

[110] Fix | Delete

[111] Fix | Delete

/**

[112] Fix | Delete

* Get api key from conf

[113] Fix | Delete

* @since 5.3

[114] Fix | Delete

*/

[115] Fix | Delete

private function _api_key()

[116] Fix | Delete

{

[117] Fix | Delete

return $this->conf(self::O_API_KEY);

[118] Fix | Delete

}

[119] Fix | Delete

[120] Fix | Delete

/**

[121] Fix | Delete

* Show latest commit version always if is on dev

[122] Fix | Delete

*

[123] Fix | Delete

* @since 3.0

[124] Fix | Delete

*/

[125] Fix | Delete

public function check_dev_version()

[126] Fix | Delete

{

[127] Fix | Delete

if (!preg_match('/[^\d\.]/', Core::VER)) {

[128] Fix | Delete

return;

[129] Fix | Delete

}

[130] Fix | Delete

[131] Fix | Delete

$last_check = empty($this->_summary['last_request.' . self::API_VER]) ? 0 : $this->_summary['last_request.' . self::API_VER];

[132] Fix | Delete

[133] Fix | Delete

if (time() - $last_check > 86400) {

[134] Fix | Delete

$auto_v = self::version_check('dev');

[135] Fix | Delete

if (!empty($auto_v['dev'])) {

[136] Fix | Delete

self::save_summary(array('version.dev' => $auto_v['dev']));

[137] Fix | Delete

}

[138] Fix | Delete

}

[139] Fix | Delete

[140] Fix | Delete

if (empty($this->_summary['version.dev'])) {

[141] Fix | Delete

return;

[142] Fix | Delete

}

[143] Fix | Delete

[144] Fix | Delete

self::debug('Latest dev version ' . $this->_summary['version.dev']);

[145] Fix | Delete

[146] Fix | Delete

if (version_compare($this->_summary['version.dev'], Core::VER, '<=')) {

[147] Fix | Delete

return;

[148] Fix | Delete

}

[149] Fix | Delete

[150] Fix | Delete

// Show the dev banner

[151] Fix | Delete

require_once LSCWP_DIR . 'tpl/banner/new_version_dev.tpl.php';

[152] Fix | Delete

}

[153] Fix | Delete

[154] Fix | Delete

/**

[155] Fix | Delete

* Check latest version

[156] Fix | Delete

*

[157] Fix | Delete

* @since 2.9

[158] Fix | Delete

* @access public

[159] Fix | Delete

*/

[160] Fix | Delete

public static function version_check($src = false)

[161] Fix | Delete

{

[162] Fix | Delete

$req_data = array(

[163] Fix | Delete

'v' => defined('LSCWP_CUR_V') ? LSCWP_CUR_V : '',

[164] Fix | Delete

'src' => $src,

[165] Fix | Delete

'php' => phpversion(),

[166] Fix | Delete

);

[167] Fix | Delete

if (defined('LITESPEED_ERR')) {

[168] Fix | Delete

$req_data['err'] = base64_encode(!is_string(LITESPEED_ERR) ? \json_encode(LITESPEED_ERR) : LITESPEED_ERR);

[169] Fix | Delete

}

[170] Fix | Delete

$data = self::post(self::API_VER, $req_data);

[171] Fix | Delete

[172] Fix | Delete

return $data;

[173] Fix | Delete

}

[174] Fix | Delete

[175] Fix | Delete

/**

[176] Fix | Delete

* Show latest news

[177] Fix | Delete

*

[178] Fix | Delete

* @since 3.0

[179] Fix | Delete

*/

[180] Fix | Delete

public function news()

[181] Fix | Delete

{

[182] Fix | Delete

$this->_update_news();

[183] Fix | Delete

[184] Fix | Delete

if (empty($this->_summary['news.new'])) {

[185] Fix | Delete

return;

[186] Fix | Delete

}

[187] Fix | Delete

[188] Fix | Delete

if (!empty($this->_summary['news.plugin']) && Activation::cls()->dash_notifier_is_plugin_active($this->_summary['news.plugin'])) {

[189] Fix | Delete

return;

[190] Fix | Delete

}

[191] Fix | Delete

[192] Fix | Delete

require_once LSCWP_DIR . 'tpl/banner/cloud_news.tpl.php';

[193] Fix | Delete

}

[194] Fix | Delete

[195] Fix | Delete

/**

[196] Fix | Delete

* Update latest news

[197] Fix | Delete

*

[198] Fix | Delete

* @since 2.9.9.1

[199] Fix | Delete

*/

[200] Fix | Delete

private function _update_news()

[201] Fix | Delete

{

[202] Fix | Delete

if (!empty($this->_summary['news.utime']) && time() - $this->_summary['news.utime'] < 86400 * 7) {

[203] Fix | Delete

return;

[204] Fix | Delete

}

[205] Fix | Delete

[206] Fix | Delete

self::save_summary(array('news.utime' => time()));

[207] Fix | Delete

[208] Fix | Delete

$data = self::get(self::API_NEWS);

[209] Fix | Delete

if (empty($data['id'])) {

[210] Fix | Delete

return;

[211] Fix | Delete

}

[212] Fix | Delete

[213] Fix | Delete

// Save news

[214] Fix | Delete

if (!empty($this->_summary['news.id']) && $this->_summary['news.id'] == $data['id']) {

[215] Fix | Delete

return;

[216] Fix | Delete

}

[217] Fix | Delete

[218] Fix | Delete

$this->_summary['news.id'] = $data['id'];

[219] Fix | Delete

$this->_summary['news.plugin'] = !empty($data['plugin']) ? $data['plugin'] : '';

[220] Fix | Delete

$this->_summary['news.title'] = !empty($data['title']) ? $data['title'] : '';

[221] Fix | Delete

$this->_summary['news.content'] = !empty($data['content']) ? $data['content'] : '';

[222] Fix | Delete

$this->_summary['news.zip'] = !empty($data['zip']) ? $data['zip'] : '';

[223] Fix | Delete

$this->_summary['news.new'] = 1;

[224] Fix | Delete

[225] Fix | Delete

if ($this->_summary['news.plugin']) {

[226] Fix | Delete

$plugin_info = Activation::cls()->dash_notifier_get_plugin_info($this->_summary['news.plugin']);

[227] Fix | Delete

if ($plugin_info && !empty($plugin_info->name)) {

[228] Fix | Delete

$this->_summary['news.plugin_name'] = $plugin_info->name;

[229] Fix | Delete

}

[230] Fix | Delete

}

[231] Fix | Delete

[232] Fix | Delete

self::save_summary();

[233] Fix | Delete

}

[234] Fix | Delete

[235] Fix | Delete

/**

[236] Fix | Delete

* Check if contains a package in a service or not

[237] Fix | Delete

*

[238] Fix | Delete

* @since 4.0

[239] Fix | Delete

*/

[240] Fix | Delete

public function has_pkg($service, $pkg)

[241] Fix | Delete

{

[242] Fix | Delete

if (!empty($this->_summary['usage.' . $service]['pkgs']) && $this->_summary['usage.' . $service]['pkgs'] & $pkg) {

[243] Fix | Delete

return true;

[244] Fix | Delete

}

[245] Fix | Delete

[246] Fix | Delete

return false;

[247] Fix | Delete

}

[248] Fix | Delete

[249] Fix | Delete

/**

[250] Fix | Delete

* Get allowance of current service

[251] Fix | Delete

*

[252] Fix | Delete

* @since 3.0

[253] Fix | Delete

* @access private

[254] Fix | Delete

*/

[255] Fix | Delete

public function allowance($service, &$err = false)

[256] Fix | Delete

{

[257] Fix | Delete

// Only auto sync usage at most one time per day

[258] Fix | Delete

if (empty($this->_summary['last_request.' . self::SVC_D_USAGE]) || time() - $this->_summary['last_request.' . self::SVC_D_USAGE] > 86400) {

[259] Fix | Delete

$this->sync_usage();

[260] Fix | Delete

}

[261] Fix | Delete

[262] Fix | Delete

if (in_array($service, array(self::SVC_CCSS, self::SVC_UCSS, self::SVC_VPI))) {

[263] Fix | Delete

// @since 4.2

[264] Fix | Delete

$service = self::SVC_PAGE_OPTM;

[265] Fix | Delete

}

[266] Fix | Delete

[267] Fix | Delete

if (empty($this->_summary['usage.' . $service])) {

[268] Fix | Delete

return 0;

[269] Fix | Delete

}

[270] Fix | Delete

$usage = $this->_summary['usage.' . $service];

[271] Fix | Delete

[272] Fix | Delete

// Image optm is always free

[273] Fix | Delete

$allowance_max = 0;

[274] Fix | Delete

if ($service == self::SVC_IMG_OPTM) {

[275] Fix | Delete

$allowance_max = self::IMG_OPTM_DEFAULT_GROUP;

[276] Fix | Delete

if (!empty($usage['pkgs']) && $usage['pkgs'] & self::BM_IMG_OPTM_JUMBO_GROUP) {

[277] Fix | Delete

$allowance_max = self::IMG_OPTM_JUMBO_GROUP;

[278] Fix | Delete

}

[279] Fix | Delete

}

[280] Fix | Delete

[281] Fix | Delete

$allowance = $usage['quota'] - $usage['used'];

[282] Fix | Delete

[283] Fix | Delete

$err = 'out_of_quota';

[284] Fix | Delete

[285] Fix | Delete

if ($allowance > 0) {

[286] Fix | Delete

if ($allowance_max && $allowance_max < $allowance) {

[287] Fix | Delete

$allowance = $allowance_max;

[288] Fix | Delete

}

[289] Fix | Delete

[290] Fix | Delete

// Daily limit @since 4.2

[291] Fix | Delete

if (isset($usage['remaining_daily_quota']) && $usage['remaining_daily_quota'] >= 0 && $usage['remaining_daily_quota'] < $allowance) {

[292] Fix | Delete

$allowance = $usage['remaining_daily_quota'];

[293] Fix | Delete

if (!$allowance) {

[294] Fix | Delete

$err = 'out_of_daily_quota';

[295] Fix | Delete

}

[296] Fix | Delete

}

[297] Fix | Delete

[298] Fix | Delete

return $allowance;

[299] Fix | Delete

}

[300] Fix | Delete

[301] Fix | Delete

// Check Pay As You Go balance

[302] Fix | Delete

if (empty($usage['pag_bal'])) {

[303] Fix | Delete

return $allowance_max;

[304] Fix | Delete

}

[305] Fix | Delete

[306] Fix | Delete

if ($allowance_max && $allowance_max < $usage['pag_bal']) {

[307] Fix | Delete

return $allowance_max;

[308] Fix | Delete

}

[309] Fix | Delete

[310] Fix | Delete

return $usage['pag_bal'];

[311] Fix | Delete

}

[312] Fix | Delete

[313] Fix | Delete

/**

[314] Fix | Delete

* Sync Cloud usage summary data

[315] Fix | Delete

*

[316] Fix | Delete

* @since 3.0

[317] Fix | Delete

* @access public

[318] Fix | Delete

*/

[319] Fix | Delete

public function sync_usage()

[320] Fix | Delete

{

[321] Fix | Delete

$usage = $this->_post(self::SVC_D_USAGE);

[322] Fix | Delete

if (!$usage) {

[323] Fix | Delete

return;

[324] Fix | Delete

}

[325] Fix | Delete

[326] Fix | Delete

self::debug('sync_usage ' . \json_encode($usage));

[327] Fix | Delete

[328] Fix | Delete

foreach (self::$SERVICES as $v) {

[329] Fix | Delete

$this->_summary['usage.' . $v] = !empty($usage[$v]) ? $usage[$v] : false;

[330] Fix | Delete

}

[331] Fix | Delete

[332] Fix | Delete

self::save_summary();

[333] Fix | Delete

[334] Fix | Delete

return $this->_summary;

[335] Fix | Delete

}

[336] Fix | Delete

[337] Fix | Delete

/**

[338] Fix | Delete

* Clear all existing cloud nodes for future reconnect

[339] Fix | Delete

*

[340] Fix | Delete

* @since 3.0

[341] Fix | Delete

* @access public

[342] Fix | Delete

*/

[343] Fix | Delete

public function clear_cloud()

[344] Fix | Delete

{

[345] Fix | Delete

foreach (self::$SERVICES as $service) {

[346] Fix | Delete

if (isset($this->_summary['server.' . $service])) {

[347] Fix | Delete

unset($this->_summary['server.' . $service]);

[348] Fix | Delete

}

[349] Fix | Delete

if (isset($this->_summary['server_date.' . $service])) {

[350] Fix | Delete

unset($this->_summary['server_date.' . $service]);

[351] Fix | Delete

}

[352] Fix | Delete

}

[353] Fix | Delete

self::save_summary();

[354] Fix | Delete

[355] Fix | Delete

self::debug('Cleared all local service node caches');

[356] Fix | Delete

}

[357] Fix | Delete

[358] Fix | Delete

/**

[359] Fix | Delete

* ping clouds to find the fastest node

[360] Fix | Delete

*

[361] Fix | Delete

* @since 3.0

[362] Fix | Delete

* @access public

[363] Fix | Delete

*/

[364] Fix | Delete

public function detect_cloud($service, $force = false)

[365] Fix | Delete

{

[366] Fix | Delete

if (in_array($service, self::$CENTER_SVC_SET)) {

[367] Fix | Delete

return self::CLOUD_SERVER;

[368] Fix | Delete

}

[369] Fix | Delete

[370] Fix | Delete

if (in_array($service, self::$WP_SVC_SET)) {

[371] Fix | Delete

return self::CLOUD_SERVER_WP;

[372] Fix | Delete

}

[373] Fix | Delete

[374] Fix | Delete

// Check if the stored server needs to be refreshed

[375] Fix | Delete

if (!$force) {

[376] Fix | Delete

if (

[377] Fix | Delete

!empty($this->_summary['server.' . $service]) &&

[378] Fix | Delete

!empty($this->_summary['server_date.' . $service]) &&

[379] Fix | Delete

$this->_summary['server_date.' . $service] > time() - 86400 * self::TTL_NODE

[380] Fix | Delete

) {

[381] Fix | Delete

return $this->_summary['server.' . $service];

[382] Fix | Delete

}

[383] Fix | Delete

}

[384] Fix | Delete

[385] Fix | Delete

if (!$service || !in_array($service, self::$SERVICES)) {

[386] Fix | Delete

$msg = __('Cloud Error', 'litespeed-cache') . ': ' . $service;

[387] Fix | Delete

Admin_Display::error($msg);

[388] Fix | Delete

return false;

[389] Fix | Delete

}

[390] Fix | Delete

[391] Fix | Delete

// Send request to Quic Online Service

[392] Fix | Delete

$json = $this->_post(self::SVC_D_NODES, array('svc' => $this->_maybe_queue($service)));

[393] Fix | Delete

[394] Fix | Delete

// Check if get list correctly

[395] Fix | Delete

if (empty($json['list']) || !is_array($json['list'])) {

[396] Fix | Delete

self::debug('request cloud list failed: ', $json);

[397] Fix | Delete

[398] Fix | Delete

if ($json) {

[399] Fix | Delete

$msg = __('Cloud Error', 'litespeed-cache') . ": [Service] $service [Info] " . \json_encode($json);

[400] Fix | Delete

Admin_Display::error($msg);

[401] Fix | Delete

}

[402] Fix | Delete

[403] Fix | Delete

return false;

[404] Fix | Delete

}

[405] Fix | Delete

[406] Fix | Delete

// Ping closest cloud

[407] Fix | Delete

$speed_list = array();

[408] Fix | Delete

foreach ($json['list'] as $v) {

[409] Fix | Delete

// Exclude possible failed 503 nodes

[410] Fix | Delete

if (!empty($this->_summary['disabled_node']) && !empty($this->_summary['disabled_node'][$v]) && time() - $this->_summary['disabled_node'][$v] < 86400) {

[411] Fix | Delete

continue;

[412] Fix | Delete

}

[413] Fix | Delete

$speed_list[$v] = Utility::ping($v);

[414] Fix | Delete

}

[415] Fix | Delete

[416] Fix | Delete

if (!$speed_list) {

[417] Fix | Delete

self::debug('nodes are in 503 failed nodes');

[418] Fix | Delete

return false;

[419] Fix | Delete

}

[420] Fix | Delete

[421] Fix | Delete

$min = min($speed_list);

[422] Fix | Delete

[423] Fix | Delete

if ($min == 99999) {

[424] Fix | Delete

self::debug('failed to ping all clouds');

[425] Fix | Delete

return false;

[426] Fix | Delete

}

[427] Fix | Delete

[428] Fix | Delete

// Random pick same time range ip (230ms 250ms)

[429] Fix | Delete

$range_len = strlen($min);

[430] Fix | Delete

$range_num = substr($min, 0, 1);

[431] Fix | Delete

$valid_clouds = array();

[432] Fix | Delete

foreach ($speed_list as $node => $speed) {

[433] Fix | Delete

if (strlen($speed) == $range_len && substr($speed, 0, 1) == $range_num) {

[434] Fix | Delete

$valid_clouds[] = $node;

[435] Fix | Delete

}

[436] Fix | Delete

// Append the lower speed ones

[437] Fix | Delete

elseif ($speed < $min * 4) {

[438] Fix | Delete

$valid_clouds[] = $node;

[439] Fix | Delete

}

[440] Fix | Delete

}

[441] Fix | Delete

[442] Fix | Delete

if (!$valid_clouds) {

[443] Fix | Delete

$msg = __('Cloud Error', 'litespeed-cache') . ": [Service] $service [Info] " . __('No available Cloud Node.', 'litespeed-cache');

[444] Fix | Delete

Admin_Display::error($msg);

[445] Fix | Delete

return false;

[446] Fix | Delete

}

[447] Fix | Delete

[448] Fix | Delete

self::debug('Closest nodes list', $valid_clouds);

[449] Fix | Delete

[450] Fix | Delete

// Check server load

[451] Fix | Delete

if (in_array($service, self::$SERVICES_LOAD_CHECK)) {

[452] Fix | Delete

$valid_cloud_loads = array();

[453] Fix | Delete

foreach ($valid_clouds as $k => $v) {

[454] Fix | Delete

$response = wp_remote_get($v, array('timeout' => 5, 'sslverify' => true));

[455] Fix | Delete

if (is_wp_error($response)) {

[456] Fix | Delete

$error_message = $response->get_error_message();

[457] Fix | Delete

self::debug('failed to do load checker: ' . $error_message);

[458] Fix | Delete

continue;

[459] Fix | Delete

}

[460] Fix | Delete

[461] Fix | Delete

$curr_load = \json_decode($response['body'], true);

[462] Fix | Delete

if (!empty($curr_load['_res']) && $curr_load['_res'] == 'ok' && isset($curr_load['load'])) {

[463] Fix | Delete

$valid_cloud_loads[$v] = $curr_load['load'];

[464] Fix | Delete

}

[465] Fix | Delete

}

[466] Fix | Delete

[467] Fix | Delete

if (!$valid_cloud_loads) {

[468] Fix | Delete

$msg = __('Cloud Error', 'litespeed-cache') . ": [Service] $service [Info] " . __('No available Cloud Node after checked server load.', 'litespeed-cache');

[469] Fix | Delete

Admin_Display::error($msg);

[470] Fix | Delete

return false;

[471] Fix | Delete

}

[472] Fix | Delete

[473] Fix | Delete

self::debug('Closest nodes list after load check', $valid_cloud_loads);

[474] Fix | Delete

[475] Fix | Delete

$qualified_list = array_keys($valid_cloud_loads, min($valid_cloud_loads));

[476] Fix | Delete

} else {

[477] Fix | Delete

$qualified_list = $valid_clouds;

[478] Fix | Delete

}

[479] Fix | Delete

[480] Fix | Delete

$closest = $qualified_list[array_rand($qualified_list)];

[481] Fix | Delete

[482] Fix | Delete

self::debug('Chose node: ' . $closest);

[483] Fix | Delete

[484] Fix | Delete

// store data into option locally

[485] Fix | Delete

$this->_summary['server.' . $service] = $closest;

[486] Fix | Delete

$this->_summary['server_date.' . $service] = time();

[487] Fix | Delete

self::save_summary();

[488] Fix | Delete

[489] Fix | Delete

return $this->_summary['server.' . $service];

[490] Fix | Delete

}

[491] Fix | Delete

[492] Fix | Delete

/**

[493] Fix | Delete

* May need to convert to queue service

[494] Fix | Delete

*/

[495] Fix | Delete

private function _maybe_queue($service)

[496] Fix | Delete

{

[497] Fix | Delete

if (in_array($service, self::$_QUEUE_SVC_SET)) {

[498] Fix | Delete

return self::SVC_QUEUE;

[499] Fix | Delete