Jetpack_Sync_Module_Full_Sync - Code Metrics - Inspection of "Admin Page: Fix incorrect create account link" - Automattic/jetpack - Measure and Improve Code Quality continuously with Scrutinizer

Completed

Push — fix/create-account-start ( dc031f...d06ff8 )

unknown

created 2016-10-20 15:45 UTC

Jetpack_Sync_Module_Full_Sync C

↳ Parent: Project

Complexity

Total Complexity

Size/Duplication

Total Lines	351
Duplicated Lines	0 %

Coupling/Cohesion

Components	1
Dependencies	5

Importance

Changes

Metric	Value
dl	0
loc	351
rs	5.7894
c	0
b	0
f	0
wmc	65
lcom	1
cbo	5

20 Methods

Rating	Name	Size	Complexity
A	name()	3	1
A	init_full_sync_listeners()	6	1
A	init_before_send()	4	1
A	reset_data()	6	1
A	get_status_option()	12	3
A	set_enqueue_status()	3	1
A	get_enqueue_status()	3	1
A	set_config()	3	1
A	get_config()	3	1
B	write_option()	26	2
A	read_option()	16	3
C	start()	72	12
C	continue_enqueuing()	70	14
D	update_sent_progress_action()	33	9
A	get_action_name()	6	3
A	is_started()	3	1
A	is_finished()	3	1
B	get_status()	39	6
A	clear_status()	12	2
A	update_status_option()	4	1

How to fix Complexity

<?php

/**
 * This class does a full resync of the database by
 * enqueuing an outbound action for every single object
 * that we care about.
 *
 * This class, and its related class Jetpack_Sync_Module, contain a few non-obvious optimisations that should be explained:
 * - we fire an action called jetpack_full_sync_start so that WPCOM can erase the contents of the cached database
 * - for each object type, we page through the object IDs and enqueue them by firing some monitored actions
 * - we load the full objects for those IDs in chunks of Jetpack_Sync_Module::ARRAY_CHUNK_SIZE (to reduce the number of MySQL calls)
 * - we fire a trigger for the entire array which the Jetpack_Sync_Listener then serializes and queues.
 */

class Jetpack_Sync_Module_Full_Sync extends Jetpack_Sync_Module {
	const STATUS_OPTION_PREFIX = 'jetpack_sync_full_';
	const FULL_SYNC_TIMEOUT = 3600;

	public function name() {
		return 'full-sync';
	}

	function init_full_sync_listeners( $callable ) {
		// synthetic actions for full sync
		add_action( 'jetpack_full_sync_start', $callable );
		add_action( 'jetpack_full_sync_end', $callable );
		add_action( 'jetpack_full_sync_cancelled', $callable );
	}

	function init_before_send() {
		// this is triggered after actions have been processed on the server
		add_action( 'jetpack_sync_processed_actions', array( $this, 'update_sent_progress_action' ) );
	}

	function start( $module_configs = null ) {
		$was_already_running = $this->is_started() && ! $this->is_finished();

		// remove all evidence of previous full sync items and status
		$this->reset_data();

		if ( $was_already_running ) {
			/**
			 * Fires when a full sync is cancelled.
			 *
			 * @since 4.2.0
			 */
			do_action( 'jetpack_full_sync_cancelled' );
		}

		$this->update_status_option( 'started', time() );
		$this->update_status_option( 'params', $module_configs );

		$enqueue_status = array();
		$full_sync_config = array();

		// default value is full sync
		if ( ! is_array( $module_configs ) ) {
			$module_configs = array();
			foreach ( Jetpack_Sync_Modules::get_modules() as $module ) {
				$module_configs[ $module->name() ] = true;
			}
		}

		// set default configuration, calculate totals, and save configuration if totals > 0
		foreach ( Jetpack_Sync_Modules::get_modules() as $module ) {
			$module_name = $module->name();
			$module_config = isset( $module_configs[ $module_name ] ) ? $module_configs[ $module_name ] : false;
			
			if ( ! $module_config ) {
				continue;
			}

			if ( 'users' === $module_name && 'initial' === $module_config ) {
				$module_config = $module->get_initial_sync_user_config();
			}

			$enqueue_status[ $module_name ] = false;

			$total_items = $module->estimate_full_sync_actions( $module_config );

			// if there's information to process, configure this module
			if ( ! is_null( $total_items ) && $total_items > 0 ) {
				$full_sync_config[ $module_name ] = $module_config;
				$enqueue_status[ $module_name ] = array(
					$total_items,   // total
					0,              // queued
					false,          // current state
				);
			}
		}

		$this->set_config( $full_sync_config );
		$this->set_enqueue_status( $enqueue_status );

		/**
		 * Fires when a full sync begins. This action is serialized
		 * and sent to the server so that it knows a full sync is coming.
		 *
		 * @since 4.2.0
		 */
		do_action( 'jetpack_full_sync_start', $full_sync_config );

		$this->continue_enqueuing( $full_sync_config, $enqueue_status );

		return true;
	}

	function continue_enqueuing( $configs = null, $enqueue_status = null ) {
		if ( ! $this->is_started() || $this->get_status_option( 'queue_finished' ) ) {
			return;
		}

		// if full sync queue is full, don't enqueue more items
		$max_queue_size_full_sync = Jetpack_Sync_Settings::get_setting( 'max_queue_size_full_sync' );
		$full_sync_queue = new Jetpack_Sync_Queue( 'full_sync' );
		
		$available_queue_slots = $max_queue_size_full_sync - $full_sync_queue->size();

		if ( $available_queue_slots <= 0 ) {
			return;
		} else {
			$remaining_items_to_enqueue = min( Jetpack_Sync_Settings::get_setting( 'max_enqueue_full_sync' ), $available_queue_slots );
		}

		if ( ! $configs ) {
			$configs = $this->get_config();
		}

		if ( ! $enqueue_status ) {
			$enqueue_status = $this->get_enqueue_status();
		}

		foreach ( Jetpack_Sync_Modules::get_modules() as $module ) {
			$module_name = $module->name();

			// skip module if not configured for this sync or module is done
			if ( ! isset( $configs[ $module_name ] ) 
				|| // no module config
					! $configs[ $module_name ] 
				|| // no enqueue status
					! $enqueue_status[ $module_name ] 
				|| // finished enqueuing this module
					true === $enqueue_status[ $module_name ][ 2 ] ) {
				continue;
			}

			list( $items_enqueued, $next_enqueue_state ) = $module->enqueue_full_sync_actions( $configs[ $module_name ], $remaining_items_to_enqueue, $enqueue_status[ $module_name ][ 2 ] );

			$enqueue_status[ $module_name ][ 2 ] = $next_enqueue_state;

			// if items were processed, subtract them from the limit
			if ( ! is_null( $items_enqueued ) && $items_enqueued > 0 ) {
				$enqueue_status[ $module_name ][ 1 ] += $items_enqueued;
				$remaining_items_to_enqueue -= $items_enqueued;
			}

			// stop processing if we've reached our limit of items to enqueue
			if ( 0 >= $remaining_items_to_enqueue ) {
				$this->set_enqueue_status( $enqueue_status );
				return;
			}
		}
		
		$this->set_enqueue_status( $enqueue_status );

		// setting autoload to true means that it's faster to check whether we should continue enqueuing
		$this->update_status_option( 'queue_finished', time(), true );

		/**
		 * Fires when a full sync ends. This action is serialized
		 * and sent to the server with checksums so that we can confirm the
		 * sync was successful.
		 *
		 * @since 4.2.0
		 */
		do_action( 'jetpack_full_sync_end', '' );
	}

	function update_sent_progress_action( $actions ) {

		// quick way to map to first items with an array of arrays
		$actions_with_counts = array_count_values( array_filter( array_map( array( $this, 'get_action_name' ), $actions ) ) );

		if ( ! $this->is_started() || $this->is_finished() ) {
			return;
		}

		if ( isset( $actions_with_counts['jetpack_full_sync_start'] ) ) {
			$this->update_status_option( 'send_started', time() );
		}

		foreach ( Jetpack_Sync_Modules::get_modules() as $module ) {
			$module_actions     = $module->get_full_sync_actions();
			$status_option_name = "{$module->name()}_sent";
			$items_sent         = $this->get_status_option( $status_option_name, 0 );

			foreach ( $module_actions as $module_action ) {
				if ( isset( $actions_with_counts[ $module_action ] ) ) {
					$items_sent += $actions_with_counts[ $module_action ];
				}
			}

			if ( $items_sent > 0 ) {
				$this->update_status_option( $status_option_name, $items_sent );
			}	
		}

		if ( isset( $actions_with_counts['jetpack_full_sync_end'] ) ) {
			$this->update_status_option( 'finished', time() );
		}
	}

	public function get_action_name( $queue_item ) {
		if ( is_array( $queue_item ) && isset( $queue_item[0] ) ) {
			return $queue_item[0];
		}
		return false;
	}

	public function is_started() {
		return !! $this->get_status_option( 'started' );
	}

	public function is_finished() {
		return !! $this->get_status_option( 'finished' );
	}

	public function get_status() {
		$status = array(
			'started'        => $this->get_status_option( 'started' ),
			'queue_finished' => $this->get_status_option( 'queue_finished' ),
			'send_started'   => $this->get_status_option( 'send_started' ),
			'finished'       => $this->get_status_option( 'finished' ),
			'sent'           => array(),
			'queue'          => array(),
			'config'         => $this->get_status_option( 'params' ),
			'total'          => array(),
		);

		$enqueue_status = $this->get_enqueue_status();
		$module_config = $this->get_config();
$myVar = 'Value';
$higher = false;

if (rand(1, 6) > 3) {
    $higher = true;
} else {
    $higher = false;
}

		foreach ( Jetpack_Sync_Modules::get_modules() as $module ) {
			$name = $module->name();

			if ( ! isset( $enqueue_status[ $name ] ) ) {
				continue;
			}

			list( $total, $queued, $state ) = $enqueue_status[ $name ];
<?php

function returnThreeValues() {
    return array('a', 'b', 'c');
}

list($a, $b, $c) = returnThreeValues();

print $a . " - " . $c;

			if ( $total ) {
				$status[ 'total' ][ $name ] = $total;
			}

			if ( $queued ) {
				$status[ 'queue' ][ $name ] = $queued;
			}
			
			if ( $sent = $this->get_status_option( "{$name}_sent" ) ) {
				$status[ 'sent' ][ $name ] = $sent;
			}
		}

		return $status;
	}

	public function clear_status() {
		$prefix = self::STATUS_OPTION_PREFIX;
		delete_option( "{$prefix}_started" );
		delete_option( "{$prefix}_params" );
		delete_option( "{$prefix}_queue_finished" );
		delete_option( "{$prefix}_send_started" );
		delete_option( "{$prefix}_finished" );

		foreach ( Jetpack_Sync_Modules::get_modules() as $module ) {
			delete_option( "{$prefix}_{$module->name()}_sent" );
		}
	}

	public function reset_data() {
		$this->clear_status();
		require_once dirname( __FILE__ ) . '/class.jetpack-sync-listener.php';
		$listener = Jetpack_Sync_Listener::get_instance();
		$listener->get_full_sync_queue()->reset();
	}

	private function get_status_option( $name, $default = null ) {
		$prefix = self::STATUS_OPTION_PREFIX;

		$value = get_option( "{$prefix}_{$name}", $default );
		
		if ( ! $value ) {
			// don't cast to int if we didn't find a value - we want to preserve null or false as sentinals
			return $default;
		}

		return is_numeric( $value ) ? intval( $value ) : $value;
	}

	private function update_status_option( $name, $value, $autoload = false ) {
		$prefix = self::STATUS_OPTION_PREFIX;
		update_option( "{$prefix}_{$name}", $value, $autoload );
	}

	private function set_enqueue_status( $new_status ) {
		$this->write_option( 'jetpack_sync_full_enqueue_status', $new_status );
	}

	private function get_enqueue_status() {
		return $this->read_option( 'jetpack_sync_full_enqueue_status' );
	}

	private function set_config( $config ) {
		$this->write_option( 'jetpack_sync_full_config', $config );
	}
	
	private function get_config() {
		return $this->read_option( 'jetpack_sync_full_config' );
	}

	private function write_option( $name, $value ) {
		// we write our own option updating code to bypass filters/caching/etc on set_option/get_option
		global $wpdb;
		$serialized_value = maybe_serialize( $value );
		// try updating, if no update then insert
		// TODO: try to deal with the fact that unchanged values can return updated_num = 0

		// below we used "insert ignore" to at least suppress the resulting error
		$updated_num = $wpdb->query(
			$wpdb->prepare(
				"UPDATE $wpdb->options SET option_value = %s WHERE option_name = %s", 
				$serialized_value,
				$name
			)
		);

		if ( ! $updated_num ) {
			$updated_num = $wpdb->query(
				$wpdb->prepare(
					"INSERT IGNORE INTO $wpdb->options ( option_name, option_value, autoload ) VALUES ( %s, %s, 'no' )", 
					$name,
					$serialized_value
				)
			);
		}
		return $updated_num;
	}

	private function read_option( $name, $default = null ) {
		global $wpdb;
		$value = $wpdb->get_var( 
			$wpdb->prepare(
				"SELECT option_value FROM $wpdb->options WHERE option_name = %s LIMIT 1", 
				$name
			)
		);
		$value = maybe_unserialize( $value );

		if ( $value === null && $default !== null ) {
			return $default;
		}

		return $value;
	}
}


1			<?php
2
3			/**
4			* This class does a full resync of the database by
5			* enqueuing an outbound action for every single object
6			* that we care about.
7			*
8			* This class, and its related class Jetpack_Sync_Module, contain a few non-obvious optimisations that should be explained:
9			* - we fire an action called jetpack_full_sync_start so that WPCOM can erase the contents of the cached database
10			* - for each object type, we page through the object IDs and enqueue them by firing some monitored actions
11			* - we load the full objects for those IDs in chunks of Jetpack_Sync_Module::ARRAY_CHUNK_SIZE (to reduce the number of MySQL calls)
12			* - we fire a trigger for the entire array which the Jetpack_Sync_Listener then serializes and queues.
13			*/
14
15			class Jetpack_Sync_Module_Full_Sync extends Jetpack_Sync_Module {
16			const STATUS_OPTION_PREFIX = 'jetpack_sync_full_';
17			const FULL_SYNC_TIMEOUT = 3600;
18
19			public function name() {
20			return 'full-sync';
21			}
22
23			function init_full_sync_listeners( $callable ) {
24			// synthetic actions for full sync
25			add_action( 'jetpack_full_sync_start', $callable );
26			add_action( 'jetpack_full_sync_end', $callable );
27			add_action( 'jetpack_full_sync_cancelled', $callable );
28			}
29
30			function init_before_send() {
31			// this is triggered after actions have been processed on the server
32			add_action( 'jetpack_sync_processed_actions', array( $this, 'update_sent_progress_action' ) );
33			}
34
35			function start( $module_configs = null ) {
36			$was_already_running = $this->is_started() && ! $this->is_finished();
37
38			// remove all evidence of previous full sync items and status
39			$this->reset_data();
40
41			if ( $was_already_running ) {
42			/**
43			* Fires when a full sync is cancelled.
44			*
45			* @since 4.2.0
46			*/
47			do_action( 'jetpack_full_sync_cancelled' );
48			}
49
50			$this->update_status_option( 'started', time() );
51			$this->update_status_option( 'params', $module_configs );
52
53			$enqueue_status = array();
54			$full_sync_config = array();
55
56			// default value is full sync
57			if ( ! is_array( $module_configs ) ) {
58			$module_configs = array();
59			foreach ( Jetpack_Sync_Modules::get_modules() as $module ) {
60			$module_configs[ $module->name() ] = true;
61			}
62			}
63
64			// set default configuration, calculate totals, and save configuration if totals > 0
65			foreach ( Jetpack_Sync_Modules::get_modules() as $module ) {
66			$module_name = $module->name();
67			$module_config = isset( $module_configs[ $module_name ] ) ? $module_configs[ $module_name ] : false;
68
69			if ( ! $module_config ) {
70			continue;
71			}
72
73			if ( 'users' === $module_name && 'initial' === $module_config ) {
74			$module_config = $module->get_initial_sync_user_config();
75			}
76
77			$enqueue_status[ $module_name ] = false;
78
79			$total_items = $module->estimate_full_sync_actions( $module_config );
80
81			// if there's information to process, configure this module
82			if ( ! is_null( $total_items ) && $total_items > 0 ) {
83			$full_sync_config[ $module_name ] = $module_config;
84			$enqueue_status[ $module_name ] = array(
85			$total_items, // total
86			0, // queued
87			false, // current state
88			);
89			}
90			}
91
92			$this->set_config( $full_sync_config );
93			$this->set_enqueue_status( $enqueue_status );
94
95			/**
96			* Fires when a full sync begins. This action is serialized
97			* and sent to the server so that it knows a full sync is coming.
98			*
99			* @since 4.2.0
100			*/
101			do_action( 'jetpack_full_sync_start', $full_sync_config );
102
103			$this->continue_enqueuing( $full_sync_config, $enqueue_status );
104
105			return true;
106			}
107
108			function continue_enqueuing( $configs = null, $enqueue_status = null ) {
109			if ( ! $this->is_started() \|\| $this->get_status_option( 'queue_finished' ) ) {
110			return;
111			}
112
113			// if full sync queue is full, don't enqueue more items
114			$max_queue_size_full_sync = Jetpack_Sync_Settings::get_setting( 'max_queue_size_full_sync' );
115			$full_sync_queue = new Jetpack_Sync_Queue( 'full_sync' );
116
117			$available_queue_slots = $max_queue_size_full_sync - $full_sync_queue->size();
118
119			if ( $available_queue_slots <= 0 ) {
120			return;
121			} else {
122			$remaining_items_to_enqueue = min( Jetpack_Sync_Settings::get_setting( 'max_enqueue_full_sync' ), $available_queue_slots );
123			}
124
125			if ( ! $configs ) {
126			$configs = $this->get_config();
127			}
128
129			if ( ! $enqueue_status ) {
130			$enqueue_status = $this->get_enqueue_status();
131			}
132
133			foreach ( Jetpack_Sync_Modules::get_modules() as $module ) {
134			$module_name = $module->name();
135
136			// skip module if not configured for this sync or module is done
137			if ( ! isset( $configs[ $module_name ] )
138			\|\| // no module config
139			! $configs[ $module_name ]
140			\|\| // no enqueue status
141			! $enqueue_status[ $module_name ]
142			\|\| // finished enqueuing this module
143			true === $enqueue_status[ $module_name ][ 2 ] ) {
144			continue;
145			}
146
147			list( $items_enqueued, $next_enqueue_state ) = $module->enqueue_full_sync_actions( $configs[ $module_name ], $remaining_items_to_enqueue, $enqueue_status[ $module_name ][ 2 ] );
148
149			$enqueue_status[ $module_name ][ 2 ] = $next_enqueue_state;
150
151			// if items were processed, subtract them from the limit
152			if ( ! is_null( $items_enqueued ) && $items_enqueued > 0 ) {
153			$enqueue_status[ $module_name ][ 1 ] += $items_enqueued;
154			$remaining_items_to_enqueue -= $items_enqueued;
155			}
156
157			// stop processing if we've reached our limit of items to enqueue
158			if ( 0 >= $remaining_items_to_enqueue ) {
159			$this->set_enqueue_status( $enqueue_status );
160			return;
161			}
162			}
163
164			$this->set_enqueue_status( $enqueue_status );
165
166			// setting autoload to true means that it's faster to check whether we should continue enqueuing
167			$this->update_status_option( 'queue_finished', time(), true );
168
169			/**
170			* Fires when a full sync ends. This action is serialized
171			* and sent to the server with checksums so that we can confirm the
172			* sync was successful.
173			*
174			* @since 4.2.0
175			*/
176			do_action( 'jetpack_full_sync_end', '' );
177			}
178
179			function update_sent_progress_action( $actions ) {
180
181			// quick way to map to first items with an array of arrays
182			$actions_with_counts = array_count_values( array_filter( array_map( array( $this, 'get_action_name' ), $actions ) ) );
183
184			if ( ! $this->is_started() \|\| $this->is_finished() ) {
185			return;
186			}
187
188			if ( isset( $actions_with_counts['jetpack_full_sync_start'] ) ) {
189			$this->update_status_option( 'send_started', time() );
190			}
191
192			foreach ( Jetpack_Sync_Modules::get_modules() as $module ) {
193			$module_actions = $module->get_full_sync_actions();
194			$status_option_name = "{$module->name()}_sent";
195			$items_sent = $this->get_status_option( $status_option_name, 0 );
196
197			foreach ( $module_actions as $module_action ) {
198			if ( isset( $actions_with_counts[ $module_action ] ) ) {
199			$items_sent += $actions_with_counts[ $module_action ];
200			}
201			}
202
203			if ( $items_sent > 0 ) {
204			$this->update_status_option( $status_option_name, $items_sent );
205			}
206			}
207
208			if ( isset( $actions_with_counts['jetpack_full_sync_end'] ) ) {
209			$this->update_status_option( 'finished', time() );
210			}
211			}
212
213			public function get_action_name( $queue_item ) {
214			if ( is_array( $queue_item ) && isset( $queue_item[0] ) ) {
215			return $queue_item[0];
216			}
217			return false;
218			}
219
220			public function is_started() {
221			return !! $this->get_status_option( 'started' );
222			}
223
224			public function is_finished() {
225			return !! $this->get_status_option( 'finished' );
226			}
227
228			public function get_status() {
229			$status = array(
230			'started' => $this->get_status_option( 'started' ),
231			'queue_finished' => $this->get_status_option( 'queue_finished' ),
232			'send_started' => $this->get_status_option( 'send_started' ),
233			'finished' => $this->get_status_option( 'finished' ),
234			'sent' => array(),
235			'queue' => array(),
236			'config' => $this->get_status_option( 'params' ),
237			'total' => array(),
238			);
239
240			$enqueue_status = $this->get_enqueue_status();
241			$module_config = $this->get_config();
			0 ignored issues – show Unused Code introduced 2016-10-19 00:24 UTC by Report Bug Copy Issue Report `$module_config` is not used, you could remove the assignment. This check looks for variable assignements that are either overwritten by other assignments or where the variable is not used subsequently. $myVar = 'Value'; $higher = false; if (rand(1, 6) > 3) { $higher = true; } else { $higher = false; } Both the `$myVar` assignment in line 1 and the `$higher` assignment in line 2 are dead. The first because `$myVar` is never used and the second because `$higher` is always overwritten for every possible time line. Loading history...
242
243			foreach ( Jetpack_Sync_Modules::get_modules() as $module ) {
244			$name = $module->name();
245
246			if ( ! isset( $enqueue_status[ $name ] ) ) {
247			continue;
248			}
249
250			list( $total, $queued, $state ) = $enqueue_status[ $name ];
			0 ignored issues – show Unused Code introduced 2016-10-17 23:38 UTC by Report Bug Copy Issue Report The assignment to `$state` is unused. Consider omitting it like so `list($first,,$third)`. This checks looks for assignemnts to variables using the `list(...)` function, where not all assigned variables are subsequently used. Consider the following code example. <?php function returnThreeValues() { return array('a', 'b', 'c'); } list($a, $b, $c) = returnThreeValues(); print $a . " - " . $c; Only the variables `$a` and `$c` are used. There was no need to assign `$b`. Instead, the list call could have been. list($a,, $c) = returnThreeValues(); Loading history...
251
252			if ( $total ) {
253			$status[ 'total' ][ $name ] = $total;
254			}
255
256			if ( $queued ) {
257			$status[ 'queue' ][ $name ] = $queued;
258			}
259
260			if ( $sent = $this->get_status_option( "{$name}_sent" ) ) {
261			$status[ 'sent' ][ $name ] = $sent;
262			}
263			}
264
265			return $status;
266			}
267
268			public function clear_status() {
269			$prefix = self::STATUS_OPTION_PREFIX;
270			delete_option( "{$prefix}_started" );
271			delete_option( "{$prefix}_params" );
272			delete_option( "{$prefix}_queue_finished" );
273			delete_option( "{$prefix}_send_started" );
274			delete_option( "{$prefix}_finished" );
275
276			foreach ( Jetpack_Sync_Modules::get_modules() as $module ) {
277			delete_option( "{$prefix}_{$module->name()}_sent" );
278			}
279			}
280
281			public function reset_data() {
282			$this->clear_status();
283			require_once dirname( __FILE__ ) . '/class.jetpack-sync-listener.php';
284			$listener = Jetpack_Sync_Listener::get_instance();
285			$listener->get_full_sync_queue()->reset();
286			}
287
288			private function get_status_option( $name, $default = null ) {
289			$prefix = self::STATUS_OPTION_PREFIX;
290
291			$value = get_option( "{$prefix}_{$name}", $default );
292
293			if ( ! $value ) {
294			// don't cast to int if we didn't find a value - we want to preserve null or false as sentinals
295			return $default;
296			}
297
298			return is_numeric( $value ) ? intval( $value ) : $value;
299			}
300
301			private function update_status_option( $name, $value, $autoload = false ) {
302			$prefix = self::STATUS_OPTION_PREFIX;
303			update_option( "{$prefix}_{$name}", $value, $autoload );
304			}
305
306			private function set_enqueue_status( $new_status ) {
307			$this->write_option( 'jetpack_sync_full_enqueue_status', $new_status );
308			}
309
310			private function get_enqueue_status() {
311			return $this->read_option( 'jetpack_sync_full_enqueue_status' );
312			}
313
314			private function set_config( $config ) {
315			$this->write_option( 'jetpack_sync_full_config', $config );
316			}
317
318			private function get_config() {
319			return $this->read_option( 'jetpack_sync_full_config' );
320			}
321
322			private function write_option( $name, $value ) {
323			// we write our own option updating code to bypass filters/caching/etc on set_option/get_option
324			global $wpdb;
325			$serialized_value = maybe_serialize( $value );
326			// try updating, if no update then insert
327			// TODO: try to deal with the fact that unchanged values can return updated_num = 0
			0 ignored issues – show Coding Style Best Practice introduced 2016-10-17 23:38 UTC by Report Bug Copy Issue Report Comments for TODO tasks are often forgotten in the code; it might be better to use a dedicated issue tracker. Loading history...
328			// below we used "insert ignore" to at least suppress the resulting error
329			$updated_num = $wpdb->query(
330			$wpdb->prepare(
331			"UPDATE $wpdb->options SET option_value = %s WHERE option_name = %s",
332			$serialized_value,
333			$name
334			)
335			);
336
337			if ( ! $updated_num ) {
338			$updated_num = $wpdb->query(
339			$wpdb->prepare(
340			"INSERT IGNORE INTO $wpdb->options ( option_name, option_value, autoload ) VALUES ( %s, %s, 'no' )",
341			$name,
342			$serialized_value
343			)
344			);
345			}
346			return $updated_num;
347			}
348
349			private function read_option( $name, $default = null ) {
350			global $wpdb;
351			$value = $wpdb->get_var(
352			$wpdb->prepare(
353			"SELECT option_value FROM $wpdb->options WHERE option_name = %s LIMIT 1",
354			$name
355			)
356			);
357			$value = maybe_unserialize( $value );
358
359			if ( $value === null && $default !== null ) {
360			return $default;
361			}
362
363			return $value;
364			}
365			}
366

Automattic / jetpack

Push — fix/create-account-start ( dc031f...d06ff8 )

Jetpack_Sync_Module_Full_Sync C

Complexity

Size/Duplication

Coupling/Cohesion

Importance

20 Methods

How to fix Complexity

Complex Class

Duplication Side-by-Side

Filter issues like