<?php
declare(strict_types=1);

namespace Cf7stg;

final class Activator
{
    public const DB_VERSION = '1';
    public const DB_VERSION_OPTION = 'cf7stg_db_version';

    public static function activate(): void
    {
        self::guard_requirements();
        self::install_table();
        self::schedule_events();
    }

    public static function deactivate(): void
    {
        wp_clear_scheduled_hook('cf7stg_dispatch');
        wp_clear_scheduled_hook('cf7stg_cleanup');
    }

    private static function guard_requirements(): void
    {
        if (version_compare(PHP_VERSION, '7.4', '<')) {
            deactivate_plugins(plugin_basename(CF7STG_PLUGIN_FILE));
            wp_die('Плагин CF7 Spam → Telegram требует PHP 7.4 или выше. Текущая: ' . PHP_VERSION);
        }
        global $wp_version;
        if (version_compare($wp_version, '6.0', '<')) {
            deactivate_plugins(plugin_basename(CF7STG_PLUGIN_FILE));
            wp_die('Плагин CF7 Spam → Telegram требует WordPress 6.0 или выше.');
        }
    }

    private static function install_table(): void
    {
        global $wpdb;
        $table = $wpdb->prefix . 'cf7stg_queue';
        $charset_collate = $wpdb->get_charset_collate();

        $sql = "CREATE TABLE {$table} (
            id BIGINT UNSIGNED NOT NULL AUTO_INCREMENT,
            flamingo_post_id BIGINT UNSIGNED NULL,
            form_id BIGINT UNSIGNED NULL,
            source_key VARCHAR(40) NOT NULL DEFAULT 'cf7',
            payload_json LONGTEXT NOT NULL,
            label VARCHAR(10) NOT NULL DEFAULT 'unclear',
            is_retro TINYINT(1) NOT NULL DEFAULT 0,
            status VARCHAR(20) NOT NULL DEFAULT 'pending',
            attempts SMALLINT UNSIGNED NOT NULL DEFAULT 0,
            last_error TEXT NULL,
            next_try_at DATETIME NULL,
            created_at DATETIME NOT NULL,
            sent_at DATETIME NULL,
            PRIMARY KEY  (id),
            KEY idx_status_next (status, next_try_at),
            UNIQUE KEY uq_flamingo (flamingo_post_id, is_retro)
        ) {$charset_collate};";

        require_once ABSPATH . 'wp-admin/includes/upgrade.php';
        dbDelta($sql);
        update_option(self::DB_VERSION_OPTION, self::DB_VERSION);
    }

    private static function schedule_events(): void
    {
        // Register the custom 60-second schedule here — Dispatcher::register_hooks()
        // runs on plugins_loaded, which is AFTER activation. Without this filter
        // being in place during activate(), wp_schedule_event with an unknown
        // recurrence ('cf7stg_every_minute') silently fails and the event never
        // fires.
        add_filter('cron_schedules', ['\\Cf7stg\\Dispatcher', 'register_schedule']);

        if (!wp_next_scheduled('cf7stg_dispatch')) {
            wp_schedule_event(time() + 60, 'cf7stg_every_minute', 'cf7stg_dispatch');
        }
        if (!wp_next_scheduled('cf7stg_cleanup')) {
            wp_schedule_event(time() + 3600, 'daily', 'cf7stg_cleanup');
        }
    }
}