File "ActionScheduler_Store.php"

Full path: /home/kosmetik/public_html/wp-content/plugins/woocommerce/packages/action-scheduler/classes/abstracts/ActionScheduler_Store.php
File size: 6.32 B
MIME-type: text/x-php
Charset: utf-8

Download   Open   Edit   Advanced Editor   Back

<?php

abstract class ActionScheduler_Store extends ActionScheduler_Store_Deprecated
{
    const STATUS_COMPLETE = 'complete';
    const STATUS_PENDING = 'pending';
    const STATUS_RUNNING = 'in-progress';
    const STATUS_FAILED = 'failed';
    const STATUS_CANCELED = 'canceled';
    const DEFAULT_CLASS = 'ActionScheduler_wpPostStore';
    private static $store = NULL;
    protected static $max_args_length = 191;
    public abstract function save_action(ActionScheduler_Action $action, DateTime $scheduled_date = NULL);
    public abstract function fetch_action($action_id);
    public function find_action($hook, $params = array())
    {
        $params = wp_parse_args($params, array('args' => null, 'status' => self::STATUS_PENDING, 'group' => ''));
        $params['hook'] = $hook;
        $params['orderby'] = 'date';
        $params['per_page'] = 1;
        if (!empty($params['status'])) {
            if (self::STATUS_PENDING === $params['status']) {
                $params['order'] = 'ASC';
            } else {
                $params['order'] = 'DESC';
            }
        }
        $results = $this->query_actions($params);
        return empty($results) ? null : $results[0];
    }
    public abstract function query_actions($query = array(), $query_type = 'select');
    public function query_action($query)
    {
        $query['per_page'] = 1;
        $query['offset'] = 0;
        $results = $this->query_actions($query);
        if (empty($results)) {
            return null;
        } else {
            return (int) $results[0];
        }
    }
    public abstract function action_counts();
    public abstract function cancel_action($action_id);
    public abstract function delete_action($action_id);
    public abstract function get_date($action_id);
    public abstract function stake_claim($max_actions = 10, DateTime $before_date = null, $hooks = array(), $group = '');
    public abstract function get_claim_count();
    public abstract function release_claim(ActionScheduler_ActionClaim $claim);
    public abstract function unclaim_action($action_id);
    public abstract function mark_failure($action_id);
    public abstract function log_execution($action_id);
    public abstract function mark_complete($action_id);
    public abstract function get_status($action_id);
    public abstract function get_claim_id($action_id);
    public abstract function find_actions_by_claim_id($claim_id);
    protected function validate_sql_comparator($comparison_operator)
    {
        if (in_array($comparison_operator, array('!=', '>', '>=', '<', '<=', '='))) {
            return $comparison_operator;
        }
        return '=';
    }
    protected function get_scheduled_date_string(ActionScheduler_Action $action, DateTime $scheduled_date = NULL)
    {
        $next = null === $scheduled_date ? $action->get_schedule()->get_date() : $scheduled_date;
        if (!$next) {
            return '0000-00-00 00:00:00';
        }
        $next->setTimezone(new DateTimeZone('UTC'));
        return $next->format('Y-m-d H:i:s');
    }
    protected function get_scheduled_date_string_local(ActionScheduler_Action $action, DateTime $scheduled_date = NULL)
    {
        $next = null === $scheduled_date ? $action->get_schedule()->get_date() : $scheduled_date;
        if (!$next) {
            return '0000-00-00 00:00:00';
        }
        ActionScheduler_TimezoneHelper::set_local_timezone($next);
        return $next->format('Y-m-d H:i:s');
    }
    protected function validate_args($args, $action_id)
    {
        if (!is_array($args)) {
            throw ActionScheduler_InvalidActionException::from_decoding_args($action_id);
        }
        if (function_exists('json_last_error') && JSON_ERROR_NONE !== json_last_error()) {
            throw ActionScheduler_InvalidActionException::from_decoding_args($action_id, $args);
        }
    }
    protected function validate_schedule($schedule, $action_id)
    {
        if (empty($schedule) || !is_a($schedule, 'ActionScheduler_Schedule')) {
            throw ActionScheduler_InvalidActionException::from_schedule($action_id, $schedule);
        }
    }
    protected function validate_action(ActionScheduler_Action $action)
    {
        if (strlen(json_encode($action->get_args())) > static::$max_args_length) {
            throw new InvalidArgumentException(sprintf(__('ActionScheduler_Action::$args too long. To ensure the args column can be indexed, action args should not be more than %d characters when encoded as JSON.', 'woocommerce'), static::$max_args_length));
        }
    }
    public function cancel_actions_by_hook($hook)
    {
        $action_ids = true;
        while (!empty($action_ids)) {
            $action_ids = $this->query_actions(array('hook' => $hook, 'status' => self::STATUS_PENDING, 'per_page' => 1000, 'orderby' => 'action_id'));
            $this->bulk_cancel_actions($action_ids);
        }
    }
    public function cancel_actions_by_group($group)
    {
        $action_ids = true;
        while (!empty($action_ids)) {
            $action_ids = $this->query_actions(array('group' => $group, 'status' => self::STATUS_PENDING, 'per_page' => 1000, 'orderby' => 'action_id'));
            $this->bulk_cancel_actions($action_ids);
        }
    }
    private function bulk_cancel_actions($action_ids)
    {
        foreach ($action_ids as $action_id) {
            $this->cancel_action($action_id);
        }
        do_action('action_scheduler_bulk_cancel_actions', $action_ids);
    }
    public function get_status_labels()
    {
        return array(self::STATUS_COMPLETE => __('Complete', 'woocommerce'), self::STATUS_PENDING => __('Pending', 'woocommerce'), self::STATUS_RUNNING => __('In-progress', 'woocommerce'), self::STATUS_FAILED => __('Failed', 'woocommerce'), self::STATUS_CANCELED => __('Canceled', 'woocommerce'));
    }
    public function has_pending_actions_due()
    {
        $pending_actions = $this->query_actions(array('date' => as_get_datetime_object(), 'status' => ActionScheduler_Store::STATUS_PENDING, 'orderby' => 'none'));
        return !empty($pending_actions);
    }
    public function init()
    {
    }
    public function mark_migrated($action_id)
    {
    }
    public static function instance()
    {
        if (empty(self::$store)) {
            $class = apply_filters('action_scheduler_store_class', self::DEFAULT_CLASS);
            self::$store = new $class();
        }
        return self::$store;
    }
}