insideout10 / wordlift-plugin

src/wordlift/dataset/class-sync-hooks-wordpress-ontology.php

Indentation +30 added lines, -30 removed lines

@@ -6,48 +6,48 @@
 
 class Sync_Hooks_Wordpress_Ontology {
 
-	const HTTP_PURL_ORG_WORDPRESS_1_0 = 'http://purl.org/wordpress/1.0/';
+    const HTTP_PURL_ORG_WORDPRESS_1_0 = 'http://purl.org/wordpress/1.0/';
 
-	public function __construct() {
-		add_filter( 'wl_dataset__sync_service__sync_item__jsonld', array( $this, 'jsonld' ), 10, 3 );
-	}
+    public function __construct() {
+        add_filter( 'wl_dataset__sync_service__sync_item__jsonld', array( $this, 'jsonld' ), 10, 3 );
+    }
 
-	public function jsonld( $jsonld, $type, $object_id ) {
+    public function jsonld( $jsonld, $type, $object_id ) {
 
-		$jsonld[0][ self::HTTP_PURL_ORG_WORDPRESS_1_0 . 'id' ] = $object_id;
+        $jsonld[0][ self::HTTP_PURL_ORG_WORDPRESS_1_0 . 'id' ] = $object_id;
 
-		switch ( $type ) {
+        switch ( $type ) {
 
-			case Object_Type_Enum::TERM:
-				$term = get_term( $object_id );
+            case Object_Type_Enum::TERM:
+                $term = get_term( $object_id );
 
-				$jsonld[0][ self::HTTP_PURL_ORG_WORDPRESS_1_0 . 'type' ]        = 'term';
-				$jsonld[0][ self::HTTP_PURL_ORG_WORDPRESS_1_0 . 'name' ]        = $term->name;
-				$jsonld[0][ self::HTTP_PURL_ORG_WORDPRESS_1_0 . 'description' ] = $term->description;
-				break;
+                $jsonld[0][ self::HTTP_PURL_ORG_WORDPRESS_1_0 . 'type' ]        = 'term';
+                $jsonld[0][ self::HTTP_PURL_ORG_WORDPRESS_1_0 . 'name' ]        = $term->name;
+                $jsonld[0][ self::HTTP_PURL_ORG_WORDPRESS_1_0 . 'description' ] = $term->description;
+                break;
 
-			case Object_Type_Enum::USER:
-				$user = get_userdata( $object_id );
+            case Object_Type_Enum::USER:
+                $user = get_userdata( $object_id );
 
-				$jsonld[0][ self::HTTP_PURL_ORG_WORDPRESS_1_0 . 'type' ]        = 'user';
-				$jsonld[0][ self::HTTP_PURL_ORG_WORDPRESS_1_0 . 'displayName' ] = $user->display_name;
-				break;
+                $jsonld[0][ self::HTTP_PURL_ORG_WORDPRESS_1_0 . 'type' ]        = 'user';
+                $jsonld[0][ self::HTTP_PURL_ORG_WORDPRESS_1_0 . 'displayName' ] = $user->display_name;
+                break;
 
-			case Object_Type_Enum::POST:
-				$post = get_post( $object_id );
+            case Object_Type_Enum::POST:
+                $post = get_post( $object_id );
 
-				$jsonld[0][ self::HTTP_PURL_ORG_WORDPRESS_1_0 . 'type' ]       = 'post';
-				$jsonld[0][ self::HTTP_PURL_ORG_WORDPRESS_1_0 . 'customType' ] = $post->post_type;
-				$jsonld[0][ self::HTTP_PURL_ORG_WORDPRESS_1_0 . 'title' ]      = $post->post_title;
-				$jsonld[0][ self::HTTP_PURL_ORG_WORDPRESS_1_0 . 'status' ]     = $post->post_status;
-				$jsonld[0][ self::HTTP_PURL_ORG_WORDPRESS_1_0 . 'content' ]    = do_shortcode( $post->post_content );
-				break;
+                $jsonld[0][ self::HTTP_PURL_ORG_WORDPRESS_1_0 . 'type' ]       = 'post';
+                $jsonld[0][ self::HTTP_PURL_ORG_WORDPRESS_1_0 . 'customType' ] = $post->post_type;
+                $jsonld[0][ self::HTTP_PURL_ORG_WORDPRESS_1_0 . 'title' ]      = $post->post_title;
+                $jsonld[0][ self::HTTP_PURL_ORG_WORDPRESS_1_0 . 'status' ]     = $post->post_status;
+                $jsonld[0][ self::HTTP_PURL_ORG_WORDPRESS_1_0 . 'content' ]    = do_shortcode( $post->post_content );
+                break;
 
-			default:
+            default:
 
-		}
+        }
 
-		return $jsonld;
-	}
+        return $jsonld;
+    }
 
 }

Spacing +17 added lines, -17 removed lines

@@ -9,38 +9,38 @@
 	const HTTP_PURL_ORG_WORDPRESS_1_0 = 'http://purl.org/wordpress/1.0/';
 
 	public function __construct() {
-		add_filter( 'wl_dataset__sync_service__sync_item__jsonld', array( $this, 'jsonld' ), 10, 3 );
+		add_filter('wl_dataset__sync_service__sync_item__jsonld', array($this, 'jsonld'), 10, 3);
 	}
 
-	public function jsonld( $jsonld, $type, $object_id ) {
+	public function jsonld($jsonld, $type, $object_id) {
 
-		$jsonld[0][ self::HTTP_PURL_ORG_WORDPRESS_1_0 . 'id' ] = $object_id;
+		$jsonld[0][self::HTTP_PURL_ORG_WORDPRESS_1_0.'id'] = $object_id;
 
-		switch ( $type ) {
+		switch ($type) {
 
 			case Object_Type_Enum::TERM:
-				$term = get_term( $object_id );
+				$term = get_term($object_id);
 
-				$jsonld[0][ self::HTTP_PURL_ORG_WORDPRESS_1_0 . 'type' ]        = 'term';
-				$jsonld[0][ self::HTTP_PURL_ORG_WORDPRESS_1_0 . 'name' ]        = $term->name;
-				$jsonld[0][ self::HTTP_PURL_ORG_WORDPRESS_1_0 . 'description' ] = $term->description;
+				$jsonld[0][self::HTTP_PURL_ORG_WORDPRESS_1_0.'type']        = 'term';
+				$jsonld[0][self::HTTP_PURL_ORG_WORDPRESS_1_0.'name']        = $term->name;
+				$jsonld[0][self::HTTP_PURL_ORG_WORDPRESS_1_0.'description'] = $term->description;
 				break;
 
 			case Object_Type_Enum::USER:
-				$user = get_userdata( $object_id );
+				$user = get_userdata($object_id);
 
-				$jsonld[0][ self::HTTP_PURL_ORG_WORDPRESS_1_0 . 'type' ]        = 'user';
-				$jsonld[0][ self::HTTP_PURL_ORG_WORDPRESS_1_0 . 'displayName' ] = $user->display_name;
+				$jsonld[0][self::HTTP_PURL_ORG_WORDPRESS_1_0.'type']        = 'user';
+				$jsonld[0][self::HTTP_PURL_ORG_WORDPRESS_1_0.'displayName'] = $user->display_name;
 				break;
 
 			case Object_Type_Enum::POST:
-				$post = get_post( $object_id );
+				$post = get_post($object_id);
 
-				$jsonld[0][ self::HTTP_PURL_ORG_WORDPRESS_1_0 . 'type' ]       = 'post';
-				$jsonld[0][ self::HTTP_PURL_ORG_WORDPRESS_1_0 . 'customType' ] = $post->post_type;
-				$jsonld[0][ self::HTTP_PURL_ORG_WORDPRESS_1_0 . 'title' ]      = $post->post_title;
-				$jsonld[0][ self::HTTP_PURL_ORG_WORDPRESS_1_0 . 'status' ]     = $post->post_status;
-				$jsonld[0][ self::HTTP_PURL_ORG_WORDPRESS_1_0 . 'content' ]    = do_shortcode( $post->post_content );
+				$jsonld[0][self::HTTP_PURL_ORG_WORDPRESS_1_0.'type']       = 'post';
+				$jsonld[0][self::HTTP_PURL_ORG_WORDPRESS_1_0.'customType'] = $post->post_type;
+				$jsonld[0][self::HTTP_PURL_ORG_WORDPRESS_1_0.'title']      = $post->post_title;
+				$jsonld[0][self::HTTP_PURL_ORG_WORDPRESS_1_0.'status']     = $post->post_status;
+				$jsonld[0][self::HTTP_PURL_ORG_WORDPRESS_1_0.'content']    = do_shortcode($post->post_content);
 				break;
 
 			default:

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

Indentation +111 added lines, -111 removed lines

@@ -18,116 +18,116 @@
  */
 class Sync_Background_Process extends \Wordlift_Plugin_WP_Background_Process {
 
-	const STATE_STARTED = 'started';
-	const STATE_STOPPED = 'stopped';
-
-	protected $action = 'wl_dataset__sync';
-
-	/**
-	 * @var Sync_Service
-	 */
-	private $sync_service;
-
-	/**
-	 * @var Sync_Object_Adapter_Factory
-	 */
-	private $sync_object_adapter_factory;
-
-	/**
-	 * @var \Wordlift_Log_Service
-	 */
-	private $log;
-
-	/**
-	 * @var Sync_Background_Process_State
-	 */
-	private $state;
-
-	/**
-	 * Sync_Background_Process constructor.
-	 *
-	 * @param Sync_Service $sync_service A {@link Sync_Service} instance providing the supporting functions to this background process.
-	 * @param Sync_Object_Adapter_Factory $sync_object_adapter_factory
-	 */
-	public function __construct( $sync_service, $sync_object_adapter_factory ) {
-		parent::__construct();
-
-		$this->log = \Wordlift_Log_Service::get_logger( get_class() );
-
-		$this->sync_service                = $sync_service;
-		$this->sync_object_adapter_factory = $sync_object_adapter_factory;
-
-		// Set the current state.
-		if ( self::STATE_STARTED === $this->get_state() ) {
-			$this->state = new Sync_Background_Process_Started_State( $this, $this->sync_service, $this->sync_object_adapter_factory );
-		} else {
-			$this->state = new Sync_Background_Process_Stopped_State( $this );
-		}
-
-	}
-
-	/**
-	 * This function is called:
-	 *  - To start a new Synchronization, by passing a {@link Sync_Start_Message} instance.
-	 *  - To synchronize a post, by passing a numeric ID.
-	 *
-	 * This function returns the parameter for the next call or NULL if there are no more posts to process.
-	 *
-	 * @param mixed $item Queue item to iterate over.
-	 *
-	 * @return int[]|false The next post IDs or false if there are no more.
-	 */
-	protected function task( $item ) {
-
-		return $this->state->task( $item );
-	}
-
-	/**
-	 * Transition to the started state.
-	 */
-	public function start() {
-		$this->state->leave();
-		$this->state = new Sync_Background_Process_Started_State( $this, $this->sync_service, $this->sync_object_adapter_factory );
-		$this->state->enter();
-	}
-
-	/**
-	 * Transition to the stopped state.
-	 */
-	public function stop() {
-		$this->state->leave();
-		$this->state = new Sync_Background_Process_Stopped_State( $this );
-		$this->state->enter();
-	}
-
-	public function resume() {
-		$this->state->resume();
-	}
-
-	/**
-	 * Get the current state.
-	 *
-	 * @return string Either self::STARTED_STATE or self::STOPPED_STATE (default).
-	 */
-	public function get_state() {
-		return get_option( '_wl_sync_background_process_state', self::STATE_STOPPED );
-	}
-
-	/**
-	 * Persist the current state.
-	 *
-	 * @param string $value
-	 *
-	 * @return bool
-	 */
-	public function set_state( $value ) {
-		return null === $value
-			? delete_option( '_wl_sync_background_process_state' )
-			: update_option( '_wl_sync_background_process_state', $value, true );
-	}
-
-	public function get_info() {
-		return $this->state->get_info();
-	}
+    const STATE_STARTED = 'started';
+    const STATE_STOPPED = 'stopped';
+
+    protected $action = 'wl_dataset__sync';
+
+    /**
+     * @var Sync_Service
+     */
+    private $sync_service;
+
+    /**
+     * @var Sync_Object_Adapter_Factory
+     */
+    private $sync_object_adapter_factory;
+
+    /**
+     * @var \Wordlift_Log_Service
+     */
+    private $log;
+
+    /**
+     * @var Sync_Background_Process_State
+     */
+    private $state;
+
+    /**
+     * Sync_Background_Process constructor.
+     *
+     * @param Sync_Service $sync_service A {@link Sync_Service} instance providing the supporting functions to this background process.
+     * @param Sync_Object_Adapter_Factory $sync_object_adapter_factory
+     */
+    public function __construct( $sync_service, $sync_object_adapter_factory ) {
+        parent::__construct();
+
+        $this->log = \Wordlift_Log_Service::get_logger( get_class() );
+
+        $this->sync_service                = $sync_service;
+        $this->sync_object_adapter_factory = $sync_object_adapter_factory;
+
+        // Set the current state.
+        if ( self::STATE_STARTED === $this->get_state() ) {
+            $this->state = new Sync_Background_Process_Started_State( $this, $this->sync_service, $this->sync_object_adapter_factory );
+        } else {
+            $this->state = new Sync_Background_Process_Stopped_State( $this );
+        }
+
+    }
+
+    /**
+     * This function is called:
+     *  - To start a new Synchronization, by passing a {@link Sync_Start_Message} instance.
+     *  - To synchronize a post, by passing a numeric ID.
+     *
+     * This function returns the parameter for the next call or NULL if there are no more posts to process.
+     *
+     * @param mixed $item Queue item to iterate over.
+     *
+     * @return int[]|false The next post IDs or false if there are no more.
+     */
+    protected function task( $item ) {
+
+        return $this->state->task( $item );
+    }
+
+    /**
+     * 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-abstract-sync-background-process-state.php

Indentation +28 added lines, -28 removed lines

@@ -4,33 +4,33 @@
 
 abstract class Abstract_Sync_Background_Process_State implements Sync_Background_Process_State {
 
-	private $state;
-
-	function __construct( $state ) {
-		$this->state = $state;
-	}
-
-	function get_info() {
-		$started     = get_option( '_wl_sync_background_process_started' );
-		$offset      = get_option( '_wl_sync_background_process_offset' );
-		$stage       = get_option( '_wl_sync_background_process_stage' );
-		$counts      = get_option( '_wl_sync_background_process_count', array( 0 ) );
-		$last_update = get_option( '_wl_sync_background_process_updated' );
-
-		// Calculate the overall index by adding the count of completed stages.
-		$index = $offset + 1;
-		for ( $i = 0; $i < $stage; $i ++ ) {
-			$index += $counts[ $i ];
-		}
-
-		// Get the total count.
-		$total_count = array_sum( $counts );
-
-		return new Sync_Background_Process_Info( $this->state, $started, $index, $total_count, $last_update );
-	}
-
-	function resume() {
-		// do nothing.
-	}
+    private $state;
+
+    function __construct( $state ) {
+        $this->state = $state;
+    }
+
+    function get_info() {
+        $started     = get_option( '_wl_sync_background_process_started' );
+        $offset      = get_option( '_wl_sync_background_process_offset' );
+        $stage       = get_option( '_wl_sync_background_process_stage' );
+        $counts      = get_option( '_wl_sync_background_process_count', array( 0 ) );
+        $last_update = get_option( '_wl_sync_background_process_updated' );
+
+        // Calculate the overall index by adding the count of completed stages.
+        $index = $offset + 1;
+        for ( $i = 0; $i < $stage; $i ++ ) {
+            $index += $counts[ $i ];
+        }
+
+        // Get the total count.
+        $total_count = array_sum( $counts );
+
+        return new Sync_Background_Process_Info( $this->state, $started, $index, $total_count, $last_update );
+    }
+
+    function resume() {
+        // do nothing.
+    }
 
 }

Spacing +10 added lines, -10 removed lines

@@ -6,27 +6,27 @@
 
 	private $state;
 
-	function __construct( $state ) {
+	function __construct($state) {
 		$this->state = $state;
 	}
 
 	function get_info() {
-		$started     = get_option( '_wl_sync_background_process_started' );
-		$offset      = get_option( '_wl_sync_background_process_offset' );
-		$stage       = get_option( '_wl_sync_background_process_stage' );
-		$counts      = get_option( '_wl_sync_background_process_count', array( 0 ) );
-		$last_update = get_option( '_wl_sync_background_process_updated' );
+		$started     = get_option('_wl_sync_background_process_started');
+		$offset      = get_option('_wl_sync_background_process_offset');
+		$stage       = get_option('_wl_sync_background_process_stage');
+		$counts      = get_option('_wl_sync_background_process_count', array(0));
+		$last_update = get_option('_wl_sync_background_process_updated');
 
 		// Calculate the overall index by adding the count of completed stages.
 		$index = $offset + 1;
-		for ( $i = 0; $i < $stage; $i ++ ) {
-			$index += $counts[ $i ];
+		for ($i = 0; $i < $stage; $i++) {
+			$index += $counts[$i];
 		}
 
 		// Get the total count.
-		$total_count = array_sum( $counts );
+		$total_count = array_sum($counts);
 
-		return new Sync_Background_Process_Info( $this->state, $started, $index, $total_count, $last_update );
+		return new Sync_Background_Process_Info($this->state, $started, $index, $total_count, $last_update);
 	}
 
 	function resume() {

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

Indentation +61 added lines, -61 removed lines

@@ -6,66 +6,66 @@
 
 class Sync_Background_Process_Wpjson_Endpoint {
 
-	/**
-	 * @var Sync_Background_Process
-	 */
-	private $sync_background_process;
-
-	/**
-	 * Sync_Background_Process_Wpjson_Endpoint constructor.
-	 *
-	 * @param Sync_Background_Process $sync_background_process
-	 */
-	function __construct( $sync_background_process ) {
-
-		add_action( 'rest_api_init', array( $this, 'rest_api_init' ) );
-
-		$this->sync_background_process = $sync_background_process;
-
-	}
-
-	function rest_api_init() {
-
-		register_rest_route( 'wordlift/v1', '/dataset/background/sync', array(
-			'methods'             => WP_REST_Server::CREATABLE,
-			'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 );
-			}
-		) );
-
-		register_rest_route( 'wordlift/v1', '/dataset/background/sync', array(
-			'methods'             => WP_REST_Server::READABLE,
-			'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 );
-			}
-		) );
-
-		register_rest_route( 'wordlift/v1', '/dataset/background/sync', array(
-			'methods'             => WP_REST_Server::DELETABLE,
-			'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 );
-			}
-		) );
-
-		register_rest_route( 'wordlift/v1', '/dataset/background/sync', array(
-			'methods'             => 'PUT',
-			'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 );
-			}
-		) );
-
-	}
+    /**
+     * @var Sync_Background_Process
+     */
+    private $sync_background_process;
+
+    /**
+     * Sync_Background_Process_Wpjson_Endpoint constructor.
+     *
+     * @param Sync_Background_Process $sync_background_process
+     */
+    function __construct( $sync_background_process ) {
+
+        add_action( 'rest_api_init', array( $this, 'rest_api_init' ) );
+
+        $this->sync_background_process = $sync_background_process;
+
+    }
+
+    function rest_api_init() {
+
+        register_rest_route( 'wordlift/v1', '/dataset/background/sync', array(
+            'methods'             => WP_REST_Server::CREATABLE,
+            '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 );
+            }
+        ) );
+
+        register_rest_route( 'wordlift/v1', '/dataset/background/sync', array(
+            'methods'             => WP_REST_Server::READABLE,
+            '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 );
+            }
+        ) );
+
+        register_rest_route( 'wordlift/v1', '/dataset/background/sync', array(
+            'methods'             => WP_REST_Server::DELETABLE,
+            '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 );
+            }
+        ) );
+
+        register_rest_route( 'wordlift/v1', '/dataset/background/sync', array(
+            'methods'             => 'PUT',
+            '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 );
+            }
+        ) );
+
+    }
 
 }

Spacing +22 added lines, -22 removed lines

@@ -16,9 +16,9 @@ 
 	 *
 	 * @param Sync_Background_Process $sync_background_process
 	 */
-	function __construct( $sync_background_process ) {
+	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;
 
@@ -26,45 +26,45 @@ 
 
 	function rest_api_init() {
 
-		register_rest_route( 'wordlift/v1', '/dataset/background/sync', array(
+		register_rest_route('wordlift/v1', '/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 );
+				return is_super_admin($user->ID) || in_array('administrator', (array) $user->roles);
 			}
-		) );
+		));
 
-		register_rest_route( 'wordlift/v1', '/dataset/background/sync', array(
+		register_rest_route('wordlift/v1', '/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 );
+				return is_super_admin($user->ID) || in_array('administrator', (array) $user->roles);
 			}
-		) );
+		));
 
-		register_rest_route( 'wordlift/v1', '/dataset/background/sync', array(
+		register_rest_route('wordlift/v1', '/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 );
+				return is_super_admin($user->ID) || in_array('administrator', (array) $user->roles);
 			}
-		) );
+		));
 
-		register_rest_route( 'wordlift/v1', '/dataset/background/sync', array(
+		register_rest_route('wordlift/v1', '/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 );
+				return is_super_admin($user->ID) || in_array('administrator', (array) $user->roles);
 			}
-		) );
+		));
 
 	}
 

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

Indentation +127 added lines, -127 removed lines

@@ -11,132 +11,132 @@
 
 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
-	 */
-	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 ),
-		);
-	}
-
-	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();
-	}
-
-	function resume() {
-		$this->context->push_to_queue( true );
-		$this->context->save()->dispatch();
-	}
-
-	function leave() {
-		$this->context->set_state( null );
-	}
-
-	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 );
-		} 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
+     */
+    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 ),
+        );
+    }
+
+    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();
+    }
+
+    function resume() {
+        $this->context->push_to_queue( true );
+        $this->context->save()->dispatch();
+    }
+
+    function leave() {
+        $this->context->set_state( null );
+    }
+
+    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 );
+        } 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 +34 added lines, -34 removed lines

@@ -40,16 +40,16 @@ 
 	 * @param Sync_Object_Adapter_Factory $sync_object_adapter_factory
 	 * @param bool $reset Whether to reset the counters
 	 */
-	function __construct( $context, $sync_service, $sync_object_adapter_factory, $reset = true ) {
-		parent::__construct( Sync_Background_Process::STATE_STARTED );
+	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),
 		);
 	}
 
@@ -58,61 +58,61 @@ 
 		$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 ) {
+		$counts = array_map(function($item) {
 			return $item->count();
-		}, $this->stages );
+		}, $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();
 	}
 
 	function resume() {
-		$this->context->push_to_queue( true );
+		$this->context->push_to_queue(true);
 		$this->context->save()->dispatch();
 	}
 
 	function leave() {
-		$this->context->set_state( null );
+		$this->context->set_state(null);
 	}
 
-	function task( $args ) {
+	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 );
+		$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 );
-		} catch ( \Exception $e ) {
+			$object_adapters = $this->stages[$stage]->get_sync_object_adapters($offset, $batch_size);
+			$this->sync_service->sync_many($object_adapters, true);
+		} 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;
 		}
@@ -130,9 +130,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/background/class-sync-background-process-state.php

Indentation +24 added lines, -24 removed lines

@@ -4,29 +4,29 @@
 
 interface Sync_Background_Process_State {
 
-	function enter();
-
-	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.
-	 *
-	 * @param mixed $item Queue item to iterate over.
-	 *
-	 * @return mixed
-	 */
-	function task( $item );
-
-	function get_info();
-
-	/**
-	 * Try to resume an interrupted task.
-	 */
-	function resume();
+    function enter();
+
+    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.
+     *
+     * @param mixed $item Queue item to iterate over.
+     *
+     * @return mixed
+     */
+    function task( $item );
+
+    function get_info();
+
+    /**
+     * Try to resume an interrupted task.
+     */
+    function resume();
 
 }
\ No newline at end of file