ync is not allowed, if it is not allowed. * * @return array */ public static function get_debug_details() { $debug = array(); $debug['debug_details']['sync_allowed'] = self::sync_allowed(); $debug['debug_details']['sync_health'] = Health::get_status(); if ( false === $debug['debug_details']['sync_allowed'] ) { if ( defined( 'IS_WPCOM' ) && IS_WPCOM ) { $debug['debug_details']['is_wpcom'] = true; } if ( defined( 'PHPUNIT_JETPACK_TESTSUITE' ) ) { $debug['debug_details']['PHPUNIT_JETPACK_TESTSUITE'] = true; } if ( ! Settings::is_sync_enabled() ) { $debug['debug_details']['is_sync_enabled'] = false; $debug['debug_details']['jetpack_sync_disable'] = Settings::get_setting( 'disable' ); $debug['debug_details']['jetpack_sync_network_disable'] = Settings::get_setting( 'network_disable' ); } if ( ( new Status() )->is_offline_mode() ) { $debug['debug_details']['is_offline_mode'] = true; } if ( ( new Status() )->in_safe_mode() ) { $debug['debug_details']['in_safe_mode'] = true; } $connection = new Jetpack_Connection(); if ( ! $connection->is_connected() ) { $debug['debug_details']['active_connection'] = false; } } // Sync locks. $debug['debug_details']['dedicated_sync_enabled'] = Settings::is_dedicated_sync_enabled(); $queue = self::$sender->get_sync_queue(); $full_queue = self::$sender->get_full_sync_queue(); $debug['debug_details']['sync_locks'] = array( 'retry_time_sync' => get_option( self::RETRY_AFTER_PREFIX . 'sync' ), 'retry_time_full_sync' => get_option( self::RETRY_AFTER_PREFIX . 'full_sync' ), 'next_sync_time_sync' => self::$sender->get_next_sync_time( 'sync' ), 'next_sync_time_full_sync' => self::$sender->get_next_sync_time( 'full_sync' ), 'queue_locked_sync' => $queue->is_locked(), 'queue_locked_full_sync' => $full_queue->is_locked(), 'dedicated_sync_request_lock' => \Jetpack_Options::get_raw_option( Dedicated_Sender::DEDICATED_SYNC_REQUEST_LOCK_OPTION_NAME, null ), 'dedicated_sync_temporary_disable_flag' => get_transient( Dedicated_Sender::DEDICATED_SYNC_TEMPORARY_DISABLE_FLAG ), ); // Sync Logs. $debug['debug_details']['last_succesful_sync'] = get_option( self::LAST_SUCCESS_PREFIX . 'sync', '' ); $debug['debug_details']['sync_error_log'] = get_option( self::ERROR_LOG_PREFIX . 'sync', '' ); return $debug; } /** * Determines if syncing during a cron job is allowed. * * @access public * @static * * @return bool|int */ public static function sync_via_cron_allowed() { return ( Settings::get_setting( 'sync_via_cron' ) ); } /** * Decides if the given post should be Publicized based on its type. * * @access public * @static * * @param bool $should_publicize Publicize status prior to this filter running. * @param \WP_Post $post The post to test for Publicizability. * @return bool */ public static function prevent_publicize_blacklisted_posts( $should_publicize, $post ) { if ( in_array( $post->post_type, Settings::get_setting( 'post_types_blacklist' ), true ) ) { return false; } return $should_publicize; } /** * Set an importing flag to `true` in sync settings. * * @access public * @static */ public static function set_is_importing_true() { Settings::set_importing( true ); } /** * Sends data to WordPress.com via an XMLRPC or a REST API request based on the settings. * * @access public * @static * * @param object $data Data relating to a sync action. * @param string $codec_name The name of the codec that encodes the data. * @param float $sent_timestamp Current server time so we can compensate for clock differences. * @param string $queue_id The queue the action belongs to, sync or full_sync. * @param float $checkout_duration Time spent retrieving queue items from the DB. * @param float $preprocess_duration Time spent converting queue items into data to send. * @param int $queue_size The size of the sync queue at the time of processing. * @param string $buffer_id The ID of the Queue buffer checked out for processing. * @return mixed|WP_Error The result of the sending request. */ 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, 'cd' => sprintf( '%.4f', $checkout_duration ), 'pd' => sprintf( '%.4f', $preprocess_duration ), 'queue_size' => $queue_size, 'buffer_id' => $buffer_id, // TODO this will be extended in the future. Might be good to extract in a separate method to support future entries too. 'sync_flow_type' => Settings::is_dedicated_sync_enabled() ? 'dedicated' : 'default', 'storage_type' => Settings::is_custom_queue_table_enabled() ? 'custom' : 'options', ); $query_args['timeout'] = Settings::is_doing_cron() ? 30 : 20; if ( 'immediate-send' === $queue_id ) { $query_args['timeout'] = 30; } /** * Filters query parameters appended to the Sync request URL sent to WordPress.com. * * @since 1.6.3 * @since-jetpack 4.7.0 * * @param array $query_args associative array of query parameters. */ $query_args = apply_filters( 'jetpack_sync_send_data_query_args', $query_args ); $retry_after_header = false; $dedicated_sync_header = false; // If REST API is enabled, use it. if ( Settings::is_wpcom_rest_api_enabled() ) { $jsonl_data = self::prepare_jsonl_data( $data ); $url = '/sites/' . \Jetpack_Options::get_option( 'id' ) . '/jetpack-sync-actions'; $url = add_query_arg( $query_args, $url ); $args = array( 'method' => 'POST', 'format' => 'jsonl', 'timeout' => $query_args['timeout'], ); $response = Client::wpcom_json_api_request_as_blog( $url, '2', $args, $jsonl_data, 'wpcom' ); $retry_after_header = wp_remote_retrieve_header( $response, 'Retry-After' ) ? wp_remote_retrieve_header( $response, 'Retry-After' ) : false; $dedicated_sync_header = wp_remote_retrieve_header( $response, 'Jetpack-Dedicated-Sync' ) ? wp_remote_retrieve_header( $response, 'Jetpack-Dedicated-Sync' ) : false; $response = self::process_rest_api_response( $response ); } else { // Use XML-RPC. $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', esc_html__( 'Sync has been aborted because the IXR client is missing.', 'jetpack-sync' ) ); } $rpc = new \Jetpack_IXR_Client( array( 'url' => $url, 'timeout' => $query_args['timeout'], ) ); $result = $rpc->query( 'jetpack.syncActions', $data ); $retry_after_header = $rpc->get_response_header( 'Retry-After' ); $dedicated_sync_header = $rpc->get_response_header( 'Jetpack-Dedicated-Sync' ); if ( $result ) { $response = $rpc->getResponse(); } else { $response = $rpc->get_jetpack_error(); } } // Adhere to Retry-After headers. if ( false !== $retry_after_header ) { if ( (int) $retry_after_header > 0 ) { update_option( self::RETRY_AFTER_PREFIX . $queue_id, microtime( true ) + (int) $retry_after_header, false ); } else { // if unexpected value default to 3 minutes. update_option( self::RETRY_AFTER_PREFIX . $queue_id, microtime( true ) + 180, false ); } } // Enable/Disable Dedicated Sync flow via response headers. if ( false !== $dedicated_sync_header ) { Dedicated_Sender::maybe_change_dedicated_sync_status_from_wpcom_header( $dedicated_sync_header ); } if ( is_wp_error( $response ) ) { $error = $response; if ( false === $retry_after_header ) { // We received a non standard response from WP.com, lets backoff from sending requests for 1 minute. update_option( self::RETRY_AFTER_PREFIX . $queue_id, microtime( true ) + 60, false ); } // Record Sync Errors. $error_log = get_option( self::ERROR_LOG_PREFIX . $queue_id, array() ); if ( ! is_array( $error_log ) ) { $error_log = array(); } // Trim existing array to last 4 entries. if ( 5 <= count( $error_log ) ) { $error_log = array_slice( $error_log, -4, null, true ); } // Add new error indexed to time. if ( isset( $rpc ) && ! empty( $rpc->get_last_response() ) ) { $error_with_last_response = clone $error; $error_with_last_response->add_data( $rpc->get_last_response() ); $error_log[ (string) microtime( true ) ] = $error_with_last_response; } else { $error_log[ (string) microtime( true ) ] = $error; } // Update the error log. update_option( self::ERROR_LOG_PREFIX . $queue_id, $error_log ); return $error; } // Check if WordPress.com IDC mitigation blocked the sync request. if ( Identity_Crisis::init()->check_response_for_idc( $response ) ) { return new WP_Error( 'sync_error_idc', esc_html__( 'Sync has been blocked from WordPress.com because it would cause an identity crisis', 'jetpack-sync' ) ); } if ( isset( $response['processed_items'] ) ) { // Return only processed items. $response = $response['processed_items']; } // Record last successful sync. update_option( self::LAST_SUCCESS_PREFIX . $queue_id, microtime( true ), false ); return $response; } /** * Kicks off the initial sync. * * @access public * @static * * @return bool|null False if sync is not allowed. */ public static function do_initial_sync() { // Let's not sync if we are not supposed to. if ( ! self::sync_allowed() ) { return false; } // Don't start new sync if a full sync is in process. $full_sync_module = Modules::get_module( 'full-sync' ); '@phan-var Modules\Full_Sync_Immediately|Modules\Full_Sync $full_sync_module'; if ( $full_sync_module && $full_sync_module->is_started() && ! $full_sync_module->is_finished() ) { return false; } $initial_sync_config = array( 'options' => true, 'functions' => true, 'constants' => true, 'users' => array( get_current_user_id() ), 'network_options' => true, ); self::do_full_sync( $initial_sync_config ); } /** * Do an initial full sync only if one has not already been started. * * @return bool|null False if the initial full sync was already started, otherwise null. */ public static function do_only_first_initial_sync() { $full_sync_module = Modules::get_module( 'full-sync' ); '@phan-var Modules\Full_Sync_Immediately|Modules\Full_Sync $full_sync_module'; if ( $full_sync_module && $full_sync_module->is_started() ) { return false; } static::do_initial_sync(); } /** * Kicks off a full sync. * * @access public * @static * * @param array $modules The sync modules should be included in this full sync. All will be included if null. * @return bool True if full sync was successfully started. */ public static function do_full_sync( $modules = null ) { if ( ! self::sync_allowed() ) { return false; } $full_sync_module = Modules::get_module( 'full-sync' ); '@phan-var Modules\Full_Sync_Immediately|Modules\Full_Sync $full_sync_module'; if ( ! $full_sync_module ) { return false; } self::initialize_listener(); $full_sync_module->start( $modules ); return true; } /** * Adds a cron schedule for regular syncing via cron, unless the schedule already exists. * * @access public * @static * * @param array $schedules The list of WordPress cron schedules prior to this filter. * @return array A list of WordPress cron schedules with the Jetpack sync interval added. */ public static function jetpack_cron_schedule( $schedules ) { if ( ! isset( $schedules[ self::DEFAULT_SYNC_CRON_INTERVAL_NAME ] ) ) { $minutes = (int) ( self::DEFAULT_SYNC_CRON_INTERVAL_VALUE / 60 ); $display = ( 1 === $minutes ) ? __( 'Every minute', 'jetpack-sync' ) : /* translators: %d is an integer indicating the number of minutes. */ sprintf( __( 'Every %d minutes', 'jetpack-sync' ), $minutes ); $schedules[ self::DEFAULT_SYNC_CRON_INTERVAL_NAME ] = array( 'interval' => self::DEFAULT_SYNC_CRON_INTERVAL_VALUE, 'display' => $display, ); } return $schedules; } /** * Starts an incremental sync via cron. * * @access public * @static */ public static function do_cron_sync() { self::do_cron_sync_by_type( 'sync' ); } /** * Starts a full sync via cron. * * @access public * @static */ public static function do_cron_full_sync() { self::do_cron_sync_by_type( 'full_sync' ); } /** * Try to send actions until we run out of things to send, * or have to wait more than 15s before sending again, * or we hit a lock or some other sending issue * * @access public * @static * * @param string $type Sync type. Can be `sync` or `full_sync`. */ public static function do_cron_sync_by_type( $type ) { if ( ! self::sync_allowed() || ( 'sync' !== $type && 'full_sync' !== $type ) ) { return; } self::initialize_sender(); $time_limit = Settings::get_setting( 'cron_sync_time_limit' ); $start_time = time(); $executions = 0; do { $next_sync_time = self::$sender->get_next_sync_time( $type ); if ( $next_sync_time ) { $delay = $next_sync_time - time() + 1; if ( $delay > 15 ) { break; } elseif ( $delay > 0 ) { sleep( $delay ); } } // Explicitly only allow 1 do_full_sync call until issue with Immediate Full Sync is resolved. // For more context see p1HpG7-9pe-p2. if ( 'full_sync' === $type && $executions >= 1 ) { break; } /** * Only try to sync once if Dedicated Sync is enabled. Dedicated Sync has its own requeueing mechanism * that will re-run it if there are items in the queue at the end. */ if ( 'sync' === $type && $executions >= 1 && Settings::is_dedicated_sync_enabled() ) { break; } $result = 'full_sync' === $type ? self::$sender->do_full_sync() : self::$sender->do_sync(); // # of send actions performed. ++$executions; } while ( $result && ! is_wp_error( $result ) && ( $start_time + $time_limit ) > time() ); return $executions; } /** * Initialize the sync listener. * * @access public * @static */ public static function initialize_listener() { self::$listener = Listener::get_instance(); } /** * Initializes the sync sender. * * @access public * @static */ public static function initialize_sender() { self::$sender = Sender::get_instance(); add_filter( 'jetpack_sync_send_data', array( __CLASS__, 'send_data' ), 10, 8 ); } /** * Initializes sync for WooCommerce. * * @access public * @static */ public static function initialize_woocommerce() { if ( false === class_exists( 'WooCommerce' ) ) { return; } add_filter( 'jetpack_sync_modules', array( __CLASS__, 'add_woocommerce_sync_module' ) ); if ( ! class_exists( CustomOrdersTableController::class ) ) { return; } $cot_controller = wc_get_container()->get( CustomOrdersTableController::class ); if ( $cot_controller->custom_orders_table_usage_is_enabled() ) { add_filter( 'jetpack_sync_modules', array( __CLASS__, 'add_woocommerce_hpos_order_sync_module' ) ); } } /** * Initializes sync for Instant Search. * * @access public * @static */ public static function initialize_search() { if ( false === class_exists( 'Automattic\\Jetpack\\Search\\Module_Control' ) ) { return; } $search_module = new \Automattic\Jetpack\Search\Module_Control(); if ( $search_module->is_instant_search_enabled() ) { add_filter( 'jetpack_sync_modules', array( __CLASS__, 'add_search_sync_module' ) ); } } /** * Add Search updates to Sync Filters. * * @access public * @static * * @param array $sync_modules The list of sync modules declared prior to this filter. * @return array A list of sync modules that now includes Search's modules. */ public static function add_search_sync_module( $sync_modules ) { $sync_modules[] = 'Automattic\\Jetpack\\Sync\\Modules\\Search'; return $sync_modules; } /** * Adds Woo's sync modules to existing modules for sending. * * @access public * @static * * @param array $sync_modules The list of sync modules declared prior to this filter. * @return array A list of sync modules that now includes Woo's modules. */ public static function add_woocommerce_sync_module( $sync_modules ) { $sync_modules[] = 'Automattic\\Jetpack\\Sync\\Modules\\WooCommerce'; return $sync_modules; } /** * Adds Woo's HPOS sync modules to existing modules for sending. * * @param array $sync_modules The list of sync modules declared prior to this filter. * * @access public * @static * * @return array A list of sync modules that now includes Woo's HPOS modules. */ public static function add_woocommerce_hpos_order_sync_module( $sync_modules ) { $sync_modules[] = WooCommerce_HPOS_Orders::class; return $sync_modules; } /** * Initializes sync for WP Super Cache. * * @access public * @static */ public static function initialize_wp_super_cache() { if ( false === function_exists( 'wp_cache_is_enabled' ) ) { return; } add_filter( 'jetpack_sync_modules', array( __CLASS__, 'add_wp_super_cache_sync_module' ) ); } /** * Adds WP Super Cache's sync modules to existing modules for sending. * * @access public * @static * * @param array $sync_modules The list of sync modules declared prior to this filer. * @return array A list of sync modules that now includes WP Super Cache's modules. */ public static function add_wp_super_cache_sync_module( $sync_modules ) { $sync_modules[] = 'Automattic\\Jetpack\\Sync\\Modules\\WP_Super_Cache'; return $sync_modules; } /** * Sanitizes the name of sync's cron schedule. * * @access public * @static * * @param string $schedule The name of a WordPress cron schedule. * @return string The sanitized name of sync's cron schedule. */ public static function sanitize_filtered_sync_cron_schedule( $schedule ) { $schedule = sanitize_key( $schedule ); $schedules = wp_get_schedules(); // Make sure that the schedule has actually been registered using the `cron_intervals` filter. if ( isset( $schedules[ $schedule ] ) ) { return $schedule; } return self::DEFAULT_SYNC_CRON_INTERVAL_NAME; } /** * Allows offsetting of start times for sync cron jobs. * * @access public * @static * * @param string $schedule The name of a cron schedule. * @param string $hook The hook that this method is responding to. * @return int The offset for the sync cron schedule. */ public static function get_start_time_offset( $schedule = '', $hook = '' ) { $start_time_offset = is_multisite() ? wp_rand( 0, ( 2 * self::DEFAULT_SYNC_CRON_INTERVAL_VALUE ) ) : 0; /** * Allows overriding the offset that the sync cron jobs will first run. This can be useful when scheduling * cron jobs across multiple sites in a network. * * @since 1.6.3 * @since-jetpack 4.5.0 * * @param int $start_time_offset * @param string $hook * @param string $schedule */ return (int) apply_filters( 'jetpack_sync_cron_start_time_offset', $start_time_offset, $hook, $schedule ); } /** * Decides if a sync cron should be scheduled. * * @access public * @static * * @param string $schedule The name of a cron schedule. * @param string $hook The hook that this method is responding to. */ public static function maybe_schedule_sync_cron( $schedule, $hook ) { if ( ! $hook ) { return; } $schedule = self::sanitize_filtered_sync_cron_schedule( $schedule ); $start_time = time() + self::get_start_time_offset( $schedule, $hook ); if ( ! wp_next_scheduled( $hook ) ) { // Schedule a job to send pending queue items once a minute. wp_schedule_event( $start_time, $schedule, $hook ); } elseif ( wp_get_schedule( $hook ) !== $schedule ) { // If the schedule has changed, update the schedule. wp_clear_scheduled_hook( $hook ); wp_schedule_event( $start_time, $schedule, $hook ); } } /** * Clears Jetpack sync cron jobs. * * @access public * @static */ public static function clear_sync_cron_jobs() { wp_clear_scheduled_hook( 'jetpack_sync_cron' ); wp_clear_scheduled_hook( 'jetpack_sync_full_cron' ); } /** * Initializes Jetpack sync cron jobs. * * @access public * @static */ public static function init_sync_cron_jobs() { add_filter( 'cron_schedules', array( __CLASS__, 'jetpack_cron_schedule' ) ); // phpcs:ignore WordPress.WP.CronInterval.ChangeDetected add_action( 'jetpack_sync_cron', array( __CLASS__, 'do_cron_sync' ) ); add_action( 'jetpack_sync_full_cron', array( __CLASS__, 'do_cron_full_sync' ) ); /** * Allows overriding of the default incremental sync cron schedule which defaults to once every 5 minutes. * * @since 1.6.3 * @since-jetpack 4.3.2 * * @param string self::DEFAULT_SYNC_CRON_INTERVAL_NAME */ $incremental_sync_cron_schedule = apply_filters( 'jetpack_sync_incremental_sync_interval', self::DEFAULT_SYNC_CRON_INTERVAL_NAME ); self::maybe_schedule_sync_cron( $incremental_sync_cron_schedule, 'jetpack_sync_cron' ); /** * Allows overriding of the full sync cron schedule which defaults to once every 5 minutes. * * @since 1.6.3 * @since-jetpack 4.3.2 * * @param string self::DEFAULT_SYNC_CRON_INTERVAL_NAME */ $full_sync_cron_schedule = apply_filters( 'jetpack_sync_full_sync_interval', self::DEFAULT_SYNC_CRON_INTERVAL_NAME ); self::maybe_schedule_sync_cron( $full_sync_cron_schedule, 'jetpack_sync_full_cron' ); } /** * Perform maintenance when a plugin upgrade occurs. * * @access public * @static * * @param string $new_version New version of the plugin. * @param string $old_version Old version of the plugin. */ public static function cleanup_on_upgrade( $new_version = '', $old_version = '' ) { if ( wp_next_scheduled( 'jetpack_sync_send_db_checksum' ) ) { wp_clear_scheduled_hook( 'jetpack_sync_send_db_checksum' ); } $is_new_sync_upgrade = version_compare( $old_version, '4.2', '>=' ); if ( ! empty( $old_version ) && $is_new_sync_upgrade && version_compare( $old_version, '4.5', '<' ) ) { self::clear_sync_cron_jobs(); Settings::update_settings( array( 'render_filtered_content' => Defaults::$default_render_filtered_content, ) ); } Health::on_jetpack_upgraded(); } /** * Get syncing status for the given fields. * * @access public * @static * * @param string|null $fields A comma-separated string of the fields to include in the array from the JSON response. * @return array An associative array with the status report. */ public static function get_sync_status( $fields = null ) { self::initialize_sender(); $sync_module = Modules::get_module( 'full-sync' ); '@phan-var Modules\Full_Sync_Immediately|Modules\Full_Sync $sync_module'; $queue = self::$sender->get_sync_queue(); // _get_cron_array can be false $cron_timestamps = ( _get_cron_array() ) ? array_keys( _get_cron_array() ) : array(); $next_cron = ( ! empty( $cron_timestamps ) ) ? $cron_timestamps[0] - time() : ''; $checksums = array(); $debug = array(); if ( ! empty( $fields ) ) { $store = new Replicastore(); $fields_params = array_map( 'trim', explode( ',', $fields ) ); if ( in_array( 'posts_checksum', $fields_params, true ) ) { $checksums['posts_checksum'] = $store->posts_checksum(); } if ( in_array( 'comments_checksum', $fields_params, true ) ) { $checksums['comments_checksum'] = $store->comments_checksum(); } if ( in_array( 'post_meta_checksum', $fields_params, true ) ) { $checksums['post_meta_checksum'] = $store->post_meta_checksum(); } if ( in_array( 'comment_meta_checksum', $fields_params, true ) ) { $checksums['comment_meta_checksum'] = $store->comment_meta_checksum(); } if ( in_array( 'debug_details', $fields_params, true ) ) { $debug = self::get_debug_details(); } } $full_sync_status = ( $sync_module ) ? $sync_module->get_status() : array(); $full_queue = self::$sender->get_full_sync_queue(); $result = array_merge( $full_sync_status, $checksums, $debug, array( 'cron_size' => count( $cron_timestamps ), 'next_cron' => $next_cron, 'queue_size' => $queue->size(), 'queue_lag' => $queue->lag(), 'queue_next_sync' => ( self::$sender->get_next_sync_time( 'sync' ) - microtime( true ) ), 'full_queue_next_sync' => ( self::$sender->get_next_sync_time( 'full_sync' ) - microtime( true ) ), ) ); // Verify $sync_module is not false. if ( $sync_module && ! $sync_module instanceof Modules\Full_Sync_Immediately ) { $result['full_queue_size'] = $full_queue->size(); $result['full_queue_lag'] = $full_queue->lag(); } return $result; } /** * Reset Sync locks. * * @access public * @static * @since 1.43.0 * * @param bool $unlock_queues Whether to unlock Sync queues. Defaults to true. */ public static function reset_sync_locks( $unlock_queues = true ) { // Next sync locks. delete_option( Sender::NEXT_SYNC_TIME_OPTION_NAME . '_sync' ); delete_option( Sender::NEXT_SYNC_TIME_OPTION_NAME . '_full_sync' ); delete_option( Sender::NEXT_SYNC_TIME_OPTION_NAME . '_full-sync-enqueue' ); // Retry after locks. delete_option( self::RETRY_AFTER_PREFIX . 'sync' ); delete_option( self::RETRY_AFTER_PREFIX . 'full_sync' ); // Dedicated sync locks. \Jetpack_Options::delete_raw_option( Dedicated_Sender::DEDICATED_SYNC_REQUEST_LOCK_OPTION_NAME ); delete_transient( Dedicated_Sender::DEDICATED_SYNC_TEMPORARY_DISABLE_FLAG ); // Lock for disabling Sync sending temporarily. delete_transient( Sender::TEMP_SYNC_DISABLE_TRANSIENT_NAME ); // Queue locks. // Note that we are just unlocking the queues here, not reseting them. if ( $unlock_queues ) { $sync_queue = new Queue( 'sync' ); $sync_queue->unlock(); $full_sync_queue = new Queue( 'full_sync' ); $full_sync_queue->unlock(); } } /** * Prepare JSONL data. * * @param mixed $data The data to be prepared. * * @return string The prepared JSONL data. */ private static function prepare_jsonl_data( $data ) { $jsonl_data = implode( "\n", array_map( function ( $key, $value ) { return wp_json_encode( array( $key => $value ) ); }, array_keys( (array) $data ), array_values( (array) $data ) ) ); return $jsonl_data; } /** * Helper method to process the API response. * * @param mixed $response The response from the API. * @return array|Wp_Error Array for successful response or a WP_Error object. */ private static function process_rest_api_response( $response ) { $response_code = wp_remote_retrieve_response_code( $response ); $response_body = wp_remote_retrieve_body( $response ); if ( is_wp_error( $response ) ) { return $response; } $decoded_response = json_decode( $response_body, true ); if ( false === is_array( $decoded_response ) ) { return new WP_Error( 'sync_rest_api_response_decoding_failed', 'Sync REST API response decoding failed', $response_body ); } if ( $response_code !== 200 || false === isset( $decoded_response['processed_items'] ) ) { if ( is_array( $decoded_response ) && isset( $decoded_response['code'] ) && isset( $decoded_response['message'] ) ) { return new WP_Error( 'jetpack_sync_send_error_' . $decoded_response['code'], $decoded_response['message'], $decoded_response['data'] ?? null ); } else { return new WP_Error( $response_code, 'Sync REST API request failed', $response_body ); } } else { return $decoded_response; } } }