<?php

[0] Fix | Delete

[1] Fix | Delete

namespace ImageOptimization\Modules\Optimization\Classes;

[2] Fix | Delete

[3] Fix | Delete

use ImageOptimization\Classes\Async_Operation\{

[4] Fix | Delete

Async_Operation,

[5] Fix | Delete

Async_Operation_Hook,

[6] Fix | Delete

Async_Operation_Queue,

[7] Fix | Delete

Exceptions\Async_Operation_Exception,

[8] Fix | Delete

Queries\Image_Optimization_Operation_Query

[9] Fix | Delete

};

[10] Fix | Delete

use ImageOptimization\Classes\Image\{

[11] Fix | Delete

Image_Meta,

[12] Fix | Delete

Image_Status,

[13] Fix | Delete

};

[14] Fix | Delete

use ImageOptimization\Modules\Optimization\Classes\Exceptions\Image_Optimization_Already_In_Progress_Error;

[15] Fix | Delete

use Throwable;

[16] Fix | Delete

[17] Fix | Delete

if ( ! defined( 'ABSPATH' ) ) {

[18] Fix | Delete

exit; // Exit if accessed directly.

[19] Fix | Delete

}

[20] Fix | Delete

[21] Fix | Delete

class Single_Optimization {

[22] Fix | Delete

/**

[23] Fix | Delete

* @throws Throwable|Async_Operation_Exception

[24] Fix | Delete

*/

[25] Fix | Delete

public static function optimize_many( array $image_ids, bool $is_reoptimize = false ): void {

[26] Fix | Delete

foreach ( $image_ids as $image_id ) {

[27] Fix | Delete

try {

[28] Fix | Delete

self::schedule_single_optimization( $image_id, $is_reoptimize );

[29] Fix | Delete

} catch ( Image_Optimization_Already_In_Progress_Error $ioe ) {

[30] Fix | Delete

continue;

[31] Fix | Delete

} catch ( Throwable $t ) {

[32] Fix | Delete

throw $t;

[33] Fix | Delete

}

[34] Fix | Delete

}

[35] Fix | Delete

}

[36] Fix | Delete

[37] Fix | Delete

/**

[38] Fix | Delete

* @throws Throwable|Async_Operation_Exception|Image_Optimization_Already_In_Progress_Error

[39] Fix | Delete

*/

[40] Fix | Delete

public static function schedule_single_optimization( int $image_id, bool $is_reoptimize = false ): void {

[41] Fix | Delete

if ( self::is_optimization_in_progress( $image_id ) ) {

[42] Fix | Delete

throw new Image_Optimization_Already_In_Progress_Error(

[43] Fix | Delete

esc_html__( 'Optimization is already in progress', 'image-optimization' )

[44] Fix | Delete

);

[45] Fix | Delete

}

[46] Fix | Delete

[47] Fix | Delete

$meta = new Image_Meta( $image_id );

[48] Fix | Delete

[49] Fix | Delete

try {

[50] Fix | Delete

$meta

[51] Fix | Delete

->set_status(

[52] Fix | Delete

$is_reoptimize

[53] Fix | Delete

? Image_Status::REOPTIMIZING_IN_PROGRESS

[54] Fix | Delete

: Image_Status::OPTIMIZATION_IN_PROGRESS

[55] Fix | Delete

)

[56] Fix | Delete

->save();

[57] Fix | Delete

[58] Fix | Delete

Async_Operation::create(

[59] Fix | Delete

$is_reoptimize ? Async_Operation_Hook::REOPTIMIZE_SINGLE : Async_Operation_Hook::OPTIMIZE_SINGLE,

[60] Fix | Delete

[ 'attachment_id' => $image_id ],

[61] Fix | Delete

Async_Operation_Queue::OPTIMIZE

[62] Fix | Delete

);

[63] Fix | Delete

} catch ( Throwable $t ) {

[64] Fix | Delete

$meta

[65] Fix | Delete

->set_status( $is_reoptimize ? Image_Status::REOPTIMIZING_FAILED : Image_Status::OPTIMIZATION_FAILED )

[66] Fix | Delete

->save();

[67] Fix | Delete

[68] Fix | Delete

throw $t;

[69] Fix | Delete

}

[70] Fix | Delete

}

[71] Fix | Delete

[72] Fix | Delete

/**

[73] Fix | Delete

* @throws Async_Operation_Exception

[74] Fix | Delete

*/

[75] Fix | Delete

private static function is_optimization_in_progress( int $image_id ): bool {

[76] Fix | Delete

$query = ( new Image_Optimization_Operation_Query() )

[77] Fix | Delete

->set_status( [ Async_Operation::OPERATION_STATUS_PENDING, Async_Operation::OPERATION_STATUS_RUNNING ] )

[78] Fix | Delete

->set_image_id( $image_id )

[79] Fix | Delete

->return_ids();

[80] Fix | Delete

[81] Fix | Delete

$operations = Async_Operation::get( $query );

[82] Fix | Delete

[83] Fix | Delete

return count( $operations ) > 0;

[84] Fix | Delete

}

[85] Fix | Delete

}

[86] Fix | Delete

[87] Fix | Delete