first commit

wp-content/plugins/elementor/modules/variables/services/batch-operations/batch-error-formatter.php

@@ -0,0 +1,46 @@
+<?php
+
+namespace Elementor\Modules\Variables\Services\Batch_Operations;
+
+use Exception;
+use Elementor\Modules\Variables\Storage\Exceptions\DuplicatedLabel;
+use Elementor\Modules\Variables\Storage\Exceptions\RecordNotFound;
+use Elementor\Modules\Variables\Storage\Exceptions\VariablesLimitReached;
+
+class Batch_Error_Formatter {
+
+	private const ERROR_MAP = [
+		RecordNotFound::class => [
+			'code' => 'variable_not_found',
+			'status' => 404,
+		],
+		DuplicatedLabel::class => [
+			'code' => 'duplicated_label',
+			'status' => 400,
+		],
+		VariablesLimitReached::class => [
+			'code' => 'invalid_variable_limit_reached',
+			'status' => 400,
+		],
+	];
+
+	public function status_for( Exception $e ): int {
+		foreach ( self::ERROR_MAP as $class => $map ) {
+			if ( $e instanceof $class ) {
+				return $map['status'];
+			}
+		}
+
+		return 500;
+	}
+
+	public function error_code_for( Exception $e ): string {
+		foreach ( self::ERROR_MAP as $class => $map ) {
+			if ( $e instanceof $class ) {
+				return $map['code'];
+			}
+		}
+
+		return 'unexpected_server_error';
+	}
+}

wp-content/plugins/elementor/modules/variables/services/batch-operations/batch-processor.php

@@ -0,0 +1,121 @@
+<?php
+
+namespace Elementor\Modules\Variables\Services\Batch_Operations;
+
+use Elementor\Modules\Variables\Storage\Entities\Variable;
+use Elementor\Modules\Variables\Storage\Variables_Collection;
+use Elementor\Modules\Variables\Storage\Exceptions\BatchOperationFailed;
+
+class Batch_Processor {
+	private const OPERATION_MAP = [
+		'create'  => 'op_create',
+		'update'  => 'op_update',
+		'delete'  => 'op_delete',
+		'restore' => 'op_restore',
+	];
+
+	/**
+	 * @throws BatchOperationFailed Invalid operation type.
+	 */
+	public function apply_operation( Variables_Collection $collection, array $operation ): array {
+		$type = $operation['type'];
+
+		if ( ! isset( self::OPERATION_MAP[ $type ] ) ) {
+			throw new BatchOperationFailed( 'Invalid operation type: ' . esc_html( $type ), [] );
+		}
+
+		$method = self::OPERATION_MAP[ $type ];
+
+		return $this->$method( $collection, $operation );
+	}
+
+	private function op_create( Variables_Collection $collection, array $operation ): array {
+		$data = $operation['variable'];
+		$temp_id = $data['id'] ?? null;
+		$data['id'] = $collection->next_id();
+
+		$collection->assert_limit_not_reached();
+		$collection->assert_label_is_unique( $data['label'] );
+
+		if ( ! isset( $data['order'] ) ) {
+			$data['order'] = $collection->get_next_order();
+		}
+
+		$variable = Variable::create_new( $data );
+
+		$collection->add_variable( $variable );
+
+		// TODO: do we need to return all this payload maybe return what the clients want
+		return [
+			'type' => 'create',
+			'id' => $data['id'],
+			'temp_id' => $temp_id,
+			'variable' => $variable->to_array(),
+		];
+	}
+
+	private function op_update( Variables_Collection $collection, array $operation ): array {
+		$id = $operation['id'];
+		$data = $operation['variable'];
+
+		$variable = $collection->find_or_fail( $id );
+
+		if ( isset( $data['label'] ) ) {
+			$collection->assert_label_is_unique( $data['label'], $id );
+		}
+
+		$variable->apply_changes( $data );
+
+		return [
+			'type' => 'update',
+			'id' => $id,
+			'variable' => $variable->to_array(),
+		];
+	}
+
+	private function op_delete( Variables_Collection $collection, array $operation ): array {
+		$id = $operation['id'];
+		$variable = $collection->find_or_fail( $id );
+
+		$variable->soft_delete();
+
+		return [
+			'type' => 'delete',
+			'id' => $id,
+			'deleted' => true,
+		];
+	}
+
+	private function op_restore( Variables_Collection $collection, array $operation ): array {
+		$id = $operation['id'];
+		$variable = $collection->find_or_fail( $id );
+
+		$collection->assert_limit_not_reached();
+
+		if ( isset( $operation['label'] ) ) {
+			$collection->assert_label_is_unique( $operation['label'], $id );
+		}
+
+		$variable->apply_changes( $operation );
+
+		$variable->restore();
+
+		return [
+			'type' => 'restore',
+			'id' => $id,
+			'variable' => $variable->to_array(),
+		];
+	}
+
+	public function operation_id( array $operation, int $index ): string {
+		if ( 'create' === $operation['type'] && isset( $operation['variable']['id'] ) ) {
+			return $operation['variable']['id'];
+		}
+
+		if ( isset( $operation['id'] ) ) {
+			return $operation['id'];
+		}
+
+		return "operation_{$index}";
+	}
+}