insideout10 / wordlift-plugin

src/wordlift.php

Spacing +61 added lines, -61 removed lines

@@ -31,29 +31,29 @@ 
 use Wordlift\Features\Features_Registry;
 use Wordlift\Post\Post_Adapter;
 // If this file is called directly, abort.
-if ( ! defined( 'WPINC' ) ) {
+if ( ! defined('WPINC')) {
 	die;
 }
 define(
 	'WORDLIFT_PLUGIN_FILE',
 	__FILE__
 );
-define( 'WORDLIFT_VERSION', '3.41.0-dev' );
+define('WORDLIFT_VERSION', '3.41.0-dev');
 
-require_once plugin_dir_path( __FILE__ ) . '/libraries/action-scheduler/action-scheduler.php';
-require_once __DIR__ . '/modules/common/load.php';
-require_once __DIR__ . '/modules/include-exclude/load.php';
+require_once plugin_dir_path(__FILE__).'/libraries/action-scheduler/action-scheduler.php';
+require_once __DIR__.'/modules/common/load.php';
+require_once __DIR__.'/modules/include-exclude/load.php';
 
 /**
  * Filter to disable WLP on any request, defaults to true.
  *
  * @since 3.33.6
  */
-if ( ! apply_filters( 'wl_is_enabled', true ) ) {
+if ( ! apply_filters('wl_is_enabled', true)) {
 	return;
 }
 
-require_once plugin_dir_path( __FILE__ ) . 'vendor/autoload.php';
+require_once plugin_dir_path(__FILE__).'vendor/autoload.php';
 
 /*
 	 * We introduce the WordLift autoloader, since we start using classes in namespaces, i.e. Wordlift\Http.
@@ -63,15 +63,15 @@ 
 wordlift_plugin_autoload_register();
 
 // Include WordLift constants.
-require_once plugin_dir_path( __FILE__ ) . 'wordlift-constants.php';
+require_once plugin_dir_path(__FILE__).'wordlift-constants.php';
 
 // Load modules.
-require_once plugin_dir_path( __FILE__ ) . 'modules/core/wordlift-core.php';
+require_once plugin_dir_path(__FILE__).'modules/core/wordlift-core.php';
 
-require_once plugin_dir_path( __FILE__ ) . 'deprecations.php';
+require_once plugin_dir_path(__FILE__).'deprecations.php';
 
 // Load early to enable/disable features.
-require_once plugin_dir_path( __FILE__ ) . 'wordlift/features/index.php';
+require_once plugin_dir_path(__FILE__).'wordlift/features/index.php';
 
 /**
  * The code that runs during plugin activation.
@@ -79,11 +79,11 @@ 
  */
 function activate_wordlift() {
 
-	$log = Wordlift_Log_Service::get_logger( 'activate_wordlift' );
+	$log = Wordlift_Log_Service::get_logger('activate_wordlift');
 
-	$log->info( 'Activating WordLift...' );
+	$log->info('Activating WordLift...');
 
-	require_once plugin_dir_path( __FILE__ ) . 'includes/class-wordlift-activator.php';
+	require_once plugin_dir_path(__FILE__).'includes/class-wordlift-activator.php';
 	Wordlift_Activator::activate();
 
 	/**
@@ -103,8 +103,8 @@ 
 	 */
 	Top_Entities::activate();
 
-	if ( ! wp_next_scheduled( 'wl_daily_cron' ) ) {
-		wp_schedule_event( time(), 'daily', 'wl_daily_cron' );
+	if ( ! wp_next_scheduled('wl_daily_cron')) {
+		wp_schedule_event(time(), 'daily', 'wl_daily_cron');
 	}
 
 }
@@ -115,7 +115,7 @@ 
  */
 function deactivate_wordlift() {
 
-	require_once plugin_dir_path( __FILE__ ) . 'includes/class-wordlift-deactivator.php';
+	require_once plugin_dir_path(__FILE__).'includes/class-wordlift-deactivator.php';
 	Wordlift_Deactivator::deactivate();
 	Wordlift_Http_Api::deactivate();
 	Ttl_Cache_Cleaner::deactivate();
@@ -131,18 +131,18 @@ 
 	Key_Validation_Notice::remove_notification_flag();
 	flush_rewrite_rules();
 
-	wp_clear_scheduled_hook( 'wl_daily_cron' );
+	wp_clear_scheduled_hook('wl_daily_cron');
 
 }
 
-register_activation_hook( __FILE__, 'activate_wordlift' );
-register_deactivation_hook( __FILE__, 'deactivate_wordlift' );
+register_activation_hook(__FILE__, 'activate_wordlift');
+register_deactivation_hook(__FILE__, 'deactivate_wordlift');
 
 /**
  * The core plugin class that is used to define internationalization,
  * admin-specific hooks, and public-facing site hooks.
  */
-require plugin_dir_path( __FILE__ ) . 'includes/class-wordlift.php';
+require plugin_dir_path(__FILE__).'includes/class-wordlift.php';
 
 /**
  * Begins execution of the plugin.
@@ -162,12 +162,12 @@ 
 	 * @return bool
 	 * @since 3.27.6
 	 */
-	if ( apply_filters( 'wl_feature__enable__widgets', true ) ) {
-		add_action( 'widgets_init', 'wl_register_chord_widget' );
-		add_action( 'widgets_init', 'wl_register_geo_widget' );
-		add_action( 'widgets_init', 'wl_register_timeline_widget' );
+	if (apply_filters('wl_feature__enable__widgets', true)) {
+		add_action('widgets_init', 'wl_register_chord_widget');
+		add_action('widgets_init', 'wl_register_geo_widget');
+		add_action('widgets_init', 'wl_register_timeline_widget');
 	}
-	add_filter( 'widget_text', 'do_shortcode' );
+	add_filter('widget_text', 'do_shortcode');
 
 	/**
 	 * Filter: wl_feature__enable__analysis
@@ -177,10 +177,10 @@ 
 	 * @return bool
 	 * @since 3.27.6
 	 */
-	if ( apply_filters( 'wl_feature__enable__analysis', true ) ) {
-		add_action( 'wp_ajax_wl_analyze', 'wl_ajax_analyze_action' );
+	if (apply_filters('wl_feature__enable__analysis', true)) {
+		add_action('wp_ajax_wl_analyze', 'wl_ajax_analyze_action');
 	} else {
-		add_action( 'wp_ajax_wl_analyze', 'wl_ajax_analyze_disabled_action' );
+		add_action('wp_ajax_wl_analyze', 'wl_ajax_analyze_disabled_action');
 	}
 
 	$plugin = new Wordlift();
@@ -197,7 +197,7 @@ 
 
 	add_action(
 		'plugins_loaded',
-		function () {
+		function() {
 			// All features from registry should be initialized here.
 			$features_registry = Features_Registry::get_instance();
 			$features_registry->initialize_all_features();
@@ -208,27 +208,27 @@ 
 	add_action(
 		'plugins_loaded',
 		// phpcs:ignore VariableAnalysis.CodeAnalysis.VariableAnalysis.UnusedVariable
-		function () use ( $plugin ) {
+		function() use ($plugin) {
 
 			new Wordlift_Products_Navigator_Shortcode_REST();
 
 			// Register the Dataset module, requires `$api_service`.
-			require_once plugin_dir_path( __FILE__ ) . 'wordlift/dataset/index.php';
-			require_once plugin_dir_path( __FILE__ ) . 'wordlift/shipping-data/index.php';
+			require_once plugin_dir_path(__FILE__).'wordlift/dataset/index.php';
+			require_once plugin_dir_path(__FILE__).'wordlift/shipping-data/index.php';
 
 			/*
 			* Require the Entity annotation cleanup module.
 			*
 			* @since 3.34.6
 			*/
-			require_once plugin_dir_path( __FILE__ ) . 'wordlift/cleanup/index.php';
+			require_once plugin_dir_path(__FILE__).'wordlift/cleanup/index.php';
 
 			/*
 			* Import LOD entities.
 			*
 			* @since 3.35.0
 			*/
-			require_once plugin_dir_path( __FILE__ ) . 'wordlift/lod-import/index.php';
+			require_once plugin_dir_path(__FILE__).'wordlift/lod-import/index.php';
 
 		}
 	);
@@ -246,23 +246,23 @@ 
 function wordlift_plugin_autoload_register() {
 
 	spl_autoload_register(
-		function ( $class_name ) {
+		function($class_name) {
 
 			// Bail out if these are not our classes.
-			if ( 0 !== strpos( $class_name, 'Wordlift\\' ) ) {
+			if (0 !== strpos($class_name, 'Wordlift\\')) {
 				return false;
 			}
 
-			$class_name_lc = strtolower( str_replace( '_', '-', $class_name ) );
+			$class_name_lc = strtolower(str_replace('_', '-', $class_name));
 
-			preg_match( '|^(?:(.*)\\\\)?(.+?)$|', $class_name_lc, $matches );
+			preg_match('|^(?:(.*)\\\\)?(.+?)$|', $class_name_lc, $matches);
 
-			$path = str_replace( '\\', DIRECTORY_SEPARATOR, $matches[1] );
-			$file = 'class-' . $matches[2] . '.php';
+			$path = str_replace('\\', DIRECTORY_SEPARATOR, $matches[1]);
+			$file = 'class-'.$matches[2].'.php';
 
-			$full_path = plugin_dir_path( __FILE__ ) . $path . DIRECTORY_SEPARATOR . $file;
+			$full_path = plugin_dir_path(__FILE__).$path.DIRECTORY_SEPARATOR.$file;
 
-			if ( ! file_exists( $full_path ) ) {
+			if ( ! file_exists($full_path)) {
 				return false;
 			}
 
@@ -274,13 +274,13 @@ 
 
 }
 
-function wl_block_categories( $categories ) {
+function wl_block_categories($categories) {
 	return array_merge(
 		$categories,
 		array(
 			array(
 				'slug'  => 'wordlift',
-				'title' => __( 'WordLift', 'wordlift' ),
+				'title' => __('WordLift', 'wordlift'),
 			),
 		)
 	);
@@ -290,45 +290,45 @@ 
  * This function is created temporarily to handle the legacy library,
  * this has to be removed when removing the legacy fields from the ui.
  */
-function wl_enqueue_leaflet( $in_footer = false ) {
+function wl_enqueue_leaflet($in_footer = false) {
 	// Leaflet.
-	wp_enqueue_style( 'wl-leaflet', plugin_dir_url( __FILE__ ) . 'js/leaflet/leaflet.css', array(), '1.6.0' );
-	wp_enqueue_script( 'wl-leaflet', plugin_dir_url( __FILE__ ) . 'js/leaflet/leaflet.js', array(), '1.6.0', $in_footer );
+	wp_enqueue_style('wl-leaflet', plugin_dir_url(__FILE__).'js/leaflet/leaflet.css', array(), '1.6.0');
+	wp_enqueue_script('wl-leaflet', plugin_dir_url(__FILE__).'js/leaflet/leaflet.js', array(), '1.6.0', $in_footer);
 }
 
-add_filter( 'block_categories', 'wl_block_categories', 10 );
+add_filter('block_categories', 'wl_block_categories', 10);
 
 // Temporary fix for a typo in WooCommerce Extension.
 add_filter(
 	'wl_feature__enable__dataset',
-	function ( $value ) {
-		return apply_filters( 'wl_features__enable__dataset', $value );
+	function($value) {
+		return apply_filters('wl_features__enable__dataset', $value);
 	}
 );
 
-require_once __DIR__ . '/modules/food-kg/load.php';
-require_once __DIR__ . '/modules/acf4so/load.php';
-require_once __DIR__ . '/modules/pods/load.php';
-require_once __DIR__ . '/modules/include-exclude-push-config/load.php';
+require_once __DIR__.'/modules/food-kg/load.php';
+require_once __DIR__.'/modules/acf4so/load.php';
+require_once __DIR__.'/modules/pods/load.php';
+require_once __DIR__.'/modules/include-exclude-push-config/load.php';
 
 add_action(
 	'update_plugins_adthrive.wordlift.io',
-	function ( $update, $plugin_data, $plugin_file ) {
+	function($update, $plugin_data, $plugin_file) {
 		// Bail out if it's not our plugin.
 		$update_uri = $plugin_data['UpdateURI'];
-		if ( 'wordlift/wordlift.php' !== $plugin_file || ! isset( $update_uri ) ) {
+		if ('wordlift/wordlift.php' !== $plugin_file || ! isset($update_uri)) {
 			return $update;
 		}
 
-		$response = wp_remote_get( "$update_uri?nocache=" . time() );
+		$response = wp_remote_get("$update_uri?nocache=".time());
 
-		if ( is_wp_error( $response ) ) {
+		if (is_wp_error($response)) {
 			return $update;
 		}
 
 		try {
-			return json_decode( wp_remote_retrieve_body( $response ) );
-		} catch ( Exception $e ) {
+			return json_decode(wp_remote_retrieve_body($response));
+		} catch (Exception $e) {
 			return $update;
 		}
 	},

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

Spacing +14 added lines, -14 removed lines

@@ -16,9 +16,9 @@ 
 	 *
 	 * @param Action_Scheduler_Sync_Background_Process $sync_background_process
 	 */
-	public function __construct( $sync_background_process ) {
+	public function __construct($sync_background_process) {
 
-		add_action( 'rest_api_init', array( $this, 'rest_api_init' ) );
+		add_action('rest_api_init', array($this, 'rest_api_init'));
 
 		$this->sync_background_process = $sync_background_process;
 
@@ -31,11 +31,11 @@ 
 			'/dataset/background/sync',
 			array(
 				'methods'             => WP_REST_Server::CREATABLE,
-				'callback'            => array( $this->sync_background_process, 'start' ),
-				'permission_callback' => function () {
+				'callback'            => array($this->sync_background_process, 'start'),
+				'permission_callback' => function() {
 					$user = wp_get_current_user();
 
-					return is_super_admin( $user->ID ) || in_array( 'administrator', (array) $user->roles, true );
+					return is_super_admin($user->ID) || in_array('administrator', (array) $user->roles, true);
 				},
 			)
 		);
@@ -45,11 +45,11 @@ 
 			'/dataset/background/sync',
 			array(
 				'methods'             => WP_REST_Server::READABLE,
-				'callback'            => array( $this->sync_background_process, 'get_info' ),
-				'permission_callback' => function () {
+				'callback'            => array($this->sync_background_process, 'get_info'),
+				'permission_callback' => function() {
 					$user = wp_get_current_user();
 
-					return is_super_admin( $user->ID ) || in_array( 'administrator', (array) $user->roles, true );
+					return is_super_admin($user->ID) || in_array('administrator', (array) $user->roles, true);
 				},
 			)
 		);
@@ -59,11 +59,11 @@ 
 			'/dataset/background/sync',
 			array(
 				'methods'             => WP_REST_Server::DELETABLE,
-				'callback'            => array( $this->sync_background_process, 'stop' ),
-				'permission_callback' => function () {
+				'callback'            => array($this->sync_background_process, 'stop'),
+				'permission_callback' => function() {
 					$user = wp_get_current_user();
 
-					return is_super_admin( $user->ID ) || in_array( 'administrator', (array) $user->roles, true );
+					return is_super_admin($user->ID) || in_array('administrator', (array) $user->roles, true);
 				},
 			)
 		);
@@ -73,11 +73,11 @@ 
 			'/dataset/background/sync',
 			array(
 				'methods'             => 'PUT',
-				'callback'            => array( $this->sync_background_process, 'resume' ),
-				'permission_callback' => function () {
+				'callback'            => array($this->sync_background_process, 'resume'),
+				'permission_callback' => function() {
 					$user = wp_get_current_user();
 
-					return is_super_admin( $user->ID ) || in_array( 'administrator', (array) $user->roles, true );
+					return is_super_admin($user->ID) || in_array('administrator', (array) $user->roles, true);
 				},
 			)
 		);

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

Spacing +14 added lines, -14 removed lines

@@ -34,29 +34,29 @@ 
 	 * @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( self::HOOK_NAME, 'wordlift' );
+	public function __construct($sync_service, $sync_object_adapter_factory) {
+		parent::__construct(self::HOOK_NAME, 'wordlift');
 		$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);
 		}
 	}
 
 	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();
 		$this->schedule();
 	}
 
 	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();
 	}
 
@@ -66,9 +66,9 @@ 
 	}
 
 
-	public function do_task( $args ) {
-		$result = $this->state->task( $args );
-		if ( ! $result->has_next() ) {
+	public function do_task($args) {
+		$result = $this->state->task($args);
+		if ( ! $result->has_next()) {
 			$this->stop();
 		}
 		return $result;
@@ -80,7 +80,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);
 	}
 
 	/**
@@ -90,10 +90,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-stopped-state.php

Spacing +5 added lines, -5 removed lines

@@ -11,22 +11,22 @@
 	 */
 	private $context;
 
-	public function __construct( $context ) {
-		parent::__construct( Action_Scheduler_Sync_Background_Process::STATE_STOPPED );
+	public function __construct($context) {
+		parent::__construct(Action_Scheduler_Sync_Background_Process::STATE_STOPPED);
 
 		$this->context = $context;
 	}
 
 	public function enter() {
-		$this->context->set_state( Action_Scheduler_Sync_Background_Process::STATE_STOPPED );
+		$this->context->set_state(Action_Scheduler_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) {
 
 		$this->context->unschedule();
 

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( Action_Scheduler_Sync_Background_Process::STATE_STARTED );
+	public function __construct($context, $sync_service, $sync_object_adapter_factory, $reset = true) {
+		parent::__construct(Action_Scheduler_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( Action_Scheduler_Sync_Background_Process::STATE_STARTED );
+		$this->context->set_state(Action_Scheduler_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,36 +94,36 @@ 
 	 * @return State
 	 */
 	// phpcs:ignore VariableAnalysis.CodeAnalysis.VariableAnalysis.UnusedVariable
-	public function task( $args ) {
+	public function task($args) {
 		error_log("started state task() called");
-		$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 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();
 		}
@@ -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/wordlift/dataset/index.php

Spacing +12 added lines, -12 removed lines

@@ -15,39 +15,39 @@
 use Wordlift\Dataset\Sync_User_Hooks;
 use Wordlift\Jsonld\Jsonld_Service;
 
-if ( ! defined( 'ABSPATH' ) ) {
+if ( ! defined('ABSPATH')) {
 	exit;
 }
 
 // Register the Dataset JSON Endpoint.
 // phpcs:ignore WordPress.NamingConventions.ValidHookName.UseUnderscores
-if ( apply_filters( 'wl_feature__enable__dataset-ng', false ) ) {
+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 );
+	$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 );
+	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() );
+	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 ) ) {
+	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 ) ) {
+	if (apply_filters('wl_feature__enable__sync-background', false)) {
 		// Set up the sync background process.
-		$sync_background_process = new Action_Scheduler_Sync_Background_Process( $sync_service, $sync_object_adapter_factory );
-		new Sync_Background_Process_Wpjson_Endpoint( $sync_background_process );
+		$sync_background_process = new Action_Scheduler_Sync_Background_Process($sync_service, $sync_object_adapter_factory);
+		new Sync_Background_Process_Wpjson_Endpoint($sync_background_process);
 		new Sync_Page();
 	}
 }

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

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/common/background-process/action-scheduler/class-action-scheduler-background-process.php

Spacing +12 added lines, -12 removed lines

@@ -15,28 +15,28 @@ 
 	private $group;
 
 
-	public function __construct( $hook, $group ) {
+	public function __construct($hook, $group) {
 		$this->hook  = $hook;
 		$this->group = $group;
-		add_action( $this->hook, array( $this, 'task' ) );
+		add_action($this->hook, array($this, 'task'));
 	}
 
-	public function schedule( $args = array() ) {
+	public function schedule($args = array()) {
 
-		as_enqueue_async_action( $this->hook, $args, $this->group );
-		error_log( "scheduled action for hook " . $this->hook );
+		as_enqueue_async_action($this->hook, $args, $this->group);
+		error_log("scheduled action for hook ".$this->hook);
 
 	}
 
 	public function unschedule() {
-		as_unschedule_all_actions( $this->hook );
+		as_unschedule_all_actions($this->hook);
 	}
 
-	public function task( $args = array() ) {
-		$state = $this->do_task( $args );
-		error_log( 'do_task returned state ' . var_export( $state, true ) );
-		if ( $state->has_next() ) {
-			$this->schedule( $state->get_args() );
+	public function task($args = array()) {
+		$state = $this->do_task($args);
+		error_log('do_task returned state '.var_export($state, true));
+		if ($state->has_next()) {
+			$this->schedule($state->get_args());
 		}
 	}
 
@@ -47,7 +47,7 @@ 
 	 * @return State The state object provides necessary information about
 	 * whether to schedule next event or stop processing.
 	 */
-	abstract public function do_task( $args );
+	abstract public function do_task($args);
 
 
 }