Update plugin jetpack to 4.2.2

1 files changed, 148 insertions, 0 deletions

diff --git a/plugins/jetpack/sync/class.jetpack-sync-module-callables.php b/plugins/jetpack/sync/class.jetpack-sync-module-callables.php
new file mode 100644
index 00000000..d2d8bc5a
--- /dev/null
+++ b/plugins/jetpack/sync/class.jetpack-sync-module-callables.php
@@ -0,0 +1,148 @@
+<?php
+
+require_once dirname( __FILE__ ) . '/class.jetpack-sync-functions.php';
+
+class Jetpack_Sync_Module_Callables extends Jetpack_Sync_Module {
+	const CALLABLES_CHECKSUM_OPTION_NAME = 'jetpack_callables_sync_checksum';
+	const CALLABLES_AWAIT_TRANSIENT_NAME = 'jetpack_sync_callables_await';
+
+	private $callable_whitelist;
+
+	public function name() {
+		return 'functions';
+	}
+
+	public function set_defaults() {
+		if ( is_multisite() ) {
+			$this->callable_whitelist = array_merge( Jetpack_Sync_Defaults::$default_callable_whitelist, Jetpack_Sync_Defaults::$default_multisite_callable_whitelist );
+		} else {
+			$this->callable_whitelist = Jetpack_Sync_Defaults::$default_callable_whitelist;
+		}
+	}
+
+	public function init_listeners( $callable ) {
+		add_action( 'jetpack_sync_callable', $callable, 10, 2 );
+
+		// always send change to active modules right away
+		add_action( 'update_option_jetpack_active_modules', array( $this, 'unlock_sync_callable' ) );
+
+		// get_plugins and wp_version
+		// gets fired when new code gets installed, updates etc.
+		add_action( 'upgrader_process_complete', array( $this, 'unlock_sync_callable' ) );
+	}
+
+	public function init_full_sync_listeners( $callable ) {
+		add_action( 'jetpack_full_sync_callables', $callable );
+	}
+
+	public function init_before_send() {
+		add_action( 'jetpack_sync_before_send_queue_sync', array( $this, 'maybe_sync_callables' ) );
+
+		// full sync
+		add_filter( 'jetpack_sync_before_send_jetpack_full_sync_callables', array( $this, 'expand_callables' ) );
+	}
+
+	public function reset_data() {
+		delete_option( self::CALLABLES_CHECKSUM_OPTION_NAME );
+		delete_transient( self::CALLABLES_AWAIT_TRANSIENT_NAME );
+	}
+
+	function set_callable_whitelist( $callables ) {
+		$this->callable_whitelist = $callables;
+	}
+
+	function get_callable_whitelist() {
+		return $this->callable_whitelist;
+	}
+
+	public function get_all_callables() {
+		// get_all_callables should run as the master user always.
+		$current_user_id = get_current_user_id();
+		wp_set_current_user( Jetpack_Options::get_option( 'master_user' ) );
+		$callables = array_combine(
+			array_keys( $this->callable_whitelist ),
+			array_map( array( $this, 'get_callable' ), array_values( $this->callable_whitelist ) )
+		);
+		wp_set_current_user( $current_user_id );
+
+		return $callables;
+	}
+
+	private function get_callable( $callable ) {
+		return call_user_func( $callable );
+	}
+
+	public function enqueue_full_sync_actions( $config ) {
+		/**
+		 * Tells the client to sync all callables to the server
+		 *
+		 * @since 4.2.0
+		 *
+		 * @param boolean Whether to expand callables (should always be true)
+		 */
+		do_action( 'jetpack_full_sync_callables', true );
+
+		return 1; // The number of actions enqueued
+	}
+
+	public function estimate_full_sync_actions( $config ) {
+		return 1;
+	}
+
+	public function get_full_sync_actions() {
+		return array( 'jetpack_full_sync_callables' );
+	}
+
+	public function unlock_sync_callable() {
+		delete_transient( self::CALLABLES_AWAIT_TRANSIENT_NAME );
+	}
+	
+	public function maybe_sync_callables() {
+		if ( ! is_admin() || Jetpack_Sync_Settings::is_doing_cron() ) {
+			return;
+		}
+
+		if ( get_transient( self::CALLABLES_AWAIT_TRANSIENT_NAME ) ) {
+			return;
+		}
+
+		set_transient( self::CALLABLES_AWAIT_TRANSIENT_NAME, microtime( true ), Jetpack_Sync_Defaults::$default_sync_callables_wait_time );
+
+		$callables = $this->get_all_callables();
+
+		if ( empty( $callables ) ) {
+			return;
+		}
+
+		$callable_checksums = (array) get_option( self::CALLABLES_CHECKSUM_OPTION_NAME, array() );
+
+		// only send the callables that have changed
+		foreach ( $callables as $name => $value ) {
+			$checksum = $this->get_check_sum( $value );
+			// explicitly not using Identical comparison as get_option returns a string
+			if ( ! $this->still_valid_checksum( $callable_checksums, $name, $checksum ) && ! is_null( $value ) ) {
+				/**
+				 * Tells the client to sync a callable (aka function) to the server
+				 *
+				 * @since 4.2.0
+				 *
+				 * @param string The name of the callable
+				 * @param mixed The value of the callable
+				 */
+				do_action( 'jetpack_sync_callable', $name, $value );
+				$callable_checksums[ $name ] = $checksum;
+			} else {
+				$callable_checksums[ $name ] = $checksum;
+			}
+		}
+		update_option( self::CALLABLES_CHECKSUM_OPTION_NAME, $callable_checksums );
+	}
+
+	public function expand_callables( $args ) {
+		if ( $args[0] ) {
+			return $this->get_all_callables();
+		}
+
+		return $args;
+	}
+}