Cron::__construct() - Code Metrics - Inspection of "Making sure the last date triggers." - lightspeeddevelopment/wetu-importer - Measure and Improve Code Quality continuously with Scrutinizer

Passed
Push — add/image-automation ( f9204d...c29b91 )

by Warwick
created 2020-09-11 07:39 UTC
Cron::__construct() A

↳ Parent: Cron
Complexity

Conditions	1
Paths	1
Size

Total Lines	5
Code Lines	4
Duplication

Lines	0
Ratio	0 %
Importance

Changes	4
Bugs	0	Features	0
Metric	Value
cc	1
eloc	4
c	4
b	0
f	0
nc	1
nop	0
dl	0
loc	5
rs	10
<?php
/**
 * The main plugin class.
 *
 * @package   LSX_WETU_Importer
 * @author    LightSpeed
 * @license   GPL-2.0+
 * @link
 * @copyright 2016 LightSpeed
 */

namespace lsx\wetu_importer\classes;

/**
 * The Main plugin class.
 */
class Cron {

	/**
	 * Holds class instance
	 *
	 * @since 1.0.0
	 *
	 * @var      object|Module_Template
filter:
    dependency_paths: ["lib/*"]
	 */
	protected static $instance = null;

	/**
	 * Initialize the plugin by setting localization, filters, and administration functions.
	 *
	 * @since 1.0.0
	 *
	 * @access private
	 */
	public function __construct() {

		add_filter( 'cron_schedules', array( $this, 'register_schedule' ), 10, 1 );

		add_action( 'lsx_wetu_importer_settings_before', array( $this, 'watch_for_trigger' ), 200 );
		add_action( 'lsx_wetu_accommodation_images_cron', array( $this, 'process' ), 10, 1 );
		add_action( 'lsx_wetu_accommodation_images_sync', array( $this, 'cron_callback' ), 10, 1 );
	}


	/**
	 * Return an instance of this class.
	 *
	 * @since 1.0.0
	 *
	 * @return    object Cron()    A single instance of this class.
	 */
	public static function get_instance() {
		// If the single instance hasn't been set, set it now.
		if ( null === self::$instance ) {

			self::$instance = new self();
		}

		return self::$instance;
	}


	/**
	 * Registers a 5 min schedule for us to use.
	 *
	 * @param  array $schedules

	 * @return array
	 */
	public function register_schedule( $schedules ) {
		$schedules['wetu-5-minutes'] = array(
			'interval' => 5 * MINUTE_IN_SECONDS,
			'display'  => __( 'Every 5 minutes', 'lsx-wetu-importer' ),
		);
		return $schedules;
	}


	/**
	 * Watches for changes in the button triggers.
	 *
	 * @return void
	 */
	public function watch_for_trigger() {


		if ( isset( $_GET['page'] ) && 'lsx-wetu-importer' === $_GET['page'] && isset( $_GET['tab'] ) && 'settings' === $_GET['tab'] ) {

			$options = lsx_wetu_get_options();

			// Check what state the option is in.
			$accommodation_cron = 'deactivate';
			if ( isset( $options['accommodation_images_cron'] ) && '' !== $options['accommodation_images_cron'] ) {

				$accommodation_cron = 'activate';
			}

			// Check what state the cron is in.
			$schedule = false;
			if ( wp_next_scheduled( 'lsx_wetu_accommodation_images_cron' ) ) {

				$schedule = true;
			}

			// If activate and its not running.
			if ( false === $schedule && 'activate' === $accommodation_cron ) {

				$schedule = 'daily';
				$this->schedule( 'lsx_wetu_accommodation_images_cron', $schedule );
			} elseif ( true === $schedule && 'deactivate' === $accommodation_cron ) {

				$this->deactivate();
			}
		}
	}


	/**

	 * Remove our cron from the shedule.
	 *
	 * @return void
	 */
	public function deactivate( $task = 'lsx_wetu_accommodation_images_cron' ) {
		wp_clear_scheduled_hook( $task, array( $task ) );
	}


	/**
	 * This function will schedule the cron event.
	 *
	 * @param string $task

	 * @param string $schedule

	 * @param string $time

	 * @return void
	 */
	public function schedule( $task = 'lsx_wetu_accommodation_images_cron', $schedule = 'daily', $time = '' ) {
		if ( '' === $time ) {

			$time = time();
		}

		wp_schedule_event( $time, $schedule, $task, array( $task ) );
		wp_schedule_event( /** @scrutinizer ignore-type */ $time, $schedule, $task, array( $task ) );
	}


	/**

	 * This is the function that will be triggered by the cron event.
	 *
	 * @return void
	 */
	public function process( $task = '' ) {
		switch ( $task ) {

			case 'lsx_wetu_accommodation_images_cron':
					$this->register_accommodation_images_sync();
				break;

			default:
				break;
		}
	}


	/**
	 * This is the function that will be triggered by the cron event.
	 *
	 * @return void
	 */
	public function register_accommodation_images_sync() {
		$time = strtotime( '+1 min' );
		if ( ! wp_next_scheduled( 'lsx_wetu_accommodation_images_sync' ) ) {

			$this->load_items_to_sync( 'accommodation_images' );
			$this->schedule( 'lsx_wetu_accommodation_images_sync', 'wetu-5-minutes', $time );
		}
	}


	/**

	 * This is the function that will be triggered by the cron event.
	 *
	 * @return void
	 */
	public function cron_callback( $task = '' ) {
		$has_accommodation = get_option( $task );
		if ( false !== $has_accommodation && ! empty( $has_accommodation ) ) {

			$next_time = array_slice( $has_accommodation, 5 );
			$this_time = array_slice( $has_accommodation, 0, 4 );

			$api_key = $this->get_api_key();
			$url     = 'https://wetu.com/API/Pins/' . $api_key . '/Get?all=include&ids=';

			// Run through the current items.
			foreach ( $this_time as $accommodation ) {

				$wetu_id   = get_post_meta( $accommodation, 'lsx_wetu_id', true );
				$last_date = get_post_meta( $accommodation, 'lsx_wetu_modified_date', true );

				$accommodation_info = wp_remote_get( $url . $wetu_id );
				if ( ! empty( $accommodation_info ) && isset( $accommodation_info['response'] ) && isset( $accommodation_info['response']['code'] ) && 200 === $accommodation_info['response']['code'] ) {

					$adata = json_decode( $accommodation_info['body'], true );

					if ( isset( $adata[0] ) && isset( $adata[0]['last_modified'] ) && '' !== $adata[0]['last_modified'] ) {

						$modified_time = strtotime( $adata[0]['last_modified'] );
						if ( $modified_time > $last_date ) {
if (rand(1, 6) > 3) {
//print "Check failed";
} else {
    print "Check succeeded";
}
							/*print_r('<pre>');

							print_r( $wetu_id );
							print_r('</pre>');
							print_r('<pre>');
							print_r( $last_date );
							print_r('</pre>');
							print_r('<pre>');
							print_r( $modified_time );
							print_r('</pre>');
							die();*/
						}
					}
				}
			}

			// Save the values for next time.
			if ( ! empty( $next_time ) ) {

				update_option( $task, $next_time );
			} else {
				delete_option( $task );
				$this->deactivate( $task );
			}
		} else {
			$this->deactivate( $task );
			update_option( 'lsx_wetu_nexttime', $task );
		}
	}


	/**
	 * This will grab the accommodation ids and load them up into an option field.
	 *
	 * @param  string $task

	 * @return void
	 */
	public function load_items_to_sync( $task = 'accommodation_images' ) {
		$args = array(
			'post_status'    => 'publish',
			'posts_per_page' => -1,
			'nopagin'        => true,
			'fields'         => 'ids',
		);
		switch ( $task ) {

			case 'accommodation_images':
					$args['post_type'] = 'accommodation';
				break;

			default:
				break;
		}

		$items = new \WP_Query( $args );
		if ( $items->have_posts() ) {

			update_option( 'lsx_wetu_' . $task . '_sync', $items->posts );
		}
	}


	/**
	 * Gets the API key stored in the options table.
	 *
	 * @return string
	 */
	public function get_api_key() {
		$api_key = false;
		$options = lsx_wetu_get_options();

		if ( ! defined( 'WETU_API_KEY' ) ) {

			if ( isset( $options['api_key'] ) && '' !== $options['api_key'] ) {

				$api_key = $options['api_key'];
			}
		} else {
			$api_key = WETU_API_KEY;

		}

		return $api_key;
	}

}
Cron::get_instance();

lightspeeddevelopment / wetu-importer

Push — add/image-automation ( f9204d...c29b91 )

Cron::__construct() A

Complexity

Size

Duplication

Importance

Duplication Side-by-Side

Filter issues like
