tdown(); } } } /** * Sync Data Loss Handler * * @param Queue $queue Sync queue. * @return boolean was send successful */ public function sync_data_loss( $queue ) { if ( ! Settings::is_sync_enabled() ) { return; } $updated = Health::update_status( Health::STATUS_OUT_OF_SYNC ); if ( ! $updated ) { return; } $data = array( 'timestamp' => microtime( true ), 'queue_size' => $queue->size(), 'queue_lag' => $queue->lag(), ); $sender = Sender::get_instance(); return $sender->send_action( 'jetpack_sync_data_loss', $data ); } /** * Get the event's actor. * * @param string $current_filter Current wp-admin page. * @param object $args Sync event. * @return array Actor information. */ public function get_actor( $current_filter, $args ) { if ( 'wp_login' === $current_filter ) { $user = get_user_by( 'ID', $args[1]->data->ID ); } else { $user = wp_get_current_user(); } $roles = new Roles(); $translated_role = $roles->translate_user_to_role( $user ); $actor = array( 'wpcom_user_id' => null, 'external_user_id' => isset( $user->ID ) ? $user->ID : null, 'display_name' => isset( $user->display_name ) ? $user->display_name : null, 'user_email' => isset( $user->user_email ) ? $user->user_email : null, 'user_roles' => isset( $user->roles ) ? $user->roles : null, 'translated_role' => $translated_role ? $translated_role : null, 'is_cron' => defined( 'DOING_CRON' ) ? DOING_CRON : false, 'is_rest' => defined( 'REST_API_REQUEST' ) ? REST_API_REQUEST : false, 'is_xmlrpc' => defined( 'XMLRPC_REQUEST' ) ? XMLRPC_REQUEST : false, 'is_wp_rest' => defined( 'REST_REQUEST' ) ? REST_REQUEST : false, 'is_ajax' => defined( 'DOING_AJAX' ) ? DOING_AJAX : false, 'is_wp_admin' => is_admin(), 'is_cli' => defined( 'WP_CLI' ) ? WP_CLI : false, 'from_url' => $this->get_request_url(), ); if ( $this->should_send_user_data_with_actor( $current_filter ) ) { require_once JETPACK__PLUGIN_DIR . 'modules/protect/shared-functions.php'; $actor['ip'] = jetpack_protect_get_ip(); $actor['user_agent'] = isset( $_SERVER['HTTP_USER_AGENT'] ) ? $_SERVER['HTTP_USER_AGENT'] : 'unknown'; } return $actor; } /** * Should user data be sent as the actor? * * @param string $current_filter The current WordPress filter being executed. * @return bool */ public function should_send_user_data_with_actor( $current_filter ) { $should_send = in_array( $current_filter, array( 'jetpack_wp_login', 'wp_logout', 'jetpack_valid_failed_login_attempt' ), true ); /** * Allow or deny sending actor's user data ( IP and UA ) during a sync event * * @since 5.8.0 * * @module sync * * @param bool True if we should send user data * @param string The current filter that is performing the sync action */ return apply_filters( 'jetpack_sync_actor_user_data', $should_send, $current_filter ); } /** * Sets Listener defaults. */ public function set_defaults() { $this->sync_queue = new Queue( 'sync' ); $this->full_sync_queue = new Queue( 'full_sync' ); $this->set_queue_size_limit( Settings::get_setting( 'max_queue_size' ) ); $this->set_queue_lag_limit( Settings::get_setting( 'max_queue_lag' ) ); } /** * Get the request URL. * * @return string Request URL, if known. Otherwise, wp-admin or home_url. */ public function get_request_url() { if ( isset( $_SERVER['HTTP_HOST'], $_SERVER['REQUEST_URI'] ) ) { return 'http' . ( isset( $_SERVER['HTTPS'] ) ? 's' : '' ) . '://' . "{$_SERVER['HTTP_HOST']}{$_SERVER['REQUEST_URI']}"; } return is_admin() ? get_admin_url( get_current_blog_id() ) : home_url(); } }