Passed
Push — master ( 495efb...ace576 )
by Brian
06:14 queued 01:46
created
includes/libraries/action-scheduler/classes/ActionScheduler_ListTable.php 1 patch
Spacing   +120 added lines, -120 removed lines patch added patch discarded remove patch
@@ -80,26 +80,26 @@  discard block
 block discarded – undo
80 80
 	 * @param ActionScheduler_Logger $logger
81 81
 	 * @param ActionScheduler_QueueRunner $runner
82 82
 	 */
83
-	public function __construct( ActionScheduler_Store $store, ActionScheduler_Logger $logger, ActionScheduler_QueueRunner $runner ) {
83
+	public function __construct(ActionScheduler_Store $store, ActionScheduler_Logger $logger, ActionScheduler_QueueRunner $runner) {
84 84
 
85 85
 		$this->store  = $store;
86 86
 		$this->logger = $logger;
87 87
 		$this->runner = $runner;
88 88
 
89
-		$this->table_header = __( 'Scheduled Actions', 'action-scheduler' );
89
+		$this->table_header = __('Scheduled Actions', 'action-scheduler');
90 90
 
91 91
 		$this->bulk_actions = array(
92
-			'delete' => __( 'Delete', 'action-scheduler' ),
92
+			'delete' => __('Delete', 'action-scheduler'),
93 93
 		);
94 94
 
95 95
 		$this->columns = array(
96
-			'hook'        => __( 'Hook', 'action-scheduler' ),
97
-			'status'      => __( 'Status', 'action-scheduler' ),
98
-			'args'        => __( 'Arguments', 'action-scheduler' ),
99
-			'group'       => __( 'Group', 'action-scheduler' ),
100
-			'recurrence'  => __( 'Recurrence', 'action-scheduler' ),
101
-			'schedule'    => __( 'Scheduled Date', 'action-scheduler' ),
102
-			'log_entries' => __( 'Log', 'action-scheduler' ),
96
+			'hook'        => __('Hook', 'action-scheduler'),
97
+			'status'      => __('Status', 'action-scheduler'),
98
+			'args'        => __('Arguments', 'action-scheduler'),
99
+			'group'       => __('Group', 'action-scheduler'),
100
+			'recurrence'  => __('Recurrence', 'action-scheduler'),
101
+			'schedule'    => __('Scheduled Date', 'action-scheduler'),
102
+			'log_entries' => __('Log', 'action-scheduler'),
103 103
 		);
104 104
 
105 105
 		$this->sort_by = array(
@@ -116,22 +116,22 @@  discard block
 block discarded – undo
116 116
 
117 117
 		$request_status = $this->get_request_status();
118 118
 
119
-		if ( empty( $request_status ) ) {
119
+		if (empty($request_status)) {
120 120
 			$this->sort_by[] = 'status';
121
-		} elseif ( in_array( $request_status, array( 'in-progress', 'failed' ) ) ) {
122
-			$this->columns  += array( 'claim_id' => __( 'Claim ID', 'action-scheduler' ) );
121
+		} elseif (in_array($request_status, array('in-progress', 'failed'))) {
122
+			$this->columns  += array('claim_id' => __('Claim ID', 'action-scheduler'));
123 123
 			$this->sort_by[] = 'claim_id';
124 124
 		}
125 125
 
126 126
 		$this->row_actions = array(
127 127
 			'hook' => array(
128 128
 				'run' => array(
129
-					'name'  => __( 'Run', 'action-scheduler' ),
130
-					'desc'  => __( 'Process the action now as if it were run as part of a queue', 'action-scheduler' ),
129
+					'name'  => __('Run', 'action-scheduler'),
130
+					'desc'  => __('Process the action now as if it were run as part of a queue', 'action-scheduler'),
131 131
 				),
132 132
 				'cancel' => array(
133
-					'name'  => __( 'Cancel', 'action-scheduler' ),
134
-					'desc'  => __( 'Cancel the action now to avoid it being run in future', 'action-scheduler' ),
133
+					'name'  => __('Cancel', 'action-scheduler'),
134
+					'desc'  => __('Cancel the action now to avoid it being run in future', 'action-scheduler'),
135 135
 					'class' => 'cancel trash',
136 136
 				),
137 137
 			),
@@ -141,45 +141,45 @@  discard block
 block discarded – undo
141 141
 			array(
142 142
 				'seconds' => YEAR_IN_SECONDS,
143 143
 				/* translators: %s: amount of time */
144
-				'names'   => _n_noop( '%s year', '%s years', 'action-scheduler' ),
144
+				'names'   => _n_noop('%s year', '%s years', 'action-scheduler'),
145 145
 			),
146 146
 			array(
147 147
 				'seconds' => MONTH_IN_SECONDS,
148 148
 				/* translators: %s: amount of time */
149
-				'names'   => _n_noop( '%s month', '%s months', 'action-scheduler' ),
149
+				'names'   => _n_noop('%s month', '%s months', 'action-scheduler'),
150 150
 			),
151 151
 			array(
152 152
 				'seconds' => WEEK_IN_SECONDS,
153 153
 				/* translators: %s: amount of time */
154
-				'names'   => _n_noop( '%s week', '%s weeks', 'action-scheduler' ),
154
+				'names'   => _n_noop('%s week', '%s weeks', 'action-scheduler'),
155 155
 			),
156 156
 			array(
157 157
 				'seconds' => DAY_IN_SECONDS,
158 158
 				/* translators: %s: amount of time */
159
-				'names'   => _n_noop( '%s day', '%s days', 'action-scheduler' ),
159
+				'names'   => _n_noop('%s day', '%s days', 'action-scheduler'),
160 160
 			),
161 161
 			array(
162 162
 				'seconds' => HOUR_IN_SECONDS,
163 163
 				/* translators: %s: amount of time */
164
-				'names'   => _n_noop( '%s hour', '%s hours', 'action-scheduler' ),
164
+				'names'   => _n_noop('%s hour', '%s hours', 'action-scheduler'),
165 165
 			),
166 166
 			array(
167 167
 				'seconds' => MINUTE_IN_SECONDS,
168 168
 				/* translators: %s: amount of time */
169
-				'names'   => _n_noop( '%s minute', '%s minutes', 'action-scheduler' ),
169
+				'names'   => _n_noop('%s minute', '%s minutes', 'action-scheduler'),
170 170
 			),
171 171
 			array(
172 172
 				'seconds' => 1,
173 173
 				/* translators: %s: amount of time */
174
-				'names'   => _n_noop( '%s second', '%s seconds', 'action-scheduler' ),
174
+				'names'   => _n_noop('%s second', '%s seconds', 'action-scheduler'),
175 175
 			),
176 176
 		);
177 177
 
178
-		parent::__construct( array(
178
+		parent::__construct(array(
179 179
 			'singular' => 'action-scheduler',
180 180
 			'plural'   => 'action-scheduler',
181 181
 			'ajax'     => false,
182
-		) );
182
+		));
183 183
 	}
184 184
 
185 185
 	/**
@@ -195,24 +195,24 @@  discard block
 block discarded – undo
195 195
 	 * @param int $periods_to_include Depth of time periods to include, e.g. for an interval of 70, and $periods_to_include of 2, both minutes and seconds would be included. With a value of 1, only minutes would be included.
196 196
 	 * @return string A human friendly string representation of the interval.
197 197
 	 */
198
-	private static function human_interval( $interval, $periods_to_include = 2 ) {
198
+	private static function human_interval($interval, $periods_to_include = 2) {
199 199
 
200
-		if ( $interval <= 0 ) {
201
-			return __( 'Now!', 'action-scheduler' );
200
+		if ($interval <= 0) {
201
+			return __('Now!', 'action-scheduler');
202 202
 		}
203 203
 
204 204
 		$output = '';
205 205
 
206
-		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++ ) {
206
+		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++) {
207 207
 
208
-			$periods_in_interval = floor( $seconds_remaining / self::$time_periods[ $time_period_index ]['seconds'] );
208
+			$periods_in_interval = floor($seconds_remaining / self::$time_periods[$time_period_index]['seconds']);
209 209
 
210
-			if ( $periods_in_interval > 0 ) {
211
-				if ( ! empty( $output ) ) {
210
+			if ($periods_in_interval > 0) {
211
+				if (!empty($output)) {
212 212
 					$output .= ' ';
213 213
 				}
214
-				$output .= sprintf( _n( self::$time_periods[ $time_period_index ]['names'][0], self::$time_periods[ $time_period_index ]['names'][1], $periods_in_interval, 'action-scheduler' ), $periods_in_interval );
215
-				$seconds_remaining -= $periods_in_interval * self::$time_periods[ $time_period_index ]['seconds'];
214
+				$output .= sprintf(_n(self::$time_periods[$time_period_index]['names'][0], self::$time_periods[$time_period_index]['names'][1], $periods_in_interval, 'action-scheduler'), $periods_in_interval);
215
+				$seconds_remaining -= $periods_in_interval * self::$time_periods[$time_period_index]['seconds'];
216 216
 				$periods_included++;
217 217
 			}
218 218
 		}
@@ -227,20 +227,20 @@  discard block
 block discarded – undo
227 227
 	 *
228 228
 	 * @return string
229 229
 	 */
230
-	protected function get_recurrence( $action ) {
230
+	protected function get_recurrence($action) {
231 231
 		$schedule = $action->get_schedule();
232
-		if ( $schedule->is_recurring() ) {
232
+		if ($schedule->is_recurring()) {
233 233
 			$recurrence = $schedule->get_recurrence();
234 234
 
235
-			if ( is_numeric( $recurrence ) ) {
235
+			if (is_numeric($recurrence)) {
236 236
 				/* translators: %s: time interval */
237
-				return sprintf( __( 'Every %s', 'action-scheduler' ), self::human_interval( $recurrence ) );
237
+				return sprintf(__('Every %s', 'action-scheduler'), self::human_interval($recurrence));
238 238
 			} else {
239 239
 				return $recurrence;
240 240
 			}
241 241
 		}
242 242
 
243
-		return __( 'Non-repeating', 'action-scheduler' );
243
+		return __('Non-repeating', 'action-scheduler');
244 244
 	}
245 245
 
246 246
 	/**
@@ -250,18 +250,18 @@  discard block
 block discarded – undo
250 250
 	 *
251 251
 	 * @return string
252 252
 	 */
253
-	public function column_args( array $row ) {
254
-		if ( empty( $row['args'] ) ) {
255
-			return apply_filters( 'action_scheduler_list_table_column_args', '', $row );
253
+	public function column_args(array $row) {
254
+		if (empty($row['args'])) {
255
+			return apply_filters('action_scheduler_list_table_column_args', '', $row);
256 256
 		}
257 257
 
258 258
 		$row_html = '<ul>';
259
-		foreach ( $row['args'] as $key => $value ) {
260
-			$row_html .= sprintf( '<li><code>%s => %s</code></li>', esc_html( var_export( $key, true ) ), esc_html( var_export( $value, true ) ) );
259
+		foreach ($row['args'] as $key => $value) {
260
+			$row_html .= sprintf('<li><code>%s => %s</code></li>', esc_html(var_export($key, true)), esc_html(var_export($value, true)));
261 261
 		}
262 262
 		$row_html .= '</ul>';
263 263
 
264
-		return apply_filters( 'action_scheduler_list_table_column_args', $row_html, $row );
264
+		return apply_filters('action_scheduler_list_table_column_args', $row_html, $row);
265 265
 	}
266 266
 
267 267
 	/**
@@ -270,14 +270,14 @@  discard block
 block discarded – undo
270 270
 	 * @param array $row Action array.
271 271
 	 * @return string
272 272
 	 */
273
-	public function column_log_entries( array $row ) {
273
+	public function column_log_entries(array $row) {
274 274
 
275 275
 		$log_entries_html = '<ol>';
276 276
 
277
-		$timezone = new DateTimezone( 'UTC' );
277
+		$timezone = new DateTimezone('UTC');
278 278
 
279
-		foreach ( $row['log_entries'] as $log_entry ) {
280
-			$log_entries_html .= $this->get_log_entry_html( $log_entry, $timezone );
279
+		foreach ($row['log_entries'] as $log_entry) {
280
+			$log_entries_html .= $this->get_log_entry_html($log_entry, $timezone);
281 281
 		}
282 282
 
283 283
 		$log_entries_html .= '</ol>';
@@ -292,10 +292,10 @@  discard block
 block discarded – undo
292 292
 	 * @param DateTimezone $timezone
293 293
 	 * @return string
294 294
 	 */
295
-	protected function get_log_entry_html( ActionScheduler_LogEntry $log_entry, DateTimezone $timezone ) {
295
+	protected function get_log_entry_html(ActionScheduler_LogEntry $log_entry, DateTimezone $timezone) {
296 296
 		$date = $log_entry->get_date();
297
-		$date->setTimezone( $timezone );
298
-		return sprintf( '<li><strong>%s</strong><br/>%s</li>', esc_html( $date->format( 'Y-m-d H:i:s O' ) ), esc_html( $log_entry->get_message() ) );
297
+		$date->setTimezone($timezone);
298
+		return sprintf('<li><strong>%s</strong><br/>%s</li>', esc_html($date->format('Y-m-d H:i:s O')), esc_html($log_entry->get_message()));
299 299
 	}
300 300
 
301 301
 	/**
@@ -306,9 +306,9 @@  discard block
 block discarded – undo
306 306
 	 *
307 307
 	 * @return string
308 308
 	 */
309
-	protected function maybe_render_actions( $row, $column_name ) {
310
-		if ( 'pending' === strtolower( $row['status'] ) ) {
311
-			return parent::maybe_render_actions( $row, $column_name );
309
+	protected function maybe_render_actions($row, $column_name) {
310
+		if ('pending' === strtolower($row['status'])) {
311
+			return parent::maybe_render_actions($row, $column_name);
312 312
 		}
313 313
 
314 314
 		return '';
@@ -325,7 +325,7 @@  discard block
 block discarded – undo
325 325
 	public function display_admin_notices() {
326 326
 		global $wpdb;
327 327
 
328
-		if ( ( is_a( $this->store, 'ActionScheduler_HybridStore' ) || is_a( $this->store, 'ActionScheduler_DBStore' ) ) && apply_filters( 'action_scheduler_enable_recreate_data_store', true ) ) {
328
+		if ((is_a($this->store, 'ActionScheduler_HybridStore') || is_a($this->store, 'ActionScheduler_DBStore')) && apply_filters('action_scheduler_enable_recreate_data_store', true)) {
329 329
 			$table_list = array(
330 330
 				'actionscheduler_actions',
331 331
 				'actionscheduler_logs',
@@ -333,12 +333,12 @@  discard block
 block discarded – undo
333 333
 				'actionscheduler_claims',
334 334
 			);
335 335
 
336
-			$found_tables = $wpdb->get_col( "SHOW TABLES LIKE '{$wpdb->prefix}actionscheduler%'" ); // phpcs:ignore WordPress.DB.PreparedSQL.InterpolatedNotPrepared
337
-			foreach ( $table_list as $table_name ) {
338
-				if ( ! in_array( $wpdb->prefix . $table_name, $found_tables ) ) {
336
+			$found_tables = $wpdb->get_col("SHOW TABLES LIKE '{$wpdb->prefix}actionscheduler%'"); // phpcs:ignore WordPress.DB.PreparedSQL.InterpolatedNotPrepared
337
+			foreach ($table_list as $table_name) {
338
+				if (!in_array($wpdb->prefix . $table_name, $found_tables)) {
339 339
 					$this->admin_notices[] = array(
340 340
 						'class'   => 'error',
341
-						'message' => __( 'It appears one or more database tables were missing. Attempting to re-create the missing table(s).' , 'action-scheduler' ),
341
+						'message' => __('It appears one or more database tables were missing. Attempting to re-create the missing table(s).', 'action-scheduler'),
342 342
 					);
343 343
 					$this->recreate_tables();
344 344
 					parent::display_admin_notices();
@@ -348,7 +348,7 @@  discard block
 block discarded – undo
348 348
 			}
349 349
 		}
350 350
 
351
-		if ( $this->runner->has_maximum_concurrent_batches() ) {
351
+		if ($this->runner->has_maximum_concurrent_batches()) {
352 352
 			$claim_count           = $this->store->get_claim_count();
353 353
 			$this->admin_notices[] = array(
354 354
 				'class'   => 'updated',
@@ -363,18 +363,18 @@  discard block
 block discarded – undo
363 363
 					$claim_count
364 364
 				),
365 365
 			);
366
-		} elseif ( $this->store->has_pending_actions_due() ) {
366
+		} elseif ($this->store->has_pending_actions_due()) {
367 367
 
368
-			$async_request_lock_expiration = ActionScheduler::lock()->get_expiration( 'async-request-runner' );
368
+			$async_request_lock_expiration = ActionScheduler::lock()->get_expiration('async-request-runner');
369 369
 
370 370
 			// No lock set or lock expired
371
-			if ( false === $async_request_lock_expiration || $async_request_lock_expiration < time() ) {
372
-				$in_progress_url       = add_query_arg( 'status', 'in-progress', remove_query_arg( 'status' ) );
371
+			if (false === $async_request_lock_expiration || $async_request_lock_expiration < time()) {
372
+				$in_progress_url       = add_query_arg('status', 'in-progress', remove_query_arg('status'));
373 373
 				/* translators: %s: process URL */
374
-				$async_request_message = sprintf( __( 'A new queue has begun processing. <a href="%s">View actions in-progress &raquo;</a>', 'action-scheduler' ), esc_url( $in_progress_url ) );
374
+				$async_request_message = sprintf(__('A new queue has begun processing. <a href="%s">View actions in-progress &raquo;</a>', 'action-scheduler'), esc_url($in_progress_url));
375 375
 			} else {
376 376
 				/* translators: %d: seconds */
377
-				$async_request_message = sprintf( __( 'The next queue will begin processing in approximately %d seconds.', 'action-scheduler' ), $async_request_lock_expiration - time() );
377
+				$async_request_message = sprintf(__('The next queue will begin processing in approximately %d seconds.', 'action-scheduler'), $async_request_lock_expiration - time());
378 378
 			}
379 379
 
380 380
 			$this->admin_notices[] = array(
@@ -383,36 +383,36 @@  discard block
 block discarded – undo
383 383
 			);
384 384
 		}
385 385
 
386
-		$notification = get_transient( 'action_scheduler_admin_notice' );
386
+		$notification = get_transient('action_scheduler_admin_notice');
387 387
 
388
-		if ( is_array( $notification ) ) {
389
-			delete_transient( 'action_scheduler_admin_notice' );
388
+		if (is_array($notification)) {
389
+			delete_transient('action_scheduler_admin_notice');
390 390
 
391
-			$action = $this->store->fetch_action( $notification['action_id'] );
391
+			$action = $this->store->fetch_action($notification['action_id']);
392 392
 			$action_hook_html = '<strong><code>' . $action->get_hook() . '</code></strong>';
393
-			if ( 1 == $notification['success'] ) {
393
+			if (1 == $notification['success']) {
394 394
 				$class = 'updated';
395
-				switch ( $notification['row_action_type'] ) {
395
+				switch ($notification['row_action_type']) {
396 396
 					case 'run' :
397 397
 						/* translators: %s: action HTML */
398
-						$action_message_html = sprintf( __( 'Successfully executed action: %s', 'action-scheduler' ), $action_hook_html );
398
+						$action_message_html = sprintf(__('Successfully executed action: %s', 'action-scheduler'), $action_hook_html);
399 399
 						break;
400 400
 					case 'cancel' :
401 401
 						/* translators: %s: action HTML */
402
-						$action_message_html = sprintf( __( 'Successfully canceled action: %s', 'action-scheduler' ), $action_hook_html );
402
+						$action_message_html = sprintf(__('Successfully canceled action: %s', 'action-scheduler'), $action_hook_html);
403 403
 						break;
404 404
 					default :
405 405
 						/* translators: %s: action HTML */
406
-						$action_message_html = sprintf( __( 'Successfully processed change for action: %s', 'action-scheduler' ), $action_hook_html );
406
+						$action_message_html = sprintf(__('Successfully processed change for action: %s', 'action-scheduler'), $action_hook_html);
407 407
 						break;
408 408
 				}
409 409
 			} else {
410 410
 				$class = 'error';
411 411
 				/* translators: 1: action HTML 2: action ID 3: error message */
412
-				$action_message_html = sprintf( __( 'Could not process change for action: "%1$s" (ID: %2$d). Error: %3$s', 'action-scheduler' ), $action_hook_html, esc_html( $notification['action_id'] ), esc_html( $notification['error_message'] ) );
412
+				$action_message_html = sprintf(__('Could not process change for action: "%1$s" (ID: %2$d). Error: %3$s', 'action-scheduler'), $action_hook_html, esc_html($notification['action_id']), esc_html($notification['error_message']));
413 413
 			}
414 414
 
415
-			$action_message_html = apply_filters( 'action_scheduler_admin_notice_html', $action_message_html, $action, $notification );
415
+			$action_message_html = apply_filters('action_scheduler_admin_notice_html', $action_message_html, $action, $notification);
416 416
 
417 417
 			$this->admin_notices[] = array(
418 418
 				'class'   => $class,
@@ -430,8 +430,8 @@  discard block
 block discarded – undo
430 430
 	 *
431 431
 	 * @return string
432 432
 	 */
433
-	public function column_schedule( $row ) {
434
-		return $this->get_schedule_display_string( $row['schedule'] );
433
+	public function column_schedule($row) {
434
+		return $this->get_schedule_display_string($row['schedule']);
435 435
 	}
436 436
 
437 437
 	/**
@@ -440,25 +440,25 @@  discard block
 block discarded – undo
440 440
 	 * @param ActionScheduler_Schedule $schedule
441 441
 	 * @return string
442 442
 	 */
443
-	protected function get_schedule_display_string( ActionScheduler_Schedule $schedule ) {
443
+	protected function get_schedule_display_string(ActionScheduler_Schedule $schedule) {
444 444
 
445 445
 		$schedule_display_string = '';
446 446
 
447
-		if ( ! $schedule->get_date() ) {
447
+		if (!$schedule->get_date()) {
448 448
 			return '0000-00-00 00:00:00';
449 449
 		}
450 450
 
451 451
 		$next_timestamp = $schedule->get_date()->getTimestamp();
452 452
 
453
-		$schedule_display_string .= $schedule->get_date()->format( 'Y-m-d H:i:s O' );
453
+		$schedule_display_string .= $schedule->get_date()->format('Y-m-d H:i:s O');
454 454
 		$schedule_display_string .= '<br/>';
455 455
 
456
-		if ( gmdate( 'U' ) > $next_timestamp ) {
456
+		if (gmdate('U') > $next_timestamp) {
457 457
 			/* translators: %s: date interval */
458
-			$schedule_display_string .= sprintf( __( ' (%s ago)', 'action-scheduler' ), self::human_interval( gmdate( 'U' ) - $next_timestamp ) );
458
+			$schedule_display_string .= sprintf(__(' (%s ago)', 'action-scheduler'), self::human_interval(gmdate('U') - $next_timestamp));
459 459
 		} else {
460 460
 			/* translators: %s: date interval */
461
-			$schedule_display_string .= sprintf( __( ' (%s)', 'action-scheduler' ), self::human_interval( $next_timestamp - gmdate( 'U' ) ) );
461
+			$schedule_display_string .= sprintf(__(' (%s)', 'action-scheduler'), self::human_interval($next_timestamp - gmdate('U')));
462 462
 		}
463 463
 
464 464
 		return $schedule_display_string;
@@ -473,9 +473,9 @@  discard block
 block discarded – undo
473 473
 	 * @param array $ids
474 474
 	 * @param string $ids_sql Inherited and unused
475 475
 	 */
476
-	protected function bulk_delete( array $ids, $ids_sql ) {
477
-		foreach ( $ids as $id ) {
478
-			$this->store->delete_action( $id );
476
+	protected function bulk_delete(array $ids, $ids_sql) {
477
+		foreach ($ids as $id) {
478
+			$this->store->delete_action($id);
479 479
 		}
480 480
 	}
481 481
 
@@ -485,8 +485,8 @@  discard block
 block discarded – undo
485 485
 	 *
486 486
 	 * @param int $action_id
487 487
 	 */
488
-	protected function row_action_cancel( $action_id ) {
489
-		$this->process_row_action( $action_id, 'cancel' );
488
+	protected function row_action_cancel($action_id) {
489
+		$this->process_row_action($action_id, 'cancel');
490 490
 	}
491 491
 
492 492
 	/**
@@ -495,27 +495,27 @@  discard block
 block discarded – undo
495 495
 	 *
496 496
 	 * @param int $action_id
497 497
 	 */
498
-	protected function row_action_run( $action_id ) {
499
-		$this->process_row_action( $action_id, 'run' );
498
+	protected function row_action_run($action_id) {
499
+		$this->process_row_action($action_id, 'run');
500 500
 	}
501 501
 
502 502
 	/**
503 503
 	 * Force the data store schema updates.
504 504
 	 */
505 505
 	protected function recreate_tables() {
506
-		if ( is_a( $this->store, 'ActionScheduler_HybridStore' ) ) {
506
+		if (is_a($this->store, 'ActionScheduler_HybridStore')) {
507 507
 			$store = $this->store;
508 508
 		} else {
509 509
 			$store = new ActionScheduler_HybridStore();
510 510
 		}
511
-		add_action( 'action_scheduler/created_table', array( $store, 'set_autoincrement' ), 10, 2 );
511
+		add_action('action_scheduler/created_table', array($store, 'set_autoincrement'), 10, 2);
512 512
 
513 513
 		$store_schema  = new ActionScheduler_StoreSchema();
514 514
 		$logger_schema = new ActionScheduler_LoggerSchema();
515
-		$store_schema->register_tables( true );
516
-		$logger_schema->register_tables( true );
515
+		$store_schema->register_tables(true);
516
+		$logger_schema->register_tables(true);
517 517
 
518
-		remove_action( 'action_scheduler/created_table', array( $store, 'set_autoincrement' ), 10 );
518
+		remove_action('action_scheduler/created_table', array($store, 'set_autoincrement'), 10);
519 519
 	}
520 520
 	/**
521 521
 	 * Implements the logic behind processing an action once an action link is clicked on the list table.
@@ -523,24 +523,24 @@  discard block
 block discarded – undo
523 523
 	 * @param int $action_id
524 524
 	 * @param string $row_action_type The type of action to perform on the action.
525 525
 	 */
526
-	protected function process_row_action( $action_id, $row_action_type ) {
526
+	protected function process_row_action($action_id, $row_action_type) {
527 527
 		try {
528
-			switch ( $row_action_type ) {
528
+			switch ($row_action_type) {
529 529
 				case 'run' :
530
-					$this->runner->process_action( $action_id, 'Admin List Table' );
530
+					$this->runner->process_action($action_id, 'Admin List Table');
531 531
 					break;
532 532
 				case 'cancel' :
533
-					$this->store->cancel_action( $action_id );
533
+					$this->store->cancel_action($action_id);
534 534
 					break;
535 535
 			}
536 536
 			$success = 1;
537 537
 			$error_message = '';
538
-		} catch ( Exception $e ) {
538
+		} catch (Exception $e) {
539 539
 			$success = 0;
540 540
 			$error_message = $e->getMessage();
541 541
 		}
542 542
 
543
-		set_transient( 'action_scheduler_admin_notice', compact( 'action_id', 'success', 'error_message', 'row_action_type' ), 30 );
543
+		set_transient('action_scheduler_admin_notice', compact('action_id', 'success', 'error_message', 'row_action_type'), 30);
544 544
 	}
545 545
 
546 546
 	/**
@@ -549,7 +549,7 @@  discard block
 block discarded – undo
549 549
 	public function prepare_items() {
550 550
 		$this->prepare_column_headers();
551 551
 
552
-		$per_page = $this->get_items_per_page( $this->package . '_items_per_page', $this->items_per_page );
552
+		$per_page = $this->get_items_per_page($this->package . '_items_per_page', $this->items_per_page);
553 553
 		$query = array(
554 554
 			'per_page' => $per_page,
555 555
 			'offset'   => $this->get_items_offset(),
@@ -561,37 +561,37 @@  discard block
 block discarded – undo
561 561
 
562 562
 		$this->items = array();
563 563
 
564
-		$total_items = $this->store->query_actions( $query, 'count' );
564
+		$total_items = $this->store->query_actions($query, 'count');
565 565
 
566 566
 		$status_labels = $this->store->get_status_labels();
567 567
 
568
-		foreach ( $this->store->query_actions( $query ) as $action_id ) {
568
+		foreach ($this->store->query_actions($query) as $action_id) {
569 569
 			try {
570
-				$action = $this->store->fetch_action( $action_id );
571
-			} catch ( Exception $e ) {
570
+				$action = $this->store->fetch_action($action_id);
571
+			} catch (Exception $e) {
572 572
 				continue;
573 573
 			}
574
-			if ( is_a( $action, 'ActionScheduler_NullAction' ) ) {
574
+			if (is_a($action, 'ActionScheduler_NullAction')) {
575 575
 				continue;
576 576
 			}
577
-			$this->items[ $action_id ] = array(
577
+			$this->items[$action_id] = array(
578 578
 				'ID'          => $action_id,
579 579
 				'hook'        => $action->get_hook(),
580
-				'status'      => $status_labels[ $this->store->get_status( $action_id ) ],
580
+				'status'      => $status_labels[$this->store->get_status($action_id)],
581 581
 				'args'        => $action->get_args(),
582 582
 				'group'       => $action->get_group(),
583
-				'log_entries' => $this->logger->get_logs( $action_id ),
584
-				'claim_id'    => $this->store->get_claim_id( $action_id ),
585
-				'recurrence'  => $this->get_recurrence( $action ),
583
+				'log_entries' => $this->logger->get_logs($action_id),
584
+				'claim_id'    => $this->store->get_claim_id($action_id),
585
+				'recurrence'  => $this->get_recurrence($action),
586 586
 				'schedule'    => $action->get_schedule(),
587 587
 			);
588 588
 		}
589 589
 
590
-		$this->set_pagination_args( array(
590
+		$this->set_pagination_args(array(
591 591
 			'total_items' => $total_items,
592 592
 			'per_page'    => $per_page,
593
-			'total_pages' => ceil( $total_items / $per_page ),
594
-		) );
593
+			'total_pages' => ceil($total_items / $per_page),
594
+		));
595 595
 	}
596 596
 
597 597
 	/**
@@ -606,6 +606,6 @@  discard block
 block discarded – undo
606 606
 	 * Get the text to display in the search box on the list table.
607 607
 	 */
608 608
 	protected function get_search_box_button_text() {
609
-		return __( 'Search hook, args and claim ID', 'action-scheduler' );
609
+		return __('Search hook, args and claim ID', 'action-scheduler');
610 610
 	}
611 611
 }
Please login to merge, or discard this patch.
includes/libraries/action-scheduler/classes/WP_CLI/ProgressBar.php 1 patch
Spacing   +8 added lines, -8 removed lines patch added patch discarded remove patch
@@ -41,10 +41,10 @@  discard block
 block discarded – undo
41 41
  	 *
42 42
 	 * @throws Exception When this is not run within WP CLI
43 43
 	 */
44
-	public function __construct( $message, $count, $interval = 100 ) {
45
-		if ( ! ( defined( 'WP_CLI' ) && WP_CLI ) ) {
44
+	public function __construct($message, $count, $interval = 100) {
45
+		if (!(defined('WP_CLI') && WP_CLI)) {
46 46
 			/* translators: %s php class name */
47
-			throw new \Exception( sprintf( __( 'The %s class can only be run within WP CLI.', 'action-scheduler' ), __CLASS__ ) );
47
+			throw new \Exception(sprintf(__('The %s class can only be run within WP CLI.', 'action-scheduler'), __CLASS__));
48 48
 		}
49 49
 
50 50
 		$this->total_ticks = 0;
@@ -57,14 +57,14 @@  discard block
 block discarded – undo
57 57
 	 * Increment the progress bar ticks.
58 58
 	 */
59 59
 	public function tick() {
60
-		if ( null === $this->progress_bar ) {
60
+		if (null === $this->progress_bar) {
61 61
 			$this->setup_progress_bar();
62 62
 		}
63 63
 
64 64
 		$this->progress_bar->tick();
65 65
 		$this->total_ticks++;
66 66
 
67
-		do_action( 'action_scheduler/progress_tick', $this->total_ticks );
67
+		do_action('action_scheduler/progress_tick', $this->total_ticks);
68 68
 	}
69 69
 
70 70
 	/**
@@ -80,7 +80,7 @@  discard block
 block discarded – undo
80 80
 	 * Finish the current progress bar.
81 81
 	 */
82 82
 	public function finish() {
83
-		if ( null !== $this->progress_bar ) {
83
+		if (null !== $this->progress_bar) {
84 84
 			$this->progress_bar->finish();
85 85
 		}
86 86
 
@@ -92,7 +92,7 @@  discard block
 block discarded – undo
92 92
 	 *
93 93
 	 * @param string $message The message to be used when the next progress bar is created.
94 94
 	 */
95
-	public function set_message( $message ) {
95
+	public function set_message($message) {
96 96
 		$this->message = $message;
97 97
 	}
98 98
 
@@ -101,7 +101,7 @@  discard block
 block discarded – undo
101 101
 	 *
102 102
 	 * @param integer $count The total number of ticks expected to complete.
103 103
 	 */
104
-	public function set_count( $count ) {
104
+	public function set_count($count) {
105 105
 		$this->count = $count;
106 106
 		$this->finish();
107 107
 	}
Please login to merge, or discard this patch.
action-scheduler/classes/WP_CLI/ActionScheduler_WPCLI_QueueRunner.php 1 patch
Spacing   +37 added lines, -37 removed lines patch added patch discarded remove patch
@@ -27,13 +27,13 @@  discard block
 block discarded – undo
27 27
 	 *
28 28
 	 * @throws Exception When this is not run within WP CLI
29 29
 	 */
30
-	public function __construct( ActionScheduler_Store $store = null, ActionScheduler_FatalErrorMonitor $monitor = null, ActionScheduler_QueueCleaner $cleaner = null ) {
31
-		if ( ! ( defined( 'WP_CLI' ) && WP_CLI ) ) {
30
+	public function __construct(ActionScheduler_Store $store = null, ActionScheduler_FatalErrorMonitor $monitor = null, ActionScheduler_QueueCleaner $cleaner = null) {
31
+		if (!(defined('WP_CLI') && WP_CLI)) {
32 32
 			/* translators: %s php class name */
33
-			throw new Exception( sprintf( __( 'The %s class can only be run within WP CLI.', 'action-scheduler' ), __CLASS__ ) );
33
+			throw new Exception(sprintf(__('The %s class can only be run within WP CLI.', 'action-scheduler'), __CLASS__));
34 34
 		}
35 35
 
36
-		parent::__construct( $store, $monitor, $cleaner );
36
+		parent::__construct($store, $monitor, $cleaner);
37 37
 	}
38 38
 
39 39
 	/**
@@ -49,25 +49,25 @@  discard block
 block discarded – undo
49 49
 	 * @return int The number of actions that will be run.
50 50
 	 * @throws \WP_CLI\ExitException When there are too many concurrent batches.
51 51
 	 */
52
-	public function setup( $batch_size, $hooks = array(), $group = '', $force = false ) {
52
+	public function setup($batch_size, $hooks = array(), $group = '', $force = false) {
53 53
 		$this->run_cleanup();
54 54
 		$this->add_hooks();
55 55
 
56 56
 		// Check to make sure there aren't too many concurrent processes running.
57
-		if ( $this->has_maximum_concurrent_batches() ) {
58
-			if ( $force ) {
59
-				WP_CLI::warning( __( 'There are too many concurrent batches, but the run is forced to continue.', 'action-scheduler' ) );
57
+		if ($this->has_maximum_concurrent_batches()) {
58
+			if ($force) {
59
+				WP_CLI::warning(__('There are too many concurrent batches, but the run is forced to continue.', 'action-scheduler'));
60 60
 			} else {
61
-				WP_CLI::error( __( 'There are too many concurrent batches.', 'action-scheduler' ) );
61
+				WP_CLI::error(__('There are too many concurrent batches.', 'action-scheduler'));
62 62
 			}
63 63
 		}
64 64
 
65 65
 		// Stake a claim and store it.
66
-		$this->claim = $this->store->stake_claim( $batch_size, null, $hooks, $group );
67
-		$this->monitor->attach( $this->claim );
66
+		$this->claim = $this->store->stake_claim($batch_size, null, $hooks, $group);
67
+		$this->monitor->attach($this->claim);
68 68
 		$this->actions = $this->claim->get_actions();
69 69
 
70
-		return count( $this->actions );
70
+		return count($this->actions);
71 71
 	}
72 72
 
73 73
 	/**
@@ -76,9 +76,9 @@  discard block
 block discarded – undo
76 76
 	 * @author Jeremy Pry
77 77
 	 */
78 78
 	protected function add_hooks() {
79
-		add_action( 'action_scheduler_before_execute', array( $this, 'before_execute' ) );
80
-		add_action( 'action_scheduler_after_execute', array( $this, 'after_execute' ), 10, 2 );
81
-		add_action( 'action_scheduler_failed_execution', array( $this, 'action_failed' ), 10, 2 );
79
+		add_action('action_scheduler_before_execute', array($this, 'before_execute'));
80
+		add_action('action_scheduler_after_execute', array($this, 'after_execute'), 10, 2);
81
+		add_action('action_scheduler_failed_execution', array($this, 'action_failed'), 10, 2);
82 82
 	}
83 83
 
84 84
 	/**
@@ -87,10 +87,10 @@  discard block
 block discarded – undo
87 87
 	 * @author Jeremy Pry
88 88
 	 */
89 89
 	protected function setup_progress_bar() {
90
-		$count              = count( $this->actions );
90
+		$count              = count($this->actions);
91 91
 		$this->progress_bar = new ProgressBar(
92 92
 			/* translators: %d: amount of actions */
93
-			sprintf( _n( 'Running %d action', 'Running %d actions', $count, 'action-scheduler' ), number_format_i18n( $count ) ),
93
+			sprintf(_n('Running %d action', 'Running %d actions', $count, 'action-scheduler'), number_format_i18n($count)),
94 94
 			$count
95 95
 		);
96 96
 	}
@@ -104,24 +104,24 @@  discard block
 block discarded – undo
104 104
 	 *
105 105
 	 * @return int The number of actions processed.
106 106
 	 */
107
-	public function run( $context = 'WP CLI' ) {
108
-		do_action( 'action_scheduler_before_process_queue' );
107
+	public function run($context = 'WP CLI') {
108
+		do_action('action_scheduler_before_process_queue');
109 109
 		$this->setup_progress_bar();
110
-		foreach ( $this->actions as $action_id ) {
110
+		foreach ($this->actions as $action_id) {
111 111
 			// Error if we lost the claim.
112
-			if ( ! in_array( $action_id, $this->store->find_actions_by_claim_id( $this->claim->get_id() ) ) ) {
113
-				WP_CLI::warning( __( 'The claim has been lost. Aborting current batch.', 'action-scheduler' ) );
112
+			if (!in_array($action_id, $this->store->find_actions_by_claim_id($this->claim->get_id()))) {
113
+				WP_CLI::warning(__('The claim has been lost. Aborting current batch.', 'action-scheduler'));
114 114
 				break;
115 115
 			}
116 116
 
117
-			$this->process_action( $action_id, $context );
117
+			$this->process_action($action_id, $context);
118 118
 			$this->progress_bar->tick();
119 119
 		}
120 120
 
121 121
 		$completed = $this->progress_bar->current();
122 122
 		$this->progress_bar->finish();
123
-		$this->store->release_claim( $this->claim );
124
-		do_action( 'action_scheduler_after_process_queue' );
123
+		$this->store->release_claim($this->claim);
124
+		do_action('action_scheduler_after_process_queue');
125 125
 
126 126
 		return $completed;
127 127
 	}
@@ -133,9 +133,9 @@  discard block
 block discarded – undo
133 133
 	 *
134 134
 	 * @param $action_id
135 135
 	 */
136
-	public function before_execute( $action_id ) {
136
+	public function before_execute($action_id) {
137 137
 		/* translators: %s refers to the action ID */
138
-		WP_CLI::log( sprintf( __( 'Started processing action %s', 'action-scheduler' ), $action_id ) );
138
+		WP_CLI::log(sprintf(__('Started processing action %s', 'action-scheduler'), $action_id));
139 139
 	}
140 140
 
141 141
 	/**
@@ -146,13 +146,13 @@  discard block
 block discarded – undo
146 146
 	 * @param int $action_id
147 147
 	 * @param null|ActionScheduler_Action $action The instance of the action. Default to null for backward compatibility.
148 148
 	 */
149
-	public function after_execute( $action_id, $action = null ) {
149
+	public function after_execute($action_id, $action = null) {
150 150
 		// backward compatibility
151
-		if ( null === $action ) {
152
-			$action = $this->store->fetch_action( $action_id );
151
+		if (null === $action) {
152
+			$action = $this->store->fetch_action($action_id);
153 153
 		}
154 154
 		/* translators: 1: action ID 2: hook name */
155
-		WP_CLI::log( sprintf( __( 'Completed processing action %1$s with hook: %2$s', 'action-scheduler' ), $action_id, $action->get_hook() ) );
155
+		WP_CLI::log(sprintf(__('Completed processing action %1$s with hook: %2$s', 'action-scheduler'), $action_id, $action->get_hook()));
156 156
 	}
157 157
 
158 158
 	/**
@@ -164,10 +164,10 @@  discard block
 block discarded – undo
164 164
 	 * @param Exception $exception
165 165
 	 * @throws \WP_CLI\ExitException With failure message.
166 166
 	 */
167
-	public function action_failed( $action_id, $exception ) {
167
+	public function action_failed($action_id, $exception) {
168 168
 		WP_CLI::error(
169 169
 			/* translators: 1: action ID 2: exception message */
170
-			sprintf( __( 'Error processing action %1$s: %2$s', 'action-scheduler' ), $action_id, $exception->getMessage() ),
170
+			sprintf(__('Error processing action %1$s: %2$s', 'action-scheduler'), $action_id, $exception->getMessage()),
171 171
 			false
172 172
 		);
173 173
 	}
@@ -178,8 +178,8 @@  discard block
 block discarded – undo
178 178
 	 * @param int $sleep_time Amount of seconds to sleep
179 179
 	 * @deprecated 3.0.0
180 180
 	 */
181
-	protected function stop_the_insanity( $sleep_time = 0 ) {
182
-		_deprecated_function( 'ActionScheduler_WPCLI_QueueRunner::stop_the_insanity', '3.0.0', 'ActionScheduler_DataController::free_memory' );
181
+	protected function stop_the_insanity($sleep_time = 0) {
182
+		_deprecated_function('ActionScheduler_WPCLI_QueueRunner::stop_the_insanity', '3.0.0', 'ActionScheduler_DataController::free_memory');
183 183
 
184 184
 		ActionScheduler_DataController::free_memory();
185 185
 	}
@@ -189,8 +189,8 @@  discard block
 block discarded – undo
189 189
 	 */
190 190
 	protected function maybe_stop_the_insanity() {
191 191
 		// The value returned by progress_bar->current() might be padded. Remove padding, and convert to int.
192
-		$current_iteration = intval( trim( $this->progress_bar->current() ) );
193
-		if ( 0 === $current_iteration % 50 ) {
192
+		$current_iteration = intval(trim($this->progress_bar->current()));
193
+		if (0 === $current_iteration % 50) {
194 194
 			$this->stop_the_insanity();
195 195
 		}
196 196
 	}
Please login to merge, or discard this patch.
includes/libraries/action-scheduler/classes/WP_CLI/Migration_Command.php 1 patch
Spacing   +40 added lines, -40 removed lines patch added patch discarded remove patch
@@ -28,11 +28,11 @@  discard block
 block discarded – undo
28 28
 	 * Register the command with WP-CLI
29 29
 	 */
30 30
 	public function register() {
31
-		if ( ! defined( 'WP_CLI' ) || ! WP_CLI ) {
31
+		if (!defined('WP_CLI') || !WP_CLI) {
32 32
 			return;
33 33
 		}
34 34
 
35
-		WP_CLI::add_command( 'action-scheduler migrate', [ $this, 'migrate' ], [
35
+		WP_CLI::add_command('action-scheduler migrate', [$this, 'migrate'], [
36 36
 			'shortdesc' => 'Migrates actions to the DB tables store',
37 37
 			'synopsis'  => [
38 38
 				[
@@ -63,7 +63,7 @@  discard block
 block discarded – undo
63 63
 					'description' => 'Reports on the actions that would have been migrated, but does not change any data',
64 64
 				],
65 65
 			],
66
-		] );
66
+		]);
67 67
 	}
68 68
 
69 69
 	/**
@@ -74,31 +74,31 @@  discard block
 block discarded – undo
74 74
 	 *
75 75
 	 * @return void
76 76
 	 */
77
-	public function migrate( $positional_args, $assoc_args ) {
77
+	public function migrate($positional_args, $assoc_args) {
78 78
 		$this->init_logging();
79 79
 
80
-		$config = $this->get_migration_config( $assoc_args );
81
-		$runner = new Runner( $config );
80
+		$config = $this->get_migration_config($assoc_args);
81
+		$runner = new Runner($config);
82 82
 		$runner->init_destination();
83 83
 
84
-		$batch_size = isset( $assoc_args[ 'batch-size' ] ) ? (int) $assoc_args[ 'batch-size' ] : 100;
85
-		$free_on    = isset( $assoc_args[ 'free-memory-on' ] ) ? (int) $assoc_args[ 'free-memory-on' ] : 50;
86
-		$sleep      = isset( $assoc_args[ 'pause' ] ) ? (int) $assoc_args[ 'pause' ] : 0;
87
-		\ActionScheduler_DataController::set_free_ticks( $free_on );
88
-		\ActionScheduler_DataController::set_sleep_time( $sleep );
84
+		$batch_size = isset($assoc_args['batch-size']) ? (int) $assoc_args['batch-size'] : 100;
85
+		$free_on    = isset($assoc_args['free-memory-on']) ? (int) $assoc_args['free-memory-on'] : 50;
86
+		$sleep      = isset($assoc_args['pause']) ? (int) $assoc_args['pause'] : 0;
87
+		\ActionScheduler_DataController::set_free_ticks($free_on);
88
+		\ActionScheduler_DataController::set_sleep_time($sleep);
89 89
 
90 90
 		do {
91
-			$actions_processed     = $runner->run( $batch_size );
91
+			$actions_processed = $runner->run($batch_size);
92 92
 			$this->total_processed += $actions_processed;
93
-		} while ( $actions_processed > 0 );
93
+		} while ($actions_processed > 0);
94 94
 
95
-		if ( ! $config->get_dry_run() ) {
95
+		if (!$config->get_dry_run()) {
96 96
 			// let the scheduler know that there's nothing left to do
97 97
 			$scheduler = new Scheduler();
98 98
 			$scheduler->mark_complete();
99 99
 		}
100 100
 
101
-		WP_CLI::success( sprintf( '%s complete. %d actions processed.', $config->get_dry_run() ? 'Dry run' : 'Migration', $this->total_processed ) );
101
+		WP_CLI::success(sprintf('%s complete. %d actions processed.', $config->get_dry_run() ? 'Dry run' : 'Migration', $this->total_processed));
102 102
 	}
103 103
 
104 104
 	/**
@@ -108,13 +108,13 @@  discard block
 block discarded – undo
108 108
 	 *
109 109
 	 * @return ActionScheduler\Migration\Config
110 110
 	 */
111
-	private function get_migration_config( $args ) {
112
-		$args = wp_parse_args( $args, [
111
+	private function get_migration_config($args) {
112
+		$args = wp_parse_args($args, [
113 113
 			'dry-run' => false,
114
-		] );
114
+		]);
115 115
 
116 116
 		$config = Controller::instance()->get_migration_config_object();
117
-		$config->set_dry_run( ! empty( $args[ 'dry-run' ] ) );
117
+		$config->set_dry_run(!empty($args['dry-run']));
118 118
 
119 119
 		return $config;
120 120
 	}
@@ -123,26 +123,26 @@  discard block
 block discarded – undo
123 123
 	 * Hook command line logging into migration actions.
124 124
 	 */
125 125
 	private function init_logging() {
126
-		add_action( 'action_scheduler/migrate_action_dry_run', function ( $action_id ) {
127
-			WP_CLI::debug( sprintf( 'Dry-run: migrated action %d', $action_id ) );
128
-		}, 10, 1 );
129
-		add_action( 'action_scheduler/no_action_to_migrate', function ( $action_id ) {
130
-			WP_CLI::debug( sprintf( 'No action found to migrate for ID %d', $action_id ) );
131
-		}, 10, 1 );
132
-		add_action( 'action_scheduler/migrate_action_failed', function ( $action_id ) {
133
-			WP_CLI::warning( sprintf( 'Failed migrating action with ID %d', $action_id ) );
134
-		}, 10, 1 );
135
-		add_action( 'action_scheduler/migrate_action_incomplete', function ( $source_id, $destination_id ) {
136
-			WP_CLI::warning( sprintf( 'Unable to remove source action with ID %d after migrating to new ID %d', $source_id, $destination_id ) );
137
-		}, 10, 2 );
138
-		add_action( 'action_scheduler/migrated_action', function ( $source_id, $destination_id ) {
139
-			WP_CLI::debug( sprintf( 'Migrated source action with ID %d to new store with ID %d', $source_id, $destination_id ) );
140
-		}, 10, 2 );
141
-		add_action( 'action_scheduler/migration_batch_starting', function ( $batch ) {
142
-			WP_CLI::debug( 'Beginning migration of batch: ' . print_r( $batch, true ) );
143
-		}, 10, 1 );
144
-		add_action( 'action_scheduler/migration_batch_complete', function ( $batch ) {
145
-			WP_CLI::log( sprintf( 'Completed migration of %d actions', count( $batch ) ) );
146
-		}, 10, 1 );
126
+		add_action('action_scheduler/migrate_action_dry_run', function($action_id) {
127
+			WP_CLI::debug(sprintf('Dry-run: migrated action %d', $action_id));
128
+		}, 10, 1);
129
+		add_action('action_scheduler/no_action_to_migrate', function($action_id) {
130
+			WP_CLI::debug(sprintf('No action found to migrate for ID %d', $action_id));
131
+		}, 10, 1);
132
+		add_action('action_scheduler/migrate_action_failed', function($action_id) {
133
+			WP_CLI::warning(sprintf('Failed migrating action with ID %d', $action_id));
134
+		}, 10, 1);
135
+		add_action('action_scheduler/migrate_action_incomplete', function($source_id, $destination_id) {
136
+			WP_CLI::warning(sprintf('Unable to remove source action with ID %d after migrating to new ID %d', $source_id, $destination_id));
137
+		}, 10, 2);
138
+		add_action('action_scheduler/migrated_action', function($source_id, $destination_id) {
139
+			WP_CLI::debug(sprintf('Migrated source action with ID %d to new store with ID %d', $source_id, $destination_id));
140
+		}, 10, 2);
141
+		add_action('action_scheduler/migration_batch_starting', function($batch) {
142
+			WP_CLI::debug('Beginning migration of batch: ' . print_r($batch, true));
143
+		}, 10, 1);
144
+		add_action('action_scheduler/migration_batch_complete', function($batch) {
145
+			WP_CLI::log(sprintf('Completed migration of %d actions', count($batch)));
146
+		}, 10, 1);
147 147
 	}
148 148
 }
Please login to merge, or discard this patch.
action-scheduler/classes/WP_CLI/ActionScheduler_WPCLI_Scheduler_command.php 1 patch
Spacing   +33 added lines, -33 removed lines patch added patch discarded remove patch
@@ -40,20 +40,20 @@  discard block
 block discarded – undo
40 40
 	 *
41 41
 	 * @subcommand run
42 42
 	 */
43
-	public function run( $args, $assoc_args ) {
43
+	public function run($args, $assoc_args) {
44 44
 		// Handle passed arguments.
45
-		$batch   = absint( \WP_CLI\Utils\get_flag_value( $assoc_args, 'batch-size', 100 ) );
46
-		$batches = absint( \WP_CLI\Utils\get_flag_value( $assoc_args, 'batches', 0 ) );
47
-		$clean   = absint( \WP_CLI\Utils\get_flag_value( $assoc_args, 'cleanup-batch-size', $batch ) );
48
-		$hooks   = explode( ',', WP_CLI\Utils\get_flag_value( $assoc_args, 'hooks', '' ) );
49
-		$hooks   = array_filter( array_map( 'trim', $hooks ) );
50
-		$group   = \WP_CLI\Utils\get_flag_value( $assoc_args, 'group', '' );
51
-		$free_on = \WP_CLI\Utils\get_flag_value( $assoc_args, 'free-memory-on', '' );
52
-		$sleep   = \WP_CLI\Utils\get_flag_value( $assoc_args, 'pause', '' );
53
-		$force   = \WP_CLI\Utils\get_flag_value( $assoc_args, 'force', false );
45
+		$batch   = absint(\WP_CLI\Utils\get_flag_value($assoc_args, 'batch-size', 100));
46
+		$batches = absint(\WP_CLI\Utils\get_flag_value($assoc_args, 'batches', 0));
47
+		$clean   = absint(\WP_CLI\Utils\get_flag_value($assoc_args, 'cleanup-batch-size', $batch));
48
+		$hooks   = explode(',', WP_CLI\Utils\get_flag_value($assoc_args, 'hooks', ''));
49
+		$hooks   = array_filter(array_map('trim', $hooks));
50
+		$group   = \WP_CLI\Utils\get_flag_value($assoc_args, 'group', '');
51
+		$free_on = \WP_CLI\Utils\get_flag_value($assoc_args, 'free-memory-on', '');
52
+		$sleep   = \WP_CLI\Utils\get_flag_value($assoc_args, 'pause', '');
53
+		$force   = \WP_CLI\Utils\get_flag_value($assoc_args, 'force', false);
54 54
 
55
-		ActionScheduler_DataController::set_free_ticks( $free_on );
56
-		ActionScheduler_DataController::set_sleep_time( $sleep );
55
+		ActionScheduler_DataController::set_free_ticks($free_on);
56
+		ActionScheduler_DataController::set_sleep_time($sleep);
57 57
 
58 58
 		$batches_completed = 0;
59 59
 		$actions_completed = 0;
@@ -61,29 +61,29 @@  discard block
 block discarded – undo
61 61
 
62 62
 		try {
63 63
 			// Custom queue cleaner instance.
64
-			$cleaner = new ActionScheduler_QueueCleaner( null, $clean );
64
+			$cleaner = new ActionScheduler_QueueCleaner(null, $clean);
65 65
 
66 66
 			// Get the queue runner instance
67
-			$runner = new ActionScheduler_WPCLI_QueueRunner( null, null, $cleaner );
67
+			$runner = new ActionScheduler_WPCLI_QueueRunner(null, null, $cleaner);
68 68
 
69 69
 			// Determine how many tasks will be run in the first batch.
70
-			$total = $runner->setup( $batch, $hooks, $group, $force );
70
+			$total = $runner->setup($batch, $hooks, $group, $force);
71 71
 
72 72
 			// Run actions for as long as possible.
73
-			while ( $total > 0 ) {
74
-				$this->print_total_actions( $total );
73
+			while ($total > 0) {
74
+				$this->print_total_actions($total);
75 75
 				$actions_completed += $runner->run();
76 76
 				$batches_completed++;
77 77
 
78 78
 				// Maybe set up tasks for the next batch.
79
-				$total = ( $unlimited || $batches_completed < $batches ) ? $runner->setup( $batch, $hooks, $group, $force ) : 0;
79
+				$total = ($unlimited || $batches_completed < $batches) ? $runner->setup($batch, $hooks, $group, $force) : 0;
80 80
 			}
81
-		} catch ( Exception $e ) {
82
-			$this->print_error( $e );
81
+		} catch (Exception $e) {
82
+			$this->print_error($e);
83 83
 		}
84 84
 
85
-		$this->print_total_batches( $batches_completed );
86
-		$this->print_success( $actions_completed );
85
+		$this->print_total_batches($batches_completed);
86
+		$this->print_success($actions_completed);
87 87
 	}
88 88
 
89 89
 	/**
@@ -93,12 +93,12 @@  discard block
 block discarded – undo
93 93
 	 *
94 94
 	 * @param int $total
95 95
 	 */
96
-	protected function print_total_actions( $total ) {
96
+	protected function print_total_actions($total) {
97 97
 		WP_CLI::log(
98 98
 			sprintf(
99 99
 				/* translators: %d refers to how many scheduled taks were found to run */
100
-				_n( 'Found %d scheduled task', 'Found %d scheduled tasks', $total, 'action-scheduler' ),
101
-				number_format_i18n( $total )
100
+				_n('Found %d scheduled task', 'Found %d scheduled tasks', $total, 'action-scheduler'),
101
+				number_format_i18n($total)
102 102
 			)
103 103
 		);
104 104
 	}
@@ -110,12 +110,12 @@  discard block
 block discarded – undo
110 110
 	 *
111 111
 	 * @param int $batches_completed
112 112
 	 */
113
-	protected function print_total_batches( $batches_completed ) {
113
+	protected function print_total_batches($batches_completed) {
114 114
 		WP_CLI::log(
115 115
 			sprintf(
116 116
 				/* translators: %d refers to the total number of batches executed */
117
-				_n( '%d batch executed.', '%d batches executed.', $batches_completed, 'action-scheduler' ),
118
-				number_format_i18n( $batches_completed )
117
+				_n('%d batch executed.', '%d batches executed.', $batches_completed, 'action-scheduler'),
118
+				number_format_i18n($batches_completed)
119 119
 			)
120 120
 		);
121 121
 	}
@@ -129,11 +129,11 @@  discard block
 block discarded – undo
129 129
 	 *
130 130
 	 * @throws \WP_CLI\ExitException
131 131
 	 */
132
-	protected function print_error( Exception $e ) {
132
+	protected function print_error(Exception $e) {
133 133
 		WP_CLI::error(
134 134
 			sprintf(
135 135
 				/* translators: %s refers to the exception error message */
136
-				__( 'There was an error running the action scheduler: %s', 'action-scheduler' ),
136
+				__('There was an error running the action scheduler: %s', 'action-scheduler'),
137 137
 				$e->getMessage()
138 138
 			)
139 139
 		);
@@ -146,12 +146,12 @@  discard block
 block discarded – undo
146 146
 	 *
147 147
 	 * @param int $actions_completed
148 148
 	 */
149
-	protected function print_success( $actions_completed ) {
149
+	protected function print_success($actions_completed) {
150 150
 		WP_CLI::success(
151 151
 			sprintf(
152 152
 				/* translators: %d refers to the total number of taskes completed */
153
-				_n( '%d scheduled task completed.', '%d scheduled tasks completed.', $actions_completed, 'action-scheduler' ),
154
-				number_format_i18n( $actions_completed )
153
+				_n('%d scheduled task completed.', '%d scheduled tasks completed.', $actions_completed, 'action-scheduler'),
154
+				number_format_i18n($actions_completed)
155 155
 			)
156 156
 		);
157 157
 	}
Please login to merge, or discard this patch.
includes/libraries/action-scheduler/classes/ActionScheduler_DateTime.php 1 patch
Spacing   +5 added lines, -5 removed lines patch added patch discarded remove patch
@@ -25,7 +25,7 @@  discard block
 block discarded – undo
25 25
 	 * @return int
26 26
 	 */
27 27
 	public function getTimestamp() {
28
-		return method_exists( 'DateTime', 'getTimestamp' ) ? parent::getTimestamp() : $this->format( 'U' );
28
+		return method_exists('DateTime', 'getTimestamp') ? parent::getTimestamp() : $this->format('U');
29 29
 	}
30 30
 
31 31
 	/**
@@ -35,8 +35,8 @@  discard block
 block discarded – undo
35 35
 	 *
36 36
 	 * @param $offset
37 37
 	 */
38
-	public function setUtcOffset( $offset ) {
39
-		$this->utcOffset = intval( $offset );
38
+	public function setUtcOffset($offset) {
39
+		$this->utcOffset = intval($offset);
40 40
 	}
41 41
 
42 42
 	/**
@@ -57,9 +57,9 @@  discard block
 block discarded – undo
57 57
 	 * @return static
58 58
 	 * @link http://php.net/manual/en/datetime.settimezone.php
59 59
 	 */
60
-	public function setTimezone( $timezone ) {
60
+	public function setTimezone($timezone) {
61 61
 		$this->utcOffset = 0;
62
-		parent::setTimezone( $timezone );
62
+		parent::setTimezone($timezone);
63 63
 
64 64
 		return $this;
65 65
 	}
Please login to merge, or discard this patch.
includes/libraries/action-scheduler/classes/ActionScheduler_LogEntry.php 1 patch
Spacing   +5 added lines, -5 removed lines patch added patch discarded remove patch
@@ -8,12 +8,12 @@  discard block
 block discarded – undo
8 8
 	/**
9 9
 	 * @var int $action_id
10 10
 	 */
11
-	protected $action_id =  '';
11
+	protected $action_id = '';
12 12
 
13 13
 	/**
14 14
 	 * @var string $message
15 15
 	 */
16
-	protected $message =  '';
16
+	protected $message = '';
17 17
 
18 18
 	/**
19 19
 	 * @var Datetime $date
@@ -28,7 +28,7 @@  discard block
 block discarded – undo
28 28
 	 * @param Datetime $date    Datetime object with the time when this log entry was created. If this parameter is
29 29
 	 *                          not provided a new Datetime object (with current time) will be created.
30 30
 	 */
31
-	public function __construct( $action_id, $message, $date = null ) {
31
+	public function __construct($action_id, $message, $date = null) {
32 32
 
33 33
 		/*
34 34
 		 * ActionScheduler_wpCommentLogger::get_entry() previously passed a 3rd param of $comment->comment_type
@@ -37,8 +37,8 @@  discard block
 block discarded – undo
37 37
 		 * goodness knows why, so we need to guard against that here instead of using a DateTime type declaration
38 38
 		 * for the constructor's 3rd param of $date and causing a fatal error with older versions of FUE.
39 39
 		 */
40
-		if ( null !== $date && ! is_a( $date, 'DateTime' ) ) {
41
-			_doing_it_wrong( __METHOD__, 'The third parameter must be a valid DateTime instance, or null.', '2.0.0' );
40
+		if (null !== $date && !is_a($date, 'DateTime')) {
41
+			_doing_it_wrong(__METHOD__, 'The third parameter must be a valid DateTime instance, or null.', '2.0.0');
42 42
 			$date = null;
43 43
 		}
44 44
 
Please login to merge, or discard this patch.
libraries/action-scheduler/classes/ActionScheduler_DataController.php 1 patch
Spacing   +25 added lines, -25 removed lines patch added patch discarded remove patch
@@ -44,8 +44,8 @@  discard block
 block discarded – undo
44 44
 	 * @return bool
45 45
 	 */
46 46
 	public static function dependencies_met() {
47
-		$php_support = version_compare( PHP_VERSION, self::MIN_PHP_VERSION, '>=' );
48
-		return $php_support && apply_filters( 'action_scheduler_migration_dependencies_met', true );
47
+		$php_support = version_compare(PHP_VERSION, self::MIN_PHP_VERSION, '>=');
48
+		return $php_support && apply_filters('action_scheduler_migration_dependencies_met', true);
49 49
 	}
50 50
 
51 51
 	/**
@@ -54,14 +54,14 @@  discard block
 block discarded – undo
54 54
 	 * @return bool Whether the flag has been set marking the migration as complete
55 55
 	 */
56 56
 	public static function is_migration_complete() {
57
-		return get_option( self::STATUS_FLAG ) === self::STATUS_COMPLETE;
57
+		return get_option(self::STATUS_FLAG) === self::STATUS_COMPLETE;
58 58
 	}
59 59
 
60 60
 	/**
61 61
 	 * Mark the migration as complete.
62 62
 	 */
63 63
 	public static function mark_migration_complete() {
64
-		update_option( self::STATUS_FLAG, self::STATUS_COMPLETE );
64
+		update_option(self::STATUS_FLAG, self::STATUS_COMPLETE);
65 65
 	}
66 66
 
67 67
 	/**
@@ -70,7 +70,7 @@  discard block
 block discarded – undo
70 70
 	 * deactivated and the site was running on AS 2.x again.
71 71
 	 */
72 72
 	public static function mark_migration_incomplete() {
73
-		delete_option( self::STATUS_FLAG );
73
+		delete_option(self::STATUS_FLAG);
74 74
 	}
75 75
 
76 76
 	/**
@@ -80,7 +80,7 @@  discard block
 block discarded – undo
80 80
 	 *
81 81
 	 * @return string
82 82
 	 */
83
-	public static function set_store_class( $class ) {
83
+	public static function set_store_class($class) {
84 84
 		return self::DATASTORE_CLASS;
85 85
 	}
86 86
 
@@ -91,7 +91,7 @@  discard block
 block discarded – undo
91 91
 	 *
92 92
 	 * @return string
93 93
 	 */
94
-	public static function set_logger_class( $class ) {
94
+	public static function set_logger_class($class) {
95 95
 		return self::LOGGER_CLASS;
96 96
 	}
97 97
 
@@ -100,7 +100,7 @@  discard block
 block discarded – undo
100 100
 	 *
101 101
 	 * @param integer $sleep_time The number of seconds to pause before resuming operation.
102 102
 	 */
103
-	public static function set_sleep_time( $sleep_time ) {
103
+	public static function set_sleep_time($sleep_time) {
104 104
 		self::$sleep_time = $sleep_time;
105 105
 	}
106 106
 
@@ -109,7 +109,7 @@  discard block
 block discarded – undo
109 109
 	 *
110 110
 	 * @param integer $free_ticks The number of ticks to free memory on.
111 111
 	 */
112
-	public static function set_free_ticks( $free_ticks ) {
112
+	public static function set_free_ticks($free_ticks) {
113 113
 		self::$free_ticks = $free_ticks;
114 114
 	}
115 115
 
@@ -118,8 +118,8 @@  discard block
 block discarded – undo
118 118
 	 *
119 119
 	 * @param int $ticks Current tick count.
120 120
 	 */
121
-	public static function maybe_free_memory( $ticks ) {
122
-		if ( self::$free_ticks && 0 === $ticks % self::$free_ticks ) {
121
+	public static function maybe_free_memory($ticks) {
122
+		if (self::$free_ticks && 0 === $ticks % self::$free_ticks) {
123 123
 			self::free_memory();
124 124
 		}
125 125
 	}
@@ -128,13 +128,13 @@  discard block
 block discarded – undo
128 128
 	 * Reduce memory footprint by clearing the database query and object caches.
129 129
 	 */
130 130
 	public static function free_memory() {
131
-		if ( 0 < self::$sleep_time ) {
131
+		if (0 < self::$sleep_time) {
132 132
 			/* translators: %d: amount of time */
133
-			\WP_CLI::warning( sprintf( _n( 'Stopped the insanity for %d second', 'Stopped the insanity for %d seconds', self::$sleep_time, 'action-scheduler' ), self::$sleep_time ) );
134
-			sleep( self::$sleep_time );
133
+			\WP_CLI::warning(sprintf(_n('Stopped the insanity for %d second', 'Stopped the insanity for %d seconds', self::$sleep_time, 'action-scheduler'), self::$sleep_time));
134
+			sleep(self::$sleep_time);
135 135
 		}
136 136
 
137
-		\WP_CLI::warning( __( 'Attempting to reduce used memory...', 'action-scheduler' ) );
137
+		\WP_CLI::warning(__('Attempting to reduce used memory...', 'action-scheduler'));
138 138
 
139 139
 		/**
140 140
 		 * @var $wpdb            \wpdb
@@ -144,7 +144,7 @@  discard block
 block discarded – undo
144 144
 
145 145
 		$wpdb->queries = array();
146 146
 
147
-		if ( ! is_a( $wp_object_cache, 'WP_Object_Cache' ) ) {
147
+		if (!is_a($wp_object_cache, 'WP_Object_Cache')) {
148 148
 			return;
149 149
 		}
150 150
 
@@ -153,8 +153,8 @@  discard block
 block discarded – undo
153 153
 		$wp_object_cache->memcache_debug = array();
154 154
 		$wp_object_cache->cache          = array();
155 155
 
156
-		if ( is_callable( array( $wp_object_cache, '__remoteset' ) ) ) {
157
-			call_user_func( array( $wp_object_cache, '__remoteset' ) ); // important
156
+		if (is_callable(array($wp_object_cache, '__remoteset'))) {
157
+			call_user_func(array($wp_object_cache, '__remoteset')); // important
158 158
 		}
159 159
 	}
160 160
 
@@ -163,22 +163,22 @@  discard block
 block discarded – undo
163 163
 	 * Otherwise, proceed with the migration if the dependencies have been met.
164 164
 	 */
165 165
 	public static function init() {
166
-		if ( self::is_migration_complete() ) {
167
-			add_filter( 'action_scheduler_store_class', array( 'ActionScheduler_DataController', 'set_store_class' ), 100 );
168
-			add_filter( 'action_scheduler_logger_class', array( 'ActionScheduler_DataController', 'set_logger_class' ), 100 );
169
-			add_action( 'deactivate_plugin', array( 'ActionScheduler_DataController', 'mark_migration_incomplete' ) );
170
-		} elseif ( self::dependencies_met() ) {
166
+		if (self::is_migration_complete()) {
167
+			add_filter('action_scheduler_store_class', array('ActionScheduler_DataController', 'set_store_class'), 100);
168
+			add_filter('action_scheduler_logger_class', array('ActionScheduler_DataController', 'set_logger_class'), 100);
169
+			add_action('deactivate_plugin', array('ActionScheduler_DataController', 'mark_migration_incomplete'));
170
+		} elseif (self::dependencies_met()) {
171 171
 			Controller::init();
172 172
 		}
173 173
 
174
-		add_action( 'action_scheduler/progress_tick', array( 'ActionScheduler_DataController', 'maybe_free_memory' ) );
174
+		add_action('action_scheduler/progress_tick', array('ActionScheduler_DataController', 'maybe_free_memory'));
175 175
 	}
176 176
 
177 177
 	/**
178 178
 	 * Singleton factory.
179 179
 	 */
180 180
 	public static function instance() {
181
-		if ( ! isset( self::$instance ) ) {
181
+		if (!isset(self::$instance)) {
182 182
 			self::$instance = new static();
183 183
 		}
184 184
 
Please login to merge, or discard this patch.
action-scheduler/classes/ActionScheduler_InvalidActionException.php 1 patch
Spacing   +8 added lines, -8 removed lines patch added patch discarded remove patch
@@ -15,15 +15,15 @@  discard block
 block discarded – undo
15 15
 	 * @param string $action_id The action ID with bad args.
16 16
 	 * @return static
17 17
 	 */
18
-	public static function from_schedule( $action_id, $schedule ) {
18
+	public static function from_schedule($action_id, $schedule) {
19 19
 		$message = sprintf(
20 20
 			/* translators: 1: action ID 2: schedule */
21
-			__( 'Action [%1$s] has an invalid schedule: %2$s', 'action-scheduler' ),
21
+			__('Action [%1$s] has an invalid schedule: %2$s', 'action-scheduler'),
22 22
 			$action_id,
23
-			var_export( $schedule, true )
23
+			var_export($schedule, true)
24 24
 		);
25 25
 
26
-		return new static( $message );
26
+		return new static($message);
27 27
 	}
28 28
 
29 29
 	/**
@@ -34,14 +34,14 @@  discard block
 block discarded – undo
34 34
 	 * @param string $action_id The action ID with bad args.
35 35
 	 * @return static
36 36
 	 */
37
-	public static function from_decoding_args( $action_id, $args = array() ) {
37
+	public static function from_decoding_args($action_id, $args = array()) {
38 38
 		$message = sprintf(
39 39
 			/* translators: 1: action ID 2: arguments */
40
-			__( 'Action [%1$s] has invalid arguments. It cannot be JSON decoded to an array. $args = %2$s', 'action-scheduler' ),
40
+			__('Action [%1$s] has invalid arguments. It cannot be JSON decoded to an array. $args = %2$s', 'action-scheduler'),
41 41
 			$action_id,
42
-			var_export( $args, true )
42
+			var_export($args, true)
43 43
 		);
44 44
 
45
-		return new static( $message );
45
+		return new static($message);
46 46
 	}
47 47
 }
Please login to merge, or discard this patch.