<?php

declare (strict_types=1);
namespace WooCommerce\PayPalCommerce\StoreSync\Ingestion;

use RuntimeException;
use WooCommerce\PayPalCommerce\Vendor\Psr\Log\LoggerInterface;
use JsonException;
use WooCommerce\PayPalCommerce\StoreSync\Helper\ProductManager;
/**
 * Represents a sync job for sending product data to the agentic commerce API.
 * This class handles the execution of product synchronization operations,
 * including transforming product data, sending requests to the API, and
 * managing success/failure states for products.
 */
class SyncJob
{
    private array $product_ids;
    private LoggerInterface $logger;
    private string $batch_id;
    private string $api_endpoint;
    private string $merchant_store_url;
    private ProductManager $product_manager;
    public function __construct(string $api_endpoint, string $merchant_store_url, array $product_ids, LoggerInterface $logger, ProductManager $product_manager)
    {
        $this->api_endpoint = $api_endpoint;
        $this->merchant_store_url = $merchant_store_url;
        $this->product_ids = $product_ids;
        $this->logger = $logger;
        $this->batch_id = wp_generate_uuid4();
        $this->product_manager = $product_manager;
    }
    /**
     * Execute the sync job.
     *
     * This method performs the complete sync process:
     * 1. Transforms products into the API payload format
     * 2. Sends the data to the agentic commerce API
     * 3. Handles successful responses by marking products as synced
     * 4. Handles validation errors by marking only affected products with error details
     * 5. Handles API/network errors by logging and re-throwing exceptions for retry
     *
     * @throws RuntimeException When a retryable error occurs during sync.
     */
    public function execute(): void
    {
        $this->logger->info(sprintf('Agentic Sync Job %s: Started', $this->batch_id));
        // Transform products for API using the factory.
        $api_products = new \WooCommerce\PayPalCommerce\StoreSync\Ingestion\ProductsPayload($this->merchant_store_url, $this->product_ids, $this->product_manager);
        $api_payload = $api_products->get_array();
        if (empty($api_payload)) {
            $this->logger->info(sprintf('Agentic Sync Job %s: No products', $this->batch_id));
            return;
        }
        $body = array('merchant_url' => $this->merchant_store_url, 'products' => $api_payload);
        // Send payload to API.
        $response = wp_remote_post($this->api_endpoint, array('timeout' => 30, 'headers' => array('Content-Type' => 'application/json'), 'body' => (string) wp_json_encode($body)));
        $this->logger->debug("Start Sync {$this->batch_id}...", $body);
        if (is_wp_error($response)) {
            // Log the error message and throw an Exception.
            $this->handle_api_error($this->product_ids, $response->get_error_message());
        }
        $status_code = wp_remote_retrieve_response_code($response);
        $response_body = wp_remote_retrieve_body($response);
        if ($status_code >= 200 && $status_code < 422) {
            $this->handle_successful_response($response_body);
            return;
        }
        // Log the error message and throw an Exception.
        $this->handle_api_error($this->product_ids, "HTTP {$status_code}: {$response_body}");
    }
    /**
     * Handle successful API response.
     *
     * Parses the response to check for individual product validation errors,
     * marks products accordingly, and logs the result.
     *
     * @param string $response_body The API response body.
     */
    private function handle_successful_response(string $response_body): void
    {
        // First, mark all products as synced to avoid re-syncing them in the next batch.
        $this->mark_products_synced($this->product_ids);
        // Check for validation issues from the response and document them in product-meta fields.
        try {
            $response_data = json_decode($response_body, \true, 512, \JSON_THROW_ON_ERROR);
            $this->logger->info(sprintf('Agentic Sync Job %s: Successfully synced %d products', $this->batch_id, count($this->product_ids)), $response_data);
            $contains_errors = \false === ($response_data['success'] ?? \false);
            $error_message = $response_data['message'] ?? '';
        } catch (JsonException $e) {
            // Do not process invalid JSON data.
            $this->logger->error('Invalid JSON response', array('response' => $response_body, 'error' => $e->getMessage()));
            return;
        }
        if ($contains_errors && $error_message) {
            $validation_errors = $this->extract_product_errors($error_message);
            $this->mark_products_by_validation_result($validation_errors);
        }
    }
    /**
     * Extract product IDs that failed validation from error message.
     *
     * Parses error messages like "data/products/0/image_link must pass..." to
     * identify which products in the batch actually failed validation.
     *
     * @param string $error_message The error message to parse.
     * @return array Array of product IDs (keys) and the relevant validation error (values).
     */
    private function extract_product_errors(string $error_message): array
    {
        $errors = array();
        // Pattern: data/products/{index} followed by error text until comma or end.
        preg_match_all('/data\/products\/(\d+)\s+([^,]+)/', $error_message, $matches, \PREG_SET_ORDER);
        foreach ($matches as $match) {
            $index = (int) $match[1];
            $id = $this->product_ids[$index] ?? null;
            if (is_null($id)) {
                continue;
            }
            $errors[$id] = trim($match[2]);
        }
        return $errors;
    }
    /**
     * Mark products based on validation results.
     *
     * Products that failed validation get error annotations.
     * Products that passed (or weren't mentioned) get marked as successfully synced.
     *
     * @param array $validation_errors Mapping of product-id to validation error.
     */
    private function mark_products_by_validation_result(array $validation_errors): void
    {
        $this->logger->warning(sprintf('Agentic Sync Job %s: Validation errors', $this->batch_id), $validation_errors);
        foreach ($validation_errors as $product_id => $error_message) {
            $this->mark_product_with_validation_error($product_id, $error_message);
        }
    }
    /**
     * Handle API or network errors by logging and throwing exception for retry.
     *
     * This method handles actual API failures (not validation errors) that should
     * trigger retry logic. Products are marked with error metadata, and an exception
     * is thrown to signal Action Scheduler to retry.
     *
     * @param array  $product_ids   Product IDs that failed to sync.
     * @param string $error_message The error message.
     * @throws RuntimeException When an error occurs during sync.
     */
    private function handle_api_error(array $product_ids, string $error_message): void
    {
        $this->logger->warning(sprintf('Agentic Sync Job %s: API Error - %s', $this->batch_id, $error_message), array('product_count' => count($product_ids), 'product_ids' => $product_ids));
        foreach ($product_ids as $product_id) {
            $product = wc_get_product($product_id);
            if (!$product) {
                continue;
            }
            $product->update_meta_data('_ppcp_agentic_sync_error', $error_message);
            $product->save_meta_data();
        }
        throw new RuntimeException(sprintf('Agentic sync failed: %s', $error_message));
    }
    /**
     * Mark a single product as synced successfully.
     *
     * @param int $product_id Product ID to mark as synced.
     */
    private function mark_product_synced(int $product_id): void
    {
        $product = wc_get_product($product_id);
        if (!$product) {
            return;
        }
        $timestamp = current_time('mysql');
        $product->update_meta_data('_ppcp_agentic_last_sync', $timestamp);
        $product->delete_meta_data('_ppcp_agentic_sync_error');
        $product->save_meta_data();
    }
    /**
     * Mark a single product with validation error.
     *
     * Products with validation errors are still considered "synced" (the sync
     * attempt was made), but store the validation error for merchant visibility.
     *
     * @param int    $product_id    Product ID.
     * @param string $error_message Validation error message.
     */
    private function mark_product_with_validation_error(int $product_id, string $error_message): void
    {
        $product = wc_get_product($product_id);
        if (!$product) {
            return;
        }
        $timestamp = current_time('mysql');
        $product->update_meta_data('_ppcp_agentic_last_sync', $timestamp);
        $product->update_meta_data('_ppcp_agentic_sync_error', $error_message);
        $product->save_meta_data();
    }
    /**
     * Mark multiple products as synced by updating their last sync timestamp.
     *
     * @param array $product_ids Product IDs to mark as synced.
     */
    private function mark_products_synced(array $product_ids): void
    {
        foreach ($product_ids as $product_id) {
            $this->mark_product_synced($product_id);
        }
    }
}