insideout10 / wordlift-plugin

src/ext/action-scheduler/classes/ActionScheduler_NullLogEntry.php

Spacing +1 added lines, -1 removed lines

@@ -4,7 +4,7 @@
  * Class ActionScheduler_NullLogEntry
  */
 class ActionScheduler_NullLogEntry extends ActionScheduler_LogEntry {
-	public function __construct( $action_id = '', $message = '' ) {
+	public function __construct($action_id = '', $message = '') {
 		// nothing to see here
 	}
 }

Indentation +3 added lines, -3 removed lines

@@ -4,8 +4,8 @@
  * Class ActionScheduler_NullLogEntry
  */
 class ActionScheduler_NullLogEntry extends ActionScheduler_LogEntry {
-	public function __construct( $action_id = '', $message = '' ) {
-		// nothing to see here
-	}
+    public function __construct( $action_id = '', $message = '' ) {
+        // nothing to see here
+    }
 }
 

src/ext/action-scheduler/classes/abstracts/ActionScheduler_Abstract_Schedule.php

Spacing +7 added lines, -7 removed lines

@@ -22,7 +22,7 @@ 
 	/**
 	 * @param DateTime $date The date & time to run the action.
 	 */
-	public function __construct( DateTime $date ) {
+	public function __construct(DateTime $date) {
 		$this->scheduled_date = $date;
 	}
 
@@ -39,7 +39,7 @@ 
 	 * @param DateTime $after
 	 * @return DateTime
 	 */
-	abstract protected function calculate_next( DateTime $after );
+	abstract protected function calculate_next(DateTime $after);
 
 	/**
 	 * Get the next date & time when this schedule should run after a given date & time.
@@ -47,10 +47,10 @@ 
 	 * @param DateTime $after
 	 * @return DateTime|null
 	 */
-	public function get_next( DateTime $after ) {
+	public function get_next(DateTime $after) {
 		$after = clone $after;
-		if ( $after > $this->scheduled_date ) {
-			$after = $this->calculate_next( $after );
+		if ($after > $this->scheduled_date) {
+			$after = $this->calculate_next($after);
 			return $after;
 		}
 		return clone $this->scheduled_date;
@@ -77,7 +77,7 @@ 
 	}
 
 	public function __wakeup() {
-		$this->scheduled_date = as_get_datetime_object( $this->scheduled_timestamp );
-		unset( $this->scheduled_timestamp );
+		$this->scheduled_date = as_get_datetime_object($this->scheduled_timestamp);
+		unset($this->scheduled_timestamp);
 	}
 }

Indentation +68 added lines, -68 removed lines

@@ -5,80 +5,80 @@
  */
 abstract class ActionScheduler_Abstract_Schedule extends ActionScheduler_Schedule_Deprecated {
 
-	/**
-	 * The date & time the schedule is set to run.
-	 *
-	 * @var DateTime
-	 */
-	private $scheduled_date = null;
+    /**
+     * The date & time the schedule is set to run.
+     *
+     * @var DateTime
+     */
+    private $scheduled_date = null;
 
-	/**
-	 * Timestamp equivalent of @see $this->scheduled_date
-	 *
-	 * @var int
-	 */
-	protected $scheduled_timestamp = null;
+    /**
+     * Timestamp equivalent of @see $this->scheduled_date
+     *
+     * @var int
+     */
+    protected $scheduled_timestamp = null;
 
-	/**
-	 * @param DateTime $date The date & time to run the action.
-	 */
-	public function __construct( DateTime $date ) {
-		$this->scheduled_date = $date;
-	}
+    /**
+     * @param DateTime $date The date & time to run the action.
+     */
+    public function __construct( DateTime $date ) {
+        $this->scheduled_date = $date;
+    }
 
-	/**
-	 * Check if a schedule should recur.
-	 *
-	 * @return bool
-	 */
-	abstract public function is_recurring();
+    /**
+     * Check if a schedule should recur.
+     *
+     * @return bool
+     */
+    abstract public function is_recurring();
 
-	/**
-	 * Calculate when the next instance of this schedule would run based on a given date & time.
-	 *
-	 * @param DateTime $after
-	 * @return DateTime
-	 */
-	abstract protected function calculate_next( DateTime $after );
+    /**
+     * Calculate when the next instance of this schedule would run based on a given date & time.
+     *
+     * @param DateTime $after
+     * @return DateTime
+     */
+    abstract protected function calculate_next( DateTime $after );
 
-	/**
-	 * Get the next date & time when this schedule should run after a given date & time.
-	 *
-	 * @param DateTime $after
-	 * @return DateTime|null
-	 */
-	public function get_next( DateTime $after ) {
-		$after = clone $after;
-		if ( $after > $this->scheduled_date ) {
-			$after = $this->calculate_next( $after );
-			return $after;
-		}
-		return clone $this->scheduled_date;
-	}
+    /**
+     * Get the next date & time when this schedule should run after a given date & time.
+     *
+     * @param DateTime $after
+     * @return DateTime|null
+     */
+    public function get_next( DateTime $after ) {
+        $after = clone $after;
+        if ( $after > $this->scheduled_date ) {
+            $after = $this->calculate_next( $after );
+            return $after;
+        }
+        return clone $this->scheduled_date;
+    }
 
-	/**
-	 * Get the date & time the schedule is set to run.
-	 *
-	 * @return DateTime|null
-	 */
-	public function get_date() {
-		return $this->scheduled_date;
-	}
+    /**
+     * Get the date & time the schedule is set to run.
+     *
+     * @return DateTime|null
+     */
+    public function get_date() {
+        return $this->scheduled_date;
+    }
 
-	/**
-	 * For PHP 5.2 compat, since DateTime objects can't be serialized
-	 *
-	 * @return array
-	 */
-	public function __sleep() {
-		$this->scheduled_timestamp = $this->scheduled_date->getTimestamp();
-		return array(
-			'scheduled_timestamp',
-		);
-	}
+    /**
+     * For PHP 5.2 compat, since DateTime objects can't be serialized
+     *
+     * @return array
+     */
+    public function __sleep() {
+        $this->scheduled_timestamp = $this->scheduled_date->getTimestamp();
+        return array(
+            'scheduled_timestamp',
+        );
+    }
 
-	public function __wakeup() {
-		$this->scheduled_date = as_get_datetime_object( $this->scheduled_timestamp );
-		unset( $this->scheduled_timestamp );
-	}
+    public function __wakeup() {
+        $this->scheduled_date = as_get_datetime_object( $this->scheduled_timestamp );
+        unset( $this->scheduled_timestamp );
+    }
 }

src/ext/action-scheduler/tests/phpunit/migration/Controller_Test.php

Indentation +49 added lines, -49 removed lines

@@ -15,62 +15,62 @@
  * @group migration
  */
 class Controller_Test extends ActionScheduler_UnitTestCase {
-	/**
-	 * Test to ensure the Migration Controller will schedule the migration.
-	 */
-	public function test_schedules_migration() {
-		as_unschedule_action( Scheduler::HOOK );
-		Controller::instance()->schedule_migration();
+    /**
+     * Test to ensure the Migration Controller will schedule the migration.
+     */
+    public function test_schedules_migration() {
+        as_unschedule_action( Scheduler::HOOK );
+        Controller::instance()->schedule_migration();
 
-		$this->assertTrue(
-			as_next_scheduled_action( Scheduler::HOOK ) > 0,
-			'Confirm that the Migration Controller scheduled the migration.'
-		);
+        $this->assertTrue(
+            as_next_scheduled_action( Scheduler::HOOK ) > 0,
+            'Confirm that the Migration Controller scheduled the migration.'
+        );
 
-		as_unschedule_action( Scheduler::HOOK );
-	}
+        as_unschedule_action( Scheduler::HOOK );
+    }
 
-	/**
-	 * Test to ensure that if an essential table is missing, the Migration
-	 * Controller will not schedule a migration.
-	 *
-	 * @see https://github.com/woocommerce/action-scheduler/issues/653
-	 */
-	public function test_migration_not_scheduled_if_tables_are_missing() {
-		as_unschedule_action( Scheduler::HOOK );
-		$this->rename_claims_table();
-		Controller::instance()->schedule_migration();
+    /**
+     * Test to ensure that if an essential table is missing, the Migration
+     * Controller will not schedule a migration.
+     *
+     * @see https://github.com/woocommerce/action-scheduler/issues/653
+     */
+    public function test_migration_not_scheduled_if_tables_are_missing() {
+        as_unschedule_action( Scheduler::HOOK );
+        $this->rename_claims_table();
+        Controller::instance()->schedule_migration();
 
-		$this->assertFalse(
-			as_next_scheduled_action( Scheduler::HOOK ),
-			'When required tables are missing, the migration will not be scheduled.'
-		);
+        $this->assertFalse(
+            as_next_scheduled_action( Scheduler::HOOK ),
+            'When required tables are missing, the migration will not be scheduled.'
+        );
 
-		$this->restore_claims_table_name();
-	}
+        $this->restore_claims_table_name();
+    }
 
-	/**
-	 * Rename the claims table, so that it cannot be used by the library.
-	 */
-	private function rename_claims_table() {
-		global $wpdb;
-		$normal_table_name   = $wpdb->prefix . Schema::CLAIMS_TABLE;
-		$modified_table_name = $normal_table_name . 'x';
+    /**
+     * Rename the claims table, so that it cannot be used by the library.
+     */
+    private function rename_claims_table() {
+        global $wpdb;
+        $normal_table_name   = $wpdb->prefix . Schema::CLAIMS_TABLE;
+        $modified_table_name = $normal_table_name . 'x';
 
-		// phpcs:ignore WordPress.DB.PreparedSQL.InterpolatedNotPrepared
-		$wpdb->query( "RENAME TABLE {$normal_table_name} TO {$modified_table_name}" );
-	}
+        // phpcs:ignore WordPress.DB.PreparedSQL.InterpolatedNotPrepared
+        $wpdb->query( "RENAME TABLE {$normal_table_name} TO {$modified_table_name}" );
+    }
 
-	/**
-	 * Restore the expected name of the claims table, so that it can be used by the library
-	 * and any further tests.
-	 */
-	private function restore_claims_table_name() {
-		global $wpdb;
-		$normal_table_name   = $wpdb->prefix . Schema::CLAIMS_TABLE;
-		$modified_table_name = $normal_table_name . 'x';
+    /**
+     * Restore the expected name of the claims table, so that it can be used by the library
+     * and any further tests.
+     */
+    private function restore_claims_table_name() {
+        global $wpdb;
+        $normal_table_name   = $wpdb->prefix . Schema::CLAIMS_TABLE;
+        $modified_table_name = $normal_table_name . 'x';
 
-		// phpcs:ignore WordPress.DB.PreparedSQL.InterpolatedNotPrepared
-		$wpdb->query( "RENAME TABLE {$modified_table_name} TO {$normal_table_name}" );
-	}
+        // phpcs:ignore WordPress.DB.PreparedSQL.InterpolatedNotPrepared
+        $wpdb->query( "RENAME TABLE {$modified_table_name} TO {$normal_table_name}" );
+    }
 }

Spacing +11 added lines, -11 removed lines

@@ -19,15 +19,15 @@ 
 	 * Test to ensure the Migration Controller will schedule the migration.
 	 */
 	public function test_schedules_migration() {
-		as_unschedule_action( Scheduler::HOOK );
+		as_unschedule_action(Scheduler::HOOK);
 		Controller::instance()->schedule_migration();
 
 		$this->assertTrue(
-			as_next_scheduled_action( Scheduler::HOOK ) > 0,
+			as_next_scheduled_action(Scheduler::HOOK) > 0,
 			'Confirm that the Migration Controller scheduled the migration.'
 		);
 
-		as_unschedule_action( Scheduler::HOOK );
+		as_unschedule_action(Scheduler::HOOK);
 	}
 
 	/**
@@ -37,12 +37,12 @@ 
 	 * @see https://github.com/woocommerce/action-scheduler/issues/653
 	 */
 	public function test_migration_not_scheduled_if_tables_are_missing() {
-		as_unschedule_action( Scheduler::HOOK );
+		as_unschedule_action(Scheduler::HOOK);
 		$this->rename_claims_table();
 		Controller::instance()->schedule_migration();
 
 		$this->assertFalse(
-			as_next_scheduled_action( Scheduler::HOOK ),
+			as_next_scheduled_action(Scheduler::HOOK),
 			'When required tables are missing, the migration will not be scheduled.'
 		);
 
@@ -54,11 +54,11 @@ 
 	 */
 	private function rename_claims_table() {
 		global $wpdb;
-		$normal_table_name   = $wpdb->prefix . Schema::CLAIMS_TABLE;
-		$modified_table_name = $normal_table_name . 'x';
+		$normal_table_name   = $wpdb->prefix.Schema::CLAIMS_TABLE;
+		$modified_table_name = $normal_table_name.'x';
 
 		// phpcs:ignore WordPress.DB.PreparedSQL.InterpolatedNotPrepared
-		$wpdb->query( "RENAME TABLE {$normal_table_name} TO {$modified_table_name}" );
+		$wpdb->query("RENAME TABLE {$normal_table_name} TO {$modified_table_name}");
 	}
 
 	/**
@@ -67,10 +67,10 @@ 
 	 */
 	private function restore_claims_table_name() {
 		global $wpdb;
-		$normal_table_name   = $wpdb->prefix . Schema::CLAIMS_TABLE;
-		$modified_table_name = $normal_table_name . 'x';
+		$normal_table_name   = $wpdb->prefix.Schema::CLAIMS_TABLE;
+		$modified_table_name = $normal_table_name.'x';
 
 		// phpcs:ignore WordPress.DB.PreparedSQL.InterpolatedNotPrepared
-		$wpdb->query( "RENAME TABLE {$modified_table_name} TO {$normal_table_name}" );
+		$wpdb->query("RENAME TABLE {$modified_table_name} TO {$normal_table_name}");
 	}
 }

src/ext/action-scheduler/tests/phpunit/lock/ActionScheduler_OptionLock_Test.php

Indentation +28 added lines, -28 removed lines

@@ -5,41 +5,41 @@
  * @package test_cases\lock
  */
 class ActionScheduler_OptionLock_Test extends ActionScheduler_UnitTestCase {
-	public function test_instance() {
-		$lock = ActionScheduler::lock();
-		$this->assertInstanceOf( 'ActionScheduler_Lock', $lock );
-		$this->assertInstanceOf( 'ActionScheduler_OptionLock', $lock );
-	}
+    public function test_instance() {
+        $lock = ActionScheduler::lock();
+        $this->assertInstanceOf( 'ActionScheduler_Lock', $lock );
+        $this->assertInstanceOf( 'ActionScheduler_OptionLock', $lock );
+    }
 
-	public function test_is_locked() {
-		$lock      = ActionScheduler::lock();
-		$lock_type = md5( rand() );
+    public function test_is_locked() {
+        $lock      = ActionScheduler::lock();
+        $lock_type = md5( rand() );
 
-		$this->assertFalse( $lock->is_locked( $lock_type ) );
+        $this->assertFalse( $lock->is_locked( $lock_type ) );
 
-		$lock->set( $lock_type );
-		$this->assertTrue( $lock->is_locked( $lock_type ) );
-	}
+        $lock->set( $lock_type );
+        $this->assertTrue( $lock->is_locked( $lock_type ) );
+    }
 
-	public function test_set() {
-		$lock      = ActionScheduler::lock();
-		$lock_type = md5( rand() );
+    public function test_set() {
+        $lock      = ActionScheduler::lock();
+        $lock_type = md5( rand() );
 
-		$lock->set( $lock_type );
-		$this->assertTrue( $lock->is_locked( $lock_type ) );
-	}
+        $lock->set( $lock_type );
+        $this->assertTrue( $lock->is_locked( $lock_type ) );
+    }
 
-	public function test_get_expiration() {
-		$lock      = ActionScheduler::lock();
-		$lock_type = md5( rand() );
+    public function test_get_expiration() {
+        $lock      = ActionScheduler::lock();
+        $lock_type = md5( rand() );
 
-		$lock->set( $lock_type );
+        $lock->set( $lock_type );
 
-		$expiration   = $lock->get_expiration( $lock_type );
-		$current_time = time();
+        $expiration   = $lock->get_expiration( $lock_type );
+        $current_time = time();
 
-		$this->assertGreaterThanOrEqual( 0, $expiration );
-		$this->assertGreaterThan( $current_time, $expiration );
-		$this->assertLessThan( $current_time + MINUTE_IN_SECONDS + 1, $expiration );
-	}
+        $this->assertGreaterThanOrEqual( 0, $expiration );
+        $this->assertGreaterThan( $current_time, $expiration );
+        $this->assertLessThan( $current_time + MINUTE_IN_SECONDS + 1, $expiration );
+    }
 }

Spacing +15 added lines, -15 removed lines

@@ -7,39 +7,39 @@
 class ActionScheduler_OptionLock_Test extends ActionScheduler_UnitTestCase {
 	public function test_instance() {
 		$lock = ActionScheduler::lock();
-		$this->assertInstanceOf( 'ActionScheduler_Lock', $lock );
-		$this->assertInstanceOf( 'ActionScheduler_OptionLock', $lock );
+		$this->assertInstanceOf('ActionScheduler_Lock', $lock);
+		$this->assertInstanceOf('ActionScheduler_OptionLock', $lock);
 	}
 
 	public function test_is_locked() {
 		$lock      = ActionScheduler::lock();
-		$lock_type = md5( rand() );
+		$lock_type = md5(rand());
 
-		$this->assertFalse( $lock->is_locked( $lock_type ) );
+		$this->assertFalse($lock->is_locked($lock_type));
 
-		$lock->set( $lock_type );
-		$this->assertTrue( $lock->is_locked( $lock_type ) );
+		$lock->set($lock_type);
+		$this->assertTrue($lock->is_locked($lock_type));
 	}
 
 	public function test_set() {
 		$lock      = ActionScheduler::lock();
-		$lock_type = md5( rand() );
+		$lock_type = md5(rand());
 
-		$lock->set( $lock_type );
-		$this->assertTrue( $lock->is_locked( $lock_type ) );
+		$lock->set($lock_type);
+		$this->assertTrue($lock->is_locked($lock_type));
 	}
 
 	public function test_get_expiration() {
 		$lock      = ActionScheduler::lock();
-		$lock_type = md5( rand() );
+		$lock_type = md5(rand());
 
-		$lock->set( $lock_type );
+		$lock->set($lock_type);
 
-		$expiration   = $lock->get_expiration( $lock_type );
+		$expiration   = $lock->get_expiration($lock_type);
 		$current_time = time();
 
-		$this->assertGreaterThanOrEqual( 0, $expiration );
-		$this->assertGreaterThan( $current_time, $expiration );
-		$this->assertLessThan( $current_time + MINUTE_IN_SECONDS + 1, $expiration );
+		$this->assertGreaterThanOrEqual(0, $expiration);
+		$this->assertGreaterThan($current_time, $expiration);
+		$this->assertLessThan($current_time + MINUTE_IN_SECONDS + 1, $expiration);
 	}
 }

src/wordlift/dataset/background/class-sync-background-process.php

Indentation +94 added lines, -94 removed lines

@@ -18,99 +18,99 @@
  */
 class Sync_Background_Process {
 
-	const STATE_STARTED = 'started';
-	const STATE_STOPPED = 'stopped';
-
-	protected $action = 'wl_dataset__sync';
-
-	/**
-	 * @var Sync_Service
-	 */
-	private $sync_service;
-
-	/**
-	 * @var Sync_Object_Adapter_Factory
-	 */
-	private $sync_object_adapter_factory;
-
-	/**
-	 * @var \Wordlift_Log_Service
-	 */
-	private $log;
-
-	/**
-	 * @var Sync_Background_Process_State
-	 */
-	private $state;
-
-	/**
-	 * Sync_Background_Process constructor.
-	 *
-	 * @param Sync_Service                $sync_service A {@link Sync_Service} instance providing the supporting functions to this background process.
-	 * @param Sync_Object_Adapter_Factory $sync_object_adapter_factory
-	 */
-	public function __construct( $sync_service, $sync_object_adapter_factory ) {
-		// parent::__construct();
-
-		$this->log = \Wordlift_Log_Service::get_logger( get_class() );
-
-		$this->sync_service                = $sync_service;
-		$this->sync_object_adapter_factory = $sync_object_adapter_factory;
-
-		// Set the current state.
-		if ( self::STATE_STARTED === $this->get_state() ) {
-			$this->state = new Sync_Background_Process_Started_State( $this, $this->sync_service, $this->sync_object_adapter_factory );
-		} else {
-			$this->state = new Sync_Background_Process_Stopped_State( $this );
-		}
-	}
-
-	/**
-	 * Transition to the started state.
-	 */
-	public function start() {
-		$this->state->leave();
-		$this->state = new Sync_Background_Process_Started_State( $this, $this->sync_service, $this->sync_object_adapter_factory );
-		$this->state->enter();
-	}
-
-	/**
-	 * Transition to the stopped state.
-	 */
-	public function stop() {
-		$this->state->leave();
-		$this->state = new Sync_Background_Process_Stopped_State( $this );
-		$this->state->enter();
-	}
-
-	public function resume() {
-		$this->state->resume();
-	}
-
-	/**
-	 * Get the current state.
-	 *
-	 * @return string Either self::STARTED_STATE or self::STOPPED_STATE (default).
-	 */
-	public function get_state() {
-		return get_option( '_wl_sync_background_process_state', self::STATE_STOPPED );
-	}
-
-	/**
-	 * Persist the current state.
-	 *
-	 * @param string $value
-	 *
-	 * @return bool
-	 */
-	public function set_state( $value ) {
-		return null === $value
-			? delete_option( '_wl_sync_background_process_state' )
-			: update_option( '_wl_sync_background_process_state', $value, true );
-	}
-
-	public function get_info() {
-		return $this->state->get_info();
-	}
+    const STATE_STARTED = 'started';
+    const STATE_STOPPED = 'stopped';
+
+    protected $action = 'wl_dataset__sync';
+
+    /**
+     * @var Sync_Service
+     */
+    private $sync_service;
+
+    /**
+     * @var Sync_Object_Adapter_Factory
+     */
+    private $sync_object_adapter_factory;
+
+    /**
+     * @var \Wordlift_Log_Service
+     */
+    private $log;
+
+    /**
+     * @var Sync_Background_Process_State
+     */
+    private $state;
+
+    /**
+     * Sync_Background_Process constructor.
+     *
+     * @param Sync_Service                $sync_service A {@link Sync_Service} instance providing the supporting functions to this background process.
+     * @param Sync_Object_Adapter_Factory $sync_object_adapter_factory
+     */
+    public function __construct( $sync_service, $sync_object_adapter_factory ) {
+        // parent::__construct();
+
+        $this->log = \Wordlift_Log_Service::get_logger( get_class() );
+
+        $this->sync_service                = $sync_service;
+        $this->sync_object_adapter_factory = $sync_object_adapter_factory;
+
+        // Set the current state.
+        if ( self::STATE_STARTED === $this->get_state() ) {
+            $this->state = new Sync_Background_Process_Started_State( $this, $this->sync_service, $this->sync_object_adapter_factory );
+        } else {
+            $this->state = new Sync_Background_Process_Stopped_State( $this );
+        }
+    }
+
+    /**
+     * Transition to the started state.
+     */
+    public function start() {
+        $this->state->leave();
+        $this->state = new Sync_Background_Process_Started_State( $this, $this->sync_service, $this->sync_object_adapter_factory );
+        $this->state->enter();
+    }
+
+    /**
+     * Transition to the stopped state.
+     */
+    public function stop() {
+        $this->state->leave();
+        $this->state = new Sync_Background_Process_Stopped_State( $this );
+        $this->state->enter();
+    }
+
+    public function resume() {
+        $this->state->resume();
+    }
+
+    /**
+     * Get the current state.
+     *
+     * @return string Either self::STARTED_STATE or self::STOPPED_STATE (default).
+     */
+    public function get_state() {
+        return get_option( '_wl_sync_background_process_state', self::STATE_STOPPED );
+    }
+
+    /**
+     * Persist the current state.
+     *
+     * @param string $value
+     *
+     * @return bool
+     */
+    public function set_state( $value ) {
+        return null === $value
+            ? delete_option( '_wl_sync_background_process_state' )
+            : update_option( '_wl_sync_background_process_state', $value, true );
+    }
+
+    public function get_info() {
+        return $this->state->get_info();
+    }
 
 }

Spacing +11 added lines, -11 removed lines

@@ -49,19 +49,19 @@ 
 	 * @param Sync_Service                $sync_service A {@link Sync_Service} instance providing the supporting functions to this background process.
 	 * @param Sync_Object_Adapter_Factory $sync_object_adapter_factory
 	 */
-	public function __construct( $sync_service, $sync_object_adapter_factory ) {
+	public function __construct($sync_service, $sync_object_adapter_factory) {
 		// parent::__construct();
 
-		$this->log = \Wordlift_Log_Service::get_logger( get_class() );
+		$this->log = \Wordlift_Log_Service::get_logger(get_class());
 
 		$this->sync_service                = $sync_service;
 		$this->sync_object_adapter_factory = $sync_object_adapter_factory;
 
 		// Set the current state.
-		if ( self::STATE_STARTED === $this->get_state() ) {
-			$this->state = new Sync_Background_Process_Started_State( $this, $this->sync_service, $this->sync_object_adapter_factory );
+		if (self::STATE_STARTED === $this->get_state()) {
+			$this->state = new Sync_Background_Process_Started_State($this, $this->sync_service, $this->sync_object_adapter_factory);
 		} else {
-			$this->state = new Sync_Background_Process_Stopped_State( $this );
+			$this->state = new Sync_Background_Process_Stopped_State($this);
 		}
 	}
 
@@ -70,7 +70,7 @@ 
 	 */
 	public function start() {
 		$this->state->leave();
-		$this->state = new Sync_Background_Process_Started_State( $this, $this->sync_service, $this->sync_object_adapter_factory );
+		$this->state = new Sync_Background_Process_Started_State($this, $this->sync_service, $this->sync_object_adapter_factory);
 		$this->state->enter();
 	}
 
@@ -79,7 +79,7 @@ 
 	 */
 	public function stop() {
 		$this->state->leave();
-		$this->state = new Sync_Background_Process_Stopped_State( $this );
+		$this->state = new Sync_Background_Process_Stopped_State($this);
 		$this->state->enter();
 	}
 
@@ -93,7 +93,7 @@ 
 	 * @return string Either self::STARTED_STATE or self::STOPPED_STATE (default).
 	 */
 	public function get_state() {
-		return get_option( '_wl_sync_background_process_state', self::STATE_STOPPED );
+		return get_option('_wl_sync_background_process_state', self::STATE_STOPPED);
 	}
 
 	/**
@@ -103,10 +103,10 @@ 
 	 *
 	 * @return bool
 	 */
-	public function set_state( $value ) {
+	public function set_state($value) {
 		return null === $value
-			? delete_option( '_wl_sync_background_process_state' )
-			: update_option( '_wl_sync_background_process_state', $value, true );
+			? delete_option('_wl_sync_background_process_state')
+			: update_option('_wl_sync_background_process_state', $value, true);
 	}
 
 	public function get_info() {

src/wordlift/dataset/background/class-sync-background-process-state.php

Indentation +22 added lines, -22 removed lines

@@ -4,27 +4,27 @@
 
 interface Sync_Background_Process_State {
 
-	public function enter();
-
-	public function leave();
-
-	/**
-	 * Task
-	 *
-	 * Override this method to perform any actions required on each
-	 * queue item. Return the modified item for further processing
-	 * in the next pass through. Or, return false to remove the
-	 * item from the queue.
-	 *
-	 * @return mixed
-	 */
-	public function task();
-
-	public function get_info();
-
-	/**
-	 * Try to resume an interrupted task.
-	 */
-	public function resume();
+    public function enter();
+
+    public function leave();
+
+    /**
+     * Task
+     *
+     * Override this method to perform any actions required on each
+     * queue item. Return the modified item for further processing
+     * in the next pass through. Or, return false to remove the
+     * item from the queue.
+     *
+     * @return mixed
+     */
+    public function task();
+
+    public function get_info();
+
+    /**
+     * Try to resume an interrupted task.
+     */
+    public function resume();
 
 }

src/wordlift/dataset/background/class-sync-background-process-stopped-state.php

Indentation +18 added lines, -18 removed lines

@@ -4,28 +4,28 @@
 
 class Sync_Background_Process_Stopped_State extends Abstract_Sync_Background_Process_State {
 
-	/**
-	 * @var Sync_Background_Process
-	 */
-	private $context;
+    /**
+     * @var Sync_Background_Process
+     */
+    private $context;
 
-	public function __construct( $context ) {
-		parent::__construct( Sync_Background_Process::STATE_STOPPED );
+    public function __construct( $context ) {
+        parent::__construct( Sync_Background_Process::STATE_STOPPED );
 
-		$this->context = $context;
-	}
+        $this->context = $context;
+    }
 
-	public function enter() {
-		$this->context->set_state( Sync_Background_Process::STATE_STOPPED );
-	}
+    public function enter() {
+        $this->context->set_state( Sync_Background_Process::STATE_STOPPED );
+    }
 
-	public function leave() {
-		$this->context->set_state( null );
-	}
+    public function leave() {
+        $this->context->set_state( null );
+    }
 
-	public function task() {
-		as_unschedule_action( 'wl_sync_data_task' );
-		return false;
-	}
+    public function task() {
+        as_unschedule_action( 'wl_sync_data_task' );
+        return false;
+    }
 
 }

Spacing +5 added lines, -5 removed lines

@@ -9,22 +9,22 @@
 	 */
 	private $context;
 
-	public function __construct( $context ) {
-		parent::__construct( Sync_Background_Process::STATE_STOPPED );
+	public function __construct($context) {
+		parent::__construct(Sync_Background_Process::STATE_STOPPED);
 
 		$this->context = $context;
 	}
 
 	public function enter() {
-		$this->context->set_state( Sync_Background_Process::STATE_STOPPED );
+		$this->context->set_state(Sync_Background_Process::STATE_STOPPED);
 	}
 
 	public function leave() {
-		$this->context->set_state( null );
+		$this->context->set_state(null);
 	}
 
 	public function task() {
-		as_unschedule_action( 'wl_sync_data_task' );
+		as_unschedule_action('wl_sync_data_task');
 		return false;
 	}
 

src/wordlift/dataset/background/class-sync-background-process-started-state.php

Indentation +137 added lines, -137 removed lines

@@ -11,142 +11,142 @@
 
 class Sync_Background_Process_Started_State extends Abstract_Sync_Background_Process_State {
 
-	/**
-	 * @var Sync_Background_Process
-	 */
-	private $context;
-
-	/**
-	 * @var Sync_Service
-	 */
-	private $sync_service;
-
-	/**
-	 * @var Sync_Background_Process_Stage[]
-	 */
-	private $stages;
-
-	private $batch_size = 5;
-	/**
-	 * @var bool
-	 */
-	private $reset;
-
-	/**
-	 * Sync_Background_Process_Started_State constructor.
-	 *
-	 * @param Sync_Background_Process     $context
-	 * @param Sync_Service                $sync_service
-	 * @param Sync_Object_Adapter_Factory $sync_object_adapter_factory
-	 * @param bool                        $reset Whether to reset the counters
-	 */
-	// phpcs:ignore VariableAnalysis.CodeAnalysis.VariableAnalysis.UnusedVariable
-	public function __construct( $context, $sync_service, $sync_object_adapter_factory, $reset = true ) {
-		parent::__construct( Sync_Background_Process::STATE_STARTED );
-
-		$this->context      = $context;
-		$this->sync_service = $sync_service;
-
-		$this->stages = array(
-			new Sync_Background_Process_Posts_Stage( $sync_object_adapter_factory ),
-			new Sync_Background_Process_Terms_Stage( $sync_object_adapter_factory ),
-			new Sync_Background_Process_Users_Stage( $sync_object_adapter_factory ),
-		);
-
-		as_enqueue_async_action( 'wl_sync_data_task' );
-		add_action( 'wl_sync_data_task', array( $this, 'task' ), 10, 0 );
-	}
-
-	public function enter() {
-		// Delete the KG contents.
-		$this->sync_service->delete_all();
-
-		// Clear caches.
-		do_action( 'wl_ttl_cache_cleaner__flush' );
-
-		$counts = array_map(
-			function ( $item ) {
-				return $item->count();
-			},
-			$this->stages
-		);
-
-		update_option( '_wl_sync_background_process_count', $counts, true );
-		update_option( '_wl_sync_background_process_stage', 0, true );
-		update_option( '_wl_sync_background_process_offset', 0, true );
-		update_option( '_wl_sync_background_process_started', time(), true );
-		update_option( '_wl_sync_background_process_updated', time(), true );
-
-		$this->context->set_state( Sync_Background_Process::STATE_STARTED );
-
-		$this->resume();
-	}
-
-	public function resume() {
-		// TODO : Resume Functionality.
-		// $this->context->push_to_queue( true );
-		// $this->context->save()->dispatch();
-	}
-
-	public function leave() {
-		$this->context->set_state( null );
-	}
-
-	// phpcs:ignore VariableAnalysis.CodeAnalysis.VariableAnalysis.UnusedVariable
-	public function task() {
-
-		$offset     = get_option( '_wl_sync_background_process_offset' );
-		$stage      = get_option( '_wl_sync_background_process_stage' );
-		$counts     = get_option( '_wl_sync_background_process_count' );
-		$batch_size = min( $counts[ $stage ] - $offset, $this->batch_size );
-
-		add_filter( 'wl_api_service__request', array( $this, 'api_service__request' ) );
-		try {
-			$object_adapters = $this->stages[ $stage ]->get_sync_object_adapters( $offset, $batch_size );
-			$this->sync_service->sync_many( $object_adapters, true );
-		// phpcs:ignore Generic.CodeAnalysis.EmptyStatement.DetectedCatch
-		} catch ( \Exception $e ) {
-			// ignored.
-		}
-		remove_filter( 'wl_api_service__request', array( $this, 'api_service__request' ) );
-
-		update_option( '_wl_sync_background_process_updated', time(), true );
-
-		// Increase the offset.
-		if ( ( $offset + $batch_size ) < $counts[ $stage ] ) {
-			update_option( '_wl_sync_background_process_offset', $offset + $batch_size, true );
-
-			return true;
-		}
-
-		// Increase the stage.
-		if ( ( $stage + 1 ) < count( $this->stages ) ) {
-			update_option( '_wl_sync_background_process_stage', $stage + 1, true );
-			update_option( '_wl_sync_background_process_offset', 0, true );
-
-			return true;
-		}
-
-		// Stop processing.
-		$this->context->stop();
-
-		return false;
-	}
-
-	/**
-	 * Hook to provide a request to update the status on the server.
-	 *
-	 * @param array $args
-	 *
-	 * @return mixed
-	 */
-	public function api_service__request( $args ) {
-
-		$state_header_value = str_replace( "\n", '', wp_json_encode( $this->context->get_info() ) );
-
-		$args['headers']['X-Wordlift-Dataset-Sync-State-V1'] = $state_header_value;
-
-		return $args;
-	}
+    /**
+     * @var Sync_Background_Process
+     */
+    private $context;
+
+    /**
+     * @var Sync_Service
+     */
+    private $sync_service;
+
+    /**
+     * @var Sync_Background_Process_Stage[]
+     */
+    private $stages;
+
+    private $batch_size = 5;
+    /**
+     * @var bool
+     */
+    private $reset;
+
+    /**
+     * Sync_Background_Process_Started_State constructor.
+     *
+     * @param Sync_Background_Process     $context
+     * @param Sync_Service                $sync_service
+     * @param Sync_Object_Adapter_Factory $sync_object_adapter_factory
+     * @param bool                        $reset Whether to reset the counters
+     */
+    // phpcs:ignore VariableAnalysis.CodeAnalysis.VariableAnalysis.UnusedVariable
+    public function __construct( $context, $sync_service, $sync_object_adapter_factory, $reset = true ) {
+        parent::__construct( Sync_Background_Process::STATE_STARTED );
+
+        $this->context      = $context;
+        $this->sync_service = $sync_service;
+
+        $this->stages = array(
+            new Sync_Background_Process_Posts_Stage( $sync_object_adapter_factory ),
+            new Sync_Background_Process_Terms_Stage( $sync_object_adapter_factory ),
+            new Sync_Background_Process_Users_Stage( $sync_object_adapter_factory ),
+        );
+
+        as_enqueue_async_action( 'wl_sync_data_task' );
+        add_action( 'wl_sync_data_task', array( $this, 'task' ), 10, 0 );
+    }
+
+    public function enter() {
+        // Delete the KG contents.
+        $this->sync_service->delete_all();
+
+        // Clear caches.
+        do_action( 'wl_ttl_cache_cleaner__flush' );
+
+        $counts = array_map(
+            function ( $item ) {
+                return $item->count();
+            },
+            $this->stages
+        );
+
+        update_option( '_wl_sync_background_process_count', $counts, true );
+        update_option( '_wl_sync_background_process_stage', 0, true );
+        update_option( '_wl_sync_background_process_offset', 0, true );
+        update_option( '_wl_sync_background_process_started', time(), true );
+        update_option( '_wl_sync_background_process_updated', time(), true );
+
+        $this->context->set_state( Sync_Background_Process::STATE_STARTED );
+
+        $this->resume();
+    }
+
+    public function resume() {
+        // TODO : Resume Functionality.
+        // $this->context->push_to_queue( true );
+        // $this->context->save()->dispatch();
+    }
+
+    public function leave() {
+        $this->context->set_state( null );
+    }
+
+    // phpcs:ignore VariableAnalysis.CodeAnalysis.VariableAnalysis.UnusedVariable
+    public function task() {
+
+        $offset     = get_option( '_wl_sync_background_process_offset' );
+        $stage      = get_option( '_wl_sync_background_process_stage' );
+        $counts     = get_option( '_wl_sync_background_process_count' );
+        $batch_size = min( $counts[ $stage ] - $offset, $this->batch_size );
+
+        add_filter( 'wl_api_service__request', array( $this, 'api_service__request' ) );
+        try {
+            $object_adapters = $this->stages[ $stage ]->get_sync_object_adapters( $offset, $batch_size );
+            $this->sync_service->sync_many( $object_adapters, true );
+        // phpcs:ignore Generic.CodeAnalysis.EmptyStatement.DetectedCatch
+        } catch ( \Exception $e ) {
+            // ignored.
+        }
+        remove_filter( 'wl_api_service__request', array( $this, 'api_service__request' ) );
+
+        update_option( '_wl_sync_background_process_updated', time(), true );
+
+        // Increase the offset.
+        if ( ( $offset + $batch_size ) < $counts[ $stage ] ) {
+            update_option( '_wl_sync_background_process_offset', $offset + $batch_size, true );
+
+            return true;
+        }
+
+        // Increase the stage.
+        if ( ( $stage + 1 ) < count( $this->stages ) ) {
+            update_option( '_wl_sync_background_process_stage', $stage + 1, true );
+            update_option( '_wl_sync_background_process_offset', 0, true );
+
+            return true;
+        }
+
+        // Stop processing.
+        $this->context->stop();
+
+        return false;
+    }
+
+    /**
+     * Hook to provide a request to update the status on the server.
+     *
+     * @param array $args
+     *
+     * @return mixed
+     */
+    public function api_service__request( $args ) {
+
+        $state_header_value = str_replace( "\n", '', wp_json_encode( $this->context->get_info() ) );
+
+        $args['headers']['X-Wordlift-Dataset-Sync-State-V1'] = $state_header_value;
+
+        return $args;
+    }
 
 }

Spacing +33 added lines, -33 removed lines

@@ -41,20 +41,20 @@ 
 	 * @param bool                        $reset Whether to reset the counters
 	 */
 	// phpcs:ignore VariableAnalysis.CodeAnalysis.VariableAnalysis.UnusedVariable
-	public function __construct( $context, $sync_service, $sync_object_adapter_factory, $reset = true ) {
-		parent::__construct( Sync_Background_Process::STATE_STARTED );
+	public function __construct($context, $sync_service, $sync_object_adapter_factory, $reset = true) {
+		parent::__construct(Sync_Background_Process::STATE_STARTED);
 
 		$this->context      = $context;
 		$this->sync_service = $sync_service;
 
 		$this->stages = array(
-			new Sync_Background_Process_Posts_Stage( $sync_object_adapter_factory ),
-			new Sync_Background_Process_Terms_Stage( $sync_object_adapter_factory ),
-			new Sync_Background_Process_Users_Stage( $sync_object_adapter_factory ),
+			new Sync_Background_Process_Posts_Stage($sync_object_adapter_factory),
+			new Sync_Background_Process_Terms_Stage($sync_object_adapter_factory),
+			new Sync_Background_Process_Users_Stage($sync_object_adapter_factory),
 		);
 
-		as_enqueue_async_action( 'wl_sync_data_task' );
-		add_action( 'wl_sync_data_task', array( $this, 'task' ), 10, 0 );
+		as_enqueue_async_action('wl_sync_data_task');
+		add_action('wl_sync_data_task', array($this, 'task'), 10, 0);
 	}
 
 	public function enter() {
@@ -62,22 +62,22 @@ 
 		$this->sync_service->delete_all();
 
 		// Clear caches.
-		do_action( 'wl_ttl_cache_cleaner__flush' );
+		do_action('wl_ttl_cache_cleaner__flush');
 
 		$counts = array_map(
-			function ( $item ) {
+			function($item) {
 				return $item->count();
 			},
 			$this->stages
 		);
 
-		update_option( '_wl_sync_background_process_count', $counts, true );
-		update_option( '_wl_sync_background_process_stage', 0, true );
-		update_option( '_wl_sync_background_process_offset', 0, true );
-		update_option( '_wl_sync_background_process_started', time(), true );
-		update_option( '_wl_sync_background_process_updated', time(), true );
+		update_option('_wl_sync_background_process_count', $counts, true);
+		update_option('_wl_sync_background_process_stage', 0, true);
+		update_option('_wl_sync_background_process_offset', 0, true);
+		update_option('_wl_sync_background_process_started', time(), true);
+		update_option('_wl_sync_background_process_updated', time(), true);
 
-		$this->context->set_state( Sync_Background_Process::STATE_STARTED );
+		$this->context->set_state(Sync_Background_Process::STATE_STARTED);
 
 		$this->resume();
 	}
@@ -89,40 +89,40 @@ 
 	}
 
 	public function leave() {
-		$this->context->set_state( null );
+		$this->context->set_state(null);
 	}
 
 	// phpcs:ignore VariableAnalysis.CodeAnalysis.VariableAnalysis.UnusedVariable
 	public function task() {
 
-		$offset     = get_option( '_wl_sync_background_process_offset' );
-		$stage      = get_option( '_wl_sync_background_process_stage' );
-		$counts     = get_option( '_wl_sync_background_process_count' );
-		$batch_size = min( $counts[ $stage ] - $offset, $this->batch_size );
+		$offset     = get_option('_wl_sync_background_process_offset');
+		$stage      = get_option('_wl_sync_background_process_stage');
+		$counts     = get_option('_wl_sync_background_process_count');
+		$batch_size = min($counts[$stage] - $offset, $this->batch_size);
 
-		add_filter( 'wl_api_service__request', array( $this, 'api_service__request' ) );
+		add_filter('wl_api_service__request', array($this, 'api_service__request'));
 		try {
-			$object_adapters = $this->stages[ $stage ]->get_sync_object_adapters( $offset, $batch_size );
-			$this->sync_service->sync_many( $object_adapters, true );
+			$object_adapters = $this->stages[$stage]->get_sync_object_adapters($offset, $batch_size);
+			$this->sync_service->sync_many($object_adapters, true);
 		// phpcs:ignore Generic.CodeAnalysis.EmptyStatement.DetectedCatch
-		} catch ( \Exception $e ) {
+		} catch (\Exception $e) {
 			// ignored.
 		}
-		remove_filter( 'wl_api_service__request', array( $this, 'api_service__request' ) );
+		remove_filter('wl_api_service__request', array($this, 'api_service__request'));
 
-		update_option( '_wl_sync_background_process_updated', time(), true );
+		update_option('_wl_sync_background_process_updated', time(), true);
 
 		// Increase the offset.
-		if ( ( $offset + $batch_size ) < $counts[ $stage ] ) {
-			update_option( '_wl_sync_background_process_offset', $offset + $batch_size, true );
+		if (($offset + $batch_size) < $counts[$stage]) {
+			update_option('_wl_sync_background_process_offset', $offset + $batch_size, true);
 
 			return true;
 		}
 
 		// Increase the stage.
-		if ( ( $stage + 1 ) < count( $this->stages ) ) {
-			update_option( '_wl_sync_background_process_stage', $stage + 1, true );
-			update_option( '_wl_sync_background_process_offset', 0, true );
+		if (($stage + 1) < count($this->stages)) {
+			update_option('_wl_sync_background_process_stage', $stage + 1, true);
+			update_option('_wl_sync_background_process_offset', 0, true);
 
 			return true;
 		}
@@ -140,9 +140,9 @@ 
 	 *
 	 * @return mixed
 	 */
-	public function api_service__request( $args ) {
+	public function api_service__request($args) {
 
-		$state_header_value = str_replace( "\n", '', wp_json_encode( $this->context->get_info() ) );
+		$state_header_value = str_replace("\n", '', wp_json_encode($this->context->get_info()));
 
 		$args['headers']['X-Wordlift-Dataset-Sync-State-V1'] = $state_header_value;
 

src/ext/action-scheduler/tests/phpunit/schedules/ActionScheduler_CronSchedule_Test.php

Indentation +57 added lines, -57 removed lines

@@ -6,72 +6,72 @@
  * @group schedules
  */
 class ActionScheduler_CronSchedule_Test extends ActionScheduler_UnitTestCase {
-	public function test_creation() {
-		$time  = as_get_datetime_object( 'tomorrow' );
-		$cron  = CronExpression::factory( '@daily' );
-		$start = clone $time;
-		$start->modify( '-1 hour' );
-		$schedule = new ActionScheduler_CronSchedule( $start, $cron );
-		$this->assertEquals( $time, $schedule->get_date() );
-		$this->assertEquals( $start, $schedule->get_first_date() );
+    public function test_creation() {
+        $time  = as_get_datetime_object( 'tomorrow' );
+        $cron  = CronExpression::factory( '@daily' );
+        $start = clone $time;
+        $start->modify( '-1 hour' );
+        $schedule = new ActionScheduler_CronSchedule( $start, $cron );
+        $this->assertEquals( $time, $schedule->get_date() );
+        $this->assertEquals( $start, $schedule->get_first_date() );
 
-		// Test delaying for a future start date
-		$start->modify( '+1 week' );
-		$time->modify( '+1 week' );
+        // Test delaying for a future start date
+        $start->modify( '+1 week' );
+        $time->modify( '+1 week' );
 
-		$schedule = new ActionScheduler_CronSchedule( $start, $cron );
-		$this->assertEquals( $time, $schedule->get_date() );
-		$this->assertEquals( $start, $schedule->get_first_date() );
-	}
+        $schedule = new ActionScheduler_CronSchedule( $start, $cron );
+        $this->assertEquals( $time, $schedule->get_date() );
+        $this->assertEquals( $start, $schedule->get_first_date() );
+    }
 
-	public function test_creation_with_first_date() {
-		$time  = as_get_datetime_object( 'tomorrow' );
-		$cron  = CronExpression::factory( '@daily' );
-		$start = clone $time;
-		$start->modify( '-1 hour' );
-		$schedule = new ActionScheduler_CronSchedule( $start, $cron );
-		$this->assertEquals( $time, $schedule->get_date() );
-		$this->assertEquals( $start, $schedule->get_first_date() );
+    public function test_creation_with_first_date() {
+        $time  = as_get_datetime_object( 'tomorrow' );
+        $cron  = CronExpression::factory( '@daily' );
+        $start = clone $time;
+        $start->modify( '-1 hour' );
+        $schedule = new ActionScheduler_CronSchedule( $start, $cron );
+        $this->assertEquals( $time, $schedule->get_date() );
+        $this->assertEquals( $start, $schedule->get_first_date() );
 
-		// Test delaying for a future start date
-		$first = clone $time;
-		$first->modify( '-1 day' );
-		$start->modify( '+1 week' );
-		$time->modify( '+1 week' );
+        // Test delaying for a future start date
+        $first = clone $time;
+        $first->modify( '-1 day' );
+        $start->modify( '+1 week' );
+        $time->modify( '+1 week' );
 
-		$schedule = new ActionScheduler_CronSchedule( $start, $cron, $first );
-		$this->assertEquals( $time, $schedule->get_date() );
-		$this->assertEquals( $first, $schedule->get_first_date() );
-	}
+        $schedule = new ActionScheduler_CronSchedule( $start, $cron, $first );
+        $this->assertEquals( $time, $schedule->get_date() );
+        $this->assertEquals( $first, $schedule->get_first_date() );
+    }
 
-	public function test_next() {
-		$time     = as_get_datetime_object( '2013-06-14' );
-		$cron     = CronExpression::factory( '@daily' );
-		$schedule = new ActionScheduler_CronSchedule( $time, $cron );
-		$this->assertEquals( as_get_datetime_object( 'tomorrow' ), $schedule->get_next( as_get_datetime_object() ) );
-	}
+    public function test_next() {
+        $time     = as_get_datetime_object( '2013-06-14' );
+        $cron     = CronExpression::factory( '@daily' );
+        $schedule = new ActionScheduler_CronSchedule( $time, $cron );
+        $this->assertEquals( as_get_datetime_object( 'tomorrow' ), $schedule->get_next( as_get_datetime_object() ) );
+    }
 
-	public function test_is_recurring() {
-		$schedule = new ActionScheduler_CronSchedule( as_get_datetime_object( '2013-06-14' ), CronExpression::factory( '@daily' ) );
-		$this->assertTrue( $schedule->is_recurring() );
-	}
+    public function test_is_recurring() {
+        $schedule = new ActionScheduler_CronSchedule( as_get_datetime_object( '2013-06-14' ), CronExpression::factory( '@daily' ) );
+        $this->assertTrue( $schedule->is_recurring() );
+    }
 
-	public function test_cron_format() {
-		$time     = as_get_datetime_object( '2014-01-01' );
-		$cron     = CronExpression::factory( '0 0 10 10 *' );
-		$schedule = new ActionScheduler_CronSchedule( $time, $cron );
-		$this->assertEquals( as_get_datetime_object( '2014-10-10' ), $schedule->get_date() );
+    public function test_cron_format() {
+        $time     = as_get_datetime_object( '2014-01-01' );
+        $cron     = CronExpression::factory( '0 0 10 10 *' );
+        $schedule = new ActionScheduler_CronSchedule( $time, $cron );
+        $this->assertEquals( as_get_datetime_object( '2014-10-10' ), $schedule->get_date() );
 
-		$cron     = CronExpression::factory( '0 0 L 1/2 *' );
-		$schedule = new ActionScheduler_CronSchedule( $time, $cron );
-		$this->assertEquals( as_get_datetime_object( '2014-01-31' ), $schedule->get_date() );
-		$this->assertEquals( as_get_datetime_object( '2014-07-31' ), $schedule->get_next( as_get_datetime_object( '2014-06-01' ) ) );
-		$this->assertEquals( as_get_datetime_object( '2028-11-30' ), $schedule->get_next( as_get_datetime_object( '2028-11-01' ) ) );
+        $cron     = CronExpression::factory( '0 0 L 1/2 *' );
+        $schedule = new ActionScheduler_CronSchedule( $time, $cron );
+        $this->assertEquals( as_get_datetime_object( '2014-01-31' ), $schedule->get_date() );
+        $this->assertEquals( as_get_datetime_object( '2014-07-31' ), $schedule->get_next( as_get_datetime_object( '2014-06-01' ) ) );
+        $this->assertEquals( as_get_datetime_object( '2028-11-30' ), $schedule->get_next( as_get_datetime_object( '2028-11-01' ) ) );
 
-		$cron     = CronExpression::factory( '30 14 * * MON#3 *' );
-		$schedule = new ActionScheduler_CronSchedule( $time, $cron );
-		$this->assertEquals( as_get_datetime_object( '2014-01-20 14:30:00' ), $schedule->get_date() );
-		$this->assertEquals( as_get_datetime_object( '2014-05-19 14:30:00' ), $schedule->get_next( as_get_datetime_object( '2014-05-01' ) ) );
-	}
+        $cron     = CronExpression::factory( '30 14 * * MON#3 *' );
+        $schedule = new ActionScheduler_CronSchedule( $time, $cron );
+        $this->assertEquals( as_get_datetime_object( '2014-01-20 14:30:00' ), $schedule->get_date() );
+        $this->assertEquals( as_get_datetime_object( '2014-05-19 14:30:00' ), $schedule->get_next( as_get_datetime_object( '2014-05-01' ) ) );
+    }
 }
 

Spacing +42 added lines, -42 removed lines

@@ -7,71 +7,71 @@
  */
 class ActionScheduler_CronSchedule_Test extends ActionScheduler_UnitTestCase {
 	public function test_creation() {
-		$time  = as_get_datetime_object( 'tomorrow' );
-		$cron  = CronExpression::factory( '@daily' );
+		$time  = as_get_datetime_object('tomorrow');
+		$cron  = CronExpression::factory('@daily');
 		$start = clone $time;
-		$start->modify( '-1 hour' );
-		$schedule = new ActionScheduler_CronSchedule( $start, $cron );
-		$this->assertEquals( $time, $schedule->get_date() );
-		$this->assertEquals( $start, $schedule->get_first_date() );
+		$start->modify('-1 hour');
+		$schedule = new ActionScheduler_CronSchedule($start, $cron);
+		$this->assertEquals($time, $schedule->get_date());
+		$this->assertEquals($start, $schedule->get_first_date());
 
 		// Test delaying for a future start date
-		$start->modify( '+1 week' );
-		$time->modify( '+1 week' );
+		$start->modify('+1 week');
+		$time->modify('+1 week');
 
-		$schedule = new ActionScheduler_CronSchedule( $start, $cron );
-		$this->assertEquals( $time, $schedule->get_date() );
-		$this->assertEquals( $start, $schedule->get_first_date() );
+		$schedule = new ActionScheduler_CronSchedule($start, $cron);
+		$this->assertEquals($time, $schedule->get_date());
+		$this->assertEquals($start, $schedule->get_first_date());
 	}
 
 	public function test_creation_with_first_date() {
-		$time  = as_get_datetime_object( 'tomorrow' );
-		$cron  = CronExpression::factory( '@daily' );
+		$time  = as_get_datetime_object('tomorrow');
+		$cron  = CronExpression::factory('@daily');
 		$start = clone $time;
-		$start->modify( '-1 hour' );
-		$schedule = new ActionScheduler_CronSchedule( $start, $cron );
-		$this->assertEquals( $time, $schedule->get_date() );
-		$this->assertEquals( $start, $schedule->get_first_date() );
+		$start->modify('-1 hour');
+		$schedule = new ActionScheduler_CronSchedule($start, $cron);
+		$this->assertEquals($time, $schedule->get_date());
+		$this->assertEquals($start, $schedule->get_first_date());
 
 		// Test delaying for a future start date
 		$first = clone $time;
-		$first->modify( '-1 day' );
-		$start->modify( '+1 week' );
-		$time->modify( '+1 week' );
+		$first->modify('-1 day');
+		$start->modify('+1 week');
+		$time->modify('+1 week');
 
-		$schedule = new ActionScheduler_CronSchedule( $start, $cron, $first );
-		$this->assertEquals( $time, $schedule->get_date() );
-		$this->assertEquals( $first, $schedule->get_first_date() );
+		$schedule = new ActionScheduler_CronSchedule($start, $cron, $first);
+		$this->assertEquals($time, $schedule->get_date());
+		$this->assertEquals($first, $schedule->get_first_date());
 	}
 
 	public function test_next() {
-		$time     = as_get_datetime_object( '2013-06-14' );
-		$cron     = CronExpression::factory( '@daily' );
-		$schedule = new ActionScheduler_CronSchedule( $time, $cron );
-		$this->assertEquals( as_get_datetime_object( 'tomorrow' ), $schedule->get_next( as_get_datetime_object() ) );
+		$time     = as_get_datetime_object('2013-06-14');
+		$cron     = CronExpression::factory('@daily');
+		$schedule = new ActionScheduler_CronSchedule($time, $cron);
+		$this->assertEquals(as_get_datetime_object('tomorrow'), $schedule->get_next(as_get_datetime_object()));
 	}
 
 	public function test_is_recurring() {
-		$schedule = new ActionScheduler_CronSchedule( as_get_datetime_object( '2013-06-14' ), CronExpression::factory( '@daily' ) );
-		$this->assertTrue( $schedule->is_recurring() );
+		$schedule = new ActionScheduler_CronSchedule(as_get_datetime_object('2013-06-14'), CronExpression::factory('@daily'));
+		$this->assertTrue($schedule->is_recurring());
 	}
 
 	public function test_cron_format() {
-		$time     = as_get_datetime_object( '2014-01-01' );
-		$cron     = CronExpression::factory( '0 0 10 10 *' );
-		$schedule = new ActionScheduler_CronSchedule( $time, $cron );
-		$this->assertEquals( as_get_datetime_object( '2014-10-10' ), $schedule->get_date() );
+		$time     = as_get_datetime_object('2014-01-01');
+		$cron     = CronExpression::factory('0 0 10 10 *');
+		$schedule = new ActionScheduler_CronSchedule($time, $cron);
+		$this->assertEquals(as_get_datetime_object('2014-10-10'), $schedule->get_date());
 
-		$cron     = CronExpression::factory( '0 0 L 1/2 *' );
-		$schedule = new ActionScheduler_CronSchedule( $time, $cron );
-		$this->assertEquals( as_get_datetime_object( '2014-01-31' ), $schedule->get_date() );
-		$this->assertEquals( as_get_datetime_object( '2014-07-31' ), $schedule->get_next( as_get_datetime_object( '2014-06-01' ) ) );
-		$this->assertEquals( as_get_datetime_object( '2028-11-30' ), $schedule->get_next( as_get_datetime_object( '2028-11-01' ) ) );
+		$cron     = CronExpression::factory('0 0 L 1/2 *');
+		$schedule = new ActionScheduler_CronSchedule($time, $cron);
+		$this->assertEquals(as_get_datetime_object('2014-01-31'), $schedule->get_date());
+		$this->assertEquals(as_get_datetime_object('2014-07-31'), $schedule->get_next(as_get_datetime_object('2014-06-01')));
+		$this->assertEquals(as_get_datetime_object('2028-11-30'), $schedule->get_next(as_get_datetime_object('2028-11-01')));
 
-		$cron     = CronExpression::factory( '30 14 * * MON#3 *' );
-		$schedule = new ActionScheduler_CronSchedule( $time, $cron );
-		$this->assertEquals( as_get_datetime_object( '2014-01-20 14:30:00' ), $schedule->get_date() );
-		$this->assertEquals( as_get_datetime_object( '2014-05-19 14:30:00' ), $schedule->get_next( as_get_datetime_object( '2014-05-01' ) ) );
+		$cron     = CronExpression::factory('30 14 * * MON#3 *');
+		$schedule = new ActionScheduler_CronSchedule($time, $cron);
+		$this->assertEquals(as_get_datetime_object('2014-01-20 14:30:00'), $schedule->get_date());
+		$this->assertEquals(as_get_datetime_object('2014-05-19 14:30:00'), $schedule->get_next(as_get_datetime_object('2014-05-01')));
 	}
 }