<?php
/**
 * WooCommerce product sync hooks for AgentInStore.
 *
 * @package CheckoutAgent
 * @license GPL-2.0-or-later
 */

if (!defined('ABSPATH')) {
    exit;
}

/**
 * Keeps AgentInStore catalog in sync with WooCommerce for all common cases:
 * create, update, stock change, status/draft, trash, restore, permanent delete,
 * and variations. Each event pushes only that product (no full-catalog re-sync).
 * Initial full sync runs once on Connect via AGENTI_API::handshake / kick_full_sync.
 */
class AGENTI_Sync {
    public static function init() {
        // Create / update (WooCommerce CRUD helpers)
        add_action('woocommerce_new_product', [__CLASS__, 'on_product_save'], 20, 1);
        add_action('woocommerce_update_product', [__CLASS__, 'on_product_save'], 20, 1);
        add_action('woocommerce_new_product_variation', [__CLASS__, 'on_variation_save'], 20, 1);
        add_action('woocommerce_update_product_variation', [__CLASS__, 'on_variation_save'], 20, 1);

        // Broad catch-all when product (or variation) post is saved in admin/API
        add_action('save_post_product', [__CLASS__, 'on_save_post_product'], 30, 3);
        add_action('save_post_product_variation', [__CLASS__, 'on_save_post_variation'], 30, 3);

        // Stock / inventory
        add_action('woocommerce_product_set_stock_status', [__CLASS__, 'on_stock_status'], 20, 3);
        add_action('woocommerce_variation_set_stock_status', [__CLASS__, 'on_variation_stock_status'], 20, 3);
        add_action('woocommerce_product_set_stock', [__CLASS__, 'on_stock_qty'], 20, 1);
        add_action('woocommerce_variation_set_stock', [__CLASS__, 'on_stock_qty'], 20, 1);

        // Trash / restore / permanent delete
        add_action('wp_trash_post', [__CLASS__, 'on_product_trash'], 10, 1);
        add_action('untrashed_post', [__CLASS__, 'on_product_untrash'], 10, 1);
        add_action('before_delete_post', [__CLASS__, 'on_product_delete'], 10, 1);
        add_action('woocommerce_trash_product', [__CLASS__, 'on_wc_trash'], 10, 1);
        add_action('woocommerce_untrash_product', [__CLASS__, 'on_wc_untrash'], 10, 1);
        add_action('woocommerce_delete_product', [__CLASS__, 'on_wc_delete'], 10, 1);

        // Status transitions (publish ↔ draft ↔ private)
        add_action('transition_post_status', [__CLASS__, 'on_status_transition'], 20, 3);

        add_action('agenti_daily_heartbeat', function () {
            // Blocking so we can honor needs_image_refresh from AgentInStore.
            AGENTI_API::heartbeat(true);
        });
        add_action('agenti_full_catalog_sync', [__CLASS__, 'run_full_sync']);
    }

    private static function is_product_post($post_id) {
        $type = get_post_type($post_id);
        return in_array($type, ['product', 'product_variation'], true);
    }

    private static function parent_or_self($product_id) {
        $product_id = (int) $product_id;
        if (!$product_id || !function_exists('wc_get_product')) {
            return $product_id;
        }
        $product = wc_get_product($product_id);
        if (!$product) {
            return $product_id;
        }
        if ($product->is_type('variation')) {
            $parent = $product->get_parent_id();
            return $parent ? (int) $parent : $product_id;
        }
        return $product_id;
    }

    private static function push($product_id, $action = 'upsert') {
        $id = self::parent_or_self($product_id);
        if (!$id) {
            return;
        }
        // Avoid duplicate pushes in the same request
        static $done = [];
        $key = $action . ':' . $id;
        if (isset($done[$key])) {
            return;
        }
        $done[$key] = true;
        AGENTI_API::push_product($id, $action);
    }

    public static function on_product_save($product_id) {
        $product_id = (int) $product_id;
        if (!$product_id) {
            return;
        }
        $type = get_post_type($product_id);
        if ($type && !in_array($type, ['product', 'product_variation'], true)) {
            return;
        }
        self::push($product_id, 'upsert');
    }

    public static function on_variation_save($variation_id) {
        self::push((int) $variation_id, 'upsert');
    }

    public static function on_save_post_product($post_id, $post, $update) {
        if (defined('DOING_AUTOSAVE') && DOING_AUTOSAVE) {
            return;
        }
        if (wp_is_post_revision($post_id)) {
            return;
        }
        if (!$post || $post->post_type !== 'product') {
            return;
        }
        if ($post->post_status === 'auto-draft') {
            return;
        }
        if ($post->post_status === 'trash') {
            self::push((int) $post_id, 'deleted');
            return;
        }
        self::push((int) $post_id, 'upsert');
    }

    public static function on_save_post_variation($post_id, $post, $update) {
        if (defined('DOING_AUTOSAVE') && DOING_AUTOSAVE) {
            return;
        }
        if (!$post || $post->post_type !== 'product_variation') {
            return;
        }
        if ($post->post_status === 'trash') {
            self::push((int) $post_id, 'deleted');
            return;
        }
        self::push((int) $post_id, 'upsert');
    }

    public static function on_stock_status($product_id, $stock_status = '', $product = null) {
        self::push((int) $product_id, 'upsert');
    }

    public static function on_variation_stock_status($variation_id, $stock_status = '', $product = null) {
        self::push((int) $variation_id, 'upsert');
    }

    public static function on_stock_qty($product) {
        $id = is_object($product) && method_exists($product, 'get_id') ? $product->get_id() : (int) $product;
        if ($id) {
            self::push($id, 'upsert');
        }
    }

    public static function on_product_trash($post_id) {
        if (!self::is_product_post($post_id)) {
            return;
        }
        self::push((int) $post_id, 'deleted');
    }

    public static function on_product_untrash($post_id) {
        if (!self::is_product_post($post_id)) {
            return;
        }
        self::push((int) $post_id, 'upsert');
    }

    public static function on_product_delete($post_id) {
        if (!self::is_product_post($post_id)) {
            return;
        }
        self::push((int) $post_id, 'deleted');
    }

    public static function on_wc_trash($product_id) {
        self::push((int) $product_id, 'deleted');
    }

    public static function on_wc_untrash($product_id) {
        self::push((int) $product_id, 'upsert');
    }

    public static function on_wc_delete($product_id) {
        self::push((int) $product_id, 'deleted');
    }

    public static function on_status_transition($new_status, $old_status, $post) {
        if (!$post || !isset($post->post_type)) {
            return;
        }
        if (!in_array($post->post_type, ['product', 'product_variation'], true)) {
            return;
        }
        if ($new_status === $old_status) {
            return;
        }
        if ($new_status === 'trash') {
            self::push((int) $post->ID, 'deleted');
            return;
        }
        if ($old_status === 'trash' || in_array($new_status, ['publish', 'draft', 'private', 'pending'], true)) {
            self::push((int) $post->ID, 'upsert');
        }
    }

    public static function run_full_sync() {
        if (function_exists('set_time_limit')) {
            @set_time_limit(0);
        }
        if (function_exists('ignore_user_abort')) {
            @ignore_user_abort(true);
        }
        AGENTI_API::sync_all_products(100);
    }
}