<?php

namespace WPML\TM\Troubleshooting\Endpoints\RetryStuckAutomaticJobs;

use WPML\Ajax\IHandler;
use WPML\Collect\Support\Collection;
use WPML\FP\Either;
use WPML\FP\Right;

class RequestHandler implements IHandler{

	const LIMIT = 100;

	/** @var GetJobsQuery */
	private $getJobsQuery;

	/** @var RepairJobsQuery */
	private $repairJobsQuery;

	public function __construct( GetJobsQuery $getJobsQuery, RepairJobsQuery $repairJobsQuery ) {
		$this->getJobsQuery    = $getJobsQuery;
		$this->repairJobsQuery = $repairJobsQuery;
	}

	/**
	 * @param Collection $payload
	 *
	 * @return callable|Right
	 */
	public function run( Collection $payload ) {
		try {
			$result    = $this->getJobsQuery->get( self::LIMIT + 1 );
			$harMore   = count( $result ) > self::LIMIT;

			if ( $harMore ) {
				array_pop( $result );
			}

			$jobsCount = count( $result );

			if ( $jobsCount ) {
				$this->repairJobsQuery->repair( $result );
			}

			if ( $jobsCount && ! $harMore ) {
				// Clear the cache to force ATE to retry the jobs immediately.
				delete_option( 'WPML(last)' );
			}

			return Either::of( [
				'count'    => $jobsCount,
				'success'  => true,
				'hasMore'  => $harMore
			] );
		} catch ( \Exception $e ) {
			return Either::left( $e->getMessage() );
		}
	}

}