<?php

[0] Fix | Delete

[1] Fix | Delete

/**

[2] Fix | Delete

* The viewport image class.

[3] Fix | Delete

*

[4] Fix | Delete

* @since 4.7

[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 VPI extends Base

[12] Fix | Delete

{

[13] Fix | Delete

const LOG_TAG = '[VPI]';

[14] Fix | Delete

[15] Fix | Delete

const TYPE_GEN = 'gen';

[16] Fix | Delete

const TYPE_CLEAR_Q = 'clear_q';

[17] Fix | Delete

[18] Fix | Delete

protected $_summary;

[19] Fix | Delete

private $_queue;

[20] Fix | Delete

[21] Fix | Delete

/**

[22] Fix | Delete

* Init

[23] Fix | Delete

*

[24] Fix | Delete

* @since 4.7

[25] Fix | Delete

*/

[26] Fix | Delete

public function __construct()

[27] Fix | Delete

{

[28] Fix | Delete

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

[29] Fix | Delete

}

[30] Fix | Delete

[31] Fix | Delete

/**

[32] Fix | Delete

* The VPI content of the current page

[33] Fix | Delete

*

[34] Fix | Delete

* @since 4.7

[35] Fix | Delete

*/

[36] Fix | Delete

public function add_to_queue()

[37] Fix | Delete

{

[38] Fix | Delete

$is_mobile = $this->_separate_mobile();

[39] Fix | Delete

[40] Fix | Delete

global $wp;

[41] Fix | Delete

$request_url = home_url($wp->request);

[42] Fix | Delete

[43] Fix | Delete

$ua = !empty($_SERVER['HTTP_USER_AGENT']) ? $_SERVER['HTTP_USER_AGENT'] : '';

[44] Fix | Delete

[45] Fix | Delete

// Store it to prepare for cron

[46] Fix | Delete

$this->_queue = $this->load_queue('vpi');

[47] Fix | Delete

[48] Fix | Delete

if (count($this->_queue) > 500) {

[49] Fix | Delete

self::debug('Queue is full - 500');

[50] Fix | Delete

return;

[51] Fix | Delete

}

[52] Fix | Delete

[53] Fix | Delete

$home_id = get_option('page_for_posts');

[54] Fix | Delete

[55] Fix | Delete

if (!is_singular() && !($home_id > 0 && is_home())) {

[56] Fix | Delete

self::debug('not single post ID');

[57] Fix | Delete

return;

[58] Fix | Delete

}

[59] Fix | Delete

[60] Fix | Delete

$post_id = is_home() ? $home_id : get_the_ID();

[61] Fix | Delete

[62] Fix | Delete

$queue_k = ($is_mobile ? 'mobile' : '') . ' ' . $request_url;

[63] Fix | Delete

if (!empty($this->_queue[$queue_k])) {

[64] Fix | Delete

self::debug('queue k existed ' . $queue_k);

[65] Fix | Delete

return;

[66] Fix | Delete

}

[67] Fix | Delete

[68] Fix | Delete

$this->_queue[$queue_k] = array(

[69] Fix | Delete

'url' => apply_filters('litespeed_vpi_url', $request_url),

[70] Fix | Delete

'post_id' => $post_id,

[71] Fix | Delete

'user_agent' => substr($ua, 0, 200),

[72] Fix | Delete

'is_mobile' => $this->_separate_mobile(),

[73] Fix | Delete

); // Current UA will be used to request

[74] Fix | Delete

$this->save_queue('vpi', $this->_queue);

[75] Fix | Delete

self::debug('Added queue_vpi [url] ' . $queue_k . ' [UA] ' . $ua);

[76] Fix | Delete

[77] Fix | Delete

// Prepare cache tag for later purge

[78] Fix | Delete

Tag::add('VPI.' . md5($queue_k));

[79] Fix | Delete

[80] Fix | Delete

return null;

[81] Fix | Delete

}

[82] Fix | Delete

[83] Fix | Delete

/**

[84] Fix | Delete

* Notify finished from server

[85] Fix | Delete

* @since 4.7

[86] Fix | Delete

*/

[87] Fix | Delete

public function notify()

[88] Fix | Delete

{

[89] Fix | Delete

$post_data = \json_decode(file_get_contents('php://input'), true);

[90] Fix | Delete

if (is_null($post_data)) {

[91] Fix | Delete

$post_data = $_POST;

[92] Fix | Delete

}

[93] Fix | Delete

self::debug('notify() data', $post_data);

[94] Fix | Delete

[95] Fix | Delete

$this->_queue = $this->load_queue('vpi');

[96] Fix | Delete

[97] Fix | Delete

// Validate key

[98] Fix | Delete

if (empty($post_data['domain_key']) || $post_data['domain_key'] !== md5($this->conf(self::O_API_KEY))) {

[99] Fix | Delete

self::debug('❌ notify wrong key');

[100] Fix | Delete

self::save_summary(array('notify_ts_err' => time()));

[101] Fix | Delete

return Cloud::err('wrong_key');

[102] Fix | Delete

}

[103] Fix | Delete

[104] Fix | Delete

list($post_data) = $this->cls('Cloud')->extract_msg($post_data, 'vpi');

[105] Fix | Delete

[106] Fix | Delete

$notified_data = $post_data['data'];

[107] Fix | Delete

if (empty($notified_data) || !is_array($notified_data)) {

[108] Fix | Delete

self::debug('❌ notify exit: no notified data');

[109] Fix | Delete

return Cloud::err('no notified data');

[110] Fix | Delete

}

[111] Fix | Delete

[112] Fix | Delete

// Check if its in queue or not

[113] Fix | Delete

$valid_i = 0;

[114] Fix | Delete

foreach ($notified_data as $v) {

[115] Fix | Delete

if (empty($v['request_url'])) {

[116] Fix | Delete

self::debug('❌ notify bypass: no request_url', $v);

[117] Fix | Delete

continue;

[118] Fix | Delete

}

[119] Fix | Delete

if (empty($v['queue_k'])) {

[120] Fix | Delete

self::debug('❌ notify bypass: no queue_k', $v);

[121] Fix | Delete

continue;

[122] Fix | Delete

}

[123] Fix | Delete

// $queue_k = ( $is_mobile ? 'mobile' : '' ) . ' ' . $v[ 'request_url' ];

[124] Fix | Delete

$queue_k = $v['queue_k'];

[125] Fix | Delete

[126] Fix | Delete

if (empty($this->_queue[$queue_k])) {

[127] Fix | Delete

self::debug('❌ notify bypass: no this queue [q_k]' . $queue_k);

[128] Fix | Delete

continue;

[129] Fix | Delete

}

[130] Fix | Delete

[131] Fix | Delete

// Save data

[132] Fix | Delete

if (!empty($v['data_vpi'])) {

[133] Fix | Delete

$post_id = $this->_queue[$queue_k]['post_id'];

[134] Fix | Delete

$name = !empty($v['is_mobile']) ? 'litespeed_vpi_list_mobile' : 'litespeed_vpi_list';

[135] Fix | Delete

$urldecode = is_array($v['data_vpi']) ? array_map('urldecode', $v['data_vpi']) : urldecode($v['data_vpi']);

[136] Fix | Delete

self::debug('save data_vpi', $urldecode);

[137] Fix | Delete

$this->cls('Metabox')->save($post_id, $name, $urldecode);

[138] Fix | Delete

[139] Fix | Delete

$valid_i++;

[140] Fix | Delete

}

[141] Fix | Delete

[142] Fix | Delete

unset($this->_queue[$queue_k]);

[143] Fix | Delete

self::debug('notify data handled, unset queue [q_k] ' . $queue_k);

[144] Fix | Delete

}

[145] Fix | Delete

$this->save_queue('vpi', $this->_queue);

[146] Fix | Delete

[147] Fix | Delete

self::debug('notified');

[148] Fix | Delete

[149] Fix | Delete

return Cloud::ok(array('count' => $valid_i));

[150] Fix | Delete

}

[151] Fix | Delete

[152] Fix | Delete

/**

[153] Fix | Delete

* Cron

[154] Fix | Delete

*

[155] Fix | Delete

* @since 4.7

[156] Fix | Delete

*/

[157] Fix | Delete

public static function cron($continue = false)

[158] Fix | Delete

{

[159] Fix | Delete

$_instance = self::cls();

[160] Fix | Delete

return $_instance->_cron_handler($continue);

[161] Fix | Delete

}

[162] Fix | Delete

[163] Fix | Delete

/**

[164] Fix | Delete

* Cron generation

[165] Fix | Delete

*

[166] Fix | Delete

* @since 4.7

[167] Fix | Delete

*/

[168] Fix | Delete

private function _cron_handler($continue = false)

[169] Fix | Delete

{

[170] Fix | Delete

self::debug('cron start');

[171] Fix | Delete

$this->_queue = $this->load_queue('vpi');

[172] Fix | Delete

[173] Fix | Delete

if (empty($this->_queue)) {

[174] Fix | Delete

return;

[175] Fix | Delete

}

[176] Fix | Delete

[177] Fix | Delete

// For cron, need to check request interval too

[178] Fix | Delete

if (!$continue) {

[179] Fix | Delete

if (!empty($this->_summary['curr_request_vpi']) && time() - $this->_summary['curr_request_vpi'] < 300 && !$this->conf(self::O_DEBUG)) {

[180] Fix | Delete

self::debug('Last request not done');

[181] Fix | Delete

return;

[182] Fix | Delete

}

[183] Fix | Delete

}

[184] Fix | Delete

[185] Fix | Delete

$i = 0;

[186] Fix | Delete

foreach ($this->_queue as $k => $v) {

[187] Fix | Delete

if (!empty($v['_status'])) {

[188] Fix | Delete

continue;

[189] Fix | Delete

}

[190] Fix | Delete

[191] Fix | Delete

self::debug('cron job [tag] ' . $k . ' [url] ' . $v['url'] . ($v['is_mobile'] ? ' 📱 ' : '') . ' [UA] ' . $v['user_agent']);

[192] Fix | Delete

[193] Fix | Delete

$i++;

[194] Fix | Delete

$res = $this->_send_req($v['url'], $k, $v['user_agent'], $v['is_mobile']);

[195] Fix | Delete

if (!$res) {

[196] Fix | Delete

// Status is wrong, drop this this->_queue

[197] Fix | Delete

$this->_queue = $this->load_queue('vpi');

[198] Fix | Delete

unset($this->_queue[$k]);

[199] Fix | Delete

$this->save_queue('vpi', $this->_queue);

[200] Fix | Delete

[201] Fix | Delete

if (!$continue) {

[202] Fix | Delete

return;

[203] Fix | Delete

}

[204] Fix | Delete

[205] Fix | Delete

// if ( $i > 3 ) {

[206] Fix | Delete

GUI::print_loading(count($this->_queue), 'VPI');

[207] Fix | Delete

return Router::self_redirect(Router::ACTION_VPI, self::TYPE_GEN);

[208] Fix | Delete

// }

[209] Fix | Delete

[210] Fix | Delete

continue;

[211] Fix | Delete

}

[212] Fix | Delete

[213] Fix | Delete

// Exit queue if out of quota

[214] Fix | Delete

if ($res === 'out_of_quota') {

[215] Fix | Delete

return;

[216] Fix | Delete

}

[217] Fix | Delete

[218] Fix | Delete

$this->_queue = $this->load_queue('vpi');

[219] Fix | Delete

$this->_queue[$k]['_status'] = 'requested';

[220] Fix | Delete

$this->save_queue('vpi', $this->_queue);

[221] Fix | Delete

self::debug('Saved to queue [k] ' . $k);

[222] Fix | Delete

[223] Fix | Delete

// only request first one

[224] Fix | Delete

if (!$continue) {

[225] Fix | Delete

return;

[226] Fix | Delete

}

[227] Fix | Delete

[228] Fix | Delete

// if ( $i > 3 ) {

[229] Fix | Delete

GUI::print_loading(count($this->_queue), 'VPI');

[230] Fix | Delete

return Router::self_redirect(Router::ACTION_VPI, self::TYPE_GEN);

[231] Fix | Delete

// }

[232] Fix | Delete

}

[233] Fix | Delete

}

[234] Fix | Delete

[235] Fix | Delete

/**

[236] Fix | Delete

* Send to QC API to generate VPI

[237] Fix | Delete

*

[238] Fix | Delete

* @since 4.7

[239] Fix | Delete

* @access private

[240] Fix | Delete

*/

[241] Fix | Delete

private function _send_req($request_url, $queue_k, $user_agent, $is_mobile)

[242] Fix | Delete

{

[243] Fix | Delete

$svc = Cloud::SVC_VPI;

[244] Fix | Delete

// Check if has credit to push or not

[245] Fix | Delete

$err = false;

[246] Fix | Delete

$allowance = $this->cls('Cloud')->allowance($svc, $err);

[247] Fix | Delete

if (!$allowance) {

[248] Fix | Delete

self::debug('❌ No credit: ' . $err);

[249] Fix | Delete

$err && Admin_Display::error(Error::msg($err));

[250] Fix | Delete

return 'out_of_quota';

[251] Fix | Delete

}

[252] Fix | Delete

[253] Fix | Delete

set_time_limit(120);

[254] Fix | Delete

[255] Fix | Delete

// Update css request status

[256] Fix | Delete

self::save_summary(array('curr_request_vpi' => time()), true);

[257] Fix | Delete

[258] Fix | Delete

// Gather guest HTML to send

[259] Fix | Delete

$html = $this->cls('CSS')->prepare_html($request_url, $user_agent);

[260] Fix | Delete

[261] Fix | Delete

if (!$html) {

[262] Fix | Delete

return false;

[263] Fix | Delete

}

[264] Fix | Delete

[265] Fix | Delete

// Parse HTML to gather all CSS content before requesting

[266] Fix | Delete

$css = false;

[267] Fix | Delete

list($css, $html) = $this->cls('CSS')->prepare_css($html);

[268] Fix | Delete

[269] Fix | Delete

if (!$css) {

[270] Fix | Delete

self::debug('❌ No css');

[271] Fix | Delete

return false;

[272] Fix | Delete

}

[273] Fix | Delete

[274] Fix | Delete

$data = array(

[275] Fix | Delete

'url' => $request_url,

[276] Fix | Delete

'queue_k' => $queue_k,

[277] Fix | Delete

'user_agent' => $user_agent,

[278] Fix | Delete

'is_mobile' => $is_mobile ? 1 : 0, // todo:compatible w/ tablet

[279] Fix | Delete

'html' => $html,

[280] Fix | Delete

'css' => $css,

[281] Fix | Delete

);

[282] Fix | Delete

self::debug('Generating: ', $data);

[283] Fix | Delete

[284] Fix | Delete

$json = Cloud::post($svc, $data, 30);

[285] Fix | Delete

if (!is_array($json)) {

[286] Fix | Delete

return false;

[287] Fix | Delete

}

[288] Fix | Delete

[289] Fix | Delete

// Unknown status, remove this line

[290] Fix | Delete

if ($json['status'] != 'queued') {

[291] Fix | Delete

return false;

[292] Fix | Delete

}

[293] Fix | Delete

[294] Fix | Delete

// Save summary data

[295] Fix | Delete

self::reload_summary();

[296] Fix | Delete

$this->_summary['last_spent_vpi'] = time() - $this->_summary['curr_request_vpi'];

[297] Fix | Delete

$this->_summary['last_request_vpi'] = $this->_summary['curr_request_vpi'];

[298] Fix | Delete

$this->_summary['curr_request_vpi'] = 0;

[299] Fix | Delete

self::save_summary();

[300] Fix | Delete

[301] Fix | Delete

return true;

[302] Fix | Delete

}

[303] Fix | Delete

[304] Fix | Delete

/**

[305] Fix | Delete

* Handle all request actions from main cls

[306] Fix | Delete

*

[307] Fix | Delete

* @since 4.7

[308] Fix | Delete

*/

[309] Fix | Delete

public function handler()

[310] Fix | Delete

{

[311] Fix | Delete

$type = Router::verify_type();

[312] Fix | Delete

[313] Fix | Delete

switch ($type) {

[314] Fix | Delete

case self::TYPE_GEN:

[315] Fix | Delete

self::cron(true);

[316] Fix | Delete

break;

[317] Fix | Delete

[318] Fix | Delete

case self::TYPE_CLEAR_Q:

[319] Fix | Delete

$this->clear_q('vpi');

[320] Fix | Delete

break;

[321] Fix | Delete

[322] Fix | Delete

default:

[323] Fix | Delete

break;

[324] Fix | Delete

}

[325] Fix | Delete

[326] Fix | Delete

Admin::redirect();

[327] Fix | Delete

}

[328] Fix | Delete

}

[329] Fix | Delete

[330] Fix | Delete