Automattic\Jetpack\Sync\Actions::send_data()

Complexity

Conditions	12
Paths	208

Size

Total Lines

100

Duplication

Lines	0
Ratio	0 %

Importance

Changes

0

<?php
	public static function send_data( $data, $codec_name, $sent_timestamp, $queue_id, $checkout_duration, $preprocess_duration, $queue_size = null, $buffer_id = null ) {

		$query_args = array(
			'sync'       => '1',             // Add an extra parameter to the URL so we can tell it's a sync action.
			'codec'      => $codec_name,
			'timestamp'  => $sent_timestamp,
			'queue'      => $queue_id,
			'home'       => Functions::home_url(),  // Send home url option to check for Identity Crisis server-side.
			'siteurl'    => Functions::site_url(),  // Send siteurl option to check for Identity Crisis server-side.
			'cd'         => sprintf( '%.4f', $checkout_duration ),
			'pd'         => sprintf( '%.4f', $preprocess_duration ),
			'queue_size' => $queue_size,
			'buffer_id'  => $buffer_id,
		);

		// Has the site opted in to IDC mitigation?
		if ( \Jetpack::sync_idc_optin() ) {
			$query_args['idc'] = true;
		}

		if ( \Jetpack_Options::get_option( 'migrate_for_idc', false ) ) {
			$query_args['migrate_for_idc'] = true;
		}

		$query_args['timeout'] = Settings::is_doing_cron() ? 30 : 15;
		if ( 'immediate-send' === $queue_id ) {
			$query_args['timeout'] = 30;
		}

		/**
		 * Filters query parameters appended to the Sync request URL sent to WordPress.com.
		 *
		 * @since 4.7.0
		 *
		 * @param array $query_args associative array of query parameters.
		 */
		$query_args = apply_filters( 'jetpack_sync_send_data_query_args', $query_args );

		$connection = new Jetpack_Connection();
		$url        = add_query_arg( $query_args, $connection->xmlrpc_api_url() );

		// If we're currently updating to Jetpack 7.7, the IXR client may be missing briefly
		// because since 7.7 it's being autoloaded with Composer.
		if ( ! class_exists( '\\Jetpack_IXR_Client' ) ) {
			return new \WP_Error(
				'ixr_client_missing',

The call to WP_Error::__construct() has too many arguments starting with 'ixr_client_missing'.

				esc_html__( 'Sync has been aborted because the IXR client is missing.', 'jetpack' )
			);
		}

		$rpc = new \Jetpack_IXR_Client(
			array(
				'url'     => $url,
				'timeout' => $query_args['timeout'],
			)
		);

		$result = $rpc->query( 'jetpack.syncActions', $data );

		// Adhere to Retry-After headers.
		$retry_after = $rpc->getResponse_header( 'Retry-After' );
		if ( false !== $retry_after ) {
			if ( (int) $retry_after > 0 ) {
				update_option( self::RETRY_AFTER_PREFIX . $queue_id, microtime( true ) + (int) $retry_after );
			} else {
				// if unexpected value default to 3 minutes.
				update_option( self::RETRY_AFTER_PREFIX . $queue_id, microtime( true ) + 180 );
			}
		}

		if ( ! $result ) {
			return $rpc->get_jetpack_error();
		}

		$response = $rpc->getResponse();

		// Check if WordPress.com IDC mitigation blocked the sync request.
		if ( is_array( $response ) && isset( $response['error_code'] ) ) {
			$error_code              = $response['error_code'];
			$allowed_idc_error_codes = array(
				'jetpack_url_mismatch',
				'jetpack_home_url_mismatch',
				'jetpack_site_url_mismatch',
			);

			if ( in_array( $error_code, $allowed_idc_error_codes, true ) ) {
				\Jetpack_Options::update_option(
					'sync_error_idc',
					\Jetpack::get_sync_error_idc_option( $response )
				);
			}

			return new \WP_Error(
				'sync_error_idc',

The call to WP_Error::__construct() has too many arguments starting with 'sync_error_idc'.

				esc_html__( 'Sync has been blocked from WordPress.com because it would cause an identity crisis', 'jetpack' )
			);
		}

		return $response;
	}