insideout10 / wordlift-plugin

src/wordlift.php

Indentation +168 added lines, -168 removed lines

@@ -32,11 +32,11 @@ 
 use Wordlift\Post\Post_Adapter;
 // If this file is called directly, abort.
 if ( ! defined( 'WPINC' ) ) {
-	die;
+    die;
 }
 define(
-	'WORDLIFT_PLUGIN_FILE',
-	__FILE__
+    'WORDLIFT_PLUGIN_FILE',
+    __FILE__
 );
 define( 'WORDLIFT_VERSION', '3.41.0-dev' );
 
@@ -50,7 +50,7 @@ 
  * @since 3.33.6
  */
 if ( ! apply_filters( 'wl_is_enabled', true ) ) {
-	return;
+    return;
 }
 
 require_once plugin_dir_path( __FILE__ ) . 'vendor/autoload.php';
@@ -79,33 +79,33 @@ 
  */
 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';
-	Wordlift_Activator::activate();
+    require_once plugin_dir_path( __FILE__ ) . 'includes/class-wordlift-activator.php';
+    Wordlift_Activator::activate();
 
-	/**
-	 * Tell the {@link Wordlift_Http_Api} class that we're activating, to let it run activation tasks.
-	 *
-	 * @see https://github.com/insideout10/wordlift-plugin/issues/820 related issue.
-	 * @since 3.19.2
-	 */
-	Wordlift_Http_Api::activate();
-
-	// Ensure the post type is registered before flushing the rewrite rules.
-	Wordlift_Entity_Post_Type_Service::get_instance()->register();
-	flush_rewrite_rules();
-	/**
-	 * @since 3.27.7
-	 * @see https://github.com/insideout10/wordlift-plugin/issues/1214
-	 */
-	Top_Entities::activate();
+    /**
+     * Tell the {@link Wordlift_Http_Api} class that we're activating, to let it run activation tasks.
+     *
+     * @see https://github.com/insideout10/wordlift-plugin/issues/820 related issue.
+     * @since 3.19.2
+     */
+    Wordlift_Http_Api::activate();
+
+    // Ensure the post type is registered before flushing the rewrite rules.
+    Wordlift_Entity_Post_Type_Service::get_instance()->register();
+    flush_rewrite_rules();
+    /**
+     * @since 3.27.7
+     * @see https://github.com/insideout10/wordlift-plugin/issues/1214
+     */
+    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,23 +115,23 @@ 
  */
 function deactivate_wordlift() {
 
-	require_once plugin_dir_path( __FILE__ ) . 'includes/class-wordlift-deactivator.php';
-	Wordlift_Deactivator::deactivate();
-	Wordlift_Http_Api::deactivate();
-	Ttl_Cache_Cleaner::deactivate();
-	/**
-	 * @since 3.27.7
-	 * @see https://github.com/insideout10/wordlift-plugin/issues/1214
-	 */
-	Top_Entities::deactivate();
-	/**
-	 * @since 3.27.8
-	 * Remove notification flag on deactivation.
-	 */
-	Key_Validation_Notice::remove_notification_flag();
-	flush_rewrite_rules();
-
-	wp_clear_scheduled_hook( 'wl_daily_cron' );
+    require_once plugin_dir_path( __FILE__ ) . 'includes/class-wordlift-deactivator.php';
+    Wordlift_Deactivator::deactivate();
+    Wordlift_Http_Api::deactivate();
+    Ttl_Cache_Cleaner::deactivate();
+    /**
+     * @since 3.27.7
+     * @see https://github.com/insideout10/wordlift-plugin/issues/1214
+     */
+    Top_Entities::deactivate();
+    /**
+     * @since 3.27.8
+     * Remove notification flag on deactivation.
+     */
+    Key_Validation_Notice::remove_notification_flag();
+    flush_rewrite_rules();
+
+    wp_clear_scheduled_hook( 'wl_daily_cron' );
 
 }
 
@@ -154,84 +154,84 @@ 
  * @since    1.0.0
  */
 function run_wordlift() {
-	/**
-	 * Filter: wl_feature__enable__widgets.
-	 *
-	 * @param bool whether the widgets needed to be registered, defaults to true.
-	 *
-	 * @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' );
-	}
-	add_filter( 'widget_text', 'do_shortcode' );
-
-	/**
-	 * Filter: wl_feature__enable__analysis
-	 *
-	 * @param bool Whether to send api request to analysis or not
-	 *
-	 * @return bool
-	 * @since 3.27.6
-	 */
-	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' );
-	}
-
-	$plugin = new Wordlift();
-	$plugin->run();
-
-	// Initialize the TTL Cache Cleaner.
-	new Ttl_Cache_Cleaner();
-
-	// Load the new Post Adapter.
-	new Post_Adapter();
-
-	// Load the API Data Hooks.
-	new Api_Data_Hooks();
-
-	add_action(
-		'plugins_loaded',
-		function () {
-			// All features from registry should be initialized here.
-			$features_registry = Features_Registry::get_instance();
-			$features_registry->initialize_all_features();
-		},
-		5
-	);
-
-	add_action(
-		'plugins_loaded',
-		// phpcs:ignore VariableAnalysis.CodeAnalysis.VariableAnalysis.UnusedVariable
-		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';
-
-			/*
+    /**
+     * Filter: wl_feature__enable__widgets.
+     *
+     * @param bool whether the widgets needed to be registered, defaults to true.
+     *
+     * @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' );
+    }
+    add_filter( 'widget_text', 'do_shortcode' );
+
+    /**
+     * Filter: wl_feature__enable__analysis
+     *
+     * @param bool Whether to send api request to analysis or not
+     *
+     * @return bool
+     * @since 3.27.6
+     */
+    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' );
+    }
+
+    $plugin = new Wordlift();
+    $plugin->run();
+
+    // Initialize the TTL Cache Cleaner.
+    new Ttl_Cache_Cleaner();
+
+    // Load the new Post Adapter.
+    new Post_Adapter();
+
+    // Load the API Data Hooks.
+    new Api_Data_Hooks();
+
+    add_action(
+        'plugins_loaded',
+        function () {
+            // All features from registry should be initialized here.
+            $features_registry = Features_Registry::get_instance();
+            $features_registry->initialize_all_features();
+        },
+        5
+    );
+
+    add_action(
+        'plugins_loaded',
+        // phpcs:ignore VariableAnalysis.CodeAnalysis.VariableAnalysis.UnusedVariable
+        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 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,45 +245,45 @@ 
  */
 function wordlift_plugin_autoload_register() {
 
-	spl_autoload_register(
-		function ( $class_name ) {
+    spl_autoload_register(
+        function ( $class_name ) {
 
-			// Bail out if these are not our classes.
-			if ( 0 !== strpos( $class_name, 'Wordlift\\' ) ) {
-				return false;
-			}
+            // Bail out if these are not our classes.
+            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 ) ) {
-				return false;
-			}
+            if ( ! file_exists( $full_path ) ) {
+                return false;
+            }
 
-			require_once $full_path;
+            require_once $full_path;
 
-			return true;
-		}
-	);
+            return true;
+        }
+    );
 
 }
 
 function wl_block_categories( $categories ) {
-	return array_merge(
-		$categories,
-		array(
-			array(
-				'slug'  => 'wordlift',
-				'title' => __( 'WordLift', 'wordlift' ),
-			),
-		)
-	);
+    return array_merge(
+        $categories,
+        array(
+            array(
+                'slug'  => 'wordlift',
+                'title' => __( 'WordLift', 'wordlift' ),
+            ),
+        )
+    );
 }
 
 /**
@@ -291,19 +291,19 @@ 
  * this has to be removed when removing the legacy fields from the ui.
  */
 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 );
+    // 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 );
 }
 
 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 );
-	}
+    'wl_feature__enable__dataset',
+    function ( $value ) {
+        return apply_filters( 'wl_features__enable__dataset', $value );
+    }
 );
 
 require_once __DIR__ . '/modules/food-kg/load.php';
@@ -312,26 +312,26 @@ 
 require_once __DIR__ . '/modules/include-exclude-push-config/load.php';
 
 add_action(
-	'update_plugins_adthrive.wordlift.io',
-	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 ) ) {
-			return $update;
-		}
-
-		$response = wp_remote_get( "$update_uri?nocache=" . time() );
-
-		if ( is_wp_error( $response ) ) {
-			return $update;
-		}
-
-		try {
-			return json_decode( wp_remote_retrieve_body( $response ) );
-		} catch ( Exception $e ) {
-			return $update;
-		}
-	},
-	10,
-	3
+    'update_plugins_adthrive.wordlift.io',
+    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 ) ) {
+            return $update;
+        }
+
+        $response = wp_remote_get( "$update_uri?nocache=" . time() );
+
+        if ( is_wp_error( $response ) ) {
+            return $update;
+        }
+
+        try {
+            return json_decode( wp_remote_retrieve_body( $response ) );
+        } catch ( Exception $e ) {
+            return $update;
+        }
+    },
+    10,
+    3
 );

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

Indentation +18 added lines, -18 removed lines

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

Spacing +4 added lines, -4 removed lines

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

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

Indentation +41 added lines, -41 removed lines

@@ -5,47 +5,47 @@
 abstract class Action_Scheduler_Background_Process {
 
 
-	/**
-	 * @var string Hook name used for invoking the task method.
-	 */
-	private $hook;
-	/**
-	 * @var string Group which would be used when
-	 */
-	private $group;
-
-
-	public function __construct( $hook, $group ) {
-		$this->hook  = $hook;
-		$this->group = $group;
-		add_action( $this->hook, array( $this, 'task' ) );
-	}
-
-	public function schedule( $args = array() ) {
-
-		as_enqueue_async_action( $this->hook, $args, $this->group );
-
-	}
-
-	public function unschedule() {
-		as_unschedule_all_actions( $this->hook );
-	}
-
-	public function task( $args = array() ) {
-		$state = $this->do_task( $args );
-		if ( $state->has_next() ) {
-			$this->schedule( $state->get_args() );
-		}
-	}
-
-
-	/**
-	 * @param $args
-	 *
-	 * @return State The state object provides necessary information about
-	 * whether to schedule next event or stop processing.
-	 */
-	abstract public function do_task( $args );
+    /**
+     * @var string Hook name used for invoking the task method.
+     */
+    private $hook;
+    /**
+     * @var string Group which would be used when
+     */
+    private $group;
+
+
+    public function __construct( $hook, $group ) {
+        $this->hook  = $hook;
+        $this->group = $group;
+        add_action( $this->hook, array( $this, 'task' ) );
+    }
+
+    public function schedule( $args = array() ) {
+
+        as_enqueue_async_action( $this->hook, $args, $this->group );
+
+    }
+
+    public function unschedule() {
+        as_unschedule_all_actions( $this->hook );
+    }
+
+    public function task( $args = array() ) {
+        $state = $this->do_task( $args );
+        if ( $state->has_next() ) {
+            $this->schedule( $state->get_args() );
+        }
+    }
+
+
+    /**
+     * @param $args
+     *
+     * @return State The state object provides necessary information about
+     * whether to schedule next event or stop processing.
+     */
+    abstract public function do_task( $args );
 
 
 }

Spacing +10 added lines, -10 removed lines

@@ -15,26 +15,26 @@ 
 	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 );
+		as_enqueue_async_action($this->hook, $args, $this->group);
 
 	}
 
 	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 );
-		if ( $state->has_next() ) {
-			$this->schedule( $state->get_args() );
+	public function task($args = array()) {
+		$state = $this->do_task($args);
+		if ($state->has_next()) {
+			$this->schedule($state->get_args());
 		}
 	}
 
@@ -45,7 +45,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);
 
 
 }

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

Indentation +98 added lines, -98 removed lines

@@ -9,103 +9,103 @@
 
 class Sync_Background_Process extends Action_Scheduler_Background_Process {
 
-	const STATE_STARTED = 'started';
-	const STATE_STOPPED = 'stopped';
-
-	const HOOK_NAME = 'wl_dataset__sync';
-
-	/**
-	 * @var Sync_Service
-	 */
-	private $sync_service;
-
-	/**
-	 * @var Sync_Object_Adapter_Factory
-	 */
-	private $sync_object_adapter_factory;
-
-	/**
-	 * @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( 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 );
-		} else {
-			$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->enter();
-		$this->schedule();
-	}
-
-	public function stop() {
-		$this->state->leave();
-		$this->state = new Sync_Background_Process_Stopped_State( $this );
-		$this->state->enter();
-	}
-
-	public function resume() {
-		$this->schedule();
-		$this->state->resume();
-	}
-
-
-	public function do_task( $args ) {
-
-		// Action scheduler might have pending tasks which can call this method.
-		// So we need to check if the task should run or not
-		if ( self::STATE_STOPPED === $this->get_state() ) {
-			return State::complete();
-		}
-
-		$result = $this->state->task( $args );
-		if ( ! $result->has_next() ) {
-			$this->stop();
-		}
-		return $result;
-	}
-
-	/**
-	 * 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';
+
+    const HOOK_NAME = 'wl_dataset__sync';
+
+    /**
+     * @var Sync_Service
+     */
+    private $sync_service;
+
+    /**
+     * @var Sync_Object_Adapter_Factory
+     */
+    private $sync_object_adapter_factory;
+
+    /**
+     * @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( 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 );
+        } else {
+            $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->enter();
+        $this->schedule();
+    }
+
+    public function stop() {
+        $this->state->leave();
+        $this->state = new Sync_Background_Process_Stopped_State( $this );
+        $this->state->enter();
+    }
+
+    public function resume() {
+        $this->schedule();
+        $this->state->resume();
+    }
+
+
+    public function do_task( $args ) {
+
+        // Action scheduler might have pending tasks which can call this method.
+        // So we need to check if the task should run or not
+        if ( self::STATE_STOPPED === $this->get_state() ) {
+            return State::complete();
+        }
+
+        $result = $this->state->task( $args );
+        if ( ! $result->has_next() ) {
+            $this->stop();
+        }
+        return $result;
+    }
+
+    /**
+     * Get the current state.
+     *
+     * @return string Either self::STARTED_STATE or self::STOPPED_STATE (default).
+     */
+    public function get_state() {
+        return get_option( '_wl_sync_background_process_state', self::STATE_STOPPED );
+    }
+
+    /**
+     * Persist the current state.
+     *
+     * @param string $value
+     *
+     * @return bool
+     */
+    public function set_state( $value ) {
+        return null === $value
+            ? delete_option( '_wl_sync_background_process_state' )
+            : update_option( '_wl_sync_background_process_state', $value, true );
+    }
+
+    public function get_info() {
+        return $this->state->get_info();
+    }
 
 }

Spacing +15 added lines, -15 removed lines

@@ -35,29 +35,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();
 	}
 
@@ -67,16 +67,16 @@ 
 	}
 
 
-	public function do_task( $args ) {
+	public function do_task($args) {
 
 		// Action scheduler might have pending tasks which can call this method.
 		// So we need to check if the task should run or not
-		if ( self::STATE_STOPPED === $this->get_state() ) {
+		if (self::STATE_STOPPED === $this->get_state()) {
 			return State::complete();
 		}
 
-		$result = $this->state->task( $args );
-		if ( ! $result->has_next() ) {
+		$result = $this->state->task($args);
+		if ( ! $result->has_next()) {
 			$this->stop();
 		}
 		return $result;
@@ -88,7 +88,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);
 	}
 
 	/**
@@ -98,10 +98,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

Indentation +19 added lines, -19 removed lines

@@ -6,31 +6,31 @@
 
 class Sync_Background_Process_Stopped_State extends Abstract_Sync_Background_Process_State {
 
-	/**
-	 * @var Sync_Background_Process
-	 */
-	private $context;
+    /**
+     * @var Sync_Background_Process
+     */
+    private $context;
 
-	public function __construct( $context ) {
-		parent::__construct( Sync_Background_Process::STATE_STOPPED );
+    public function __construct( $context ) {
+        parent::__construct( Sync_Background_Process::STATE_STOPPED );
 
-		$this->context = $context;
-	}
+        $this->context = $context;
+    }
 
-	public function enter() {
-		$this->context->unschedule();
-		$this->context->set_state( Sync_Background_Process::STATE_STOPPED );
-	}
+    public function enter() {
+        $this->context->unschedule();
+        $this->context->set_state( Sync_Background_Process::STATE_STOPPED );
+    }
 
-	public function leave() {
-		$this->context->set_state( null );
-	}
+    public function leave() {
+        $this->context->set_state( null );
+    }
 
-	// phpcs:ignore VariableAnalysis.CodeAnalysis.VariableAnalysis.UnusedVariable
-	public function task( $item ) {
+    // phpcs:ignore VariableAnalysis.CodeAnalysis.VariableAnalysis.UnusedVariable
+    public function task( $item ) {
 
 
-		return State::complete();
-	}
+        return State::complete();
+    }
 
 }

Spacing +5 added lines, -5 removed lines

@@ -11,23 +11,23 @@
 	 */
 	private $context;
 
-	public function __construct( $context ) {
-		parent::__construct( Sync_Background_Process::STATE_STOPPED );
+	public function __construct($context) {
+		parent::__construct(Sync_Background_Process::STATE_STOPPED);
 
 		$this->context = $context;
 	}
 
 	public function enter() {
 		$this->context->unschedule();
-		$this->context->set_state( Sync_Background_Process::STATE_STOPPED );
+		$this->context->set_state(Sync_Background_Process::STATE_STOPPED);
 	}
 
 	public function leave() {
-		$this->context->set_state( null );
+		$this->context->set_state(null);
 	}
 
 	// phpcs:ignore VariableAnalysis.CodeAnalysis.VariableAnalysis.UnusedVariable
-	public function task( $item ) {
+	public function task($item) {
 
 
 		return State::complete();

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

Indentation +135 added lines, -135 removed lines

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

Spacing +32 added lines, -32 removed lines

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

src/wordlift/dataset/index.php

Indentation +28 added lines, -28 removed lines

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