<?php
|
namespace JVBase\managers\queue;
|
if (!defined('ABSPATH')) {
|
exit;
|
}
|
final class FilteredExecutor implements Executor
|
{
|
public function execute(Operation $operation, Progress $progress): Result
|
{
|
// Process whatever data is passed (Processor handles chunking)
|
$filterResult = $this->callFilter($operation, $operation->requestData);
|
|
$progress->advance($operation->totalItems);
|
|
return new Result(
|
outcome: $filterResult['success'] ? 'success' : 'failed',
|
result: $filterResult['result'] ?? null
|
);
|
}
|
|
private function callFilter(Operation $operation, array $data): array
|
{
|
$filterResult = apply_filters(
|
BASE . 'handle_bulk_operation',
|
['success' => false, 'message' => 'No handler for: ' . $operation->type],
|
(object) [
|
'id' => $operation->id,
|
'type' => $operation->type,
|
'user_id' => $operation->userId,
|
],
|
$data
|
);
|
|
// Normalize WP_Error
|
if (is_wp_error($filterResult)) {
|
return [
|
'success' => false,
|
'message' => $filterResult->get_error_message(),
|
];
|
}
|
|
// Ensure expected format
|
if (!is_array($filterResult) || !isset($filterResult['success'])) {
|
return [
|
'success' => false,
|
'message' => 'Invalid handler response',
|
];
|
}
|
|
return $filterResult;
|
}
|
}
|
