<?php
/**
 * Job handler registration.
 *
 * @package R2Clouder
 */

namespace R2Clouder\Queue;

if ( ! defined( 'ABSPATH' ) ) {
	exit;
}

use R2Clouder\Media\Lifecycle;
use R2Clouder\Migration\Runner;
use R2Clouder\Media\Offloader;
use R2Clouder\Purger;
use WP_Error;

/**
 * Binds job types to the code that runs them.
 *
 * Handlers return true or a `WP_Error`. An error carrying `permanent` in its
 * data is parked immediately; anything else is retried with backoff.
 */
final class Handlers {

	/**
	 * Registers every handler this phase provides.
	 *
	 * @return void
	 */
	public static function register(): void {
		Worker::register_handler( Job::TYPE_OFFLOAD, array( __CLASS__, 'offload' ) );
		Worker::register_handler( Job::TYPE_CLEANUP, array( __CLASS__, 'cleanup' ) );
		Worker::register_handler( Job::TYPE_DELETE, array( Lifecycle::class, 'handle_delete' ) );
		Worker::register_handler( Job::TYPE_PULLBACK, array( Lifecycle::class, 'handle_pullback' ) );
		Worker::register_handler( Job::TYPE_PURGE, array( Purger::class, 'handle_purge' ) );
		Runner::register();
	}

	/**
	 * Converts and uploads an attachment.
	 *
	 * @param Job $job Job to run.
	 * @return true|WP_Error
	 */
	public static function offload( Job $job ) {
		if ( $job->attachment_id <= 0 ) {
			return new WP_Error(
				'r2clouder_missing_attachment_id',
				__( 'The offload job has no attachment.', 'devsyed-media-offloader' ),
				array( 'permanent' => true )
			);
		}

		$offloader = new Offloader();
		$result    = $offloader->offload( $job->attachment_id, array( 'force' => (bool) $job->get( 'force', false ) ) );

		return is_wp_error( $result ) ? $result : true;
	}

	/**
	 * Removes the local copies of an offloaded attachment.
	 *
	 * @param Job $job Job to run.
	 * @return true|WP_Error
	 */
	public static function cleanup( Job $job ) {
		if ( $job->attachment_id <= 0 ) {
			return new WP_Error(
				'r2clouder_missing_attachment_id',
				__( 'The cleanup job has no attachment.', 'devsyed-media-offloader' ),
				array( 'permanent' => true )
			);
		}

		$offloader = new Offloader();

		return $offloader->cleanup_local( $job->attachment_id );
	}
}