Completed
Pull Request — develop (#1642)
by Naveen
01:27
created
src/wordlift.php 1 patch
Spacing   +61 added lines, -61 removed lines patch added patch discarded remove patch
@@ -31,29 +31,29 @@  discard block
 block discarded – undo
31 31
 use Wordlift\Features\Features_Registry;
32 32
 use Wordlift\Post\Post_Adapter;
33 33
 // If this file is called directly, abort.
34
-if ( ! defined( 'WPINC' ) ) {
34
+if ( ! defined('WPINC')) {
35 35
 	die;
36 36
 }
37 37
 define(
38 38
 	'WORDLIFT_PLUGIN_FILE',
39 39
 	__FILE__
40 40
 );
41
-define( 'WORDLIFT_VERSION', '3.41.0-dev' );
41
+define('WORDLIFT_VERSION', '3.41.0-dev');
42 42
 
43
-require_once plugin_dir_path( __FILE__ ) . '/libraries/action-scheduler/action-scheduler.php';
44
-require_once __DIR__ . '/modules/common/load.php';
45
-require_once __DIR__ . '/modules/include-exclude/load.php';
43
+require_once plugin_dir_path(__FILE__).'/libraries/action-scheduler/action-scheduler.php';
44
+require_once __DIR__.'/modules/common/load.php';
45
+require_once __DIR__.'/modules/include-exclude/load.php';
46 46
 
47 47
 /**
48 48
  * Filter to disable WLP on any request, defaults to true.
49 49
  *
50 50
  * @since 3.33.6
51 51
  */
52
-if ( ! apply_filters( 'wl_is_enabled', true ) ) {
52
+if ( ! apply_filters('wl_is_enabled', true)) {
53 53
 	return;
54 54
 }
55 55
 
56
-require_once plugin_dir_path( __FILE__ ) . 'vendor/autoload.php';
56
+require_once plugin_dir_path(__FILE__).'vendor/autoload.php';
57 57
 
58 58
 /*
59 59
 	 * We introduce the WordLift autoloader, since we start using classes in namespaces, i.e. Wordlift\Http.
@@ -63,15 +63,15 @@  discard block
 block discarded – undo
63 63
 wordlift_plugin_autoload_register();
64 64
 
65 65
 // Include WordLift constants.
66
-require_once plugin_dir_path( __FILE__ ) . 'wordlift-constants.php';
66
+require_once plugin_dir_path(__FILE__).'wordlift-constants.php';
67 67
 
68 68
 // Load modules.
69
-require_once plugin_dir_path( __FILE__ ) . 'modules/core/wordlift-core.php';
69
+require_once plugin_dir_path(__FILE__).'modules/core/wordlift-core.php';
70 70
 
71
-require_once plugin_dir_path( __FILE__ ) . 'deprecations.php';
71
+require_once plugin_dir_path(__FILE__).'deprecations.php';
72 72
 
73 73
 // Load early to enable/disable features.
74
-require_once plugin_dir_path( __FILE__ ) . 'wordlift/features/index.php';
74
+require_once plugin_dir_path(__FILE__).'wordlift/features/index.php';
75 75
 
76 76
 /**
77 77
  * The code that runs during plugin activation.
@@ -79,11 +79,11 @@  discard block
 block discarded – undo
79 79
  */
80 80
 function activate_wordlift() {
81 81
 
82
-	$log = Wordlift_Log_Service::get_logger( 'activate_wordlift' );
82
+	$log = Wordlift_Log_Service::get_logger('activate_wordlift');
83 83
 
84
-	$log->info( 'Activating WordLift...' );
84
+	$log->info('Activating WordLift...');
85 85
 
86
-	require_once plugin_dir_path( __FILE__ ) . 'includes/class-wordlift-activator.php';
86
+	require_once plugin_dir_path(__FILE__).'includes/class-wordlift-activator.php';
87 87
 	Wordlift_Activator::activate();
88 88
 
89 89
 	/**
@@ -103,8 +103,8 @@  discard block
 block discarded – undo
103 103
 	 */
104 104
 	Top_Entities::activate();
105 105
 
106
-	if ( ! wp_next_scheduled( 'wl_daily_cron' ) ) {
107
-		wp_schedule_event( time(), 'daily', 'wl_daily_cron' );
106
+	if ( ! wp_next_scheduled('wl_daily_cron')) {
107
+		wp_schedule_event(time(), 'daily', 'wl_daily_cron');
108 108
 	}
109 109
 
110 110
 }
@@ -115,7 +115,7 @@  discard block
 block discarded – undo
115 115
  */
116 116
 function deactivate_wordlift() {
117 117
 
118
-	require_once plugin_dir_path( __FILE__ ) . 'includes/class-wordlift-deactivator.php';
118
+	require_once plugin_dir_path(__FILE__).'includes/class-wordlift-deactivator.php';
119 119
 	Wordlift_Deactivator::deactivate();
120 120
 	Wordlift_Http_Api::deactivate();
121 121
 	Ttl_Cache_Cleaner::deactivate();
@@ -131,18 +131,18 @@  discard block
 block discarded – undo
131 131
 	Key_Validation_Notice::remove_notification_flag();
132 132
 	flush_rewrite_rules();
133 133
 
134
-	wp_clear_scheduled_hook( 'wl_daily_cron' );
134
+	wp_clear_scheduled_hook('wl_daily_cron');
135 135
 
136 136
 }
137 137
 
138
-register_activation_hook( __FILE__, 'activate_wordlift' );
139
-register_deactivation_hook( __FILE__, 'deactivate_wordlift' );
138
+register_activation_hook(__FILE__, 'activate_wordlift');
139
+register_deactivation_hook(__FILE__, 'deactivate_wordlift');
140 140
 
141 141
 /**
142 142
  * The core plugin class that is used to define internationalization,
143 143
  * admin-specific hooks, and public-facing site hooks.
144 144
  */
145
-require plugin_dir_path( __FILE__ ) . 'includes/class-wordlift.php';
145
+require plugin_dir_path(__FILE__).'includes/class-wordlift.php';
146 146
 
147 147
 /**
148 148
  * Begins execution of the plugin.
@@ -162,12 +162,12 @@  discard block
 block discarded – undo
162 162
 	 * @return bool
163 163
 	 * @since 3.27.6
164 164
 	 */
165
-	if ( apply_filters( 'wl_feature__enable__widgets', true ) ) {
166
-		add_action( 'widgets_init', 'wl_register_chord_widget' );
167
-		add_action( 'widgets_init', 'wl_register_geo_widget' );
168
-		add_action( 'widgets_init', 'wl_register_timeline_widget' );
165
+	if (apply_filters('wl_feature__enable__widgets', true)) {
166
+		add_action('widgets_init', 'wl_register_chord_widget');
167
+		add_action('widgets_init', 'wl_register_geo_widget');
168
+		add_action('widgets_init', 'wl_register_timeline_widget');
169 169
 	}
170
-	add_filter( 'widget_text', 'do_shortcode' );
170
+	add_filter('widget_text', 'do_shortcode');
171 171
 
172 172
 	/**
173 173
 	 * Filter: wl_feature__enable__analysis
@@ -177,10 +177,10 @@  discard block
 block discarded – undo
177 177
 	 * @return bool
178 178
 	 * @since 3.27.6
179 179
 	 */
180
-	if ( apply_filters( 'wl_feature__enable__analysis', true ) ) {
181
-		add_action( 'wp_ajax_wl_analyze', 'wl_ajax_analyze_action' );
180
+	if (apply_filters('wl_feature__enable__analysis', true)) {
181
+		add_action('wp_ajax_wl_analyze', 'wl_ajax_analyze_action');
182 182
 	} else {
183
-		add_action( 'wp_ajax_wl_analyze', 'wl_ajax_analyze_disabled_action' );
183
+		add_action('wp_ajax_wl_analyze', 'wl_ajax_analyze_disabled_action');
184 184
 	}
185 185
 
186 186
 	$plugin = new Wordlift();
@@ -197,7 +197,7 @@  discard block
 block discarded – undo
197 197
 
198 198
 	add_action(
199 199
 		'plugins_loaded',
200
-		function () {
200
+		function() {
201 201
 			// All features from registry should be initialized here.
202 202
 			$features_registry = Features_Registry::get_instance();
203 203
 			$features_registry->initialize_all_features();
@@ -208,27 +208,27 @@  discard block
 block discarded – undo
208 208
 	add_action(
209 209
 		'plugins_loaded',
210 210
 		// phpcs:ignore VariableAnalysis.CodeAnalysis.VariableAnalysis.UnusedVariable
211
-		function () use ( $plugin ) {
211
+		function() use ($plugin) {
212 212
 
213 213
 			new Wordlift_Products_Navigator_Shortcode_REST();
214 214
 
215 215
 			// Register the Dataset module, requires `$api_service`.
216
-			require_once plugin_dir_path( __FILE__ ) . 'wordlift/dataset/index.php';
217
-			require_once plugin_dir_path( __FILE__ ) . 'wordlift/shipping-data/index.php';
216
+			require_once plugin_dir_path(__FILE__).'wordlift/dataset/index.php';
217
+			require_once plugin_dir_path(__FILE__).'wordlift/shipping-data/index.php';
218 218
 
219 219
 			/*
220 220
 			* Require the Entity annotation cleanup module.
221 221
 			*
222 222
 			* @since 3.34.6
223 223
 			*/
224
-			require_once plugin_dir_path( __FILE__ ) . 'wordlift/cleanup/index.php';
224
+			require_once plugin_dir_path(__FILE__).'wordlift/cleanup/index.php';
225 225
 
226 226
 			/*
227 227
 			* Import LOD entities.
228 228
 			*
229 229
 			* @since 3.35.0
230 230
 			*/
231
-			require_once plugin_dir_path( __FILE__ ) . 'wordlift/lod-import/index.php';
231
+			require_once plugin_dir_path(__FILE__).'wordlift/lod-import/index.php';
232 232
 
233 233
 		}
234 234
 	);
@@ -246,23 +246,23 @@  discard block
 block discarded – undo
246 246
 function wordlift_plugin_autoload_register() {
247 247
 
248 248
 	spl_autoload_register(
249
-		function ( $class_name ) {
249
+		function($class_name) {
250 250
 
251 251
 			// Bail out if these are not our classes.
252
-			if ( 0 !== strpos( $class_name, 'Wordlift\\' ) ) {
252
+			if (0 !== strpos($class_name, 'Wordlift\\')) {
253 253
 				return false;
254 254
 			}
255 255
 
256
-			$class_name_lc = strtolower( str_replace( '_', '-', $class_name ) );
256
+			$class_name_lc = strtolower(str_replace('_', '-', $class_name));
257 257
 
258
-			preg_match( '|^(?:(.*)\\\\)?(.+?)$|', $class_name_lc, $matches );
258
+			preg_match('|^(?:(.*)\\\\)?(.+?)$|', $class_name_lc, $matches);
259 259
 
260
-			$path = str_replace( '\\', DIRECTORY_SEPARATOR, $matches[1] );
261
-			$file = 'class-' . $matches[2] . '.php';
260
+			$path = str_replace('\\', DIRECTORY_SEPARATOR, $matches[1]);
261
+			$file = 'class-'.$matches[2].'.php';
262 262
 
263
-			$full_path = plugin_dir_path( __FILE__ ) . $path . DIRECTORY_SEPARATOR . $file;
263
+			$full_path = plugin_dir_path(__FILE__).$path.DIRECTORY_SEPARATOR.$file;
264 264
 
265
-			if ( ! file_exists( $full_path ) ) {
265
+			if ( ! file_exists($full_path)) {
266 266
 				return false;
267 267
 			}
268 268
 
@@ -274,13 +274,13 @@  discard block
 block discarded – undo
274 274
 
275 275
 }
276 276
 
277
-function wl_block_categories( $categories ) {
277
+function wl_block_categories($categories) {
278 278
 	return array_merge(
279 279
 		$categories,
280 280
 		array(
281 281
 			array(
282 282
 				'slug'  => 'wordlift',
283
-				'title' => __( 'WordLift', 'wordlift' ),
283
+				'title' => __('WordLift', 'wordlift'),
284 284
 			),
285 285
 		)
286 286
 	);
@@ -290,45 +290,45 @@  discard block
 block discarded – undo
290 290
  * This function is created temporarily to handle the legacy library,
291 291
  * this has to be removed when removing the legacy fields from the ui.
292 292
  */
293
-function wl_enqueue_leaflet( $in_footer = false ) {
293
+function wl_enqueue_leaflet($in_footer = false) {
294 294
 	// Leaflet.
295
-	wp_enqueue_style( 'wl-leaflet', plugin_dir_url( __FILE__ ) . 'js/leaflet/leaflet.css', array(), '1.6.0' );
296
-	wp_enqueue_script( 'wl-leaflet', plugin_dir_url( __FILE__ ) . 'js/leaflet/leaflet.js', array(), '1.6.0', $in_footer );
295
+	wp_enqueue_style('wl-leaflet', plugin_dir_url(__FILE__).'js/leaflet/leaflet.css', array(), '1.6.0');
296
+	wp_enqueue_script('wl-leaflet', plugin_dir_url(__FILE__).'js/leaflet/leaflet.js', array(), '1.6.0', $in_footer);
297 297
 }
298 298
 
299
-add_filter( 'block_categories', 'wl_block_categories', 10 );
299
+add_filter('block_categories', 'wl_block_categories', 10);
300 300
 
301 301
 // Temporary fix for a typo in WooCommerce Extension.
302 302
 add_filter(
303 303
 	'wl_feature__enable__dataset',
304
-	function ( $value ) {
305
-		return apply_filters( 'wl_features__enable__dataset', $value );
304
+	function($value) {
305
+		return apply_filters('wl_features__enable__dataset', $value);
306 306
 	}
307 307
 );
308 308
 
309
-require_once __DIR__ . '/modules/food-kg/load.php';
310
-require_once __DIR__ . '/modules/acf4so/load.php';
311
-require_once __DIR__ . '/modules/pods/load.php';
312
-require_once __DIR__ . '/modules/include-exclude-push-config/load.php';
309
+require_once __DIR__.'/modules/food-kg/load.php';
310
+require_once __DIR__.'/modules/acf4so/load.php';
311
+require_once __DIR__.'/modules/pods/load.php';
312
+require_once __DIR__.'/modules/include-exclude-push-config/load.php';
313 313
 
314 314
 add_action(
315 315
 	'update_plugins_adthrive.wordlift.io',
316
-	function ( $update, $plugin_data, $plugin_file ) {
316
+	function($update, $plugin_data, $plugin_file) {
317 317
 		// Bail out if it's not our plugin.
318 318
 		$update_uri = $plugin_data['UpdateURI'];
319
-		if ( 'wordlift/wordlift.php' !== $plugin_file || ! isset( $update_uri ) ) {
319
+		if ('wordlift/wordlift.php' !== $plugin_file || ! isset($update_uri)) {
320 320
 			return $update;
321 321
 		}
322 322
 
323
-		$response = wp_remote_get( "$update_uri?nocache=" . time() );
323
+		$response = wp_remote_get("$update_uri?nocache=".time());
324 324
 
325
-		if ( is_wp_error( $response ) ) {
325
+		if (is_wp_error($response)) {
326 326
 			return $update;
327 327
 		}
328 328
 
329 329
 		try {
330
-			return json_decode( wp_remote_retrieve_body( $response ) );
331
-		} catch ( Exception $e ) {
330
+			return json_decode(wp_remote_retrieve_body($response));
331
+		} catch (Exception $e) {
332 332
 			return $update;
333 333
 		}
334 334
 	},
Please login to merge, or discard this patch.
src/wordlift/common/background-process/action-scheduler/class-state.php 1 patch
Spacing   +4 added lines, -4 removed lines patch added patch discarded remove patch
@@ -7,7 +7,7 @@  discard block
 block discarded – undo
7 7
 	private $args;
8 8
 	private $has_next;
9 9
 
10
-	public function __construct( $has_next, $args ) {
10
+	public function __construct($has_next, $args) {
11 11
 		$this->has_next = $has_next;
12 12
 		$this->args     = $args;
13 13
 	}
@@ -21,11 +21,11 @@  discard block
 block discarded – undo
21 21
 	}
22 22
 
23 23
 	public static function complete() {
24
-		return new self( false, array() );
24
+		return new self(false, array());
25 25
 	}
26 26
 
27
-	public static function items_in_queue( $args = array() ) {
28
-		return new self( true, $args );
27
+	public static function items_in_queue($args = array()) {
28
+		return new self(true, $args);
29 29
 	}
30 30
 
31 31
 
Please login to merge, or discard this patch.
action-scheduler/class-action-scheduler-background-process.php 1 patch
Spacing   +10 added lines, -10 removed lines patch added patch discarded remove patch
@@ -15,26 +15,26 @@  discard block
 block discarded – undo
15 15
 	private $group;
16 16
 
17 17
 
18
-	public function __construct( $hook, $group ) {
18
+	public function __construct($hook, $group) {
19 19
 		$this->hook  = $hook;
20 20
 		$this->group = $group;
21
-		add_action( $this->hook, array( $this, 'task' ) );
21
+		add_action($this->hook, array($this, 'task'));
22 22
 	}
23 23
 
24
-	public function schedule( $args = array() ) {
24
+	public function schedule($args = array()) {
25 25
 
26
-		as_enqueue_async_action( $this->hook, $args, $this->group );
26
+		as_enqueue_async_action($this->hook, $args, $this->group);
27 27
 
28 28
 	}
29 29
 
30 30
 	public function unschedule() {
31
-		as_unschedule_all_actions( $this->hook );
31
+		as_unschedule_all_actions($this->hook);
32 32
 	}
33 33
 
34
-	public function task( $args = array() ) {
35
-		$state = $this->do_task( $args );
36
-		if ( $state->has_next() ) {
37
-			$this->schedule( $state->get_args() );
34
+	public function task($args = array()) {
35
+		$state = $this->do_task($args);
36
+		if ($state->has_next()) {
37
+			$this->schedule($state->get_args());
38 38
 		}
39 39
 	}
40 40
 
@@ -45,7 +45,7 @@  discard block
 block discarded – undo
45 45
 	 * @return State The state object provides necessary information about
46 46
 	 * whether to schedule next event or stop processing.
47 47
 	 */
48
-	abstract public function do_task( $args );
48
+	abstract public function do_task($args);
49 49
 
50 50
 
51 51
 }
Please login to merge, or discard this patch.
src/wordlift/dataset/background/class-sync-background-process.php 1 patch
Spacing   +15 added lines, -15 removed lines patch added patch discarded remove patch
@@ -35,29 +35,29 @@  discard block
 block discarded – undo
35 35
 	 * @param Sync_Service $sync_service A {@link Sync_Service} instance providing the supporting functions to this background process.
36 36
 	 * @param Sync_Object_Adapter_Factory $sync_object_adapter_factory
37 37
 	 */
38
-	public function __construct( $sync_service, $sync_object_adapter_factory ) {
39
-		parent::__construct( self::HOOK_NAME, 'wordlift' );
38
+	public function __construct($sync_service, $sync_object_adapter_factory) {
39
+		parent::__construct(self::HOOK_NAME, 'wordlift');
40 40
 		$this->sync_service                = $sync_service;
41 41
 		$this->sync_object_adapter_factory = $sync_object_adapter_factory;
42 42
 
43 43
 		// Set the current state.
44
-		if ( self::STATE_STARTED === $this->get_state() ) {
45
-			$this->state = new Sync_Background_Process_Started_State( $this, $this->sync_service, $this->sync_object_adapter_factory );
44
+		if (self::STATE_STARTED === $this->get_state()) {
45
+			$this->state = new Sync_Background_Process_Started_State($this, $this->sync_service, $this->sync_object_adapter_factory);
46 46
 		} else {
47
-			$this->state = new Sync_Background_Process_Stopped_State( $this );
47
+			$this->state = new Sync_Background_Process_Stopped_State($this);
48 48
 		}
49 49
 	}
50 50
 
51 51
 	public function start() {
52 52
 		$this->state->leave();
53
-		$this->state = new Sync_Background_Process_Started_State( $this, $this->sync_service, $this->sync_object_adapter_factory );
53
+		$this->state = new Sync_Background_Process_Started_State($this, $this->sync_service, $this->sync_object_adapter_factory);
54 54
 		$this->state->enter();
55 55
 		$this->schedule();
56 56
 	}
57 57
 
58 58
 	public function stop() {
59 59
 		$this->state->leave();
60
-		$this->state = new Sync_Background_Process_Stopped_State( $this );
60
+		$this->state = new Sync_Background_Process_Stopped_State($this);
61 61
 		$this->state->enter();
62 62
 	}
63 63
 
@@ -67,16 +67,16 @@  discard block
 block discarded – undo
67 67
 	}
68 68
 
69 69
 
70
-	public function do_task( $args ) {
70
+	public function do_task($args) {
71 71
 
72 72
 		// Action scheduler might have pending tasks which can call this method.
73 73
 		// So we need to check if the task should run or not
74
-		if ( self::STATE_STOPPED === $this->get_state() ) {
74
+		if (self::STATE_STOPPED === $this->get_state()) {
75 75
 			return State::complete();
76 76
 		}
77 77
 
78
-		$result = $this->state->task( $args );
79
-		if ( ! $result->has_next() ) {
78
+		$result = $this->state->task($args);
79
+		if ( ! $result->has_next()) {
80 80
 			$this->stop();
81 81
 		}
82 82
 		return $result;
@@ -88,7 +88,7 @@  discard block
 block discarded – undo
88 88
 	 * @return string Either self::STARTED_STATE or self::STOPPED_STATE (default).
89 89
 	 */
90 90
 	public function get_state() {
91
-		return get_option( '_wl_sync_background_process_state', self::STATE_STOPPED );
91
+		return get_option('_wl_sync_background_process_state', self::STATE_STOPPED);
92 92
 	}
93 93
 
94 94
 	/**
@@ -98,10 +98,10 @@  discard block
 block discarded – undo
98 98
 	 *
99 99
 	 * @return bool
100 100
 	 */
101
-	public function set_state( $value ) {
101
+	public function set_state($value) {
102 102
 		return null === $value
103
-			? delete_option( '_wl_sync_background_process_state' )
104
-			: update_option( '_wl_sync_background_process_state', $value, true );
103
+			? delete_option('_wl_sync_background_process_state')
104
+			: update_option('_wl_sync_background_process_state', $value, true);
105 105
 	}
106 106
 
107 107
 	public function get_info() {
Please login to merge, or discard this patch.
wordlift/dataset/background/class-sync-background-process-stopped-state.php 1 patch
Spacing   +5 added lines, -5 removed lines patch added patch discarded remove patch
@@ -11,23 +11,23 @@
 block discarded – undo
11 11
 	 */
12 12
 	private $context;
13 13
 
14
-	public function __construct( $context ) {
15
-		parent::__construct( Sync_Background_Process::STATE_STOPPED );
14
+	public function __construct($context) {
15
+		parent::__construct(Sync_Background_Process::STATE_STOPPED);
16 16
 
17 17
 		$this->context = $context;
18 18
 	}
19 19
 
20 20
 	public function enter() {
21 21
 		$this->context->unschedule();
22
-		$this->context->set_state( Sync_Background_Process::STATE_STOPPED );
22
+		$this->context->set_state(Sync_Background_Process::STATE_STOPPED);
23 23
 	}
24 24
 
25 25
 	public function leave() {
26
-		$this->context->set_state( null );
26
+		$this->context->set_state(null);
27 27
 	}
28 28
 
29 29
 	// phpcs:ignore VariableAnalysis.CodeAnalysis.VariableAnalysis.UnusedVariable
30
-	public function task( $item ) {
30
+	public function task($item) {
31 31
 
32 32
 
33 33
 		return State::complete();
Please login to merge, or discard this patch.
wordlift/dataset/background/class-sync-background-process-started-state.php 1 patch
Spacing   +32 added lines, -32 removed lines patch added patch discarded remove patch
@@ -42,16 +42,16 @@  discard block
 block discarded – undo
42 42
 	 * @param bool                        $reset Whether to reset the counters
43 43
 	 */
44 44
 	// phpcs:ignore VariableAnalysis.CodeAnalysis.VariableAnalysis.UnusedVariable
45
-	public function __construct( $context, $sync_service, $sync_object_adapter_factory, $reset = true ) {
46
-		parent::__construct( Sync_Background_Process::STATE_STARTED );
45
+	public function __construct($context, $sync_service, $sync_object_adapter_factory, $reset = true) {
46
+		parent::__construct(Sync_Background_Process::STATE_STARTED);
47 47
 
48 48
 		$this->context      = $context;
49 49
 		$this->sync_service = $sync_service;
50 50
 
51 51
 		$this->stages = array(
52
-			new Sync_Background_Process_Posts_Stage( $sync_object_adapter_factory ),
53
-			new Sync_Background_Process_Terms_Stage( $sync_object_adapter_factory ),
54
-			new Sync_Background_Process_Users_Stage( $sync_object_adapter_factory ),
52
+			new Sync_Background_Process_Posts_Stage($sync_object_adapter_factory),
53
+			new Sync_Background_Process_Terms_Stage($sync_object_adapter_factory),
54
+			new Sync_Background_Process_Users_Stage($sync_object_adapter_factory),
55 55
 		);
56 56
 	}
57 57
 
@@ -60,22 +60,22 @@  discard block
 block discarded – undo
60 60
 		$this->sync_service->delete_all();
61 61
 
62 62
 		// Clear caches.
63
-		do_action( 'wl_ttl_cache_cleaner__flush' );
63
+		do_action('wl_ttl_cache_cleaner__flush');
64 64
 
65 65
 		$counts = array_map(
66
-			function ( $item ) {
66
+			function($item) {
67 67
 				return $item->count();
68 68
 			},
69 69
 			$this->stages
70 70
 		);
71 71
 
72
-		update_option( '_wl_sync_background_process_count', $counts, true );
73
-		update_option( '_wl_sync_background_process_stage', 0, true );
74
-		update_option( '_wl_sync_background_process_offset', 0, true );
75
-		update_option( '_wl_sync_background_process_started', time(), true );
76
-		update_option( '_wl_sync_background_process_updated', time(), true );
72
+		update_option('_wl_sync_background_process_count', $counts, true);
73
+		update_option('_wl_sync_background_process_stage', 0, true);
74
+		update_option('_wl_sync_background_process_offset', 0, true);
75
+		update_option('_wl_sync_background_process_started', time(), true);
76
+		update_option('_wl_sync_background_process_updated', time(), true);
77 77
 
78
-		$this->context->set_state( Sync_Background_Process::STATE_STARTED );
78
+		$this->context->set_state(Sync_Background_Process::STATE_STARTED);
79 79
 
80 80
 		$this->resume();
81 81
 	}
@@ -85,7 +85,7 @@  discard block
 block discarded – undo
85 85
 	}
86 86
 
87 87
 	public function leave() {
88
-		$this->context->set_state( null );
88
+		$this->context->set_state(null);
89 89
 	}
90 90
 
91 91
 	/**
@@ -94,35 +94,35 @@  discard block
 block discarded – undo
94 94
 	 * @return State
95 95
 	 */
96 96
 	// phpcs:ignore VariableAnalysis.CodeAnalysis.VariableAnalysis.UnusedVariable
97
-	public function task( $args ) {
98
-		$offset     = get_option( '_wl_sync_background_process_offset' );
99
-		$stage      = get_option( '_wl_sync_background_process_stage' );
100
-		$counts     = get_option( '_wl_sync_background_process_count' );
101
-		$batch_size = min( $counts[ $stage ] - $offset, $this->batch_size );
97
+	public function task($args) {
98
+		$offset     = get_option('_wl_sync_background_process_offset');
99
+		$stage      = get_option('_wl_sync_background_process_stage');
100
+		$counts     = get_option('_wl_sync_background_process_count');
101
+		$batch_size = min($counts[$stage] - $offset, $this->batch_size);
102 102
 
103
-		add_filter( 'wl_api_service__request', array( $this, 'api_service__request' ) );
103
+		add_filter('wl_api_service__request', array($this, 'api_service__request'));
104 104
 		try {
105
-			$object_adapters = $this->stages[ $stage ]->get_sync_object_adapters( $offset, $batch_size );
106
-			$this->sync_service->sync_many( $object_adapters, true );
105
+			$object_adapters = $this->stages[$stage]->get_sync_object_adapters($offset, $batch_size);
106
+			$this->sync_service->sync_many($object_adapters, true);
107 107
 		// phpcs:ignore Generic.CodeAnalysis.EmptyStatement.DetectedCatch
108
-		} catch ( \Exception $e ) {
108
+		} catch (\Exception $e) {
109 109
 			// ignored.
110 110
 		}
111
-		remove_filter( 'wl_api_service__request', array( $this, 'api_service__request' ) );
111
+		remove_filter('wl_api_service__request', array($this, 'api_service__request'));
112 112
 
113
-		update_option( '_wl_sync_background_process_updated', time(), true );
113
+		update_option('_wl_sync_background_process_updated', time(), true);
114 114
 
115 115
 		// Increase the offset.
116
-		if ( ( $offset + $batch_size ) < $counts[ $stage ] ) {
117
-			update_option( '_wl_sync_background_process_offset', $offset + $batch_size, true );
116
+		if (($offset + $batch_size) < $counts[$stage]) {
117
+			update_option('_wl_sync_background_process_offset', $offset + $batch_size, true);
118 118
 
119 119
 			return State::items_in_queue();
120 120
 		}
121 121
 
122 122
 		// Increase the stage.
123
-		if ( ( $stage + 1 ) < count( $this->stages ) ) {
124
-			update_option( '_wl_sync_background_process_stage', $stage + 1, true );
125
-			update_option( '_wl_sync_background_process_offset', 0, true );
123
+		if (($stage + 1) < count($this->stages)) {
124
+			update_option('_wl_sync_background_process_stage', $stage + 1, true);
125
+			update_option('_wl_sync_background_process_offset', 0, true);
126 126
 
127 127
 			return State::items_in_queue();
128 128
 		}
@@ -139,9 +139,9 @@  discard block
 block discarded – undo
139 139
 	 *
140 140
 	 * @return mixed
141 141
 	 */
142
-	public function api_service__request( $args ) {
142
+	public function api_service__request($args) {
143 143
 
144
-		$state_header_value = str_replace( "\n", '', wp_json_encode( $this->context->get_info() ) );
144
+		$state_header_value = str_replace("\n", '', wp_json_encode($this->context->get_info()));
145 145
 
146 146
 		$args['headers']['X-Wordlift-Dataset-Sync-State-V1'] = $state_header_value;
147 147
 
Please login to merge, or discard this patch.