Changeset 3764005 for langforge/trunk/includes/class-forge-queue.php

Timestamp:

10/25/2026 06:29:16 AM (23 hours ago)

Author:

avakodeforge

Message:

Release 1.3.0 (trunk + tag; see readme changelog)

File:

• langforge/trunk/includes/class-forge-queue.php (modified) (5 diffs)

langforge/trunk/includes/class-forge-queue.php

@@ -121 +121 @@
         ]);
 
-        if ($inserted) {
-            // Nudge WP-Cron so jobs start even on local/MAMP environments
-            // where no external HTTP hits trigger cron.
+        if (!$inserted) {
+            return false;
+        }
+
+        // Read before anything else writes: spawn_cron INSERTs the doing_cron
+        // transient into wp_options, and insert_id is the last row of any table
+        // (BUG-SUITE-QUEUE-01: callers were handed that row's id).
+        $id = (int) $wpdb->insert_id;
+
+        self::nudge_cron_at_shutdown();
+
+        return $id;
+    }
+
+    /** @var bool a cron nudge is already waiting for the end of this request */
+    private static $nudge_pending = false;
+
+    /**
+ * Nudge WP-Cron so jobs start even on local/MAMP environments where no
+ * external HTTP hits trigger cron. At the end of the request, not inside
+ * dispatch: the loopback request spawn_cron sends can run the job before
+ * the caller has stored its id and shown "queued". Once per request, however
+ * many jobs were queued.
+ */
+    private static function nudge_cron_at_shutdown(): void {
+        if (self::$nudge_pending) {
+            return;
+        }
+        self::$nudge_pending = true;
+        add_action('shutdown', [__CLASS__, 'nudge_cron']);
+    }
+
+    /** `shutdown` handler of nudge_cron_at_shutdown. */
+    public static function nudge_cron(): void {
+        self::$nudge_pending = false;
+        if (function_exists('spawn_cron')) {
             spawn_cron();
         }
-
-        return $inserted ? $wpdb->insert_id : false;
     }
 
@@ -282 +313 @@
     public function ajax_status() {
         check_ajax_referer('forge_queue_nonce', 'nonce');
-        if (!current_user_can('manage_options')) wp_send_json_error();
+        if (!current_user_can('manage_options')) wp_send_json_error(['message' => __('Forbidden', 'langforge')], 403);
 
         global $wpdb;
@@ -459 +490 @@
  * account binding, the Pro stamp and the Connect error list (Forge_Wporg_Disabled_Connect),
  * the seven statistics options with their hourly event (Forge_Telemetry), the
- * credits widget's caches. 'free' is the Free plugins' classes: the
- * ever-connected flag, the health history and the feedback timestamp (the
- * dashboard and feedback widget), the queue version, table and events (this
- * class), the deactivation lock, the feedback and Pro-tip user meta. A new
- * option, transient, event or meta key in a shared class goes on this list,
- * or it outlives the last Forge plugin.
- *
- * 'prefixes' are the transients whose name goes on with a product slug or a
- * user id (`forge_credits_<slug>_<user>`, `forge_deact_lock_<user>`): the
- * only names removed by prefix, and the prefixes are whole words.
+ * credits widget's caches, the MCP layer's settings, its two journals and the
+ * rate counters of agents' calls (Forge_Mcp). 'free' is the Free plugins'
+ * classes: the ever-connected flag, the health history and the feedback
+ * timestamp (the dashboard and feedback widget), the queue version, table and
+ * events (this class), the deactivation lock, the feedback and Pro-tip user
+ * meta. A new option, transient, event or meta key in a shared class goes on
+ * this list, or it outlives the last Forge plugin.
+ *
+ * 'prefixes' are the transients whose name goes on with a product slug, a
+ * user id or a hash (`forge_credits_<slug>_<user>`, `forge_deact_lock_<user>`,
+ * `forge_mcp_rl_<md5>`): the only names removed by prefix, and the prefixes
+ * are whole words.
  */
     const SUITE_KEYS = [
@@ -483 +516 @@
                 'forge_telemetry_last_heartbeat',
                 'forge_telemetry_dedup',
+                'forge_mcp_settings',
+                'forge_mcp_log',
+                'forge_mcp_log_refused',
             ],
             'cron'       => ['forge_telemetry_flush'],
             'transients' => ['forge_credits_pricing'],
-            'prefixes'   => ['forge_credits_'],
+            'prefixes'   => ['forge_credits_', 'forge_mcp_rl_'],
             'user_meta'  => [],
         ],
@@ -549 +585 @@
 
         delete_option('forge_license_last_pro_at');
+        delete_option($slug . '_license_last_pro_at');
 
         if (!$alone) {