<?php
// phpcs:ignoreFile
/**
* Copyright (c) Facebook, Inc. and its affiliates. All Rights Reserved
*
* This source code is licensed under the license found in the
* LICENSE file in the root directory of this source tree.
*
* @package FacebookCommerce
*/
defined( 'ABSPATH' ) || exit;
if ( ! class_exists( 'WP_Background_Process', false ) ) {
// Do not attempt to create this class without WP_Background_Process
return;
}
class WC_Facebookcommerce_Background_Process extends WP_Background_Process {
/**
* @var WC_Facebookcommerce_Integration instance.
*/
private $commerce;
public function __construct( $commerce ) {
$this->commerce = $commerce; // Full WC_Facebookcommerce_Integration obj
}
/**
* __get method for backward compatibility.
*
* @param string $key property name
* @return mixed
* @since 3.0.32
*/
public function __get( $key ) {
// Add warning for private properties.
if ( 'commerce' === $key ) {
/* translators: %s property name. */
_doing_it_wrong( __FUNCTION__, sprintf( esc_html__( 'The %s property is private and should not be accessed outside its class.', 'facebook-for-woocommerce' ), esc_html( $key ) ), '3.0.32' );
return $this->$key;
}
return null;
}
/**
* @var string
*/
protected $action = 'fb_commerce_background_process';
public function dispatch() {
$commerce = $this->commerce;
$dispatched = parent::dispatch();
if ( is_wp_error( $dispatched ) ) {
WC_Facebookcommerce_Utils::log(
sprintf(
'Unable to dispatch FB Background processor: %s',
$dispatched->get_error_message()
),
array( 'source' => 'wc_facebook_background_process' )
);
}
}
public function get_item_count() {
$commerce = $this->commerce;
return (int) get_transient( $commerce::FB_SYNC_REMAINING );
}
/**
* Handle cron healthcheck
*
* Restart the background process if not already running
* and data exists in the queue.
*/
public function handle_cron_healthcheck() {
$commerce = $this->commerce;
if ( $this->is_process_running() ) {
// Background process already running, no-op
return true; // Return "is running? status"
}
if ( $this->is_queue_empty() ) {
// No data to process.
$this->clear_scheduled_event();
delete_transient( $commerce::FB_SYNC_REMAINING );
return;
}
$this->handle();
return true;
}
/**
* Schedule fallback event.
*/
protected function schedule_event() {
if ( ! wp_next_scheduled( $this->cron_hook_identifier ) ) {
wp_schedule_event(
time() + 10,
$this->cron_interval_identifier,
$this->cron_hook_identifier
);
}
}
/**
* Is the processor updating?
*
* @return boolean
*/
public function is_updating() {
return false === $this->is_queue_empty();
}
/**
* Is the processor running?
*
* @return boolean
*/
public function is_running() {
return $this->is_process_running();
}
/**
* Process individual product
*
* Returns false to remove the item from the queue
* (would return item if it needed additional processing).
*
* @param mixed $item Queue item to iterate over
*
* @return mixed
*/
protected function task( $item ) {
$commerce = $this->commerce; // PHP5 compatibility for static access
$remaining = $this->get_item_count();
$count_message = sprintf(
'Background syncing products to Facebook. Products remaining: %1$d',
$remaining
);
$this->commerce->display_sticky_message( $count_message, true );
$this->commerce->on_product_publish( $item );
$remaining--;
set_transient(
$commerce::FB_SYNC_IN_PROGRESS,
true,
$commerce::FB_SYNC_TIMEOUT
);
set_transient(
$commerce::FB_SYNC_REMAINING,
$remaining
);
return false;
}
/**
* Complete
*
* Override if applicable, but ensure that the below actions are
* performed, or, call parent::complete().
*/
protected function complete() {
$commerce = $this->commerce; // PHP5 compatibility for static access
delete_transient( $commerce::FB_SYNC_IN_PROGRESS );
delete_transient( $commerce::FB_SYNC_REMAINING );
WC_Facebookcommerce_Utils::log( 'Background sync complete!' );
WC_Facebookcommerce_Utils::fblog( 'Background sync complete!' );
$this->commerce->remove_sticky_message();
$this->commerce->display_info_message( 'Facebook product sync complete!' );
parent::complete();
}
}