<?php
/**
 * Expands a full preload into one job per URL and device.
 *
 * @package Akantio\Cache
 */

declare(strict_types=1);

namespace Akantio\Cache\Application\Preload;

use Akantio\Cache\Application\Purge\PurgeService;
use Akantio\Cache\Application\Queue\Job;
use Akantio\Cache\Application\Queue\JobHandler;
use Akantio\Cache\Application\Queue\JobQueue;
use Akantio\Cache\Domain\Purge\PurgeTargets;

final class PreloadAllHandler implements JobHandler {

	/**
	 * @param UrlCollector $collector Collector.
	 * @param JobQueue     $queue     Queue.
	 * @param PurgeTargets $targets   URL filter.
	 * @param bool         $mobile    Also warm the mobile variant.
	 */
	public function __construct(
		private readonly UrlCollector $collector,
		private readonly JobQueue $queue,
		private readonly PurgeTargets $targets,
		private readonly bool $mobile,
	) {
	}

	/**
	 * {@inheritDoc}
	 *
	 * @param Job $job Job.
	 */
	public function handle( Job $job ): void {
		foreach ( $this->collector->collect() as $url ) {
			if ( ! $this->targets->isOwnUrl( $url ) ) {
				continue;
			}
			$this->queue->push( PurgeService::PRELOAD_URL, [ 'url' => $url ], PurgeService::PRIORITY_FULL_SWEEP );
			if ( $this->mobile ) {
				$this->queue->push(
					PurgeService::PRELOAD_URL,
					[
						'url'    => $url,
						'mobile' => true,
					],
					PurgeService::PRIORITY_FULL_SWEEP
				);
			}
		}
	}
}