feat(activator): create queue table, schedule cron, guard PHP/WP versions

2026-04-17 22:49:25 +05:00
parent aa66d15eb5
commit fef22c1ff8
1 changed files with 76 additions and 0 deletions
@@ -0,0 +1,76 @@
+<?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
+    {
+        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');
+        }
+    }
+}