mirror of
https://ghproxy.net/https://github.com/boldthemes/wp-juggler-server.git
synced 2026-07-27 12:57:21 +08:00
569 lines
14 KiB
PHP
569 lines
14 KiB
PHP
<?php
|
|
|
|
/**
|
|
* AJAX-specific functionality for the plugin.
|
|
*
|
|
* @link https://wpjuggler.com
|
|
* @since 1.0.0
|
|
*
|
|
* @package WP_Juggler_Server
|
|
* @subpackage WP_Juggler_Server/includes
|
|
*/
|
|
|
|
// Prevent direct access.
|
|
if (! defined('WPJS_PATH')) exit;
|
|
|
|
class WPJS_Cron
|
|
{
|
|
|
|
/**
|
|
* The ID of this plugin.
|
|
*
|
|
* @since 1.0.0
|
|
* @access private
|
|
* @var string $wp_juggler_server The ID of this plugin.
|
|
*/
|
|
private $wp_juggler_server;
|
|
|
|
/**
|
|
* The version of this plugin.
|
|
*
|
|
* @since 1.0.0
|
|
* @access private
|
|
* @var string $version The current version of this plugin.
|
|
*/
|
|
private $version;
|
|
|
|
private $plugin_name;
|
|
|
|
private $bg_process;
|
|
|
|
/**
|
|
* Initialize the class and set its properties.
|
|
*
|
|
* @since 1.0.0
|
|
* @var string $wp_juggler_server The name of this plugin.
|
|
* @var string $version The version of this plugin.
|
|
*/
|
|
public function __construct($wp_juggler_server, $version)
|
|
{
|
|
$this->wp_juggler_server = $wp_juggler_server;
|
|
$this->version = $version;
|
|
$this->plugin_name = 'wpjs';
|
|
$this->bg_process = new WPJS_Background_Process();
|
|
}
|
|
|
|
public function wpjs_init_scheduler()
|
|
{
|
|
add_filter('cron_schedules', [$this, 'wpjs_add_schedules']);
|
|
|
|
add_action('wpjs_check_client_api', [$this, 'check_client_api']);
|
|
add_action('wpjs_check_health_api', [$this, 'check_all_health_api']);
|
|
add_action('wpjs_check_debug_api', [$this, 'check_all_debug_api']);
|
|
add_action('wpjs_check_core_checksum_api', [$this, 'check_all_core_checksum_api']);
|
|
add_action('wpjs_check_plugins_api', [$this, 'check_all_plugins_api']);
|
|
add_action('wpjs_check_plugins_checksum_api', [$this, 'check_all_plugins_checksum_api']);
|
|
add_action('wpjs_check_notices_api', [$this, 'check_all_notices_api']);
|
|
|
|
|
|
// Uptime scheduler
|
|
|
|
$wpjs_uptime_cron_interval = get_option('wpjs_uptime_cron_interval');
|
|
$wpjs_uptime_cron_interval_chk = $wpjs_uptime_cron_interval ? esc_attr($wpjs_uptime_cron_interval) : 'wpjs_5min';
|
|
|
|
$this->unschedule_specific_cron_events('wpjs_check_client_api', $wpjs_uptime_cron_interval_chk);
|
|
|
|
if (!wp_next_scheduled('wpjs_check_client_api')) {
|
|
wp_schedule_event(time(), $wpjs_uptime_cron_interval_chk, 'wpjs_check_client_api');
|
|
}
|
|
|
|
// Health scheduler
|
|
|
|
$wpjs_health_cron_interval = get_option('wpjs_health_cron_interval');
|
|
$wpjs_health_cron_interval_chk = $wpjs_health_cron_interval ? esc_attr($wpjs_health_cron_interval) : 'wpjs_daily';
|
|
|
|
$this->unschedule_specific_cron_events('wpjs_check_health_api', $wpjs_health_cron_interval_chk);
|
|
|
|
if (!wp_next_scheduled('wpjs_check_health_api')) {
|
|
wp_schedule_event(time(), $wpjs_health_cron_interval_chk, 'wpjs_check_health_api');
|
|
}
|
|
|
|
// Debug scheduler
|
|
|
|
$wpjs_debug_cron_interval = get_option('wpjs_debug_cron_interval');
|
|
$wpjs_debug_cron_interval_chk = $wpjs_debug_cron_interval ? esc_attr($wpjs_debug_cron_interval) : 'wpjs_daily';
|
|
|
|
$this->unschedule_specific_cron_events('wpjs_check_debug_api', $wpjs_debug_cron_interval_chk);
|
|
|
|
if (!wp_next_scheduled('wpjs_check_debug_api')) {
|
|
wp_schedule_event(time(), $wpjs_debug_cron_interval_chk, 'wpjs_check_debug_api');
|
|
}
|
|
|
|
// Core checksum
|
|
|
|
$wpjs_core_checksum_cron_interval = get_option('wpjs_core_checksum_cron_interval');
|
|
$wpjs_core_checksum_cron_interval_chk = $wpjs_core_checksum_cron_interval ? esc_attr($wpjs_core_checksum_cron_interval) : 'wpjs_daily';
|
|
|
|
$this->unschedule_specific_cron_events('wpjs_check_core_checksum_api', $wpjs_core_checksum_cron_interval_chk);
|
|
|
|
if (!wp_next_scheduled('wpjs_check_core_checksum_api')) {
|
|
wp_schedule_event(time(), $wpjs_core_checksum_cron_interval_chk, 'wpjs_check_core_checksum_api');
|
|
}
|
|
|
|
// Plugins scheduler
|
|
|
|
$wpjs_plugins_cron_interval = get_option('wpjs_plugins_cron_interval');
|
|
$wpjs_plugins_cron_interval_chk = $wpjs_plugins_cron_interval ? esc_attr($wpjs_plugins_cron_interval) : 'wpjs_daily';
|
|
|
|
$this->unschedule_specific_cron_events('wpjs_check_plugins_api', $wpjs_plugins_cron_interval_chk);
|
|
|
|
if (!wp_next_scheduled('wpjs_check_plugins_api')) {
|
|
wp_schedule_event(time(), $wpjs_plugins_cron_interval_chk, 'wpjs_check_plugins_api');
|
|
}
|
|
|
|
// Plugins checksum
|
|
|
|
$wpjs_plugins_checksum_cron_interval = get_option('wpjs_plugins_checksum_cron_interval');
|
|
$wpjs_plugins_checksum_cron_interval_chk = $wpjs_plugins_checksum_cron_interval ? esc_attr($wpjs_plugins_checksum_cron_interval) : 'wpjs_daily';
|
|
|
|
$this->unschedule_specific_cron_events('wpjs_check_plugins_checksum_api', $wpjs_plugins_checksum_cron_interval_chk);
|
|
|
|
if (!wp_next_scheduled('wpjs_check_plugins_checksum_api')) {
|
|
wp_schedule_event(time(), $wpjs_plugins_checksum_cron_interval_chk, 'wpjs_check_plugins_checksum_api');
|
|
}
|
|
|
|
// Notices scheduler
|
|
|
|
$wpjs_notices_cron_interval = get_option('wpjs_notices_cron_interval');
|
|
$wpjs_notices_cron_interval_chk = $wpjs_notices_cron_interval ? esc_attr($wpjs_notices_cron_interval) : 'wpjs_daily';
|
|
|
|
$this->unschedule_specific_cron_events('wpjs_check_notices_api', $wpjs_notices_cron_interval_chk);
|
|
|
|
if (!wp_next_scheduled('wpjs_check_notices_api')) {
|
|
wp_schedule_event(time(), $wpjs_notices_cron_interval_chk, 'wpjs_check_notices_api');
|
|
}
|
|
|
|
|
|
}
|
|
|
|
private function unschedule_specific_cron_events($hook_name, $interval)
|
|
{
|
|
$crons = _get_cron_array();
|
|
if (empty($crons)) {
|
|
return;
|
|
}
|
|
|
|
$timestamp = time();
|
|
|
|
foreach ($crons as $time => $cron) {
|
|
if (isset($cron[$hook_name]) && is_array($cron[$hook_name])) {
|
|
foreach ($cron[$hook_name] as $hook => $event_data) {
|
|
if (isset($event_data['schedule']) && $event_data['schedule'] !== $interval) {
|
|
wp_unschedule_event($time, $hook_name, $event_data['args']);
|
|
}
|
|
}
|
|
}
|
|
}
|
|
}
|
|
|
|
public function wpjs_add_schedules($schedules)
|
|
{
|
|
if (!isset($schedules["wpjs_5min"])) {
|
|
$schedules["wpjs_5min"] = array(
|
|
'interval' => 5 * 60,
|
|
'display' => __('Once every 5 minutes')
|
|
);
|
|
}
|
|
if (!isset($schedules["wpjs_10min"])) {
|
|
$schedules["wpjs_10min"] = array(
|
|
'interval' => 10 * 60,
|
|
'display' => __('Once every 10 minutes')
|
|
);
|
|
}
|
|
if (!isset($schedules["wpjs_30min"])) {
|
|
$schedules["wpjs_30min"] = array(
|
|
'interval' => 30 * 60,
|
|
'display' => __('Once every 30 minutes')
|
|
);
|
|
}
|
|
if (!isset($schedules["wpjs_hourly"])) {
|
|
$schedules["wpjs_hourly"] = array(
|
|
'interval' => 60 * 60,
|
|
'display' => __('Once Hourly')
|
|
);
|
|
}
|
|
if (!isset($schedules["wpjs_twicedaily"])) {
|
|
$schedules["wpjs_twicedaily"] = array(
|
|
'interval' => 12 * 60 * 60,
|
|
'display' => __('Twice Daily')
|
|
);
|
|
}
|
|
if (!isset($schedules["wpjs_daily"])) {
|
|
$schedules["wpjs_daily"] = array(
|
|
'interval' => 24 * 60 * 60,
|
|
'display' => __('Once Daily')
|
|
);
|
|
}
|
|
if (!isset($schedules["wpjs_weekly"])) {
|
|
$schedules["wpjs_weekly"] = array(
|
|
'interval' => 7 * 24 * 60 * 60,
|
|
'display' => __('Once Weekly')
|
|
);
|
|
}
|
|
return $schedules;
|
|
}
|
|
|
|
public function check_all_health_api() {
|
|
|
|
$args = array(
|
|
'post_type' => 'wpjugglersites',
|
|
'post_status' => 'publish',
|
|
'meta_key' => 'wp_juggler_site_activation',
|
|
'meta_value' => 'on',
|
|
'fields' => 'ids',
|
|
'numberposts' => -1
|
|
);
|
|
|
|
$site_ids = get_posts($args);
|
|
|
|
foreach ($site_ids as $site_id) {
|
|
|
|
$this->bg_process->push_to_queue(array(
|
|
'siteId' => $site_id,
|
|
'endpoint' => 'initiateTask',
|
|
'data' => [
|
|
'taskType' => 'checkHealth',
|
|
]
|
|
));
|
|
|
|
}
|
|
|
|
$this->bg_process->save()->dispatch();
|
|
}
|
|
|
|
public function check_all_debug_api() {
|
|
|
|
$args = array(
|
|
'post_type' => 'wpjugglersites',
|
|
'post_status' => 'publish',
|
|
'meta_key' => 'wp_juggler_site_activation',
|
|
'meta_value' => 'on',
|
|
'fields' => 'ids',
|
|
'numberposts' => -1
|
|
);
|
|
|
|
$site_ids = get_posts($args);
|
|
|
|
foreach ($site_ids as $site_id) {
|
|
|
|
$this->bg_process->push_to_queue(array(
|
|
'siteId' => $site_id,
|
|
'endpoint' => 'initiateTask',
|
|
'data' => [
|
|
'taskType' => 'checkDebug',
|
|
]
|
|
));
|
|
|
|
}
|
|
|
|
$this->bg_process->save()->dispatch();
|
|
}
|
|
|
|
public function check_all_core_checksum_api() {
|
|
|
|
$args = array(
|
|
'post_type' => 'wpjugglersites',
|
|
'post_status' => 'publish',
|
|
'meta_key' => 'wp_juggler_site_activation',
|
|
'meta_value' => 'on',
|
|
'fields' => 'ids',
|
|
'numberposts' => -1
|
|
);
|
|
|
|
$site_ids = get_posts($args);
|
|
|
|
foreach ($site_ids as $site_id) {
|
|
|
|
$this->bg_process->push_to_queue(array(
|
|
'siteId' => $site_id,
|
|
'endpoint' => 'initiateTask',
|
|
'data' => [
|
|
'taskType' => 'checkCoreChecksum',
|
|
]
|
|
));
|
|
|
|
}
|
|
|
|
$this->bg_process->save()->dispatch();
|
|
}
|
|
|
|
public function check_all_plugins_api() {
|
|
|
|
$args = array(
|
|
'post_type' => 'wpjugglersites',
|
|
'post_status' => 'publish',
|
|
'meta_key' => 'wp_juggler_site_activation',
|
|
'meta_value' => 'on',
|
|
'fields' => 'ids',
|
|
'numberposts' => -1
|
|
);
|
|
|
|
$site_ids = get_posts($args);
|
|
|
|
foreach ($site_ids as $site_id) {
|
|
|
|
$this->bg_process->push_to_queue(array(
|
|
'siteId' => $site_id,
|
|
'endpoint' => 'initiateTask',
|
|
'data' => [
|
|
'taskType' => 'checkPlugins',
|
|
]
|
|
));
|
|
|
|
}
|
|
|
|
$this->bg_process->save()->dispatch();
|
|
}
|
|
|
|
public function check_all_plugins_checksum_api() {
|
|
|
|
$args = array(
|
|
'post_type' => 'wpjugglersites',
|
|
'post_status' => 'publish',
|
|
'meta_key' => 'wp_juggler_site_activation',
|
|
'meta_value' => 'on',
|
|
'fields' => 'ids',
|
|
'numberposts' => -1
|
|
);
|
|
|
|
$site_ids = get_posts($args);
|
|
|
|
foreach ($site_ids as $site_id) {
|
|
|
|
$this->bg_process->push_to_queue(array(
|
|
'siteId' => $site_id,
|
|
'endpoint' => 'initiateTask',
|
|
'data' => [
|
|
'taskType' => 'checkPluginChecksum',
|
|
]
|
|
));
|
|
|
|
}
|
|
|
|
$this->bg_process->save()->dispatch();
|
|
}
|
|
|
|
public function check_all_notices_api() {
|
|
|
|
$args = array(
|
|
'post_type' => 'wpjugglersites',
|
|
'post_status' => 'publish',
|
|
'meta_key' => 'wp_juggler_site_activation',
|
|
'meta_value' => 'on',
|
|
'fields' => 'ids',
|
|
'numberposts' => -1
|
|
);
|
|
|
|
$site_ids = get_posts($args);
|
|
|
|
foreach ($site_ids as $site_id) {
|
|
|
|
$this->bg_process->push_to_queue(array(
|
|
'siteId' => $site_id,
|
|
'endpoint' => 'initiateTask',
|
|
'data' => [
|
|
'taskType' => 'checkNotices',
|
|
]
|
|
));
|
|
|
|
}
|
|
|
|
$this->bg_process->save()->dispatch();
|
|
}
|
|
|
|
public function check_client_api()
|
|
{
|
|
|
|
$args = array(
|
|
'post_type' => 'wpjugglersites',
|
|
'post_status' => 'publish',
|
|
'meta_key' => 'wp_juggler_site_activation',
|
|
'meta_value' => 'on',
|
|
'fields' => 'ids',
|
|
'numberposts' => -1
|
|
);
|
|
|
|
$site_ids = get_posts($args);
|
|
|
|
foreach ($site_ids as $site_id) {
|
|
|
|
$this->bg_process->push_to_queue(array(
|
|
'siteId' => $site_id,
|
|
'endpoint' => 'confirmClientApi',
|
|
'data' => []
|
|
));
|
|
|
|
$data = [
|
|
'frontend_ping_url' => get_post_meta($site_id, 'wp_juggler_frontend_ping_url', true),
|
|
'frontend_ping_string' => get_post_meta($site_id, 'wp_juggler_frontend_ping_string', true)
|
|
];
|
|
|
|
$this->bg_process->push_to_queue(array(
|
|
'siteId' => $site_id,
|
|
'endpoint' => 'confirmFrontEnd',
|
|
'data' => $data
|
|
));
|
|
}
|
|
|
|
$this->bg_process->save()->dispatch();
|
|
}
|
|
}
|
|
|
|
class WPJS_Cron_Log
|
|
{
|
|
/**
|
|
* The ID of this plugin.
|
|
*
|
|
* @since 1.0.0
|
|
* @access private
|
|
* @var string $wp_juggler_server The ID of this plugin.
|
|
*/
|
|
private $wp_juggler_server;
|
|
|
|
/**
|
|
* The version of this plugin.
|
|
*
|
|
* @since 1.0.0
|
|
* @access private
|
|
* @var string $version The current version of this plugin.
|
|
*/
|
|
private $version;
|
|
|
|
private $plugin_name;
|
|
|
|
/**
|
|
* Initialize the class and set its properties.
|
|
*
|
|
* @since 1.0.0
|
|
* @var string $wp_juggler_server The name of this plugin.
|
|
* @var string $version The version of this plugin.
|
|
*/
|
|
public function __construct($wp_juggler_server, $version)
|
|
{
|
|
$this->wp_juggler_server = $wp_juggler_server;
|
|
$this->version = $version;
|
|
$this->plugin_name = 'wpjs';
|
|
}
|
|
|
|
static function create_database_tables()
|
|
{
|
|
global $wpdb;
|
|
|
|
$table_name = $wpdb->prefix . 'wpjs_cron_log';
|
|
|
|
$charset_collate = $wpdb->get_charset_collate();
|
|
|
|
$sql = "CREATE TABLE $table_name (
|
|
ID bigint(20) unsigned NOT NULL AUTO_INCREMENT,
|
|
wpjugglersites_id varchar(256) COLLATE utf8mb4_unicode_520_ci DEFAULT NULL,
|
|
log_type varchar(256) COLLATE utf8mb4_unicode_520_ci DEFAULT NULL,
|
|
log_result varchar(256) COLLATE utf8mb4_unicode_520_ci DEFAULT NULL,
|
|
log_value varchar(256) COLLATE utf8mb4_unicode_520_ci DEFAULT NULL,
|
|
log_data json DEFAULT NULL,
|
|
log_time timestamp NULL DEFAULT NULL,
|
|
PRIMARY KEY (ID),
|
|
KEY wpjugglersites_id (wpjugglersites_id),
|
|
KEY log_type (log_type),
|
|
KEY log_result (log_result),
|
|
KEY log_value (log_value),
|
|
KEY log_time (log_time)
|
|
) ENGINE=InnoDB DEFAULT CHARSET=utf8mb4 $charset_collate;";
|
|
|
|
require_once ABSPATH . 'wp-admin/includes/upgrade.php';
|
|
dbDelta($sql);
|
|
|
|
//$the_default_timestamp_query = "ALTER TABLE $table_name MODIFY COLUMN log_time timestamp NOT NULL DEFAULT CURRENT_TIMESTAMP;";
|
|
//$wpdb->query($the_default_timestamp_query);
|
|
}
|
|
|
|
static function insert_log($event)
|
|
{
|
|
if(!$event){
|
|
return;
|
|
}
|
|
global $wpdb;
|
|
|
|
$table_name = $wpdb->prefix . 'wpjs_cron_log';
|
|
|
|
if (array_key_exists('log_type', $event)) {
|
|
|
|
do_action("wpjs/cron_log/" . $event["log_type"], $event);
|
|
}
|
|
|
|
$event_fil = apply_filters("wpjs/cron_log/insert", $event);
|
|
|
|
if (array_key_exists('log_data', $event_fil)) {
|
|
$log_data = json_decode($event_fil["log_data"]);
|
|
if (json_last_error() !== JSON_ERROR_NONE) {
|
|
$log_data_array = array(
|
|
"data" => $event_fil["log_data"]
|
|
);
|
|
|
|
$log_data = json_encode($log_data_array);
|
|
$event_fil["log_data"] = $log_data;
|
|
|
|
}
|
|
}
|
|
|
|
$event_fil["log_time"] = current_time('mysql', true);
|
|
|
|
$wpdb->insert(
|
|
$table_name,
|
|
$event_fil
|
|
);
|
|
|
|
if ($wpdb->last_error !== '') :
|
|
//TODO
|
|
endif;
|
|
|
|
return $wpdb->insert_id;
|
|
}
|
|
|
|
static function update_log($event)
|
|
{
|
|
global $wpdb;
|
|
|
|
$table_name = $wpdb->prefix . 'wpjs_cron_log';
|
|
|
|
if (!isset($event['ID'])) {
|
|
return false;
|
|
}
|
|
|
|
$log_id = $event['ID'];
|
|
unset($event['ID']);
|
|
|
|
if (array_key_exists('log_data', $event)) {
|
|
$log_data = json_decode($event['log_data']);
|
|
if (json_last_error() !== JSON_ERROR_NONE) {
|
|
$log_data_array = array(
|
|
"data" => $event['log_data']
|
|
);
|
|
|
|
$log_data = json_encode($log_data_array);
|
|
$event['log_data'] = $log_data;
|
|
}
|
|
}
|
|
|
|
$result = $wpdb->update(
|
|
$table_name,
|
|
$event,
|
|
array('ID' => $log_id)
|
|
);
|
|
|
|
if ($wpdb->last_error !== '') :
|
|
//TODO
|
|
endif;
|
|
|
|
return $result !== false;
|
|
}
|
|
}
|
