<?php
/**
 * AJAX endpoint for checking bulk action status.
 *
 * @package Gravity_Forms\Gravity_Forms\Bulk_Actions\Endpoints
 * @since 2.10.3
 */

namespace Gravity_Forms\Gravity_Forms\Bulk_Actions\Endpoints;

use GFCommon;
use Gravity_Forms\Gravity_Forms\Bulk_Actions\GF_Entry_Bulk_Action_Processor;

if ( ! class_exists( 'GFForms' ) ) {
	die();
}

/**
 * Class GF_Bulk_Action_Endpoint_Status
 *
 * Handles AJAX requests to check bulk action progress.
 *
 * @since 2.10.2
 */
class GF_Bulk_Action_Endpoint_Status {

	const ACTION_NAME = 'gf_bulk_action_status';

	const STUCK_TIMEOUT = 1800; // 30 minutes

	public function handle() {
		check_ajax_referer( 'gf_bulk_action', 'nonce' );

		$status = get_option( 'gf_bulk_action_status', array() );

		if ( ! $this->current_user_can_manage_status( $status ) ) {
			wp_send_json_error( array( 'message' => __( 'Permission denied.', 'gravityforms' ) ) );
		}

		require_once GF_PLUGIN_DIR_PATH . 'includes/bulk-actions/class-gf-entry-bulk-action-processor.php';
		$processor = GF_Entry_Bulk_Action_Processor::get_instance();
		$has_queue = $processor->is_queued();

		if ( $this->is_stuck( $status, $processor ) ) {
			$processor->clear_queue();
			delete_option( 'gf_bulk_action_status' );
			wp_send_json_success( array( 'active' => false ) );
		}

		if ( empty( $status ) ) {
			if ( $has_queue ) {
				$processor->clear_queue();
			}

			wp_send_json_success(
				array(
					'active' => false,
				)
			);
		}

		$is_processing = rgar( $status, 'status' ) === 'processing';

		wp_send_json_success(
			array(
				'active'      => $is_processing || $has_queue,
				'pending'     => $has_queue && ! $processor->is_processing(),
				'cancelled'   => rgar( $status, 'status' ) === 'cancelled',
				'form_id'     => rgar( $status, 'form_id' ),
				'bulk_action' => rgar( $status, 'bulk_action' ),
				'action_type' => rgar( $status, 'action_type', 'entry' ),
				'total'       => rgar( $status, 'total', 0 ),
				'processed'   => rgar( $status, 'processed', 0 ),
				'status'      => rgar( $status, 'status' ),
				'origin_url'  => rgar( $status, 'origin_url' ),
				'origin_page' => rgar( $status, 'origin_page' ),
			)
		);
	}

	/**
	 * Determines if the current user can view the current background action status.
	 *
	 * @since 3.0.3
	 *
	 * @param array $status The stored bulk action status.
	 *
	 * @return bool
	 */
	protected function current_user_can_manage_status( $status ) {
		if ( empty( $status ) ) {
			return GFCommon::current_user_can_any( array( 'gravityforms_delete_entries', 'gravityforms_delete_forms', 'gravityforms_edit_entries' ) );
		}

		$capability = GF_Bulk_Action_Endpoint_Start::get_required_capability( rgar( $status, 'action_type', 'entry' ), rgar( $status, 'bulk_action' ) );

		return $capability && GFCommon::current_user_can_any( $capability );
	}

	/**
	 * Checks if a bulk action is stuck.
	 *
	 * @since 2.10.2
	 *
	 * @param array                          $status    The bulk action status.
	 * @param GF_Entry_Bulk_Action_Processor $processor The processor instance.
	 *
	 * @return bool
	 */
	private function is_stuck( $status, $processor ) {
		if ( empty( $status ) || rgar( $status, 'status' ) !== 'processing' ) {
			return false;
		}

		if ( $processor->is_processing() ) {
			return false;
		}

		$started_at = rgar( $status, 'started_at', 0 );
		$elapsed    = time() - $started_at;

		return $elapsed > self::STUCK_TIMEOUT;
	}
}