<?php

if (!defined('ABSPATH')) exit;

use BerqWP\BerqWP;

class berqWooCommerce extends berqIntegrations {
    function __construct() {
        add_action( 'woocommerce_product_set_stock_status', [$this, 'stock_update'] );
        // add_action( 'woocommerce_delete_product_transients', [$this, 'delete_transient'] );

        add_action('woocommerce_order_status_changed', function() {
            remove_action('woocommerce_delete_product_transients', [$this, 'delete_transient']);
        }, 1);

        add_action('woocommerce_order_status_changed', function() {
            add_action('woocommerce_delete_product_transients', [$this, 'delete_transient']);
        }, 999);

        add_action( 'wc_delete_related_product_transients_async', function () {
            add_filter( 'berqwp_can_flush_cache_on_post_update', '__return_false' );
        } );

        add_action('woocommerce_scheduled_sales', [$this, 'product_sale_end_actions']);
        // add_filter('berqwp_purge_home_post_types', [$this, 'purge_home']);

    }

    function purge_home($post_types) {

        if (!in_array('product', $post_types)) {
            $post_types[] = 'product';
        }

        return $post_types;

    }

    function flush_product_critical_css($post_id) {
        // Ensure it's a product
        if ( get_post_type( $post_id ) != 'product' ) {
            return;
        }

        // Get the full URL of the product
        $product_url = get_permalink( $post_id );
        $berqwp = new BerqWP(berqwp_get_license_key(), null, null);
        $berqwp->purge_criticlecss_url($product_url);

    }

    function stock_update($post_id) {

        global $berq_log;
        $berq_log->info("WC stock update fired: $post_id");

        $this->flush_product_cache($post_id);
    }

    function delete_transient($post_id) {

        if (class_exists('\JtlWooCommerceConnector\Controllers\ProductController')) {
            return;
        }

        global $berq_log;
        $berq_log->info("WC delete transients fired: $post_id");

        $this->flush_product_cache($post_id);
    }

    function flush_product_cache($post_id) {
        // Ensure it's a product
        if ( get_post_type( $post_id ) != 'product' ) {
            return;
        }

        global $berq_log;
        $berq_log->info("Flush product cache $post_id");

        // Get the full URL of the product
        $product_url = get_permalink( $post_id );
        berqCache::purge_page($product_url, true);
    }

    function product_sale_end_actions() {

		if (!function_exists('wc_get_products')) {
			return;
		}

        global $berq_log;
        $berq_log->info("Starting product_sale_end_actions");

        $current_time = time();
        $last_check = get_option( 'berqwp_product_sale_check', false );

        // If is first time run
        if (empty($last_check)) {
            $last_check = time() - DAY_IN_SECONDS;
        }

        $products = wc_get_products([
            'status' => 'publish',
            'meta_query' => [
                [
                    'key' => '_sale_price_dates_to',
                    'value' => $current_time,
                    'compare' => '<=',
                    'type' => 'NUMERIC'
                ]
            ]
        ]);

        $berq_log->info("Found " . count($products) . " products with expired sales");

        foreach ($products as $product) {
            $product_id = $product->get_id();
            $sale_end_date = get_post_meta( $product_id, '_sale_price_dates_to', true );
            if (!empty($sale_end_date) && $sale_end_date >= $last_check && $sale_end_date <= $current_time) {
                $berq_log->info("Flushing cache for product ID: $product_id");
                $this->flush_product_cache($product_id);
            }
        }

        update_option( 'berqwp_product_sale_check', $current_time );

        $berq_log->info("Completed product_sale_end_actions");
    }


}

new berqWooCommerce();