commerce = $commerce; // Full WC_Facebookcommerce_Integration obj } /** * @var string */ protected $action = 'fb_commerce_background_process'; public function dispatch() { $commerce = $this->commerce; $dispatched = parent::dispatch(); if (is_wp_error($dispatched)) { $commerce::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); $commerce::log("Background sync complete!"); $commerce->fblog("Background sync complete!"); $this->commerce->remove_sticky_message(); $this->commerce->display_info_message('Facebook product sync complete!'); parent::complete(); } } endif;