@@ -19,7 +19,7 @@ discard block |
||
19 | 19 | */ |
20 | 20 | public static function instance() { |
21 | 21 | |
22 | - if ( empty( self::$admin_view ) ) { |
|
22 | + if (empty(self::$admin_view)) { |
|
23 | 23 | $class = apply_filters('action_scheduler_admin_view_class', 'ActionScheduler_AdminView'); |
24 | 24 | self::$admin_view = new $class(); |
25 | 25 | } |
@@ -31,22 +31,22 @@ discard block |
||
31 | 31 | * @codeCoverageIgnore |
32 | 32 | */ |
33 | 33 | public function init() { |
34 | - if ( is_admin() && ( ! defined( 'DOING_AJAX' ) || false == DOING_AJAX ) ) { |
|
34 | + if (is_admin() && (!defined('DOING_AJAX') || false == DOING_AJAX)) { |
|
35 | 35 | |
36 | - if ( class_exists( 'WooCommerce' ) ) { |
|
37 | - add_action( 'woocommerce_admin_status_content_action-scheduler', array( $this, 'render_admin_ui' ) ); |
|
38 | - add_action( 'woocommerce_system_status_report', array( $this, 'system_status_report' ) ); |
|
39 | - add_filter( 'woocommerce_admin_status_tabs', array( $this, 'register_system_status_tab' ) ); |
|
36 | + if (class_exists('WooCommerce')) { |
|
37 | + add_action('woocommerce_admin_status_content_action-scheduler', array($this, 'render_admin_ui')); |
|
38 | + add_action('woocommerce_system_status_report', array($this, 'system_status_report')); |
|
39 | + add_filter('woocommerce_admin_status_tabs', array($this, 'register_system_status_tab')); |
|
40 | 40 | } |
41 | 41 | |
42 | - add_action( 'admin_menu', array( $this, 'register_menu' ) ); |
|
42 | + add_action('admin_menu', array($this, 'register_menu')); |
|
43 | 43 | |
44 | - add_action( 'current_screen', array( $this, 'add_help_tabs' ) ); |
|
44 | + add_action('current_screen', array($this, 'add_help_tabs')); |
|
45 | 45 | } |
46 | 46 | } |
47 | 47 | |
48 | 48 | public function system_status_report() { |
49 | - $table = new ActionScheduler_wcSystemStatus( ActionScheduler::store() ); |
|
49 | + $table = new ActionScheduler_wcSystemStatus(ActionScheduler::store()); |
|
50 | 50 | $table->render(); |
51 | 51 | } |
52 | 52 | |
@@ -56,8 +56,8 @@ discard block |
||
56 | 56 | * @param array $tabs An associative array of tab key => label. |
57 | 57 | * @return array $tabs An associative array of tab key => label, including Action Scheduler's tabs |
58 | 58 | */ |
59 | - public function register_system_status_tab( array $tabs ) { |
|
60 | - $tabs['action-scheduler'] = __( 'Scheduled Actions', 'action-scheduler' ); |
|
59 | + public function register_system_status_tab(array $tabs) { |
|
60 | + $tabs['action-scheduler'] = __('Scheduled Actions', 'action-scheduler'); |
|
61 | 61 | |
62 | 62 | return $tabs; |
63 | 63 | } |
@@ -72,13 +72,13 @@ discard block |
||
72 | 72 | public function register_menu() { |
73 | 73 | $hook_suffix = add_submenu_page( |
74 | 74 | 'tools.php', |
75 | - __( 'Scheduled Actions', 'action-scheduler' ), |
|
76 | - __( 'Scheduled Actions', 'action-scheduler' ), |
|
75 | + __('Scheduled Actions', 'action-scheduler'), |
|
76 | + __('Scheduled Actions', 'action-scheduler'), |
|
77 | 77 | 'manage_options', |
78 | 78 | 'action-scheduler', |
79 | - array( $this, 'render_admin_ui' ) |
|
79 | + array($this, 'render_admin_ui') |
|
80 | 80 | ); |
81 | - add_action( 'load-' . $hook_suffix , array( $this, 'process_admin_ui' ) ); |
|
81 | + add_action('load-' . $hook_suffix, array($this, 'process_admin_ui')); |
|
82 | 82 | } |
83 | 83 | |
84 | 84 | /** |
@@ -102,8 +102,8 @@ discard block |
||
102 | 102 | * @return ActionScheduler_ListTable |
103 | 103 | */ |
104 | 104 | protected function get_list_table() { |
105 | - if ( null === $this->list_table ) { |
|
106 | - $this->list_table = new ActionScheduler_ListTable( ActionScheduler::store(), ActionScheduler::logger(), ActionScheduler::runner() ); |
|
105 | + if (null === $this->list_table) { |
|
106 | + $this->list_table = new ActionScheduler_ListTable(ActionScheduler::store(), ActionScheduler::logger(), ActionScheduler::runner()); |
|
107 | 107 | $this->list_table->process_actions(); |
108 | 108 | } |
109 | 109 | |
@@ -116,7 +116,7 @@ discard block |
||
116 | 116 | public function add_help_tabs() { |
117 | 117 | $screen = get_current_screen(); |
118 | 118 | |
119 | - if ( ! $screen || self::$screen_id != $screen->id ) { |
|
119 | + if (!$screen || self::$screen_id != $screen->id) { |
|
120 | 120 | return; |
121 | 121 | } |
122 | 122 | |
@@ -124,11 +124,11 @@ discard block |
||
124 | 124 | $screen->add_help_tab( |
125 | 125 | array( |
126 | 126 | 'id' => 'action_scheduler_about', |
127 | - 'title' => __( 'About', 'action-scheduler' ), |
|
127 | + 'title' => __('About', 'action-scheduler'), |
|
128 | 128 | 'content' => |
129 | - '<h2>' . sprintf( __( 'About Action Scheduler %s', 'action-scheduler' ), $as_version ) . '</h2>' . |
|
129 | + '<h2>' . sprintf(__('About Action Scheduler %s', 'action-scheduler'), $as_version) . '</h2>' . |
|
130 | 130 | '<p>' . |
131 | - __( 'Action Scheduler is a scalable, traceable job queue for background processing large sets of actions. Action Scheduler works by triggering an action hook to run at some time in the future. Scheduled actions can also be scheduled to run on a recurring schedule.', 'action-scheduler' ) . |
|
131 | + __('Action Scheduler is a scalable, traceable job queue for background processing large sets of actions. Action Scheduler works by triggering an action hook to run at some time in the future. Scheduled actions can also be scheduled to run on a recurring schedule.', 'action-scheduler') . |
|
132 | 132 | '</p>', |
133 | 133 | ) |
134 | 134 | ); |
@@ -136,17 +136,17 @@ discard block |
||
136 | 136 | $screen->add_help_tab( |
137 | 137 | array( |
138 | 138 | 'id' => 'action_scheduler_columns', |
139 | - 'title' => __( 'Columns', 'action-scheduler' ), |
|
139 | + 'title' => __('Columns', 'action-scheduler'), |
|
140 | 140 | 'content' => |
141 | - '<h2>' . __( 'Scheduled Action Columns', 'action-scheduler' ) . '</h2>' . |
|
141 | + '<h2>' . __('Scheduled Action Columns', 'action-scheduler') . '</h2>' . |
|
142 | 142 | '<ul>' . |
143 | - sprintf( '<li><strong>%1$s</strong>: %2$s</li>', __( 'Hook', 'action-scheduler' ), __( 'Name of the action hook that will be triggered.', 'action-scheduler' ) ) . |
|
144 | - sprintf( '<li><strong>%1$s</strong>: %2$s</li>', __( 'Status', 'action-scheduler' ), __( 'Action statuses are Pending, Complete, Canceled, Failed', 'action-scheduler' ) ) . |
|
145 | - sprintf( '<li><strong>%1$s</strong>: %2$s</li>', __( 'Arguments', 'action-scheduler' ), __( 'Optional data array passed to the action hook.', 'action-scheduler' ) ) . |
|
146 | - sprintf( '<li><strong>%1$s</strong>: %2$s</li>', __( 'Group', 'action-scheduler' ), __( 'Optional action group.', 'action-scheduler' ) ) . |
|
147 | - sprintf( '<li><strong>%1$s</strong>: %2$s</li>', __( 'Recurrence', 'action-scheduler' ), __( 'The action\'s schedule frequency.', 'action-scheduler' ) ) . |
|
148 | - sprintf( '<li><strong>%1$s</strong>: %2$s</li>', __( 'Scheduled', 'action-scheduler' ), __( 'The date/time the action is/was scheduled to run.', 'action-scheduler' ) ) . |
|
149 | - sprintf( '<li><strong>%1$s</strong>: %2$s</li>', __( 'Log', 'action-scheduler' ), __( 'Activity log for the action.', 'action-scheduler' ) ) . |
|
143 | + sprintf('<li><strong>%1$s</strong>: %2$s</li>', __('Hook', 'action-scheduler'), __('Name of the action hook that will be triggered.', 'action-scheduler')) . |
|
144 | + sprintf('<li><strong>%1$s</strong>: %2$s</li>', __('Status', 'action-scheduler'), __('Action statuses are Pending, Complete, Canceled, Failed', 'action-scheduler')) . |
|
145 | + sprintf('<li><strong>%1$s</strong>: %2$s</li>', __('Arguments', 'action-scheduler'), __('Optional data array passed to the action hook.', 'action-scheduler')) . |
|
146 | + sprintf('<li><strong>%1$s</strong>: %2$s</li>', __('Group', 'action-scheduler'), __('Optional action group.', 'action-scheduler')) . |
|
147 | + sprintf('<li><strong>%1$s</strong>: %2$s</li>', __('Recurrence', 'action-scheduler'), __('The action\'s schedule frequency.', 'action-scheduler')) . |
|
148 | + sprintf('<li><strong>%1$s</strong>: %2$s</li>', __('Scheduled', 'action-scheduler'), __('The date/time the action is/was scheduled to run.', 'action-scheduler')) . |
|
149 | + sprintf('<li><strong>%1$s</strong>: %2$s</li>', __('Log', 'action-scheduler'), __('Activity log for the action.', 'action-scheduler')) . |
|
150 | 150 | '</ul>', |
151 | 151 | ) |
152 | 152 | ); |
@@ -14,16 +14,16 @@ discard block |
||
14 | 14 | * |
15 | 15 | * @return ActionScheduler_Action An instance of the stored action |
16 | 16 | */ |
17 | - public function get_stored_action( $status, $hook, array $args = array(), ActionScheduler_Schedule $schedule = null, $group = '' ) { |
|
17 | + public function get_stored_action($status, $hook, array $args = array(), ActionScheduler_Schedule $schedule = null, $group = '') { |
|
18 | 18 | |
19 | - switch ( $status ) { |
|
19 | + switch ($status) { |
|
20 | 20 | case ActionScheduler_Store::STATUS_PENDING : |
21 | 21 | $action_class = 'ActionScheduler_Action'; |
22 | 22 | break; |
23 | 23 | case ActionScheduler_Store::STATUS_CANCELED : |
24 | 24 | $action_class = 'ActionScheduler_CanceledAction'; |
25 | - if ( ! is_null( $schedule ) && ! is_a( $schedule, 'ActionScheduler_CanceledSchedule' ) ) { |
|
26 | - $schedule = new ActionScheduler_CanceledSchedule( $schedule->get_date() ); |
|
25 | + if (!is_null($schedule) && !is_a($schedule, 'ActionScheduler_CanceledSchedule')) { |
|
26 | + $schedule = new ActionScheduler_CanceledSchedule($schedule->get_date()); |
|
27 | 27 | } |
28 | 28 | break; |
29 | 29 | default : |
@@ -31,9 +31,9 @@ discard block |
||
31 | 31 | break; |
32 | 32 | } |
33 | 33 | |
34 | - $action_class = apply_filters( 'action_scheduler_stored_action_class', $action_class, $status, $hook, $args, $schedule, $group ); |
|
34 | + $action_class = apply_filters('action_scheduler_stored_action_class', $action_class, $status, $hook, $args, $schedule, $group); |
|
35 | 35 | |
36 | - $action = new $action_class( $hook, $args, $schedule, $group ); |
|
36 | + $action = new $action_class($hook, $args, $schedule, $group); |
|
37 | 37 | |
38 | 38 | /** |
39 | 39 | * Allow 3rd party code to change the instantiated action for a given hook, args, schedule and group. |
@@ -44,7 +44,7 @@ discard block |
||
44 | 44 | * @param ActionScheduler_Schedule $schedule The instantiated action's schedule. |
45 | 45 | * @param string $group The instantiated action's group. |
46 | 46 | */ |
47 | - return apply_filters( 'action_scheduler_stored_action_instance', $action, $hook, $args, $schedule, $group ); |
|
47 | + return apply_filters('action_scheduler_stored_action_instance', $action, $hook, $args, $schedule, $group); |
|
48 | 48 | } |
49 | 49 | |
50 | 50 | /** |
@@ -63,10 +63,10 @@ discard block |
||
63 | 63 | * |
64 | 64 | * @return string The ID of the stored action |
65 | 65 | */ |
66 | - public function async( $hook, $args = array(), $group = '' ) { |
|
66 | + public function async($hook, $args = array(), $group = '') { |
|
67 | 67 | $schedule = new ActionScheduler_NullSchedule(); |
68 | - $action = new ActionScheduler_Action( $hook, $args, $schedule, $group ); |
|
69 | - return $this->store( $action ); |
|
68 | + $action = new ActionScheduler_Action($hook, $args, $schedule, $group); |
|
69 | + return $this->store($action); |
|
70 | 70 | } |
71 | 71 | |
72 | 72 | /** |
@@ -77,11 +77,11 @@ discard block |
||
77 | 77 | * |
78 | 78 | * @return string The ID of the stored action |
79 | 79 | */ |
80 | - public function single( $hook, $args = array(), $when = null, $group = '' ) { |
|
81 | - $date = as_get_datetime_object( $when ); |
|
82 | - $schedule = new ActionScheduler_SimpleSchedule( $date ); |
|
83 | - $action = new ActionScheduler_Action( $hook, $args, $schedule, $group ); |
|
84 | - return $this->store( $action ); |
|
80 | + public function single($hook, $args = array(), $when = null, $group = '') { |
|
81 | + $date = as_get_datetime_object($when); |
|
82 | + $schedule = new ActionScheduler_SimpleSchedule($date); |
|
83 | + $action = new ActionScheduler_Action($hook, $args, $schedule, $group); |
|
84 | + return $this->store($action); |
|
85 | 85 | } |
86 | 86 | |
87 | 87 | /** |
@@ -95,14 +95,14 @@ discard block |
||
95 | 95 | * |
96 | 96 | * @return string The ID of the stored action |
97 | 97 | */ |
98 | - public function recurring( $hook, $args = array(), $first = null, $interval = null, $group = '' ) { |
|
99 | - if ( empty($interval) ) { |
|
100 | - return $this->single( $hook, $args, $first, $group ); |
|
98 | + public function recurring($hook, $args = array(), $first = null, $interval = null, $group = '') { |
|
99 | + if (empty($interval)) { |
|
100 | + return $this->single($hook, $args, $first, $group); |
|
101 | 101 | } |
102 | - $date = as_get_datetime_object( $first ); |
|
103 | - $schedule = new ActionScheduler_IntervalSchedule( $date, $interval ); |
|
104 | - $action = new ActionScheduler_Action( $hook, $args, $schedule, $group ); |
|
105 | - return $this->store( $action ); |
|
102 | + $date = as_get_datetime_object($first); |
|
103 | + $schedule = new ActionScheduler_IntervalSchedule($date, $interval); |
|
104 | + $action = new ActionScheduler_Action($hook, $args, $schedule, $group); |
|
105 | + return $this->store($action); |
|
106 | 106 | } |
107 | 107 | |
108 | 108 | /** |
@@ -118,15 +118,15 @@ discard block |
||
118 | 118 | * |
119 | 119 | * @return string The ID of the stored action |
120 | 120 | */ |
121 | - public function cron( $hook, $args = array(), $base_timestamp = null, $schedule = null, $group = '' ) { |
|
122 | - if ( empty($schedule) ) { |
|
123 | - return $this->single( $hook, $args, $base_timestamp, $group ); |
|
121 | + public function cron($hook, $args = array(), $base_timestamp = null, $schedule = null, $group = '') { |
|
122 | + if (empty($schedule)) { |
|
123 | + return $this->single($hook, $args, $base_timestamp, $group); |
|
124 | 124 | } |
125 | - $date = as_get_datetime_object( $base_timestamp ); |
|
126 | - $cron = CronExpression::factory( $schedule ); |
|
127 | - $schedule = new ActionScheduler_CronSchedule( $date, $cron ); |
|
128 | - $action = new ActionScheduler_Action( $hook, $args, $schedule, $group ); |
|
129 | - return $this->store( $action ); |
|
125 | + $date = as_get_datetime_object($base_timestamp); |
|
126 | + $cron = CronExpression::factory($schedule); |
|
127 | + $schedule = new ActionScheduler_CronSchedule($date, $cron); |
|
128 | + $action = new ActionScheduler_Action($hook, $args, $schedule, $group); |
|
129 | + return $this->store($action); |
|
130 | 130 | } |
131 | 131 | |
132 | 132 | /** |
@@ -153,18 +153,18 @@ discard block |
||
153 | 153 | * @return string The ID of the stored action |
154 | 154 | * @throws InvalidArgumentException If $action is not a recurring action. |
155 | 155 | */ |
156 | - public function repeat( $action ) { |
|
156 | + public function repeat($action) { |
|
157 | 157 | $schedule = $action->get_schedule(); |
158 | - $next = $schedule->get_next( as_get_datetime_object() ); |
|
158 | + $next = $schedule->get_next(as_get_datetime_object()); |
|
159 | 159 | |
160 | - if ( is_null( $next ) || ! $schedule->is_recurring() ) { |
|
161 | - throw new InvalidArgumentException( __( 'Invalid action - must be a recurring action.', 'action-scheduler' ) ); |
|
160 | + if (is_null($next) || !$schedule->is_recurring()) { |
|
161 | + throw new InvalidArgumentException(__('Invalid action - must be a recurring action.', 'action-scheduler')); |
|
162 | 162 | } |
163 | 163 | |
164 | - $schedule_class = get_class( $schedule ); |
|
165 | - $new_schedule = new $schedule( $next, $schedule->get_recurrence(), $schedule->get_first_date() ); |
|
166 | - $new_action = new ActionScheduler_Action( $action->get_hook(), $action->get_args(), $new_schedule, $action->get_group() ); |
|
167 | - return $this->store( $new_action ); |
|
164 | + $schedule_class = get_class($schedule); |
|
165 | + $new_schedule = new $schedule($next, $schedule->get_recurrence(), $schedule->get_first_date()); |
|
166 | + $new_action = new ActionScheduler_Action($action->get_hook(), $action->get_args(), $new_schedule, $action->get_group()); |
|
167 | + return $this->store($new_action); |
|
168 | 168 | } |
169 | 169 | |
170 | 170 | /** |
@@ -172,8 +172,8 @@ discard block |
||
172 | 172 | * |
173 | 173 | * @return string The ID of the stored action |
174 | 174 | */ |
175 | - protected function store( ActionScheduler_Action $action ) { |
|
175 | + protected function store(ActionScheduler_Action $action) { |
|
176 | 176 | $store = ActionScheduler_Store::instance(); |
177 | - return $store->save_action( $action ); |
|
177 | + return $store->save_action($action); |
|
178 | 178 | } |
179 | 179 | } |
@@ -24,7 +24,7 @@ discard block |
||
24 | 24 | * |
25 | 25 | * @param ActionScheduler_Store $source_store Source store object. |
26 | 26 | */ |
27 | - public function __construct( Store $source_store ) { |
|
27 | + public function __construct(Store $source_store) { |
|
28 | 28 | $this->store = $source_store; |
29 | 29 | } |
30 | 30 | |
@@ -35,10 +35,10 @@ discard block |
||
35 | 35 | * |
36 | 36 | * @return int[] A list of action IDs |
37 | 37 | */ |
38 | - public function fetch( $count = 10 ) { |
|
39 | - foreach ( $this->get_query_strategies( $count ) as $query ) { |
|
40 | - $action_ids = $this->store->query_actions( $query ); |
|
41 | - if ( ! empty( $action_ids ) ) { |
|
38 | + public function fetch($count = 10) { |
|
39 | + foreach ($this->get_query_strategies($count) as $query) { |
|
40 | + $action_ids = $this->store->query_actions($query); |
|
41 | + if (!empty($action_ids)) { |
|
42 | 42 | return $action_ids; |
43 | 43 | } |
44 | 44 | } |
@@ -53,7 +53,7 @@ discard block |
||
53 | 53 | * |
54 | 54 | * @return array |
55 | 55 | */ |
56 | - private function get_query_strategies( $count ) { |
|
56 | + private function get_query_strategies($count) { |
|
57 | 57 | $now = as_get_datetime_object(); |
58 | 58 | $args = [ |
59 | 59 | 'date' => $now, |
@@ -72,15 +72,15 @@ discard block |
||
72 | 72 | '', // any other unanticipated status |
73 | 73 | ]; |
74 | 74 | |
75 | - foreach ( $priorities as $status ) { |
|
76 | - yield wp_parse_args( [ |
|
75 | + foreach ($priorities as $status) { |
|
76 | + yield wp_parse_args([ |
|
77 | 77 | 'status' => $status, |
78 | 78 | 'date_compare' => '<=', |
79 | - ], $args ); |
|
80 | - yield wp_parse_args( [ |
|
79 | + ], $args); |
|
80 | + yield wp_parse_args([ |
|
81 | 81 | 'status' => $status, |
82 | 82 | 'date_compare' => '>=', |
83 | - ], $args ); |
|
83 | + ], $args); |
|
84 | 84 | } |
85 | 85 | } |
86 | 86 | } |
87 | 87 | \ No newline at end of file |
@@ -48,8 +48,8 @@ discard block |
||
48 | 48 | * @return ActionScheduler_Store |
49 | 49 | */ |
50 | 50 | public function get_source_store() { |
51 | - if ( empty( $this->source_store ) ) { |
|
52 | - throw new \RuntimeException( __( 'Source store must be configured before running a migration', 'action-scheduler' ) ); |
|
51 | + if (empty($this->source_store)) { |
|
52 | + throw new \RuntimeException(__('Source store must be configured before running a migration', 'action-scheduler')); |
|
53 | 53 | } |
54 | 54 | |
55 | 55 | return $this->source_store; |
@@ -60,7 +60,7 @@ discard block |
||
60 | 60 | * |
61 | 61 | * @param ActionScheduler_Store $store Source store object. |
62 | 62 | */ |
63 | - public function set_source_store( Store $store ) { |
|
63 | + public function set_source_store(Store $store) { |
|
64 | 64 | $this->source_store = $store; |
65 | 65 | } |
66 | 66 | |
@@ -70,8 +70,8 @@ discard block |
||
70 | 70 | * @return ActionScheduler_Logger |
71 | 71 | */ |
72 | 72 | public function get_source_logger() { |
73 | - if ( empty( $this->source_logger ) ) { |
|
74 | - throw new \RuntimeException( __( 'Source logger must be configured before running a migration', 'action-scheduler' ) ); |
|
73 | + if (empty($this->source_logger)) { |
|
74 | + throw new \RuntimeException(__('Source logger must be configured before running a migration', 'action-scheduler')); |
|
75 | 75 | } |
76 | 76 | |
77 | 77 | return $this->source_logger; |
@@ -82,7 +82,7 @@ discard block |
||
82 | 82 | * |
83 | 83 | * @param ActionScheduler_Logger $logger |
84 | 84 | */ |
85 | - public function set_source_logger( Logger $logger ) { |
|
85 | + public function set_source_logger(Logger $logger) { |
|
86 | 86 | $this->source_logger = $logger; |
87 | 87 | } |
88 | 88 | |
@@ -92,8 +92,8 @@ discard block |
||
92 | 92 | * @return ActionScheduler_Store |
93 | 93 | */ |
94 | 94 | public function get_destination_store() { |
95 | - if ( empty( $this->destination_store ) ) { |
|
96 | - throw new \RuntimeException( __( 'Destination store must be configured before running a migration', 'action-scheduler' ) ); |
|
95 | + if (empty($this->destination_store)) { |
|
96 | + throw new \RuntimeException(__('Destination store must be configured before running a migration', 'action-scheduler')); |
|
97 | 97 | } |
98 | 98 | |
99 | 99 | return $this->destination_store; |
@@ -104,7 +104,7 @@ discard block |
||
104 | 104 | * |
105 | 105 | * @param ActionScheduler_Store $store |
106 | 106 | */ |
107 | - public function set_destination_store( Store $store ) { |
|
107 | + public function set_destination_store(Store $store) { |
|
108 | 108 | $this->destination_store = $store; |
109 | 109 | } |
110 | 110 | |
@@ -114,8 +114,8 @@ discard block |
||
114 | 114 | * @return ActionScheduler_Logger |
115 | 115 | */ |
116 | 116 | public function get_destination_logger() { |
117 | - if ( empty( $this->destination_logger ) ) { |
|
118 | - throw new \RuntimeException( __( 'Destination logger must be configured before running a migration', 'action-scheduler' ) ); |
|
117 | + if (empty($this->destination_logger)) { |
|
118 | + throw new \RuntimeException(__('Destination logger must be configured before running a migration', 'action-scheduler')); |
|
119 | 119 | } |
120 | 120 | |
121 | 121 | return $this->destination_logger; |
@@ -126,7 +126,7 @@ discard block |
||
126 | 126 | * |
127 | 127 | * @param ActionScheduler_Logger $logger |
128 | 128 | */ |
129 | - public function set_destination_logger( Logger $logger ) { |
|
129 | + public function set_destination_logger(Logger $logger) { |
|
130 | 130 | $this->destination_logger = $logger; |
131 | 131 | } |
132 | 132 | |
@@ -144,7 +144,7 @@ discard block |
||
144 | 144 | * |
145 | 145 | * @param bool $dry_run |
146 | 146 | */ |
147 | - public function set_dry_run( $dry_run ) { |
|
147 | + public function set_dry_run($dry_run) { |
|
148 | 148 | $this->dry_run = (bool) $dry_run; |
149 | 149 | } |
150 | 150 | |
@@ -162,7 +162,7 @@ discard block |
||
162 | 162 | * |
163 | 163 | * @param ActionScheduler\WPCLI\ProgressBar $progress_bar |
164 | 164 | */ |
165 | - public function set_progress_bar( ProgressBar $progress_bar ) { |
|
165 | + public function set_progress_bar(ProgressBar $progress_bar) { |
|
166 | 166 | $this->progress_bar = $progress_bar; |
167 | 167 | } |
168 | 168 | } |
@@ -42,22 +42,22 @@ discard block |
||
42 | 42 | * |
43 | 43 | * @param Config $config Migration configuration object. |
44 | 44 | */ |
45 | - public function __construct( Config $config ) { |
|
45 | + public function __construct(Config $config) { |
|
46 | 46 | $this->source_store = $config->get_source_store(); |
47 | 47 | $this->destination_store = $config->get_destination_store(); |
48 | 48 | $this->source_logger = $config->get_source_logger(); |
49 | 49 | $this->destination_logger = $config->get_destination_logger(); |
50 | 50 | |
51 | - $this->batch_fetcher = new BatchFetcher( $this->source_store ); |
|
52 | - if ( $config->get_dry_run() ) { |
|
53 | - $this->log_migrator = new DryRun_LogMigrator( $this->source_logger, $this->destination_logger ); |
|
54 | - $this->action_migrator = new DryRun_ActionMigrator( $this->source_store, $this->destination_store, $this->log_migrator ); |
|
51 | + $this->batch_fetcher = new BatchFetcher($this->source_store); |
|
52 | + if ($config->get_dry_run()) { |
|
53 | + $this->log_migrator = new DryRun_LogMigrator($this->source_logger, $this->destination_logger); |
|
54 | + $this->action_migrator = new DryRun_ActionMigrator($this->source_store, $this->destination_store, $this->log_migrator); |
|
55 | 55 | } else { |
56 | - $this->log_migrator = new LogMigrator( $this->source_logger, $this->destination_logger ); |
|
57 | - $this->action_migrator = new ActionMigrator( $this->source_store, $this->destination_store, $this->log_migrator ); |
|
56 | + $this->log_migrator = new LogMigrator($this->source_logger, $this->destination_logger); |
|
57 | + $this->action_migrator = new ActionMigrator($this->source_store, $this->destination_store, $this->log_migrator); |
|
58 | 58 | } |
59 | 59 | |
60 | - if ( defined( 'WP_CLI' ) && WP_CLI ) { |
|
60 | + if (defined('WP_CLI') && WP_CLI) { |
|
61 | 61 | $this->progress_bar = $config->get_progress_bar(); |
62 | 62 | } |
63 | 63 | } |
@@ -69,21 +69,21 @@ discard block |
||
69 | 69 | * |
70 | 70 | * @return int Size of batch processed. |
71 | 71 | */ |
72 | - public function run( $batch_size = 10 ) { |
|
73 | - $batch = $this->batch_fetcher->fetch( $batch_size ); |
|
74 | - $batch_size = count( $batch ); |
|
72 | + public function run($batch_size = 10) { |
|
73 | + $batch = $this->batch_fetcher->fetch($batch_size); |
|
74 | + $batch_size = count($batch); |
|
75 | 75 | |
76 | - if ( ! $batch_size ) { |
|
76 | + if (!$batch_size) { |
|
77 | 77 | return 0; |
78 | 78 | } |
79 | 79 | |
80 | - if ( $this->progress_bar ) { |
|
80 | + if ($this->progress_bar) { |
|
81 | 81 | /* translators: %d: amount of actions */ |
82 | - $this->progress_bar->set_message( sprintf( _n( 'Migrating %d action', 'Migrating %d actions', $batch_size, 'action-scheduler' ), number_format_i18n( $batch_size ) ) ); |
|
83 | - $this->progress_bar->set_count( $batch_size ); |
|
82 | + $this->progress_bar->set_message(sprintf(_n('Migrating %d action', 'Migrating %d actions', $batch_size, 'action-scheduler'), number_format_i18n($batch_size))); |
|
83 | + $this->progress_bar->set_count($batch_size); |
|
84 | 84 | } |
85 | 85 | |
86 | - $this->migrate_actions( $batch ); |
|
86 | + $this->migrate_actions($batch); |
|
87 | 87 | |
88 | 88 | return $batch_size; |
89 | 89 | } |
@@ -93,37 +93,37 @@ discard block |
||
93 | 93 | * |
94 | 94 | * @param array $action_ids List of action IDs to migrate. |
95 | 95 | */ |
96 | - public function migrate_actions( array $action_ids ) { |
|
97 | - do_action( 'action_scheduler/migration_batch_starting', $action_ids ); |
|
96 | + public function migrate_actions(array $action_ids) { |
|
97 | + do_action('action_scheduler/migration_batch_starting', $action_ids); |
|
98 | 98 | |
99 | 99 | \ActionScheduler::logger()->unhook_stored_action(); |
100 | 100 | $this->destination_logger->unhook_stored_action(); |
101 | 101 | |
102 | - foreach ( $action_ids as $source_action_id ) { |
|
103 | - $destination_action_id = $this->action_migrator->migrate( $source_action_id ); |
|
104 | - if ( $destination_action_id ) { |
|
105 | - $this->destination_logger->log( $destination_action_id, sprintf( |
|
102 | + foreach ($action_ids as $source_action_id) { |
|
103 | + $destination_action_id = $this->action_migrator->migrate($source_action_id); |
|
104 | + if ($destination_action_id) { |
|
105 | + $this->destination_logger->log($destination_action_id, sprintf( |
|
106 | 106 | /* translators: 1: source action ID 2: source store class 3: destination action ID 4: destination store class */ |
107 | - __( 'Migrated action with ID %1$d in %2$s to ID %3$d in %4$s', 'action-scheduler' ), |
|
107 | + __('Migrated action with ID %1$d in %2$s to ID %3$d in %4$s', 'action-scheduler'), |
|
108 | 108 | $source_action_id, |
109 | - get_class( $this->source_store ), |
|
109 | + get_class($this->source_store), |
|
110 | 110 | $destination_action_id, |
111 | - get_class( $this->destination_store ) |
|
112 | - ) ); |
|
111 | + get_class($this->destination_store) |
|
112 | + )); |
|
113 | 113 | } |
114 | 114 | |
115 | - if ( $this->progress_bar ) { |
|
115 | + if ($this->progress_bar) { |
|
116 | 116 | $this->progress_bar->tick(); |
117 | 117 | } |
118 | 118 | } |
119 | 119 | |
120 | - if ( $this->progress_bar ) { |
|
120 | + if ($this->progress_bar) { |
|
121 | 121 | $this->progress_bar->finish(); |
122 | 122 | } |
123 | 123 | |
124 | 124 | \ActionScheduler::logger()->hook_stored_action(); |
125 | 125 | |
126 | - do_action( 'action_scheduler/migration_batch_complete', $action_ids ); |
|
126 | + do_action('action_scheduler/migration_batch_complete', $action_ids); |
|
127 | 127 | } |
128 | 128 | |
129 | 129 | /** |
@@ -27,7 +27,7 @@ discard block |
||
27 | 27 | * @param ActionScheduler_Logger $source_logger Source logger object. |
28 | 28 | * @param ActionScheduler_Logger $destination_Logger Destination logger object. |
29 | 29 | */ |
30 | - public function __construct( ActionScheduler_Logger $source_logger, ActionScheduler_Logger $destination_Logger ) { |
|
30 | + public function __construct(ActionScheduler_Logger $source_logger, ActionScheduler_Logger $destination_Logger) { |
|
31 | 31 | $this->source = $source_logger; |
32 | 32 | $this->destination = $destination_Logger; |
33 | 33 | } |
@@ -38,11 +38,11 @@ discard block |
||
38 | 38 | * @param int $source_action_id Source logger object. |
39 | 39 | * @param int $destination_action_id Destination logger object. |
40 | 40 | */ |
41 | - public function migrate( $source_action_id, $destination_action_id ) { |
|
42 | - $logs = $this->source->get_logs( $source_action_id ); |
|
43 | - foreach ( $logs as $log ) { |
|
44 | - if ( $log->get_action_id() == $source_action_id ) { |
|
45 | - $this->destination->log( $destination_action_id, $log->get_message(), $log->get_date() ); |
|
41 | + public function migrate($source_action_id, $destination_action_id) { |
|
42 | + $logs = $this->source->get_logs($source_action_id); |
|
43 | + foreach ($logs as $log) { |
|
44 | + if ($log->get_action_id() == $source_action_id) { |
|
45 | + $this->destination->log($destination_action_id, $log->get_message(), $log->get_date()); |
|
46 | 46 | } |
47 | 47 | } |
48 | 48 | } |
@@ -23,14 +23,14 @@ discard block |
||
23 | 23 | * Set up the callback for the scheduled job. |
24 | 24 | */ |
25 | 25 | public function hook() { |
26 | - add_action( self::HOOK, array( $this, 'run_migration' ), 10, 0 ); |
|
26 | + add_action(self::HOOK, array($this, 'run_migration'), 10, 0); |
|
27 | 27 | } |
28 | 28 | |
29 | 29 | /** |
30 | 30 | * Remove the callback for the scheduled job. |
31 | 31 | */ |
32 | 32 | public function unhook() { |
33 | - remove_action( self::HOOK, array( $this, 'run_migration' ), 10 ); |
|
33 | + remove_action(self::HOOK, array($this, 'run_migration'), 10); |
|
34 | 34 | } |
35 | 35 | |
36 | 36 | /** |
@@ -38,12 +38,12 @@ discard block |
||
38 | 38 | */ |
39 | 39 | public function run_migration() { |
40 | 40 | $migration_runner = $this->get_migration_runner(); |
41 | - $count = $migration_runner->run( $this->get_batch_size() ); |
|
41 | + $count = $migration_runner->run($this->get_batch_size()); |
|
42 | 42 | |
43 | - if ( $count === 0 ) { |
|
43 | + if ($count === 0) { |
|
44 | 44 | $this->mark_complete(); |
45 | 45 | } else { |
46 | - $this->schedule_migration( time() + $this->get_schedule_interval() ); |
|
46 | + $this->schedule_migration(time() + $this->get_schedule_interval()); |
|
47 | 47 | } |
48 | 48 | } |
49 | 49 | |
@@ -54,7 +54,7 @@ discard block |
||
54 | 54 | $this->unschedule_migration(); |
55 | 55 | |
56 | 56 | \ActionScheduler_DataController::mark_migration_complete(); |
57 | - do_action( 'action_scheduler/migration_complete' ); |
|
57 | + do_action('action_scheduler/migration_complete'); |
|
58 | 58 | } |
59 | 59 | |
60 | 60 | /** |
@@ -63,9 +63,9 @@ discard block |
||
63 | 63 | * @return bool Whether there is a pending action in the store to handle the migration |
64 | 64 | */ |
65 | 65 | public function is_migration_scheduled() { |
66 | - $next = as_next_scheduled_action( self::HOOK ); |
|
66 | + $next = as_next_scheduled_action(self::HOOK); |
|
67 | 67 | |
68 | - return ! empty( $next ); |
|
68 | + return !empty($next); |
|
69 | 69 | } |
70 | 70 | |
71 | 71 | /** |
@@ -75,25 +75,25 @@ discard block |
||
75 | 75 | * |
76 | 76 | * @return string The action ID |
77 | 77 | */ |
78 | - public function schedule_migration( $when = 0 ) { |
|
79 | - $next = as_next_scheduled_action( self::HOOK ); |
|
78 | + public function schedule_migration($when = 0) { |
|
79 | + $next = as_next_scheduled_action(self::HOOK); |
|
80 | 80 | |
81 | - if ( ! empty( $next ) ) { |
|
81 | + if (!empty($next)) { |
|
82 | 82 | return $next; |
83 | 83 | } |
84 | 84 | |
85 | - if ( empty( $when ) ) { |
|
85 | + if (empty($when)) { |
|
86 | 86 | $when = time(); |
87 | 87 | } |
88 | 88 | |
89 | - return as_schedule_single_action( $when, self::HOOK, array(), self::GROUP ); |
|
89 | + return as_schedule_single_action($when, self::HOOK, array(), self::GROUP); |
|
90 | 90 | } |
91 | 91 | |
92 | 92 | /** |
93 | 93 | * Remove the scheduled migration action. |
94 | 94 | */ |
95 | 95 | public function unschedule_migration() { |
96 | - as_unschedule_action( self::HOOK, null, self::GROUP ); |
|
96 | + as_unschedule_action(self::HOOK, null, self::GROUP); |
|
97 | 97 | } |
98 | 98 | |
99 | 99 | /** |
@@ -102,7 +102,7 @@ discard block |
||
102 | 102 | * @return int Seconds between migration runs. Defaults to 0 seconds to allow chaining migration via Async Runners. |
103 | 103 | */ |
104 | 104 | private function get_schedule_interval() { |
105 | - return (int) apply_filters( 'action_scheduler/migration_interval', 0 ); |
|
105 | + return (int) apply_filters('action_scheduler/migration_interval', 0); |
|
106 | 106 | } |
107 | 107 | |
108 | 108 | /** |
@@ -111,7 +111,7 @@ discard block |
||
111 | 111 | * @return int Number of actions to migrate in each batch. Defaults to 250. |
112 | 112 | */ |
113 | 113 | private function get_batch_size() { |
114 | - return (int) apply_filters( 'action_scheduler/migration_batch_size', 250 ); |
|
114 | + return (int) apply_filters('action_scheduler/migration_batch_size', 250); |
|
115 | 115 | } |
116 | 116 | |
117 | 117 | /** |
@@ -122,7 +122,7 @@ discard block |
||
122 | 122 | private function get_migration_runner() { |
123 | 123 | $config = Controller::instance()->get_migration_config_object(); |
124 | 124 | |
125 | - return new Runner( $config ); |
|
125 | + return new Runner($config); |
|
126 | 126 | } |
127 | 127 | |
128 | 128 | } |
@@ -20,8 +20,8 @@ |
||
20 | 20 | * |
21 | 21 | * @return int |
22 | 22 | */ |
23 | - public function migrate( $source_action_id ) { |
|
24 | - do_action( 'action_scheduler/migrate_action_dry_run', $source_action_id ); |
|
23 | + public function migrate($source_action_id) { |
|
24 | + do_action('action_scheduler/migrate_action_dry_run', $source_action_id); |
|
25 | 25 | |
26 | 26 | return 0; |
27 | 27 | } |
@@ -17,7 +17,7 @@ |
||
17 | 17 | * @param int $source_action_id Source logger object. |
18 | 18 | * @param int $destination_action_id Destination logger object. |
19 | 19 | */ |
20 | - public function migrate( $source_action_id, $destination_action_id ) { |
|
20 | + public function migrate($source_action_id, $destination_action_id) { |
|
21 | 21 | // no-op |
22 | 22 | } |
23 | 23 | } |
24 | 24 | \ No newline at end of file |