Tiny File Manager

Back Back Up Advanced Editor

<?php

class ActionScheduler_ListTable extends ActionScheduler_Abstract_ListTable
{
 protected $package = 'action-scheduler';
 protected $columns = array();
 protected $row_actions = array();
 protected $store;
 protected $logger;
 protected $runner;
 protected $bulk_actions = array();
 protected static $did_notification = false;
 private static $time_periods;
 public function __construct(ActionScheduler_Store $store, ActionScheduler_Logger $logger, ActionScheduler_QueueRunner $runner)
 {
 $this->store = $store;
 $this->logger = $logger;
 $this->runner = $runner;
 $this->table_header = __('Scheduled Actions', 'woocommerce');
 $this->bulk_actions = array('delete' => __('Delete', 'woocommerce'));
 $this->columns = array('hook' => __('Hook', 'woocommerce'), 'status' => __('Status', 'woocommerce'), 'args' => __('Arguments', 'woocommerce'), 'group' => __('Group', 'woocommerce'), 'recurrence' => __('Recurrence', 'woocommerce'), 'schedule' => __('Scheduled Date', 'woocommerce'), 'log_entries' => __('Log', 'woocommerce'));
 $this->sort_by = array('schedule', 'hook', 'group');
 $this->search_by = array('hook', 'args', 'claim_id');
 $request_status = $this->get_request_status();
 if (empty($request_status)) {
 $this->sort_by[] = 'status';
 } elseif (in_array($request_status, array('in-progress', 'failed'))) {
 $this->columns += array('claim_id' => __('Claim ID', 'woocommerce'));
 $this->sort_by[] = 'claim_id';
 }
 $this->row_actions = array('hook' => array('run' => array('name' => __('Run', 'woocommerce'), 'desc' => __('Process the action now as if it were run as part of a queue', 'woocommerce')), 'cancel' => array('name' => __('Cancel', 'woocommerce'), 'desc' => __('Cancel the action now to avoid it being run in future', 'woocommerce'), 'class' => 'cancel trash')));
 self::$time_periods = array(array('seconds' => YEAR_IN_SECONDS, 'names' => _n_noop('%s year', '%s years', 'woocommerce')), array('seconds' => MONTH_IN_SECONDS, 'names' => _n_noop('%s month', '%s months', 'woocommerce')), array('seconds' => WEEK_IN_SECONDS, 'names' => _n_noop('%s week', '%s weeks', 'woocommerce')), array('seconds' => DAY_IN_SECONDS, 'names' => _n_noop('%s day', '%s days', 'woocommerce')), array('seconds' => HOUR_IN_SECONDS, 'names' => _n_noop('%s hour', '%s hours', 'woocommerce')), array('seconds' => MINUTE_IN_SECONDS, 'names' => _n_noop('%s minute', '%s minutes', 'woocommerce')), array('seconds' => 1, 'names' => _n_noop('%s second', '%s seconds', 'woocommerce')));
 parent::__construct(array('singular' => 'action-scheduler', 'plural' => 'action-scheduler', 'ajax' => false));
 }
 private static function human_interval($interval, $periods_to_include = 2)
 {
 if ($interval <= 0) {
 return __('Now!', 'woocommerce');
 }
 $output = '';
 for ($time_period_index = 0, $periods_included = 0, $seconds_remaining = $interval; $time_period_index < count(self::$time_periods) && $seconds_remaining > 0 && $periods_included < $periods_to_include; $time_period_index++) {
 $periods_in_interval = floor($seconds_remaining / self::$time_periods[$time_period_index]['seconds']);
 if ($periods_in_interval > 0) {
 if (!empty($output)) {
 $output .= ' ';
 }
 $output .= sprintf(_n(self::$time_periods[$time_period_index]['names'][0], self::$time_periods[$time_period_index]['names'][1], $periods_in_interval, 'woocommerce'), $periods_in_interval);
 $seconds_remaining -= $periods_in_interval * self::$time_periods[$time_period_index]['seconds'];
 $periods_included++;
 }
 }
 return $output;
 }
 protected function get_recurrence($action)
 {
 $schedule = $action->get_schedule();
 if ($schedule->is_recurring()) {
 $recurrence = $schedule->get_recurrence();
 if (is_numeric($recurrence)) {
 return sprintf(__('Every %s', 'woocommerce'), self::human_interval($recurrence));
 } else {
 return $recurrence;
 }
 }
 return __('Non-repeating', 'woocommerce');
 }
 public function column_args(array $row)
 {
 if (empty($row['args'])) {
 return apply_filters('action_scheduler_list_table_column_args', '', $row);
 }
 $row_html = '<ul>';
 foreach ($row['args'] as $key => $value) {
 $row_html .= sprintf('<li><code>%s => %s</code></li>', esc_html(var_export($key, true)), esc_html(var_export($value, true)));
 }
 $row_html .= '</ul>';
 return apply_filters('action_scheduler_list_table_column_args', $row_html, $row);
 }
 public function column_log_entries(array $row)
 {
 $log_entries_html = '<ol>';
 $timezone = new DateTimezone('UTC');
 foreach ($row['log_entries'] as $log_entry) {
 $log_entries_html .= $this->get_log_entry_html($log_entry, $timezone);
 }
 $log_entries_html .= '</ol>';
 return $log_entries_html;
 }
 protected function get_log_entry_html(ActionScheduler_LogEntry $log_entry, DateTimezone $timezone)
 {
 $date = $log_entry->get_date();
 $date->setTimezone($timezone);
 return sprintf('<li>%s %s</li>', esc_html($date->format('Y-m-d H:i:s O')), esc_html($log_entry->get_message()));
 }
 protected function maybe_render_actions($row, $column_name)
 {
 if ('pending' === strtolower($row['status_name'])) {
 return parent::maybe_render_actions($row, $column_name);
 }
 return '';
 }
 public function display_admin_notices()
 {
 global $wpdb;
 if ((is_a($this->store, 'ActionScheduler_HybridStore') || is_a($this->store, 'ActionScheduler_DBStore')) && apply_filters('action_scheduler_enable_recreate_data_store', true)) {
 $table_list = array('actionscheduler_actions', 'actionscheduler_logs', 'actionscheduler_groups', 'actionscheduler_claims');
 $found_tables = $wpdb->get_col("SHOW TABLES LIKE '{$wpdb->prefix}actionscheduler%'");
 foreach ($table_list as $table_name) {
 if (!in_array($wpdb->prefix . $table_name, $found_tables)) {
 $this->admin_notices[] = array('class' => 'error', 'message' => __('It appears one or more database tables were missing. Attempting to re-create the missing table(s).', 'woocommerce'));
 $this->recreate_tables();
 parent::display_admin_notices();
 return;
 }
 }
 }
 if ($this->runner->has_maximum_concurrent_batches()) {
 $claim_count = $this->store->get_claim_count();
 $this->admin_notices[] = array('class' => 'updated', 'message' => sprintf(_n('Maximum simultaneous queues already in progress (%s queue). No additional queues will begin processing until the current queues are complete.', 'Maximum simultaneous queues already in progress (%s queues). No additional queues will begin processing until the current queues are complete.', $claim_count, 'woocommerce'), $claim_count));
 } elseif ($this->store->has_pending_actions_due()) {
 $async_request_lock_expiration = ActionScheduler::lock()->get_expiration('async-request-runner');
 if (false === $async_request_lock_expiration || $async_request_lock_expiration < time()) {
 $in_progress_url = add_query_arg('status', 'in-progress', remove_query_arg('status'));
 $async_request_message = sprintf(__('A new queue has begun processing. <a href="%s">View actions in-progress &raquo;</a>', 'woocommerce'), esc_url($in_progress_url));
 } else {
 $async_request_message = sprintf(__('The next queue will begin processing in approximately %d seconds.', 'woocommerce'), $async_request_lock_expiration - time());
 }
 $this->admin_notices[] = array('class' => 'notice notice-info', 'message' => $async_request_message);
 }
 $notification = get_transient('action_scheduler_admin_notice');
 if (is_array($notification)) {
 delete_transient('action_scheduler_admin_notice');
 $action = $this->store->fetch_action($notification['action_id']);
 $action_hook_html = '<code>' . $action->get_hook() . '</code>';
 if (1 == $notification['success']) {
 $class = 'updated';
 switch ($notification['row_action_type']) {
 case 'run':
 $action_message_html = sprintf(__('Successfully executed action: %s', 'woocommerce'), $action_hook_html);
 break;
 case 'cancel':
 $action_message_html = sprintf(__('Successfully canceled action: %s', 'woocommerce'), $action_hook_html);
 break;
 default:
 $action_message_html = sprintf(__('Successfully processed change for action: %s', 'woocommerce'), $action_hook_html);
 break;
 }
 } else {
 $class = 'error';
 $action_message_html = sprintf(__('Could not process change for action: "%1$s" (ID: %2$d). Error: %3$s', 'woocommerce'), $action_hook_html, esc_html($notification['action_id']), esc_html($notification['error_message']));
 }
 $action_message_html = apply_filters('action_scheduler_admin_notice_html', $action_message_html, $action, $notification);
 $this->admin_notices[] = array('class' => $class, 'message' => $action_message_html);
 }
 parent::display_admin_notices();
 }
 public function column_schedule($row)
 {
 return $this->get_schedule_display_string($row['schedule']);
 }
 protected function get_schedule_display_string(ActionScheduler_Schedule $schedule)
 {
 $schedule_display_string = '';
 if (!$schedule->get_date()) {
 return '0000-00-00 00:00:00';
 }
 $next_timestamp = $schedule->get_date()->getTimestamp();
 $schedule_display_string .= $schedule->get_date()->format('Y-m-d H:i:s O');
 $schedule_display_string .= ' ';
 if (gmdate('U') > $next_timestamp) {
 $schedule_display_string .= sprintf(__(' (%s ago)', 'woocommerce'), self::human_interval(gmdate('U') - $next_timestamp));
 } else {
 $schedule_display_string .= sprintf(__(' (%s)', 'woocommerce'), self::human_interval($next_timestamp - gmdate('U')));
 }
 return $schedule_display_string;
 }
 protected function bulk_delete(array $ids, $ids_sql)
 {
 foreach ($ids as $id) {
 $this->store->delete_action($id);
 }
 }
 protected function row_action_cancel($action_id)
 {
 $this->process_row_action($action_id, 'cancel');
 }
 protected function row_action_run($action_id)
 {
 $this->process_row_action($action_id, 'run');
 }
 protected function recreate_tables()
 {
 if (is_a($this->store, 'ActionScheduler_HybridStore')) {
 $store = $this->store;
 } else {
 $store = new ActionScheduler_HybridStore();
 }
 add_action('action_scheduler/created_table', array($store, 'set_autoincrement'), 10, 2);
 $store_schema = new ActionScheduler_StoreSchema();
 $logger_schema = new ActionScheduler_LoggerSchema();
 $store_schema->register_tables(true);
 $logger_schema->register_tables(true);
 remove_action('action_scheduler/created_table', array($store, 'set_autoincrement'), 10);
 }
 protected function process_row_action($action_id, $row_action_type)
 {
 try {
 switch ($row_action_type) {
 case 'run':
 $this->runner->process_action($action_id, 'Admin List Table');
 break;
 case 'cancel':
 $this->store->cancel_action($action_id);
 break;
 }
 $success = 1;
 $error_message = '';
 } catch (Exception $e) {
 $success = 0;
 $error_message = $e->getMessage();
 }
 set_transient('action_scheduler_admin_notice', compact('action_id', 'success', 'error_message', 'row_action_type'), 30);
 }
 public function prepare_items()
 {
 $this->prepare_column_headers();
 $per_page = $this->get_items_per_page($this->package . '_items_per_page', $this->items_per_page);
 $query = array('per_page' => $per_page, 'offset' => $this->get_items_offset(), 'status' => $this->get_request_status(), 'orderby' => $this->get_request_orderby(), 'order' => $this->get_request_order(), 'search' => $this->get_request_search_query());
 $this->items = array();
 $total_items = $this->store->query_actions($query, 'count');
 $status_labels = $this->store->get_status_labels();
 foreach ($this->store->query_actions($query) as $action_id) {
 try {
 $action = $this->store->fetch_action($action_id);
 } catch (Exception $e) {
 continue;
 }
 if (is_a($action, 'ActionScheduler_NullAction')) {
 continue;
 }
 $this->items[$action_id] = array('ID' => $action_id, 'hook' => $action->get_hook(), 'status_name' => $this->store->get_status($action_id), 'status' => $status_labels[$this->store->get_status($action_id)], 'args' => $action->get_args(), 'group' => $action->get_group(), 'log_entries' => $this->logger->get_logs($action_id), 'claim_id' => $this->store->get_claim_id($action_id), 'recurrence' => $this->get_recurrence($action), 'schedule' => $action->get_schedule());
 }
 $this->set_pagination_args(array('total_items' => $total_items, 'per_page' => $per_page, 'total_pages' => ceil($total_items / $per_page)));
 }
 protected function display_filter_by_status()
 {
 $this->status_counts = $this->store->action_counts();
 parent::display_filter_by_status();
 }
 protected function get_search_box_button_text()
 {
 return __('Search hook, args and claim ID', 'woocommerce');
 }
}