<?php
/**
 * Фоновые задачи плагина в Action Scheduler.
 *
 * @package Aimodelka
 */

namespace Aimodelka\Jobs;

use Aimodelka\Action_Failed;
use Aimodelka\Admin\Notices;
use Aimodelka\Api\Api_Exception;
use Aimodelka\Api\Client;
use Aimodelka\Api\Error_Kind;
use Aimodelka\Logger;
use Aimodelka\Media\Product_Saver;
use Aimodelka\Meta;

defined( 'ABSPATH' ) || exit;

/**
 * Две фоновые задачи (Documents/WPPlugin-HLD.md §4.3, раздел «Jobs»):
 *
 * 1. **Доделать ожидающее сохранение.** Ставится, когда фото из окна и его назначение
 *    записаны в мету товара, и отменяется, когда сохранение удалось. Если обработка
 *    оборвалась, задача пробует ещё несколько раз с растущей паузой — с тем же назначением.
 *    Удалось — отметка снимается, статус колонки обновляется. Не удалось — уведомление
 *    в админке с названием товара. Запись прежнего вида (от плагина до 1.4) задача
 *    не доделывает: Product_Saver снимает её с записью в журнал.
 * 2. **Проверка связи раз в сутки.** Ключ перестал работать — уведомление «ключ aiModelka
 *    не работает». Без ключа задача ничего не отправляет.
 *
 * Задачи живут в Action Scheduler, который поставляется вместе с WooCommerce. Обычный
 * планировщик WordPress (wp-cron) на малопосещаемом магазине может не срабатывать сутками —
 * он запускается посетителем сайта. Все задачи плагина — в группе «aimodelka»: так их
 * можно снять одним вызовом при выключении и удалении плагина.
 */
final class Scheduler {

	/** Событие задачи «доделать ожидающее сохранение»; аргумент — id товара. */
	public const SAVE_HOOK = 'aimodelka_finish_pending_save';

	/** Событие задачи «проверка связи раз в сутки». */
	public const CONNECTION_HOOK = 'aimodelka_check_connection';

	/** Группа задач плагина в Action Scheduler. */
	public const GROUP = 'aimodelka';

	/** Отметка «задачи надо зарегистрировать» — ставится при включении плагина. */
	public const SETUP_OPTION = 'aimodelka_jobs_setup_needed';

	/**
	 * Паузы перед попытками доделать сохранение, в секундах. Первая — с запасом больше, чем
	 * окно ждёт ответа магазина (2 минуты) и чем обычно длится запрос сохранения: задача
	 * не должна браться за список, который ещё обрабатывается.
	 */
	private const RETRY_DELAYS = array( 300, 900, 3600, 10800, 43200 );

	/**
	 * Подписывается на события: сами задачи и регистрация задач после включения плагина.
	 *
	 * @return void
	 */
	public function register(): void {
		add_action( self::SAVE_HOOK, array( $this, 'finish_pending_save' ) );
		add_action( self::CONNECTION_HOOK, array( $this, 'check_connection' ) );
		add_action( 'action_scheduler_init', array( self::class, 'setup_if_needed' ) );
	}

	/**
	 * Включение плагина: регистрирует задачи.
	 *
	 * Если Action Scheduler в этот момент ещё не готов, регистрация случится на первом
	 * же запросе к сайту после его запуска (setup_if_needed на «action_scheduler_init»).
	 *
	 * @return void
	 */
	public static function on_activation(): void {
		update_option( self::SETUP_OPTION, 1, false );

		if ( did_action( 'action_scheduler_init' ) ) {
			self::setup_if_needed();
		}
	}

	/**
	 * Выключение плагина: снимает все его задачи.
	 *
	 * Ожидающие сохранения остаются в мете товаров; при следующем включении задачи для них
	 * поставятся заново.
	 *
	 * @return void
	 */
	public static function on_deactivation(): void {
		delete_option( self::SETUP_OPTION );

		if ( function_exists( 'as_unschedule_all_actions' ) ) {
			as_unschedule_all_actions( '', array(), self::GROUP );
		}
	}

	/**
	 * Регистрирует задачи, если плагин только что включили.
	 *
	 * Ставит ежесуточную проверку связи и заново ставит задачи для ожидающих сохранений,
	 * оставшихся с прошлого включения.
	 *
	 * @return void
	 */
	public static function setup_if_needed(): void {
		if ( ! get_option( self::SETUP_OPTION ) || ! function_exists( 'as_schedule_recurring_action' ) ) {
			return;
		}

		if ( ! as_has_scheduled_action( self::CONNECTION_HOOK, array(), self::GROUP ) ) {
			as_schedule_recurring_action( time() + HOUR_IN_SECONDS, DAY_IN_SECONDS, self::CONNECTION_HOOK, array(), self::GROUP );
		}

		$pending_products = get_posts(
			array(
				'post_type'      => 'product',
				'post_status'    => 'any',
				'fields'         => 'ids',
				'posts_per_page' => 100,
				'no_found_rows'  => true,
				'meta_key'       => Meta::PENDING_SAVE, // phpcs:ignore WordPress.DB.SlowDBQuery.slow_db_query_meta_key -- один раз при включении плагина.
			)
		);

		foreach ( $pending_products as $product_id ) {
			self::schedule_pending_save( (int) $product_id, self::retry_delay( 0 ) );
		}

		delete_option( self::SETUP_OPTION );

		Logger::info( 'Background jobs registered', array( 'pending_saves' => count( $pending_products ) ) );
	}

	/**
	 * Пауза перед следующей попыткой доделать сохранение.
	 *
	 * @param int $attempts Сколько попыток уже было.
	 * @return int Секунды.
	 */
	public static function retry_delay( int $attempts ): int {
		return self::RETRY_DELAYS[ min( max( 0, $attempts ), count( self::RETRY_DELAYS ) - 1 ) ];
	}

	/**
	 * Ставит задачу «доделать сохранение» товара, заменяя прежнюю.
	 *
	 * @param int $product_id    Id товара.
	 * @param int $delay_seconds Через сколько секунд выполнить.
	 * @return void
	 */
	public static function schedule_pending_save( int $product_id, int $delay_seconds ): void {
		if ( ! function_exists( 'as_schedule_single_action' ) ) {
			return;
		}

		self::cancel_pending_save( $product_id );
		as_schedule_single_action( time() + $delay_seconds, self::SAVE_HOOK, array( $product_id ), self::GROUP );
	}

	/**
	 * Отменяет задачу «доделать сохранение» товара.
	 *
	 * @param int $product_id Id товара.
	 * @return void
	 */
	public static function cancel_pending_save( int $product_id ): void {
		if ( function_exists( 'as_unschedule_all_actions' ) ) {
			as_unschedule_all_actions( self::SAVE_HOOK, array( $product_id ), self::GROUP );
		}
	}

	/**
	 * Задача: доделать ожидающее сохранение товара.
	 *
	 * Работает от имени того, кто нажал кнопку сохранения в окне, — вложения в медиатеке получают
	 * его как автора, как при обычном сохранении.
	 *
	 * @param int|string $product_id Id товара — так Action Scheduler передаёт аргумент задачи.
	 * @return void
	 */
	public function finish_pending_save( $product_id ): void {
		$product_id = (int) $product_id;
		$pending    = Product_Saver::pending( $product_id );

		if ( null === $pending ) {
			return;
		}

		$attempts            = (int) ( $pending['attempts'] ?? 0 ) + 1;
		$pending['attempts'] = $attempts;
		update_post_meta( $product_id, Meta::PENDING_SAVE, $pending );

		$user_id = (int) ( $pending['userId'] ?? 0 );

		if ( $user_id > 0 && get_userdata( $user_id ) ) {
			wp_set_current_user( $user_id );
		}

		$context = array(
			'product_id' => $product_id,
			'attempt'    => $attempts,
		);

		try {
			Product_Saver::process( $product_id );
			Logger::info( 'Pending save finished in the background', $context );
		} catch ( Action_Failed $failure ) {
			if ( $failure->temporary && $attempts < count( self::RETRY_DELAYS ) ) {
				self::schedule_pending_save( $product_id, self::retry_delay( $attempts ) );
				Logger::warning( 'Pending save will be retried', array_merge( $context, array( 'delay_seconds' => self::retry_delay( $attempts ) ) ) );
				return;
			}

			if ( $failure->temporary ) {
				Product_Saver::clear_pending( $product_id );
			}

			Notices::add_failed_save( $product_id );
			Logger::error( 'Pending save given up', array_merge( $context, array( 'reason' => $failure->getMessage() ) ) );
		}
	}

	/**
	 * Задача: проверка связи раз в сутки.
	 *
	 * Ключ стал неверным — отметка для уведомления в админке. Ключ работает — отметка
	 * снимается. Временные неудачи (нет связи, сервис недоступен) только пишутся в журнал:
	 * про ключ они ничего не говорят.
	 *
	 * @return void
	 */
	public function check_connection(): void {
		$client = Client::from_config();

		if ( null === $client ) {
			return;
		}

		try {
			$client->get_connection();
			Notices::clear_key_rejected();
		} catch ( Api_Exception $exception ) {
			if ( Error_Kind::KeyInvalid === $exception->kind ) {
				Notices::flag_key_rejected();
			}

			Logger::warning( 'Daily connection check failed', $exception->log_context() );
		}
	}
}