1 files changed, 152 insertions, 0 deletions
diff --git a/plugins/jetpack/jetpack_vendor/automattic/jetpack-sync/src/class-users.php b/plugins/jetpack/jetpack_vendor/automattic/jetpack-sync/src/class-users.php
new file mode 100644
index 00000000..8a8c83f8
--- /dev/null
+++ b/plugins/jetpack/jetpack_vendor/automattic/jetpack-sync/src/class-users.php
@@ -0,0 +1,152 @@
+<?php
+/**
+ * Sync for users.
+ *
+ * @package automattic/jetpack-sync
+ */
+
+namespace Automattic\Jetpack\Sync;
+
+use Automattic\Jetpack\Connection\Manager as Jetpack_Connection;
+use Automattic\Jetpack\Connection\XMLRPC_Async_Call;
+use Automattic\Jetpack\Roles;
+
+/**
+ * Class Users.
+ *
+ * Responsible for syncing user data changes.
+ */
+class Users {
+	/**
+	 * Roles of all users, indexed by user ID.
+	 *
+	 * @access public
+	 * @static
+	 *
+	 * @var array
+	 */
+	public static $user_roles = array();
+
+	/**
+	 * Initialize sync for user data changes.
+	 *
+	 * @access public
+	 * @static
+	 * @todo Eventually, connection needs to be instantiated at the top level in the sync package.
+	 */
+	public static function init() {
+		add_action( 'jetpack_user_authorized', array( 'Automattic\\Jetpack\\Sync\\Actions', 'do_initial_sync' ), 10, 0 );
+		$connection = new Jetpack_Connection();
+		if ( $connection->has_connected_user() ) {
+			// Kick off synchronization of user role when it changes.
+			add_action( 'set_user_role', array( __CLASS__, 'user_role_change' ) );
+		}
+	}
+
+	/**
+	 * Synchronize connected user role changes.
+	 *
+	 * @access public
+	 * @static
+	 *
+	 * @param int $user_id ID of the user.
+	 */
+	public static function user_role_change( $user_id ) {
+		$connection = new Jetpack_Connection();
+		if ( $connection->is_user_connected( $user_id ) ) {
+			self::update_role_on_com( $user_id );
+			// Try to choose a new master if we're demoting the current one.
+			self::maybe_demote_master_user( $user_id );
+		}
+	}
+
+	/**
+	 * Retrieve the role of a user by their ID.
+	 *
+	 * @access public
+	 * @static
+	 *
+	 * @param int $user_id ID of the user.
+	 * @return string Role of the user.
+	 */
+	public static function get_role( $user_id ) {
+		if ( isset( self::$user_roles[ $user_id ] ) ) {
+			return self::$user_roles[ $user_id ];
+		}
+
+		$current_user_id = get_current_user_id();
+		wp_set_current_user( $user_id );
+		$roles = new Roles();
+		$role  = $roles->translate_current_user_to_role();
+		wp_set_current_user( $current_user_id );
+		self::$user_roles[ $user_id ] = $role;
+
+		return $role;
+	}
+
+	/**
+	 * Retrieve the signed role of a user by their ID.
+	 *
+	 * @access public
+	 * @static
+	 *
+	 * @param int $user_id ID of the user.
+	 * @return string Signed role of the user.
+	 */
+	public static function get_signed_role( $user_id ) {
+		$connection = new Jetpack_Connection();
+		return $connection->sign_role( self::get_role( $user_id ), $user_id );
+	}
+
+	/**
+	 * Retrieve the signed role and update it in WP.com for that user.
+	 *
+	 * @access public
+	 * @static
+	 *
+	 * @param int $user_id ID of the user.
+	 */
+	public static function update_role_on_com( $user_id ) {
+		$signed_role = self::get_signed_role( $user_id );
+		XMLRPC_Async_Call::add_call( 'jetpack.updateRole', get_current_user_id(), $user_id, $signed_role );
+	}
+
+	/**
+	 * Choose a new master user if we're demoting the current one.
+	 *
+	 * @access public
+	 * @static
+	 * @todo Disconnect if there is no user with enough capabilities to be the master user.
+	 * @uses \WP_User_Query
+	 *
+	 * @param int $user_id ID of the user.
+	 */
+	public static function maybe_demote_master_user( $user_id ) {
+		$master_user_id = (int) \Jetpack_Options::get_option( 'master_user' );
+		$role           = self::get_role( $user_id );
+		if ( $user_id === $master_user_id && 'administrator' !== $role ) {
+			$query      = new \WP_User_Query(
+				array(
+					'fields'  => array( 'id' ),
+					'role'    => 'administrator',
+					'orderby' => 'id',
+					'exclude' => array( $master_user_id ),
+				)
+			);
+			$new_master = false;
+			$connection = new Jetpack_Connection();
+			foreach ( $query->results as $result ) {
+				$found_user_id = absint( $result->id );
+				if ( $found_user_id && $connection->is_user_connected( $found_user_id ) ) {
+					$new_master = $found_user_id;
+					break;
+				}
+			}
+
+			if ( $new_master ) {
+				\Jetpack_Options::update_option( 'master_user', $new_master );
+			}
+			// TODO: else disconnect..?
+		}
+	}
+}