<?php

[0] Fix | Delete

[1] Fix | Delete

namespace LiteSpeed\CLI;

[2] Fix | Delete

[3] Fix | Delete

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

[4] Fix | Delete

[5] Fix | Delete

use LiteSpeed\Debug2;

[6] Fix | Delete

use LiteSpeed\Base;

[7] Fix | Delete

use LiteSpeed\Task;

[8] Fix | Delete

use LiteSpeed\Crawler as Crawler2;

[9] Fix | Delete

use WP_CLI;

[10] Fix | Delete

[11] Fix | Delete

/**

[12] Fix | Delete

* Crawler

[13] Fix | Delete

*/

[14] Fix | Delete

class Crawler extends Base

[15] Fix | Delete

{

[16] Fix | Delete

private $__crawler;

[17] Fix | Delete

[18] Fix | Delete

public function __construct()

[19] Fix | Delete

{

[20] Fix | Delete

Debug2::debug('CLI_Crawler init');

[21] Fix | Delete

[22] Fix | Delete

$this->__crawler = Crawler2::cls();

[23] Fix | Delete

}

[24] Fix | Delete

[25] Fix | Delete

/**

[26] Fix | Delete

* List all crawler

[27] Fix | Delete

*

[28] Fix | Delete

* ## OPTIONS

[29] Fix | Delete

*

[30] Fix | Delete

* ## EXAMPLES

[31] Fix | Delete

*

[32] Fix | Delete

* # List all crawlers

[33] Fix | Delete

* $ wp litespeed-crawler l

[34] Fix | Delete

*

[35] Fix | Delete

*/

[36] Fix | Delete

public function l()

[37] Fix | Delete

{

[38] Fix | Delete

$this->list();

[39] Fix | Delete

}

[40] Fix | Delete

[41] Fix | Delete

/**

[42] Fix | Delete

* List all crawler

[43] Fix | Delete

*

[44] Fix | Delete

* ## OPTIONS

[45] Fix | Delete

*

[46] Fix | Delete

* ## EXAMPLES

[47] Fix | Delete

*

[48] Fix | Delete

* # List all crawlers

[49] Fix | Delete

* $ wp litespeed-crawler list

[50] Fix | Delete

*

[51] Fix | Delete

*/

[52] Fix | Delete

public function list()

[53] Fix | Delete

{

[54] Fix | Delete

$crawler_list = $this->__crawler->list_crawlers();

[55] Fix | Delete

$summary = Crawler2::get_summary();

[56] Fix | Delete

if ($summary['curr_crawler'] >= count($crawler_list)) {

[57] Fix | Delete

$summary['curr_crawler'] = 0;

[58] Fix | Delete

}

[59] Fix | Delete

$is_running = time() - $summary['is_running'] <= $this->conf(Base::O_CRAWLER_RUN_DURATION);

[60] Fix | Delete

[61] Fix | Delete

$seconds = $this->conf(Base::O_CRAWLER_RUN_INTERVAL);

[62] Fix | Delete

if ($seconds > 0) {

[63] Fix | Delete

$recurrence = '';

[64] Fix | Delete

$hours = (int) floor($seconds / 3600);

[65] Fix | Delete

if ($hours) {

[66] Fix | Delete

if ($hours > 1) {

[67] Fix | Delete

$recurrence .= sprintf(__('%d hours', 'litespeed-cache'), $hours);

[68] Fix | Delete

} else {

[69] Fix | Delete

$recurrence .= sprintf(__('%d hour', 'litespeed-cache'), $hours);

[70] Fix | Delete

}

[71] Fix | Delete

}

[72] Fix | Delete

$minutes = (int) floor(($seconds % 3600) / 60);

[73] Fix | Delete

if ($minutes) {

[74] Fix | Delete

$recurrence .= ' ';

[75] Fix | Delete

if ($minutes > 1) {

[76] Fix | Delete

$recurrence .= sprintf(__('%d minutes', 'litespeed-cache'), $minutes);

[77] Fix | Delete

} else {

[78] Fix | Delete

$recurrence .= sprintf(__('%d minute', 'litespeed-cache'), $minutes);

[79] Fix | Delete

}

[80] Fix | Delete

}

[81] Fix | Delete

}

[82] Fix | Delete

[83] Fix | Delete

$list = array();

[84] Fix | Delete

foreach ($crawler_list as $i => $v) {

[85] Fix | Delete

$hit = !empty($summary['crawler_stats'][$i]['H']) ? $summary['crawler_stats'][$i]['H'] : 0;

[86] Fix | Delete

$miss = !empty($summary['crawler_stats'][$i]['M']) ? $summary['crawler_stats'][$i]['M'] : 0;

[87] Fix | Delete

[88] Fix | Delete

$blacklisted = !empty($summary['crawler_stats'][$i]['B']) ? $summary['crawler_stats'][$i]['B'] : 0;

[89] Fix | Delete

$blacklisted += !empty($summary['crawler_stats'][$i]['N']) ? $summary['crawler_stats'][$i]['N'] : 0;

[90] Fix | Delete

[91] Fix | Delete

if (isset($summary['crawler_stats'][$i]['W'])) {

[92] Fix | Delete

$waiting = $summary['crawler_stats'][$i]['W'] ?: 0;

[93] Fix | Delete

} else {

[94] Fix | Delete

$waiting = $summary['list_size'] - $hit - $miss - $blacklisted;

[95] Fix | Delete

}

[96] Fix | Delete

[97] Fix | Delete

$analytics = 'Waiting: ' . $waiting;

[98] Fix | Delete

$analytics .= ' Hit: ' . $hit;

[99] Fix | Delete

$analytics .= ' Miss: ' . $miss;

[100] Fix | Delete

$analytics .= ' Blocked: ' . $blacklisted;

[101] Fix | Delete

[102] Fix | Delete

$running = '';

[103] Fix | Delete

if ($i == $summary['curr_crawler']) {

[104] Fix | Delete

$running = 'Pos: ' . ($summary['last_pos'] + 1);

[105] Fix | Delete

if ($is_running) {

[106] Fix | Delete

$running .= '(Running)';

[107] Fix | Delete

}

[108] Fix | Delete

}

[109] Fix | Delete

[110] Fix | Delete

$status = $this->__crawler->is_active($i) ? '✅' : '❌';

[111] Fix | Delete

[112] Fix | Delete

$list[] = array(

[113] Fix | Delete

'ID' => $i + 1,

[114] Fix | Delete

'Name' => wp_strip_all_tags($v['title']),

[115] Fix | Delete

'Frequency' => $recurrence,

[116] Fix | Delete

'Status' => $status,

[117] Fix | Delete

'Analytics' => $analytics,

[118] Fix | Delete

'Running' => $running,

[119] Fix | Delete

);

[120] Fix | Delete

}

[121] Fix | Delete

[122] Fix | Delete

WP_CLI\Utils\format_items('table', $list, array('ID', 'Name', 'Frequency', 'Status', 'Analytics', 'Running'));

[123] Fix | Delete

}

[124] Fix | Delete

[125] Fix | Delete

/**

[126] Fix | Delete

* Enable one crawler

[127] Fix | Delete

*

[128] Fix | Delete

* ## OPTIONS

[129] Fix | Delete

*

[130] Fix | Delete

* ## EXAMPLES

[131] Fix | Delete

*

[132] Fix | Delete

* # Turn on 2nd crawler

[133] Fix | Delete

* $ wp litespeed-crawler enable 2

[134] Fix | Delete

*

[135] Fix | Delete

*/

[136] Fix | Delete

public function enable($args)

[137] Fix | Delete

{

[138] Fix | Delete

$id = $args[0] - 1;

[139] Fix | Delete

if ($this->__crawler->is_active($id)) {

[140] Fix | Delete

WP_CLI::error('ID #' . $id . ' had been enabled');

[141] Fix | Delete

return;

[142] Fix | Delete

}

[143] Fix | Delete

[144] Fix | Delete

$this->__crawler->toggle_activeness($id);

[145] Fix | Delete

WP_CLI::success('Enabled crawler #' . $id);

[146] Fix | Delete

}

[147] Fix | Delete

[148] Fix | Delete

/**

[149] Fix | Delete

* Disable one crawler

[150] Fix | Delete

*

[151] Fix | Delete

* ## OPTIONS

[152] Fix | Delete

*

[153] Fix | Delete

* ## EXAMPLES

[154] Fix | Delete

*

[155] Fix | Delete

* # Turn off 1st crawler

[156] Fix | Delete

* $ wp litespeed-crawler disable 1

[157] Fix | Delete

*

[158] Fix | Delete

*/

[159] Fix | Delete

public function disable($args)

[160] Fix | Delete

{

[161] Fix | Delete

$id = $args[0] - 1;

[162] Fix | Delete

if (!$this->__crawler->is_active($id)) {

[163] Fix | Delete

WP_CLI::error('ID #' . $id . ' has been disabled');

[164] Fix | Delete

return;

[165] Fix | Delete

}

[166] Fix | Delete

[167] Fix | Delete

$this->__crawler->toggle_activeness($id);

[168] Fix | Delete

WP_CLI::success('Disabled crawler #' . $id);

[169] Fix | Delete

}

[170] Fix | Delete

[171] Fix | Delete

/**

[172] Fix | Delete

* Run crawling

[173] Fix | Delete

*

[174] Fix | Delete

* ## OPTIONS

[175] Fix | Delete

*

[176] Fix | Delete

* ## EXAMPLES

[177] Fix | Delete

*

[178] Fix | Delete

* # Start crawling

[179] Fix | Delete

* $ wp litespeed-crawler r

[180] Fix | Delete

*

[181] Fix | Delete

*/

[182] Fix | Delete

public function r()

[183] Fix | Delete

{

[184] Fix | Delete

$this->run();

[185] Fix | Delete

}

[186] Fix | Delete

[187] Fix | Delete

/**

[188] Fix | Delete

* Run crawling

[189] Fix | Delete

*

[190] Fix | Delete

* ## OPTIONS

[191] Fix | Delete

*

[192] Fix | Delete

* ## EXAMPLES

[193] Fix | Delete

*

[194] Fix | Delete

* # Start crawling

[195] Fix | Delete

* $ wp litespeed-crawler run

[196] Fix | Delete

*

[197] Fix | Delete

*/

[198] Fix | Delete

public function run()

[199] Fix | Delete

{

[200] Fix | Delete

self::debug('⚠️⚠️⚠️ Forced take over lane (CLI)');

[201] Fix | Delete

$this->__crawler->Release_lane();

[202] Fix | Delete

[203] Fix | Delete

Task::async_call('crawler');

[204] Fix | Delete

[205] Fix | Delete

$summary = Crawler2::get_summary();

[206] Fix | Delete

[207] Fix | Delete

WP_CLI::success('Start crawling. Current crawler #' . ($summary['curr_crawler'] + 1) . ' [position] ' . $summary['last_pos'] . ' [total] ' . $summary['list_size']);

[208] Fix | Delete

}

[209] Fix | Delete

[210] Fix | Delete

/**

[211] Fix | Delete

* Reset position

[212] Fix | Delete

*

[213] Fix | Delete

* ## OPTIONS

[214] Fix | Delete

*

[215] Fix | Delete

* ## EXAMPLES

[216] Fix | Delete

*

[217] Fix | Delete

* # Reset crawler position

[218] Fix | Delete

* $ wp litespeed-crawler reset

[219] Fix | Delete

*

[220] Fix | Delete

*/

[221] Fix | Delete

public function reset()

[222] Fix | Delete

{

[223] Fix | Delete

$this->__crawler->reset_pos();

[224] Fix | Delete

[225] Fix | Delete

$summary = Crawler2::get_summary();

[226] Fix | Delete

[227] Fix | Delete

WP_CLI::success('Reset position. Current crawler #' . ($summary['curr_crawler'] + 1) . ' [position] ' . $summary['last_pos'] . ' [total] ' . $summary['list_size']);

[228] Fix | Delete

}

[229] Fix | Delete

}

[230] Fix | Delete

[231] Fix | Delete