insideout10 / wordlift-plugin

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

Spacing +11 added lines, -11 removed lines

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

Indentation +92 added lines, -92 removed lines

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

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

Indentation +22 added lines, -22 removed lines

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

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

Indentation +18 added lines, -18 removed lines

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

Spacing +5 added lines, -5 removed lines

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

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

Indentation +137 added lines, -137 removed lines

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

Spacing +33 added lines, -33 removed lines

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

src/wordlift.php

Spacing +55 added lines, -55 removed lines

@@ -32,27 +32,27 @@ 
 use Wordlift\Post\Post_Adapter;
 
 // If this file is called directly, abort.
-if ( ! defined( 'WPINC' ) ) {
+if ( ! defined('WPINC')) {
 	die;
 }
 
-define( 'WORDLIFT_VERSION', '3.40.2' );
+define('WORDLIFT_VERSION', '3.40.2');
 
-require_once __DIR__ . '/modules/common/load.php';
-require_once __DIR__ . '/modules/include-exclude/load.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';
 // Action Scheduler.
-require_once plugin_dir_path( __FILE__ ) . '/ext/dependencies/action-scheduler/action-scheduler.php';
+require_once plugin_dir_path(__FILE__).'/ext/dependencies/action-scheduler/action-scheduler.php';
 
 /*
 	 * We introduce the WordLift autoloader, since we start using classes in namespaces, i.e. Wordlift\Http.
@@ -62,15 +62,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.
@@ -78,11 +78,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();
 
 	/**
@@ -102,8 +102,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');
 	}
 
 }
@@ -114,7 +114,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();
@@ -130,18 +130,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.
@@ -161,12 +161,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
@@ -176,10 +176,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();
@@ -196,7 +196,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();
@@ -207,27 +207,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';
 
 		}
 	);
@@ -245,23 +245,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;
 			}
 
@@ -273,13 +273,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'),
 			),
 		)
 	);
@@ -289,23 +289,23 @@ 
  * 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';