insideout10 / wordlift-plugin

src/libraries/action-scheduler/classes/migration/Controller.php

Indentation +195 added lines, -195 removed lines

@@ -19,85 +19,85 @@ 
  * @codeCoverageIgnore
  */
 class Controller {
-	private static $instance;
-
-	/** @var Action_Scheduler\Migration\Scheduler */
-	private $migration_scheduler;
-
-	/** @var string */
-	private $store_classname;
-
-	/** @var string */
-	private $logger_classname;
-
-	/** @var bool */
-	private $migrate_custom_store;
-
-	/**
-	 * Controller constructor.
-	 *
-	 * @param Scheduler $migration_scheduler Migration scheduler object.
-	 */
-	protected function __construct( Scheduler $migration_scheduler ) {
-		$this->migration_scheduler = $migration_scheduler;
-		$this->store_classname     = '';
-	}
-
-	/**
-	 * Set the action store class name.
-	 *
-	 * @param string $class Classname of the store class.
-	 *
-	 * @return string
-	 */
-	public function get_store_class( $class ) {
-		if ( \ActionScheduler_DataController::is_migration_complete() ) {
-			return \ActionScheduler_DataController::DATASTORE_CLASS;
-		} elseif ( \ActionScheduler_Store::DEFAULT_CLASS !== $class ) {
-			$this->store_classname = $class;
-			return $class;
-		} else {
-			return 'ActionScheduler_HybridStore';
-		}
-	}
-
-	/**
-	 * Set the action logger class name.
-	 *
-	 * @param string $class Classname of the logger class.
-	 *
-	 * @return string
-	 */
-	public function get_logger_class( $class ) {
-		\ActionScheduler_Store::instance();
-
-		if ( $this->has_custom_datastore() ) {
-			$this->logger_classname = $class;
-			return $class;
-		} else {
-			return \ActionScheduler_DataController::LOGGER_CLASS;
-		}
-	}
-
-	/**
-	 * Get flag indicating whether a custom datastore is in use.
-	 *
-	 * @return bool
-	 */
-	public function has_custom_datastore() {
-		return (bool) $this->store_classname;
-	}
-
-	/**
-	 * Set up the background migration process.
-	 *
-	 * @return void
-	 */
-	public function schedule_migration() {
-		$logging_tables = new ActionScheduler_LoggerSchema();
-		$store_tables   = new ActionScheduler_StoreSchema();
-
-		/*
+    private static $instance;
+
+    /** @var Action_Scheduler\Migration\Scheduler */
+    private $migration_scheduler;
+
+    /** @var string */
+    private $store_classname;
+
+    /** @var string */
+    private $logger_classname;
+
+    /** @var bool */
+    private $migrate_custom_store;
+
+    /**
+     * Controller constructor.
+     *
+     * @param Scheduler $migration_scheduler Migration scheduler object.
+     */
+    protected function __construct( Scheduler $migration_scheduler ) {
+        $this->migration_scheduler = $migration_scheduler;
+        $this->store_classname     = '';
+    }
+
+    /**
+     * Set the action store class name.
+     *
+     * @param string $class Classname of the store class.
+     *
+     * @return string
+     */
+    public function get_store_class( $class ) {
+        if ( \ActionScheduler_DataController::is_migration_complete() ) {
+            return \ActionScheduler_DataController::DATASTORE_CLASS;
+        } elseif ( \ActionScheduler_Store::DEFAULT_CLASS !== $class ) {
+            $this->store_classname = $class;
+            return $class;
+        } else {
+            return 'ActionScheduler_HybridStore';
+        }
+    }
+
+    /**
+     * Set the action logger class name.
+     *
+     * @param string $class Classname of the logger class.
+     *
+     * @return string
+     */
+    public function get_logger_class( $class ) {
+        \ActionScheduler_Store::instance();
+
+        if ( $this->has_custom_datastore() ) {
+            $this->logger_classname = $class;
+            return $class;
+        } else {
+            return \ActionScheduler_DataController::LOGGER_CLASS;
+        }
+    }
+
+    /**
+     * Get flag indicating whether a custom datastore is in use.
+     *
+     * @return bool
+     */
+    public function has_custom_datastore() {
+        return (bool) $this->store_classname;
+    }
+
+    /**
+     * Set up the background migration process.
+     *
+     * @return void
+     */
+    public function schedule_migration() {
+        $logging_tables = new ActionScheduler_LoggerSchema();
+        $store_tables   = new ActionScheduler_StoreSchema();
+
+        /*
 		 * In some unusual cases, the expected tables may not have been created. In such cases
 		 * we do not schedule a migration as doing so will lead to fatal error conditions.
 		 *
@@ -107,120 +107,120 @@ 
 		 *
 		 * @see https://github.com/woocommerce/action-scheduler/issues/653
 		 */
-		if (
-			ActionScheduler_DataController::is_migration_complete()
-			|| $this->migration_scheduler->is_migration_scheduled()
-			|| ! $store_tables->tables_exist()
-			|| ! $logging_tables->tables_exist()
-		) {
-			return;
-		}
-
-		$this->migration_scheduler->schedule_migration();
-	}
-
-	/**
-	 * Get the default migration config object
-	 *
-	 * @return ActionScheduler\Migration\Config
-	 */
-	public function get_migration_config_object() {
-		static $config = null;
-
-		if ( ! $config ) {
-			$source_store  = $this->store_classname ? new $this->store_classname() : new \ActionScheduler_wpPostStore();
-			$source_logger = $this->logger_classname ? new $this->logger_classname() : new \ActionScheduler_wpCommentLogger();
-
-			$config = new Config();
-			$config->set_source_store( $source_store );
-			$config->set_source_logger( $source_logger );
-			$config->set_destination_store( new \ActionScheduler_DBStoreMigrator() );
-			$config->set_destination_logger( new \ActionScheduler_DBLogger() );
-
-			if ( defined( 'WP_CLI' ) && WP_CLI ) {
-				$config->set_progress_bar( new ProgressBar( '', 0 ) );
-			}
-		}
-
-		return apply_filters( 'action_scheduler/migration_config', $config );
-	}
-
-	/**
-	 * Hook dashboard migration notice.
-	 */
-	public function hook_admin_notices() {
-		if ( ! $this->allow_migration() || \ActionScheduler_DataController::is_migration_complete() ) {
-			return;
-		}
-		add_action( 'admin_notices', array( $this, 'display_migration_notice' ), 10, 0 );
-	}
-
-	/**
-	 * Show a dashboard notice that migration is in progress.
-	 */
-	public function display_migration_notice() {
-		printf( '<div class="notice notice-warning"><p>%s</p></div>', esc_html__( 'Action Scheduler migration in progress. The list of scheduled actions may be incomplete.', 'action-scheduler' ) );
-	}
-
-	/**
-	 * Add store classes. Hook migration.
-	 */
-	private function hook() {
-		add_filter( 'action_scheduler_store_class', array( $this, 'get_store_class' ), 100, 1 );
-		add_filter( 'action_scheduler_logger_class', array( $this, 'get_logger_class' ), 100, 1 );
-		add_action( 'init', array( $this, 'maybe_hook_migration' ) );
-		add_action( 'wp_loaded', array( $this, 'schedule_migration' ) );
-
-		// Action Scheduler may be displayed as a Tools screen or WooCommerce > Status administration screen
-		add_action( 'load-tools_page_action-scheduler', array( $this, 'hook_admin_notices' ), 10, 0 );
-		add_action( 'load-woocommerce_page_wc-status', array( $this, 'hook_admin_notices' ), 10, 0 );
-	}
-
-	/**
-	 * Possibly hook the migration scheduler action.
-	 *
-	 * @author Jeremy Pry
-	 */
-	public function maybe_hook_migration() {
-		if ( ! $this->allow_migration() || \ActionScheduler_DataController::is_migration_complete() ) {
-			return;
-		}
-
-		$this->migration_scheduler->hook();
-	}
-
-	/**
-	 * Allow datastores to enable migration to AS tables.
-	 */
-	public function allow_migration() {
-		if ( ! \ActionScheduler_DataController::dependencies_met() ) {
-			return false;
-		}
-
-		if ( null === $this->migrate_custom_store ) {
-			$this->migrate_custom_store = apply_filters( 'action_scheduler_migrate_data_store', false );
-		}
-
-		return ( ! $this->has_custom_datastore() ) || $this->migrate_custom_store;
-	}
-
-	/**
-	 * Proceed with the migration if the dependencies have been met.
-	 */
-	public static function init() {
-		if ( \ActionScheduler_DataController::dependencies_met() ) {
-			self::instance()->hook();
-		}
-	}
-
-	/**
-	 * Singleton factory.
-	 */
-	public static function instance() {
-		if ( ! isset( self::$instance ) ) {
-			self::$instance = new static( new Scheduler() );
-		}
-
-		return self::$instance;
-	}
+        if (
+            ActionScheduler_DataController::is_migration_complete()
+            || $this->migration_scheduler->is_migration_scheduled()
+            || ! $store_tables->tables_exist()
+            || ! $logging_tables->tables_exist()
+        ) {
+            return;
+        }
+
+        $this->migration_scheduler->schedule_migration();
+    }
+
+    /**
+     * Get the default migration config object
+     *
+     * @return ActionScheduler\Migration\Config
+     */
+    public function get_migration_config_object() {
+        static $config = null;
+
+        if ( ! $config ) {
+            $source_store  = $this->store_classname ? new $this->store_classname() : new \ActionScheduler_wpPostStore();
+            $source_logger = $this->logger_classname ? new $this->logger_classname() : new \ActionScheduler_wpCommentLogger();
+
+            $config = new Config();
+            $config->set_source_store( $source_store );
+            $config->set_source_logger( $source_logger );
+            $config->set_destination_store( new \ActionScheduler_DBStoreMigrator() );
+            $config->set_destination_logger( new \ActionScheduler_DBLogger() );
+
+            if ( defined( 'WP_CLI' ) && WP_CLI ) {
+                $config->set_progress_bar( new ProgressBar( '', 0 ) );
+            }
+        }
+
+        return apply_filters( 'action_scheduler/migration_config', $config );
+    }
+
+    /**
+     * Hook dashboard migration notice.
+     */
+    public function hook_admin_notices() {
+        if ( ! $this->allow_migration() || \ActionScheduler_DataController::is_migration_complete() ) {
+            return;
+        }
+        add_action( 'admin_notices', array( $this, 'display_migration_notice' ), 10, 0 );
+    }
+
+    /**
+     * Show a dashboard notice that migration is in progress.
+     */
+    public function display_migration_notice() {
+        printf( '<div class="notice notice-warning"><p>%s</p></div>', esc_html__( 'Action Scheduler migration in progress. The list of scheduled actions may be incomplete.', 'action-scheduler' ) );
+    }
+
+    /**
+     * Add store classes. Hook migration.
+     */
+    private function hook() {
+        add_filter( 'action_scheduler_store_class', array( $this, 'get_store_class' ), 100, 1 );
+        add_filter( 'action_scheduler_logger_class', array( $this, 'get_logger_class' ), 100, 1 );
+        add_action( 'init', array( $this, 'maybe_hook_migration' ) );
+        add_action( 'wp_loaded', array( $this, 'schedule_migration' ) );
+
+        // Action Scheduler may be displayed as a Tools screen or WooCommerce > Status administration screen
+        add_action( 'load-tools_page_action-scheduler', array( $this, 'hook_admin_notices' ), 10, 0 );
+        add_action( 'load-woocommerce_page_wc-status', array( $this, 'hook_admin_notices' ), 10, 0 );
+    }
+
+    /**
+     * Possibly hook the migration scheduler action.
+     *
+     * @author Jeremy Pry
+     */
+    public function maybe_hook_migration() {
+        if ( ! $this->allow_migration() || \ActionScheduler_DataController::is_migration_complete() ) {
+            return;
+        }
+
+        $this->migration_scheduler->hook();
+    }
+
+    /**
+     * Allow datastores to enable migration to AS tables.
+     */
+    public function allow_migration() {
+        if ( ! \ActionScheduler_DataController::dependencies_met() ) {
+            return false;
+        }
+
+        if ( null === $this->migrate_custom_store ) {
+            $this->migrate_custom_store = apply_filters( 'action_scheduler_migrate_data_store', false );
+        }
+
+        return ( ! $this->has_custom_datastore() ) || $this->migrate_custom_store;
+    }
+
+    /**
+     * Proceed with the migration if the dependencies have been met.
+     */
+    public static function init() {
+        if ( \ActionScheduler_DataController::dependencies_met() ) {
+            self::instance()->hook();
+        }
+    }
+
+    /**
+     * Singleton factory.
+     */
+    public static function instance() {
+        if ( ! isset( self::$instance ) ) {
+            self::$instance = new static( new Scheduler() );
+        }
+
+        return self::$instance;
+    }
 }

Spacing +31 added lines, -31 removed lines

@@ -38,7 +38,7 @@ 
 	 *
 	 * @param Scheduler $migration_scheduler Migration scheduler object.
 	 */
-	protected function __construct( Scheduler $migration_scheduler ) {
+	protected function __construct(Scheduler $migration_scheduler) {
 		$this->migration_scheduler = $migration_scheduler;
 		$this->store_classname     = '';
 	}
@@ -50,10 +50,10 @@ 
 	 *
 	 * @return string
 	 */
-	public function get_store_class( $class ) {
-		if ( \ActionScheduler_DataController::is_migration_complete() ) {
+	public function get_store_class($class) {
+		if (\ActionScheduler_DataController::is_migration_complete()) {
 			return \ActionScheduler_DataController::DATASTORE_CLASS;
-		} elseif ( \ActionScheduler_Store::DEFAULT_CLASS !== $class ) {
+		} elseif (\ActionScheduler_Store::DEFAULT_CLASS !== $class) {
 			$this->store_classname = $class;
 			return $class;
 		} else {
@@ -68,10 +68,10 @@ 
 	 *
 	 * @return string
 	 */
-	public function get_logger_class( $class ) {
+	public function get_logger_class($class) {
 		\ActionScheduler_Store::instance();
 
-		if ( $this->has_custom_datastore() ) {
+		if ($this->has_custom_datastore()) {
 			$this->logger_classname = $class;
 			return $class;
 		} else {
@@ -127,53 +127,53 @@ 
 	public function get_migration_config_object() {
 		static $config = null;
 
-		if ( ! $config ) {
+		if ( ! $config) {
 			$source_store  = $this->store_classname ? new $this->store_classname() : new \ActionScheduler_wpPostStore();
 			$source_logger = $this->logger_classname ? new $this->logger_classname() : new \ActionScheduler_wpCommentLogger();
 
 			$config = new Config();
-			$config->set_source_store( $source_store );
-			$config->set_source_logger( $source_logger );
-			$config->set_destination_store( new \ActionScheduler_DBStoreMigrator() );
-			$config->set_destination_logger( new \ActionScheduler_DBLogger() );
+			$config->set_source_store($source_store);
+			$config->set_source_logger($source_logger);
+			$config->set_destination_store(new \ActionScheduler_DBStoreMigrator());
+			$config->set_destination_logger(new \ActionScheduler_DBLogger());
 
-			if ( defined( 'WP_CLI' ) && WP_CLI ) {
-				$config->set_progress_bar( new ProgressBar( '', 0 ) );
+			if (defined('WP_CLI') && WP_CLI) {
+				$config->set_progress_bar(new ProgressBar('', 0));
 			}
 		}
 
-		return apply_filters( 'action_scheduler/migration_config', $config );
+		return apply_filters('action_scheduler/migration_config', $config);
 	}
 
 	/**
 	 * Hook dashboard migration notice.
 	 */
 	public function hook_admin_notices() {
-		if ( ! $this->allow_migration() || \ActionScheduler_DataController::is_migration_complete() ) {
+		if ( ! $this->allow_migration() || \ActionScheduler_DataController::is_migration_complete()) {
 			return;
 		}
-		add_action( 'admin_notices', array( $this, 'display_migration_notice' ), 10, 0 );
+		add_action('admin_notices', array($this, 'display_migration_notice'), 10, 0);
 	}
 
 	/**
 	 * Show a dashboard notice that migration is in progress.
 	 */
 	public function display_migration_notice() {
-		printf( '<div class="notice notice-warning"><p>%s</p></div>', esc_html__( 'Action Scheduler migration in progress. The list of scheduled actions may be incomplete.', 'action-scheduler' ) );
+		printf('<div class="notice notice-warning"><p>%s</p></div>', esc_html__('Action Scheduler migration in progress. The list of scheduled actions may be incomplete.', 'action-scheduler'));
 	}
 
 	/**
 	 * Add store classes. Hook migration.
 	 */
 	private function hook() {
-		add_filter( 'action_scheduler_store_class', array( $this, 'get_store_class' ), 100, 1 );
-		add_filter( 'action_scheduler_logger_class', array( $this, 'get_logger_class' ), 100, 1 );
-		add_action( 'init', array( $this, 'maybe_hook_migration' ) );
-		add_action( 'wp_loaded', array( $this, 'schedule_migration' ) );
+		add_filter('action_scheduler_store_class', array($this, 'get_store_class'), 100, 1);
+		add_filter('action_scheduler_logger_class', array($this, 'get_logger_class'), 100, 1);
+		add_action('init', array($this, 'maybe_hook_migration'));
+		add_action('wp_loaded', array($this, 'schedule_migration'));
 
 		// Action Scheduler may be displayed as a Tools screen or WooCommerce > Status administration screen
-		add_action( 'load-tools_page_action-scheduler', array( $this, 'hook_admin_notices' ), 10, 0 );
-		add_action( 'load-woocommerce_page_wc-status', array( $this, 'hook_admin_notices' ), 10, 0 );
+		add_action('load-tools_page_action-scheduler', array($this, 'hook_admin_notices'), 10, 0);
+		add_action('load-woocommerce_page_wc-status', array($this, 'hook_admin_notices'), 10, 0);
 	}
 
 	/**
@@ -182,7 +182,7 @@ 
 	 * @author Jeremy Pry
 	 */
 	public function maybe_hook_migration() {
-		if ( ! $this->allow_migration() || \ActionScheduler_DataController::is_migration_complete() ) {
+		if ( ! $this->allow_migration() || \ActionScheduler_DataController::is_migration_complete()) {
 			return;
 		}
 
@@ -193,22 +193,22 @@ 
 	 * Allow datastores to enable migration to AS tables.
 	 */
 	public function allow_migration() {
-		if ( ! \ActionScheduler_DataController::dependencies_met() ) {
+		if ( ! \ActionScheduler_DataController::dependencies_met()) {
 			return false;
 		}
 
-		if ( null === $this->migrate_custom_store ) {
-			$this->migrate_custom_store = apply_filters( 'action_scheduler_migrate_data_store', false );
+		if (null === $this->migrate_custom_store) {
+			$this->migrate_custom_store = apply_filters('action_scheduler_migrate_data_store', false);
 		}
 
-		return ( ! $this->has_custom_datastore() ) || $this->migrate_custom_store;
+		return ( ! $this->has_custom_datastore()) || $this->migrate_custom_store;
 	}
 
 	/**
 	 * Proceed with the migration if the dependencies have been met.
 	 */
 	public static function init() {
-		if ( \ActionScheduler_DataController::dependencies_met() ) {
+		if (\ActionScheduler_DataController::dependencies_met()) {
 			self::instance()->hook();
 		}
 	}
@@ -217,8 +217,8 @@ 
 	 * Singleton factory.
 	 */
 	public static function instance() {
-		if ( ! isset( self::$instance ) ) {
-			self::$instance = new static( new Scheduler() );
+		if ( ! isset(self::$instance)) {
+			self::$instance = new static(new Scheduler());
 		}
 
 		return self::$instance;

src/libraries/action-scheduler/classes/migration/Scheduler.php

Spacing +17 added lines, -17 removed lines

@@ -23,14 +23,14 @@ 
 	 * Set up the callback for the scheduled job.
 	 */
 	public function hook() {
-		add_action( self::HOOK, array( $this, 'run_migration' ), 10, 0 );
+		add_action(self::HOOK, array($this, 'run_migration'), 10, 0);
 	}
 
 	/**
 	 * Remove the callback for the scheduled job.
 	 */
 	public function unhook() {
-		remove_action( self::HOOK, array( $this, 'run_migration' ), 10 );
+		remove_action(self::HOOK, array($this, 'run_migration'), 10);
 	}
 
 	/**
@@ -38,12 +38,12 @@ 
 	 */
 	public function run_migration() {
 		$migration_runner = $this->get_migration_runner();
-		$count            = $migration_runner->run( $this->get_batch_size() );
+		$count            = $migration_runner->run($this->get_batch_size());
 
-		if ( $count === 0 ) {
+		if ($count === 0) {
 			$this->mark_complete();
 		} else {
-			$this->schedule_migration( time() + $this->get_schedule_interval() );
+			$this->schedule_migration(time() + $this->get_schedule_interval());
 		}
 	}
 
@@ -54,7 +54,7 @@ 
 		$this->unschedule_migration();
 
 		\ActionScheduler_DataController::mark_migration_complete();
-		do_action( 'action_scheduler/migration_complete' );
+		do_action('action_scheduler/migration_complete');
 	}
 
 	/**
@@ -63,9 +63,9 @@ 
 	 * @return bool Whether there is a pending action in the store to handle the migration
 	 */
 	public function is_migration_scheduled() {
-		$next = as_next_scheduled_action( self::HOOK );
+		$next = as_next_scheduled_action(self::HOOK);
 
-		return ! empty( $next );
+		return ! empty($next);
 	}
 
 	/**
@@ -75,25 +75,25 @@ 
 	 *
 	 * @return string The action ID
 	 */
-	public function schedule_migration( $when = 0 ) {
-		$next = as_next_scheduled_action( self::HOOK );
+	public function schedule_migration($when = 0) {
+		$next = as_next_scheduled_action(self::HOOK);
 
-		if ( ! empty( $next ) ) {
+		if ( ! empty($next)) {
 			return $next;
 		}
 
-		if ( empty( $when ) ) {
+		if (empty($when)) {
 			$when = time() + MINUTE_IN_SECONDS;
 		}
 
-		return as_schedule_single_action( $when, self::HOOK, array(), self::GROUP );
+		return as_schedule_single_action($when, self::HOOK, array(), self::GROUP);
 	}
 
 	/**
 	 * Remove the scheduled migration action.
 	 */
 	public function unschedule_migration() {
-		as_unschedule_action( self::HOOK, null, self::GROUP );
+		as_unschedule_action(self::HOOK, null, self::GROUP);
 	}
 
 	/**
@@ -102,7 +102,7 @@ 
 	 * @return int Seconds between migration runs. Defaults to 0 seconds to allow chaining migration via Async Runners.
 	 */
 	private function get_schedule_interval() {
-		return (int) apply_filters( 'action_scheduler/migration_interval', 0 );
+		return (int) apply_filters('action_scheduler/migration_interval', 0);
 	}
 
 	/**
@@ -111,7 +111,7 @@ 
 	 * @return int Number of actions to migrate in each batch. Defaults to 250.
 	 */
 	private function get_batch_size() {
-		return (int) apply_filters( 'action_scheduler/migration_batch_size', 250 );
+		return (int) apply_filters('action_scheduler/migration_batch_size', 250);
 	}
 
 	/**
@@ -122,7 +122,7 @@ 
 	private function get_migration_runner() {
 		$config = Controller::instance()->get_migration_config_object();
 
-		return new Runner( $config );
+		return new Runner($config);
 	}
 
 }

Indentation +111 added lines, -111 removed lines

@@ -12,116 +12,116 @@
  * @codeCoverageIgnore
  */
 class Scheduler {
-	/** Migration action hook. */
-	const HOOK = 'action_scheduler/migration_hook';
-
-	/** Migration action group. */
-	const GROUP = 'action-scheduler-migration';
-
-	/**
-	 * Set up the callback for the scheduled job.
-	 */
-	public function hook() {
-		add_action( self::HOOK, array( $this, 'run_migration' ), 10, 0 );
-	}
-
-	/**
-	 * Remove the callback for the scheduled job.
-	 */
-	public function unhook() {
-		remove_action( self::HOOK, array( $this, 'run_migration' ), 10 );
-	}
-
-	/**
-	 * The migration callback.
-	 */
-	public function run_migration() {
-		$migration_runner = $this->get_migration_runner();
-		$count            = $migration_runner->run( $this->get_batch_size() );
-
-		if ( $count === 0 ) {
-			$this->mark_complete();
-		} else {
-			$this->schedule_migration( time() + $this->get_schedule_interval() );
-		}
-	}
-
-	/**
-	 * Mark the migration complete.
-	 */
-	public function mark_complete() {
-		$this->unschedule_migration();
-
-		\ActionScheduler_DataController::mark_migration_complete();
-		do_action( 'action_scheduler/migration_complete' );
-	}
-
-	/**
-	 * Get a flag indicating whether the migration is scheduled.
-	 *
-	 * @return bool Whether there is a pending action in the store to handle the migration
-	 */
-	public function is_migration_scheduled() {
-		$next = as_next_scheduled_action( self::HOOK );
-
-		return ! empty( $next );
-	}
-
-	/**
-	 * Schedule the migration.
-	 *
-	 * @param int $when Optional timestamp to run the next migration batch. Defaults to now.
-	 *
-	 * @return string The action ID
-	 */
-	public function schedule_migration( $when = 0 ) {
-		$next = as_next_scheduled_action( self::HOOK );
-
-		if ( ! empty( $next ) ) {
-			return $next;
-		}
-
-		if ( empty( $when ) ) {
-			$when = time() + MINUTE_IN_SECONDS;
-		}
-
-		return as_schedule_single_action( $when, self::HOOK, array(), self::GROUP );
-	}
-
-	/**
-	 * Remove the scheduled migration action.
-	 */
-	public function unschedule_migration() {
-		as_unschedule_action( self::HOOK, null, self::GROUP );
-	}
-
-	/**
-	 * Get migration batch schedule interval.
-	 *
-	 * @return int Seconds between migration runs. Defaults to 0 seconds to allow chaining migration via Async Runners.
-	 */
-	private function get_schedule_interval() {
-		return (int) apply_filters( 'action_scheduler/migration_interval', 0 );
-	}
-
-	/**
-	 * Get migration batch size.
-	 *
-	 * @return int Number of actions to migrate in each batch. Defaults to 250.
-	 */
-	private function get_batch_size() {
-		return (int) apply_filters( 'action_scheduler/migration_batch_size', 250 );
-	}
-
-	/**
-	 * Get migration runner object.
-	 *
-	 * @return Runner
-	 */
-	private function get_migration_runner() {
-		$config = Controller::instance()->get_migration_config_object();
-
-		return new Runner( $config );
-	}
+    /** Migration action hook. */
+    const HOOK = 'action_scheduler/migration_hook';
+
+    /** Migration action group. */
+    const GROUP = 'action-scheduler-migration';
+
+    /**
+     * Set up the callback for the scheduled job.
+     */
+    public function hook() {
+        add_action( self::HOOK, array( $this, 'run_migration' ), 10, 0 );
+    }
+
+    /**
+     * Remove the callback for the scheduled job.
+     */
+    public function unhook() {
+        remove_action( self::HOOK, array( $this, 'run_migration' ), 10 );
+    }
+
+    /**
+     * The migration callback.
+     */
+    public function run_migration() {
+        $migration_runner = $this->get_migration_runner();
+        $count            = $migration_runner->run( $this->get_batch_size() );
+
+        if ( $count === 0 ) {
+            $this->mark_complete();
+        } else {
+            $this->schedule_migration( time() + $this->get_schedule_interval() );
+        }
+    }
+
+    /**
+     * Mark the migration complete.
+     */
+    public function mark_complete() {
+        $this->unschedule_migration();
+
+        \ActionScheduler_DataController::mark_migration_complete();
+        do_action( 'action_scheduler/migration_complete' );
+    }
+
+    /**
+     * Get a flag indicating whether the migration is scheduled.
+     *
+     * @return bool Whether there is a pending action in the store to handle the migration
+     */
+    public function is_migration_scheduled() {
+        $next = as_next_scheduled_action( self::HOOK );
+
+        return ! empty( $next );
+    }
+
+    /**
+     * Schedule the migration.
+     *
+     * @param int $when Optional timestamp to run the next migration batch. Defaults to now.
+     *
+     * @return string The action ID
+     */
+    public function schedule_migration( $when = 0 ) {
+        $next = as_next_scheduled_action( self::HOOK );
+
+        if ( ! empty( $next ) ) {
+            return $next;
+        }
+
+        if ( empty( $when ) ) {
+            $when = time() + MINUTE_IN_SECONDS;
+        }
+
+        return as_schedule_single_action( $when, self::HOOK, array(), self::GROUP );
+    }
+
+    /**
+     * Remove the scheduled migration action.
+     */
+    public function unschedule_migration() {
+        as_unschedule_action( self::HOOK, null, self::GROUP );
+    }
+
+    /**
+     * Get migration batch schedule interval.
+     *
+     * @return int Seconds between migration runs. Defaults to 0 seconds to allow chaining migration via Async Runners.
+     */
+    private function get_schedule_interval() {
+        return (int) apply_filters( 'action_scheduler/migration_interval', 0 );
+    }
+
+    /**
+     * Get migration batch size.
+     *
+     * @return int Number of actions to migrate in each batch. Defaults to 250.
+     */
+    private function get_batch_size() {
+        return (int) apply_filters( 'action_scheduler/migration_batch_size', 250 );
+    }
+
+    /**
+     * Get migration runner object.
+     *
+     * @return Runner
+     */
+    private function get_migration_runner() {
+        $config = Controller::instance()->get_migration_config_object();
+
+        return new Runner( $config );
+    }
 
 }

src/libraries/action-scheduler/classes/data-stores/ActionScheduler_wpPostStore_PostStatusRegistrar.php

Indentation +44 added lines, -44 removed lines

@@ -5,54 +5,54 @@
  * @codeCoverageIgnore
  */
 class ActionScheduler_wpPostStore_PostStatusRegistrar {
-	public function register() {
-		register_post_status( ActionScheduler_Store::STATUS_RUNNING, array_merge( $this->post_status_args(), $this->post_status_running_labels() ) );
-		register_post_status( ActionScheduler_Store::STATUS_FAILED, array_merge( $this->post_status_args(), $this->post_status_failed_labels() ) );
-	}
+    public function register() {
+        register_post_status( ActionScheduler_Store::STATUS_RUNNING, array_merge( $this->post_status_args(), $this->post_status_running_labels() ) );
+        register_post_status( ActionScheduler_Store::STATUS_FAILED, array_merge( $this->post_status_args(), $this->post_status_failed_labels() ) );
+    }
 
-	/**
-	 * Build the args array for the post type definition
-	 *
-	 * @return array
-	 */
-	protected function post_status_args() {
-		$args = array(
-			'public'                    => false,
-			'exclude_from_search'       => false,
-			'show_in_admin_all_list'    => true,
-			'show_in_admin_status_list' => true,
-		);
+    /**
+     * Build the args array for the post type definition
+     *
+     * @return array
+     */
+    protected function post_status_args() {
+        $args = array(
+            'public'                    => false,
+            'exclude_from_search'       => false,
+            'show_in_admin_all_list'    => true,
+            'show_in_admin_status_list' => true,
+        );
 
-		return apply_filters( 'action_scheduler_post_status_args', $args );
-	}
+        return apply_filters( 'action_scheduler_post_status_args', $args );
+    }
 
-	/**
-	 * Build the args array for the post type definition
-	 *
-	 * @return array
-	 */
-	protected function post_status_failed_labels() {
-		$labels = array(
-			'label'       => _x( 'Failed', 'post', 'action-scheduler' ),
-			/* translators: %s: count */
-			'label_count' => _n_noop( 'Failed <span class="count">(%s)</span>', 'Failed <span class="count">(%s)</span>', 'action-scheduler' ),
-		);
+    /**
+     * Build the args array for the post type definition
+     *
+     * @return array
+     */
+    protected function post_status_failed_labels() {
+        $labels = array(
+            'label'       => _x( 'Failed', 'post', 'action-scheduler' ),
+            /* translators: %s: count */
+            'label_count' => _n_noop( 'Failed <span class="count">(%s)</span>', 'Failed <span class="count">(%s)</span>', 'action-scheduler' ),
+        );
 
-		return apply_filters( 'action_scheduler_post_status_failed_labels', $labels );
-	}
+        return apply_filters( 'action_scheduler_post_status_failed_labels', $labels );
+    }
 
-	/**
-	 * Build the args array for the post type definition
-	 *
-	 * @return array
-	 */
-	protected function post_status_running_labels() {
-		$labels = array(
-			'label'       => _x( 'In-Progress', 'post', 'action-scheduler' ),
-			/* translators: %s: count */
-			'label_count' => _n_noop( 'In-Progress <span class="count">(%s)</span>', 'In-Progress <span class="count">(%s)</span>', 'action-scheduler' ),
-		);
+    /**
+     * Build the args array for the post type definition
+     *
+     * @return array
+     */
+    protected function post_status_running_labels() {
+        $labels = array(
+            'label'       => _x( 'In-Progress', 'post', 'action-scheduler' ),
+            /* translators: %s: count */
+            'label_count' => _n_noop( 'In-Progress <span class="count">(%s)</span>', 'In-Progress <span class="count">(%s)</span>', 'action-scheduler' ),
+        );
 
-		return apply_filters( 'action_scheduler_post_status_running_labels', $labels );
-	}
+        return apply_filters( 'action_scheduler_post_status_running_labels', $labels );
+    }
 }

Spacing +9 added lines, -9 removed lines

@@ -6,8 +6,8 @@ 
  */
 class ActionScheduler_wpPostStore_PostStatusRegistrar {
 	public function register() {
-		register_post_status( ActionScheduler_Store::STATUS_RUNNING, array_merge( $this->post_status_args(), $this->post_status_running_labels() ) );
-		register_post_status( ActionScheduler_Store::STATUS_FAILED, array_merge( $this->post_status_args(), $this->post_status_failed_labels() ) );
+		register_post_status(ActionScheduler_Store::STATUS_RUNNING, array_merge($this->post_status_args(), $this->post_status_running_labels()));
+		register_post_status(ActionScheduler_Store::STATUS_FAILED, array_merge($this->post_status_args(), $this->post_status_failed_labels()));
 	}
 
 	/**
@@ -23,7 +23,7 @@ 
 			'show_in_admin_status_list' => true,
 		);
 
-		return apply_filters( 'action_scheduler_post_status_args', $args );
+		return apply_filters('action_scheduler_post_status_args', $args);
 	}
 
 	/**
@@ -33,12 +33,12 @@ 
 	 */
 	protected function post_status_failed_labels() {
 		$labels = array(
-			'label'       => _x( 'Failed', 'post', 'action-scheduler' ),
+			'label'       => _x('Failed', 'post', 'action-scheduler'),
 			/* translators: %s: count */
-			'label_count' => _n_noop( 'Failed <span class="count">(%s)</span>', 'Failed <span class="count">(%s)</span>', 'action-scheduler' ),
+			'label_count' => _n_noop('Failed <span class="count">(%s)</span>', 'Failed <span class="count">(%s)</span>', 'action-scheduler'),
 		);
 
-		return apply_filters( 'action_scheduler_post_status_failed_labels', $labels );
+		return apply_filters('action_scheduler_post_status_failed_labels', $labels);
 	}
 
 	/**
@@ -48,11 +48,11 @@ 
 	 */
 	protected function post_status_running_labels() {
 		$labels = array(
-			'label'       => _x( 'In-Progress', 'post', 'action-scheduler' ),
+			'label'       => _x('In-Progress', 'post', 'action-scheduler'),
 			/* translators: %s: count */
-			'label_count' => _n_noop( 'In-Progress <span class="count">(%s)</span>', 'In-Progress <span class="count">(%s)</span>', 'action-scheduler' ),
+			'label_count' => _n_noop('In-Progress <span class="count">(%s)</span>', 'In-Progress <span class="count">(%s)</span>', 'action-scheduler'),
 		);
 
-		return apply_filters( 'action_scheduler_post_status_running_labels', $labels );
+		return apply_filters('action_scheduler_post_status_running_labels', $labels);
 	}
 }

src/libraries/action-scheduler/classes/ActionScheduler_DataController.php

Spacing +25 added lines, -25 removed lines

@@ -44,8 +44,8 @@ 
 	 * @return bool
 	 */
 	public static function dependencies_met() {
-		$php_support = version_compare( PHP_VERSION, self::MIN_PHP_VERSION, '>=' );
-		return $php_support && apply_filters( 'action_scheduler_migration_dependencies_met', true );
+		$php_support = version_compare(PHP_VERSION, self::MIN_PHP_VERSION, '>=');
+		return $php_support && apply_filters('action_scheduler_migration_dependencies_met', true);
 	}
 
 	/**
@@ -54,14 +54,14 @@ 
 	 * @return bool Whether the flag has been set marking the migration as complete
 	 */
 	public static function is_migration_complete() {
-		return get_option( self::STATUS_FLAG ) === self::STATUS_COMPLETE;
+		return get_option(self::STATUS_FLAG) === self::STATUS_COMPLETE;
 	}
 
 	/**
 	 * Mark the migration as complete.
 	 */
 	public static function mark_migration_complete() {
-		update_option( self::STATUS_FLAG, self::STATUS_COMPLETE );
+		update_option(self::STATUS_FLAG, self::STATUS_COMPLETE);
 	}
 
 	/**
@@ -70,7 +70,7 @@ 
 	 * deactivated and the site was running on AS 2.x again.
 	 */
 	public static function mark_migration_incomplete() {
-		delete_option( self::STATUS_FLAG );
+		delete_option(self::STATUS_FLAG);
 	}
 
 	/**
@@ -80,7 +80,7 @@ 
 	 *
 	 * @return string
 	 */
-	public static function set_store_class( $class ) {
+	public static function set_store_class($class) {
 		return self::DATASTORE_CLASS;
 	}
 
@@ -91,7 +91,7 @@ 
 	 *
 	 * @return string
 	 */
-	public static function set_logger_class( $class ) {
+	public static function set_logger_class($class) {
 		return self::LOGGER_CLASS;
 	}
 
@@ -100,7 +100,7 @@ 
 	 *
 	 * @param integer $sleep_time The number of seconds to pause before resuming operation.
 	 */
-	public static function set_sleep_time( $sleep_time ) {
+	public static function set_sleep_time($sleep_time) {
 		self::$sleep_time = (int) $sleep_time;
 	}
 
@@ -109,7 +109,7 @@ 
 	 *
 	 * @param integer $free_ticks The number of ticks to free memory on.
 	 */
-	public static function set_free_ticks( $free_ticks ) {
+	public static function set_free_ticks($free_ticks) {
 		self::$free_ticks = (int) $free_ticks;
 	}
 
@@ -118,8 +118,8 @@ 
 	 *
 	 * @param int $ticks Current tick count.
 	 */
-	public static function maybe_free_memory( $ticks ) {
-		if ( self::$free_ticks && 0 === $ticks % self::$free_ticks ) {
+	public static function maybe_free_memory($ticks) {
+		if (self::$free_ticks && 0 === $ticks % self::$free_ticks) {
 			self::free_memory();
 		}
 	}
@@ -128,13 +128,13 @@ 
 	 * Reduce memory footprint by clearing the database query and object caches.
 	 */
 	public static function free_memory() {
-		if ( 0 < self::$sleep_time ) {
+		if (0 < self::$sleep_time) {
 			/* translators: %d: amount of time */
-			\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 ) );
-			sleep( self::$sleep_time );
+			\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));
+			sleep(self::$sleep_time);
 		}
 
-		\WP_CLI::warning( __( 'Attempting to reduce used memory...', 'action-scheduler' ) );
+		\WP_CLI::warning(__('Attempting to reduce used memory...', 'action-scheduler'));
 
 		/**
 		 * @var $wpdb            \wpdb
@@ -144,7 +144,7 @@ 
 
 		$wpdb->queries = array();
 
-		if ( ! is_a( $wp_object_cache, 'WP_Object_Cache' ) ) {
+		if ( ! is_a($wp_object_cache, 'WP_Object_Cache')) {
 			return;
 		}
 
@@ -153,8 +153,8 @@ 
 		$wp_object_cache->memcache_debug = array();
 		$wp_object_cache->cache          = array();
 
-		if ( is_callable( array( $wp_object_cache, '__remoteset' ) ) ) {
-			call_user_func( array( $wp_object_cache, '__remoteset' ) ); // important
+		if (is_callable(array($wp_object_cache, '__remoteset'))) {
+			call_user_func(array($wp_object_cache, '__remoteset')); // important
 		}
 	}
 
@@ -163,22 +163,22 @@ 
 	 * Otherwise, proceed with the migration if the dependencies have been met.
 	 */
 	public static function init() {
-		if ( self::is_migration_complete() ) {
-			add_filter( 'action_scheduler_store_class', array( 'ActionScheduler_DataController', 'set_store_class' ), 100 );
-			add_filter( 'action_scheduler_logger_class', array( 'ActionScheduler_DataController', 'set_logger_class' ), 100 );
-			add_action( 'deactivate_plugin', array( 'ActionScheduler_DataController', 'mark_migration_incomplete' ) );
-		} elseif ( self::dependencies_met() ) {
+		if (self::is_migration_complete()) {
+			add_filter('action_scheduler_store_class', array('ActionScheduler_DataController', 'set_store_class'), 100);
+			add_filter('action_scheduler_logger_class', array('ActionScheduler_DataController', 'set_logger_class'), 100);
+			add_action('deactivate_plugin', array('ActionScheduler_DataController', 'mark_migration_incomplete'));
+		} elseif (self::dependencies_met()) {
 			Controller::init();
 		}
 
-		add_action( 'action_scheduler/progress_tick', array( 'ActionScheduler_DataController', 'maybe_free_memory' ) );
+		add_action('action_scheduler/progress_tick', array('ActionScheduler_DataController', 'maybe_free_memory'));
 	}
 
 	/**
 	 * Singleton factory.
 	 */
 	public static function instance() {
-		if ( ! isset( self::$instance ) ) {
+		if ( ! isset(self::$instance)) {
 			self::$instance = new static();
 		}
 

Indentation +170 added lines, -170 removed lines

@@ -14,174 +14,174 @@
  * @since 3.0.0
  */
 class ActionScheduler_DataController {
-	/** Action data store class name. */
-	const DATASTORE_CLASS = 'ActionScheduler_DBStore';
-
-	/** Logger data store class name. */
-	const LOGGER_CLASS = 'ActionScheduler_DBLogger';
-
-	/** Migration status option name. */
-	const STATUS_FLAG = 'action_scheduler_migration_status';
-
-	/** Migration status option value. */
-	const STATUS_COMPLETE = 'complete';
-
-	/** Migration minimum required PHP version. */
-	const MIN_PHP_VERSION = '5.5';
-
-	/** @var ActionScheduler_DataController */
-	private static $instance;
-
-	/** @var int */
-	private static $sleep_time = 0;
-
-	/** @var int */
-	private static $free_ticks = 50;
-
-	/**
-	 * Get a flag indicating whether the migration environment dependencies are met.
-	 *
-	 * @return bool
-	 */
-	public static function dependencies_met() {
-		$php_support = version_compare( PHP_VERSION, self::MIN_PHP_VERSION, '>=' );
-		return $php_support && apply_filters( 'action_scheduler_migration_dependencies_met', true );
-	}
-
-	/**
-	 * Get a flag indicating whether the migration is complete.
-	 *
-	 * @return bool Whether the flag has been set marking the migration as complete
-	 */
-	public static function is_migration_complete() {
-		return get_option( self::STATUS_FLAG ) === self::STATUS_COMPLETE;
-	}
-
-	/**
-	 * Mark the migration as complete.
-	 */
-	public static function mark_migration_complete() {
-		update_option( self::STATUS_FLAG, self::STATUS_COMPLETE );
-	}
-
-	/**
-	 * Unmark migration when a plugin is de-activated. Will not work in case of silent activation, for example in an update.
-	 * We do this to mitigate the bug of lost actions which happens if there was an AS 2.x to AS 3.x migration in the past, but that plugin is now
-	 * deactivated and the site was running on AS 2.x again.
-	 */
-	public static function mark_migration_incomplete() {
-		delete_option( self::STATUS_FLAG );
-	}
-
-	/**
-	 * Set the action store class name.
-	 *
-	 * @param string $class Classname of the store class.
-	 *
-	 * @return string
-	 */
-	public static function set_store_class( $class ) {
-		return self::DATASTORE_CLASS;
-	}
-
-	/**
-	 * Set the action logger class name.
-	 *
-	 * @param string $class Classname of the logger class.
-	 *
-	 * @return string
-	 */
-	public static function set_logger_class( $class ) {
-		return self::LOGGER_CLASS;
-	}
-
-	/**
-	 * Set the sleep time in seconds.
-	 *
-	 * @param integer $sleep_time The number of seconds to pause before resuming operation.
-	 */
-	public static function set_sleep_time( $sleep_time ) {
-		self::$sleep_time = (int) $sleep_time;
-	}
-
-	/**
-	 * Set the tick count required for freeing memory.
-	 *
-	 * @param integer $free_ticks The number of ticks to free memory on.
-	 */
-	public static function set_free_ticks( $free_ticks ) {
-		self::$free_ticks = (int) $free_ticks;
-	}
-
-	/**
-	 * Free memory if conditions are met.
-	 *
-	 * @param int $ticks Current tick count.
-	 */
-	public static function maybe_free_memory( $ticks ) {
-		if ( self::$free_ticks && 0 === $ticks % self::$free_ticks ) {
-			self::free_memory();
-		}
-	}
-
-	/**
-	 * Reduce memory footprint by clearing the database query and object caches.
-	 */
-	public static function free_memory() {
-		if ( 0 < self::$sleep_time ) {
-			/* translators: %d: amount of time */
-			\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 ) );
-			sleep( self::$sleep_time );
-		}
-
-		\WP_CLI::warning( __( 'Attempting to reduce used memory...', 'action-scheduler' ) );
-
-		/**
-		 * @var $wpdb            \wpdb
-		 * @var $wp_object_cache \WP_Object_Cache
-		 */
-		global $wpdb, $wp_object_cache;
-
-		$wpdb->queries = array();
-
-		if ( ! is_a( $wp_object_cache, 'WP_Object_Cache' ) ) {
-			return;
-		}
-
-		$wp_object_cache->group_ops      = array();
-		$wp_object_cache->stats          = array();
-		$wp_object_cache->memcache_debug = array();
-		$wp_object_cache->cache          = array();
-
-		if ( is_callable( array( $wp_object_cache, '__remoteset' ) ) ) {
-			call_user_func( array( $wp_object_cache, '__remoteset' ) ); // important
-		}
-	}
-
-	/**
-	 * Connect to table datastores if migration is complete.
-	 * Otherwise, proceed with the migration if the dependencies have been met.
-	 */
-	public static function init() {
-		if ( self::is_migration_complete() ) {
-			add_filter( 'action_scheduler_store_class', array( 'ActionScheduler_DataController', 'set_store_class' ), 100 );
-			add_filter( 'action_scheduler_logger_class', array( 'ActionScheduler_DataController', 'set_logger_class' ), 100 );
-			add_action( 'deactivate_plugin', array( 'ActionScheduler_DataController', 'mark_migration_incomplete' ) );
-		} elseif ( self::dependencies_met() ) {
-			Controller::init();
-		}
-
-		add_action( 'action_scheduler/progress_tick', array( 'ActionScheduler_DataController', 'maybe_free_memory' ) );
-	}
-
-	/**
-	 * Singleton factory.
-	 */
-	public static function instance() {
-		if ( ! isset( self::$instance ) ) {
-			self::$instance = new static();
-		}
-
-		return self::$instance;
-	}
+    /** Action data store class name. */
+    const DATASTORE_CLASS = 'ActionScheduler_DBStore';
+
+    /** Logger data store class name. */
+    const LOGGER_CLASS = 'ActionScheduler_DBLogger';
+
+    /** Migration status option name. */
+    const STATUS_FLAG = 'action_scheduler_migration_status';
+
+    /** Migration status option value. */
+    const STATUS_COMPLETE = 'complete';
+
+    /** Migration minimum required PHP version. */
+    const MIN_PHP_VERSION = '5.5';
+
+    /** @var ActionScheduler_DataController */
+    private static $instance;
+
+    /** @var int */
+    private static $sleep_time = 0;
+
+    /** @var int */
+    private static $free_ticks = 50;
+
+    /**
+     * Get a flag indicating whether the migration environment dependencies are met.
+     *
+     * @return bool
+     */
+    public static function dependencies_met() {
+        $php_support = version_compare( PHP_VERSION, self::MIN_PHP_VERSION, '>=' );
+        return $php_support && apply_filters( 'action_scheduler_migration_dependencies_met', true );
+    }
+
+    /**
+     * Get a flag indicating whether the migration is complete.
+     *
+     * @return bool Whether the flag has been set marking the migration as complete
+     */
+    public static function is_migration_complete() {
+        return get_option( self::STATUS_FLAG ) === self::STATUS_COMPLETE;
+    }
+
+    /**
+     * Mark the migration as complete.
+     */
+    public static function mark_migration_complete() {
+        update_option( self::STATUS_FLAG, self::STATUS_COMPLETE );
+    }
+
+    /**
+     * Unmark migration when a plugin is de-activated. Will not work in case of silent activation, for example in an update.
+     * We do this to mitigate the bug of lost actions which happens if there was an AS 2.x to AS 3.x migration in the past, but that plugin is now
+     * deactivated and the site was running on AS 2.x again.
+     */
+    public static function mark_migration_incomplete() {
+        delete_option( self::STATUS_FLAG );
+    }
+
+    /**
+     * Set the action store class name.
+     *
+     * @param string $class Classname of the store class.
+     *
+     * @return string
+     */
+    public static function set_store_class( $class ) {
+        return self::DATASTORE_CLASS;
+    }
+
+    /**
+     * Set the action logger class name.
+     *
+     * @param string $class Classname of the logger class.
+     *
+     * @return string
+     */
+    public static function set_logger_class( $class ) {
+        return self::LOGGER_CLASS;
+    }
+
+    /**
+     * Set the sleep time in seconds.
+     *
+     * @param integer $sleep_time The number of seconds to pause before resuming operation.
+     */
+    public static function set_sleep_time( $sleep_time ) {
+        self::$sleep_time = (int) $sleep_time;
+    }
+
+    /**
+     * Set the tick count required for freeing memory.
+     *
+     * @param integer $free_ticks The number of ticks to free memory on.
+     */
+    public static function set_free_ticks( $free_ticks ) {
+        self::$free_ticks = (int) $free_ticks;
+    }
+
+    /**
+     * Free memory if conditions are met.
+     *
+     * @param int $ticks Current tick count.
+     */
+    public static function maybe_free_memory( $ticks ) {
+        if ( self::$free_ticks && 0 === $ticks % self::$free_ticks ) {
+            self::free_memory();
+        }
+    }
+
+    /**
+     * Reduce memory footprint by clearing the database query and object caches.
+     */
+    public static function free_memory() {
+        if ( 0 < self::$sleep_time ) {
+            /* translators: %d: amount of time */
+            \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 ) );
+            sleep( self::$sleep_time );
+        }
+
+        \WP_CLI::warning( __( 'Attempting to reduce used memory...', 'action-scheduler' ) );
+
+        /**
+         * @var $wpdb            \wpdb
+         * @var $wp_object_cache \WP_Object_Cache
+         */
+        global $wpdb, $wp_object_cache;
+
+        $wpdb->queries = array();
+
+        if ( ! is_a( $wp_object_cache, 'WP_Object_Cache' ) ) {
+            return;
+        }
+
+        $wp_object_cache->group_ops      = array();
+        $wp_object_cache->stats          = array();
+        $wp_object_cache->memcache_debug = array();
+        $wp_object_cache->cache          = array();
+
+        if ( is_callable( array( $wp_object_cache, '__remoteset' ) ) ) {
+            call_user_func( array( $wp_object_cache, '__remoteset' ) ); // important
+        }
+    }
+
+    /**
+     * Connect to table datastores if migration is complete.
+     * Otherwise, proceed with the migration if the dependencies have been met.
+     */
+    public static function init() {
+        if ( self::is_migration_complete() ) {
+            add_filter( 'action_scheduler_store_class', array( 'ActionScheduler_DataController', 'set_store_class' ), 100 );
+            add_filter( 'action_scheduler_logger_class', array( 'ActionScheduler_DataController', 'set_logger_class' ), 100 );
+            add_action( 'deactivate_plugin', array( 'ActionScheduler_DataController', 'mark_migration_incomplete' ) );
+        } elseif ( self::dependencies_met() ) {
+            Controller::init();
+        }
+
+        add_action( 'action_scheduler/progress_tick', array( 'ActionScheduler_DataController', 'maybe_free_memory' ) );
+    }
+
+    /**
+     * Singleton factory.
+     */
+    public static function instance() {
+        if ( ! isset( self::$instance ) ) {
+            self::$instance = new static();
+        }
+
+        return self::$instance;
+    }
 }

src/wordlift/common/background-process/action-scheduler/class-state.php

Indentation +18 added lines, -18 removed lines

@@ -4,29 +4,29 @@
 
 class State {
 
-	private $args;
-	private $has_next;
+    private $args;
+    private $has_next;
 
-	public function __construct( $has_next, $args ) {
-		$this->has_next = $has_next;
-		$this->args     = $args;
-	}
+    public function __construct( $has_next, $args ) {
+        $this->has_next = $has_next;
+        $this->args     = $args;
+    }
 
-	public function has_next() {
-		return $this->has_next;
-	}
+    public function has_next() {
+        return $this->has_next;
+    }
 
-	public function get_args() {
-		return $this->args;
-	}
+    public function get_args() {
+        return $this->args;
+    }
 
-	public static function complete() {
-		return new self( false, array() );
-	}
+    public static function complete() {
+        return new self( false, array() );
+    }
 
-	public static function items_in_queue( $args = array() ) {
-		return new self( true, $args );
-	}
+    public static function items_in_queue( $args = array() ) {
+        return new self( true, $args );
+    }
 
 
 }

Spacing +4 added lines, -4 removed lines

@@ -7,7 +7,7 @@ 
 	private $args;
 	private $has_next;
 
-	public function __construct( $has_next, $args ) {
+	public function __construct($has_next, $args) {
 		$this->has_next = $has_next;
 		$this->args     = $args;
 	}
@@ -21,11 +21,11 @@ 
 	}
 
 	public static function complete() {
-		return new self( false, array() );
+		return new self(false, array());
 	}
 
-	public static function items_in_queue( $args = array() ) {
-		return new self( true, $args );
+	public static function items_in_queue($args = array()) {
+		return new self(true, $args);
 	}
 
 }

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

Indentation +19 added lines, -19 removed lines

@@ -6,31 +6,31 @@
 
 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->unschedule();
-		$this->context->set_state( Sync_Background_Process::STATE_STOPPED );
-	}
+    public function enter() {
+        $this->context->unschedule();
+        $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 );
+    }
 
-	// phpcs:ignore VariableAnalysis.CodeAnalysis.VariableAnalysis.UnusedVariable
-	public function task( $item ) {
+    // phpcs:ignore VariableAnalysis.CodeAnalysis.VariableAnalysis.UnusedVariable
+    public function task( $item ) {
 
 
-		return State::complete();
-	}
+        return State::complete();
+    }
 
 }

Spacing +5 added lines, -5 removed lines

@@ -11,23 +11,23 @@
 	 */
 	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->unschedule();
-		$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);
 	}
 
 	// phpcs:ignore VariableAnalysis.CodeAnalysis.VariableAnalysis.UnusedVariable
-	public function task( $item ) {
+	public function task($item) {
 
 		return State::complete();
 	}

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

Spacing +32 added lines, -32 removed lines

@@ -42,16 +42,16 @@ 
 	 * @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),
 		);
 	}
 
@@ -60,22 +60,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();
 	}
@@ -85,7 +85,7 @@ 
 	}
 
 	public function leave() {
-		$this->context->set_state( null );
+		$this->context->set_state(null);
 	}
 
 	/**
@@ -94,35 +94,35 @@ 
 	 * @return State
 	 */
 	// phpcs:ignore VariableAnalysis.CodeAnalysis.VariableAnalysis.UnusedVariable
-	public function task( $args ) {
-		$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 );
+	public function task($args) {
+		$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 State::items_in_queue();
 		}
 
 		// 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 State::items_in_queue();
 		}
@@ -139,9 +139,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;
 

Indentation +133 added lines, -133 removed lines

@@ -12,138 +12,138 @@
 
 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 ),
-		);
-	}
-
-	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() {
-		$this->context->schedule();
-	}
-
-	public function leave() {
-		$this->context->set_state( null );
-	}
-
-	/**
-	 * @param $args
-	 *
-	 * @return State
-	 */
-	// phpcs:ignore VariableAnalysis.CodeAnalysis.VariableAnalysis.UnusedVariable
-	public function task( $args ) {
-		$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 State::items_in_queue();
-		}
-
-		// 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 State::items_in_queue();
-		}
-
-		return State::complete();
-	}
-
-	/**
-	 * 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 ),
+        );
+    }
+
+    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() {
+        $this->context->schedule();
+    }
+
+    public function leave() {
+        $this->context->set_state( null );
+    }
+
+    /**
+     * @param $args
+     *
+     * @return State
+     */
+    // phpcs:ignore VariableAnalysis.CodeAnalysis.VariableAnalysis.UnusedVariable
+    public function task( $args ) {
+        $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 State::items_in_queue();
+        }
+
+        // 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 State::items_in_queue();
+        }
+
+        return State::complete();
+    }
+
+    /**
+     * 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;
+    }
 
 }

src/wordlift/dataset/index.php

Indentation +28 added lines, -28 removed lines

@@ -15,38 +15,38 @@
 use Wordlift\Jsonld\Jsonld_Service;
 
 if ( ! defined( 'ABSPATH' ) ) {
-	exit;
+    exit;
 }
 
 // Register the Dataset JSON Endpoint.
 // phpcs:ignore WordPress.NamingConventions.ValidHookName.UseUnderscores
 if ( apply_filters( 'wl_feature__enable__dataset-ng', false ) ) {
 
-	$sync_object_adapter_factory = new Sync_Object_Adapter_Factory();
-	$sync_service                = new Sync_Service( Default_Api_Service::get_instance(), $sync_object_adapter_factory, Jsonld_Service::get_instance(), Wordlift_Entity_Service::get_instance() );
-	new Sync_Post_Hooks( $sync_service, $sync_object_adapter_factory );
-	new Sync_User_Hooks( $sync_service );
-
-	// phpcs:ignore WordPress.NamingConventions.ValidHookName.UseUnderscores
-	if ( apply_filters( 'wl_feature__enable__no-vocabulary-terms', false ) ) {
-		new Sync_Term_Hooks( $sync_service, $sync_object_adapter_factory );
-	}
-	/**
-	 * @since 3.28.0
-	 * @see https://github.com/insideout10/wordlift-plugin/issues/1186
-	 */
-	new Sync_Hooks_Entity_Relation( Wordlift_Entity_Service::get_instance() );
-
-	// phpcs:ignore WordPress.NamingConventions.ValidHookName.UseUnderscores
-	if ( apply_filters( 'wl_feature__enable__wordpress-ontology', false ) ) {
-		new Sync_Hooks_Wordpress_Ontology();
-	}
-
-	// phpcs:ignore WordPress.NamingConventions.ValidHookName.UseUnderscores
-	if ( apply_filters( 'wl_feature__enable__sync-background', false ) ) {
-		// Set up the sync background process.
-		$sync_background_process = new Sync_Background_Process( $sync_service, $sync_object_adapter_factory );
-		new Sync_Background_Process_Wpjson_Endpoint( $sync_background_process );
-		new Sync_Page();
-	}
+    $sync_object_adapter_factory = new Sync_Object_Adapter_Factory();
+    $sync_service                = new Sync_Service( Default_Api_Service::get_instance(), $sync_object_adapter_factory, Jsonld_Service::get_instance(), Wordlift_Entity_Service::get_instance() );
+    new Sync_Post_Hooks( $sync_service, $sync_object_adapter_factory );
+    new Sync_User_Hooks( $sync_service );
+
+    // phpcs:ignore WordPress.NamingConventions.ValidHookName.UseUnderscores
+    if ( apply_filters( 'wl_feature__enable__no-vocabulary-terms', false ) ) {
+        new Sync_Term_Hooks( $sync_service, $sync_object_adapter_factory );
+    }
+    /**
+     * @since 3.28.0
+     * @see https://github.com/insideout10/wordlift-plugin/issues/1186
+     */
+    new Sync_Hooks_Entity_Relation( Wordlift_Entity_Service::get_instance() );
+
+    // phpcs:ignore WordPress.NamingConventions.ValidHookName.UseUnderscores
+    if ( apply_filters( 'wl_feature__enable__wordpress-ontology', false ) ) {
+        new Sync_Hooks_Wordpress_Ontology();
+    }
+
+    // phpcs:ignore WordPress.NamingConventions.ValidHookName.UseUnderscores
+    if ( apply_filters( 'wl_feature__enable__sync-background', false ) ) {
+        // Set up the sync background process.
+        $sync_background_process = new Sync_Background_Process( $sync_service, $sync_object_adapter_factory );
+        new Sync_Background_Process_Wpjson_Endpoint( $sync_background_process );
+        new Sync_Page();
+    }
 }

src/libraries/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')));
 	}
 }