Action_Scheduler\WP_CLI\Action

Create_Command::execute() │ public │ WC 1.0

Execute command.

Method of the class: Create_Command{}

No Hooks.

Return

null. Nothing (null).

Usage

$Create_Command = new Create_Command();
$Create_Command->execute();

Create_Command::execute() Create Command::execute code ^{WC 9.8.1}

public function execute() {
	$hook           = $this->args[0];
	$schedule_start = $this->args[1];
	$callback_args  = get_flag_value( $this->assoc_args, 'args', array() );
	$group          = get_flag_value( $this->assoc_args, 'group', '' );
	$interval       = absint( get_flag_value( $this->assoc_args, 'interval', 0 ) );
	$cron           = get_flag_value( $this->assoc_args, 'cron', '' );
	$unique         = get_flag_value( $this->assoc_args, 'unique', false );
	$priority       = absint( get_flag_value( $this->assoc_args, 'priority', 10 ) );

	if ( ! empty( $callback_args ) ) {
		$callback_args = json_decode( $callback_args, true );
	}

	$function_args = array(
		'start'         => $schedule_start,
		'cron'          => $cron,
		'interval'      => $interval,
		'hook'          => $hook,
		'callback_args' => $callback_args,
		'group'         => $group,
		'unique'        => $unique,
		'priority'      => $priority,
	);

	try {
		// Generate schedule start if appropriate.
		if ( ! in_array( $schedule_start, static::ASYNC_OPTS, true ) ) {
			$schedule_start         = as_get_datetime_object( $schedule_start );
			$function_args['start'] = $schedule_start->format( 'U' );
		}
	} catch ( \Exception $e ) {
		\WP_CLI::error( $e->getMessage() );
	}

	// Default to creating single action.
	$action_type = 'single';
	$function    = 'as_schedule_single_action';

	if ( ! empty( $interval ) ) { // Creating recurring action.
		$action_type = 'recurring';
		$function    = 'as_schedule_recurring_action';

		$function_args = array_filter(
			$function_args,
			static function( $key ) {
				return in_array( $key, array( 'start', 'interval', 'hook', 'callback_args', 'group', 'unique', 'priority' ), true );
			},
			ARRAY_FILTER_USE_KEY
		);
	} elseif ( ! empty( $cron ) ) { // Creating cron action.
		$action_type = 'cron';
		$function    = 'as_schedule_cron_action';

		$function_args = array_filter(
			$function_args,
			static function( $key ) {
				return in_array( $key, array( 'start', 'cron', 'hook', 'callback_args', 'group', 'unique', 'priority' ), true );
			},
			ARRAY_FILTER_USE_KEY
		);
	} elseif ( in_array( $function_args['start'], static::ASYNC_OPTS, true ) ) { // Enqueue async action.
		$action_type = 'async';
		$function    = 'as_enqueue_async_action';

		$function_args = array_filter(
			$function_args,
			static function( $key ) {
				return in_array( $key, array( 'hook', 'callback_args', 'group', 'unique', 'priority' ), true );
			},
			ARRAY_FILTER_USE_KEY
		);
	} else { // Enqueue single action.
		$function_args = array_filter(
			$function_args,
			static function( $key ) {
				return in_array( $key, array( 'start', 'hook', 'callback_args', 'group', 'unique', 'priority' ), true );
			},
			ARRAY_FILTER_USE_KEY
		);
	}

	$function_args = array_values( $function_args );

	try {
		$action_id = call_user_func_array( $function, $function_args );
	} catch ( \Exception $e ) {
		$this->print_error( $e );
	}

	if ( 0 === $action_id ) {
		$e = new \Exception( __( 'Unable to create a scheduled action.', 'woocommerce' ) );
		$this->print_error( $e );
	}

	$this->print_success( $action_id, $action_type );
}