<?php
/**
 * Order events: hooks.
 *
 * @package CortexCommerce
 */

namespace CortexCommerce\Orders;

use CortexCommerce\Settings\Flavor;
use CortexCommerce\Settings\Options;
use CortexCommerce\Support\Log;

defined( 'ABSPATH' ) || exit;

/**
 * Queues order.paid (once per order) and order.refunded (per refund) for OrderEventSender. Only ever enqueues an
 * Action Scheduler action: nothing on the checkout path waits on the network (spec §6).
 */
final class OrderEvents {

	const HOOK      = Flavor::HOOK_PREFIX . 'send_order_event';
	const GROUP     = Flavor::GROUP;
	const PAID_META = '_' . Flavor::OPTION_PREFIX . 'paid_sent';

	public function register(): void {
		add_action( 'woocommerce_payment_complete', array( $this, 'on_paid' ) );
		add_action( 'woocommerce_order_status_processing', array( $this, 'on_paid' ) );
		add_action( 'woocommerce_order_status_completed', array( $this, 'on_paid' ) );
		add_action( 'woocommerce_order_refunded', array( $this, 'on_refunded' ), 10, 2 );
		add_action( self::HOOK, array( OrderEventSender::class, 'run' ), 10, 4 );
	}

	/**
	 * @param int|string $order_id Order id.
	 */
	public function on_paid( $order_id ): void {
		try {
			if ( ! self::can_queue() ) {
				return;
			}
			$order = wc_get_order( $order_id );
			if ( ! $order instanceof \WC_Order || '' !== (string) $order->get_meta( self::PAID_META ) ) {
				return;
			}
			$action_id = as_enqueue_async_action( self::HOOK, array( 'order.paid', (int) $order->get_id(), 0, 0 ), self::GROUP );
			if ( $action_id <= 0 ) {
				// Leave PAID_META unset so the next trigger (processing, completed, payment_complete) retries.
				Log::warning( 'Order event not queued: Action Scheduler refused order.paid for order ' . $order->get_id() . '.' );
				return;
			}
			$order->update_meta_data( self::PAID_META, (string) time() );
			$order->save_meta_data();
		} catch ( \Throwable $e ) {
			try {
				Log::error( 'Order event not queued: ' . $e->getMessage() );
			} catch ( \Throwable $ignored ) {
				// A broken logger must not fatal checkout either: fail closed means no event queued, quietly.
				unset( $ignored );
			}
		}
	}

	/**
	 * @param int|string $order_id  Order id.
	 * @param int|string $refund_id Refund id.
	 */
	public function on_refunded( $order_id, $refund_id ): void {
		try {
			if ( ! self::can_queue() ) {
				return;
			}
			as_enqueue_async_action( self::HOOK, array( 'order.refunded', (int) $order_id, (int) $refund_id, 0 ), self::GROUP );
		} catch ( \Throwable $e ) {
			try {
				Log::error( 'Order event not queued: ' . $e->getMessage() );
			} catch ( \Throwable $ignored ) {
				// A broken logger must not fatal checkout either: fail closed means no event queued, quietly.
				unset( $ignored );
			}
		}
	}

	/**
	 * Drops every queued order event (the store disconnected).
	 */
	public static function unschedule_all(): void {
		if ( function_exists( 'as_unschedule_all_actions' ) ) {
			// The stub types $args as array, but Action Scheduler's own implementation treats null (not array())
			// as "any args"; array() would only cancel actions whose args are exactly empty, leaving every real
			// queued order event behind.
			// @phpstan-ignore-next-line argument.type
			as_unschedule_all_actions( self::HOOK, null, self::GROUP );
		}
	}

	private static function can_queue(): bool {
		return Options::is_connected() && function_exists( 'as_enqueue_async_action' );
	}
}