Context Navigation

← Previous Changeset
Next Changeset →

Changeset 3424156

Timestamp:

12/20/2025 11:11:10 AM (3 months ago)

Author:

loghin

Message:

1.2.997

Location:

dynamic-front-end-heartbeat-control

Files:

: 35 added
: 11 edited

tags/1.2.997 (added)
tags/1.2.997/LICENSE (added)
tags/1.2.997/admin (added)
tags/1.2.997/admin/affix.php (added)
tags/1.2.997/admin/ajax-handler.php (added)
tags/1.2.997/admin/asset-manager.php (added)
tags/1.2.997/admin/heartbeat-config.php (added)
tags/1.2.997/admin/unclogger-menu.php (added)
tags/1.2.997/css (added)
tags/1.2.997/css/dfhcsl-admin.css (added)
tags/1.2.997/defibrillator (added)
tags/1.2.997/defibrillator/cli-helper.php (added)
tags/1.2.997/defibrillator/db-health.php (added)
tags/1.2.997/defibrillator/load-estimator.php (added)
tags/1.2.997/defibrillator/rest-api.php (added)
tags/1.2.997/defibrillator/unclogger-db.php (added)
tags/1.2.997/defibrillator/unclogger.php (added)
tags/1.2.997/engine (added)
tags/1.2.997/engine/interval-helper.php (added)
tags/1.2.997/engine/server-load.php (added)
tags/1.2.997/engine/server-response.php (added)
tags/1.2.997/engine/system-load-fallback.php (added)
tags/1.2.997/heartbeat-async.php (added)
tags/1.2.997/heartbeat-controller.php (added)
tags/1.2.997/js (added)
tags/1.2.997/js/chart.js (added)
tags/1.2.997/js/dfhcsl-admin.js (added)
tags/1.2.997/js/heartbeat.js (added)
tags/1.2.997/js/heartbeat.min.js (added)
tags/1.2.997/readme.txt (added)
tags/1.2.997/settings.php (added)
tags/1.2.997/visitor (added)
tags/1.2.997/visitor/cookie-helper.php (added)
tags/1.2.997/visitor/manager.php (added)
tags/1.2.997/widget.php (added)
trunk/defibrillator/cli-helper.php (modified) (4 diffs)
trunk/defibrillator/load-estimator.php (modified) (20 diffs)
trunk/engine/server-load.php (modified) (9 diffs)
trunk/engine/server-response.php (modified) (3 diffs)
trunk/engine/system-load-fallback.php (modified) (13 diffs)
trunk/heartbeat-async.php (modified) (5 diffs)
trunk/heartbeat-controller.php (modified) (5 diffs)
trunk/readme.txt (modified) (2 diffs)
trunk/visitor/cookie-helper.php (modified) (9 diffs)
trunk/visitor/manager.php (modified) (23 diffs)
trunk/widget.php (modified) (5 diffs)

Legend:

: Unmodified
: Added
: Removed

dynamic-front-end-heartbeat-control/trunk/defibrillator/cli-helper.php

-                      r3396626
+                      r3424156
 class DFEHC_CLI_Command {
+    private function key_candidates(string $base): array {
+        $keys = [];
+        $base = (string) $base;
+        if ($base !== '') {
+            $keys[] = $base;
+        }
+        $keys[] = dfehc_scope_key($base);
+        if (\function_exists('\dfehc_scoped_key')) {
+            $keys[] = \dfehc_scoped_key($base);
+        }
+        if (\function_exists('\dfehc_key')) {
+            $keys[] = \dfehc_key($base);
+        }
+        $keys = \array_values(\array_unique(\array_filter($keys, 'strlen')));
+        return $keys;
+    }
+    private function delete_candidate_keys(string $base): void {
+        $keys = $this->key_candidates($base);
+        foreach ($keys as $k) {
+            \delete_transient($k);
+            if (\is_multisite()) {
+                \delete_site_transient($k);
+            }
+        }
+    }
+    private function set_candidate_keys(string $base, $value, int $ttl): void {
+        $keys = $this->key_candidates($base);
+        foreach ($keys as $k) {
+            if (\function_exists('\dfehc_set_transient_noautoload')) {
+                \dfehc_set_transient_noautoload($k, $value, $ttl);
+            } else {
+                \set_transient($k, $value, $ttl);
+            }
+        }
+    }
     public function recalc_interval(array $args = [], array $assoc_args = []) {
         if (!\function_exists('\dfehc_get_server_load')) {
 …
         $baseKey = \defined('DFEHC_RECOMMENDED_INTERVAL') ? \DFEHC_RECOMMENDED_INTERVAL : 'dfehc_recommended_interval';
+        $key     = dfehc_scope_key($baseKey);
+        if (\function_exists('\dfehc_set_transient_noautoload')) {
+            \dfehc_set_transient_noautoload($key, $interval, 5 * MINUTE_IN_SECONDS);
+        } else {
+            \set_transient($key, $interval, 5 * MINUTE_IN_SECONDS);
+        }
+        $ttl = 5 * MINUTE_IN_SECONDS;
+        $this->set_candidate_keys((string) $baseKey, $interval, $ttl);
         \WP_CLI::success("Heartbeat interval recalculated and cached: {$interval}s");
 …
             try {
                 foreach ($bases as $base) {
+                    $key = dfehc_scope_key($base);
+                    \delete_transient($key);
+                    \delete_site_transient($key);
+                    $this->delete_candidate_keys((string) $base);
+                }
                 \delete_option('dfehc_stale_total_visitors');
 …
         $baseKey  = \defined('DFEHC_RECOMMENDED_INTERVAL') ? \DFEHC_RECOMMENDED_INTERVAL : 'dfehc_recommended_interval';
+        $key      = dfehc_scope_key($baseKey);
+        $interval = \get_transient($key);
+        $interval = \get_transient(dfehc_scope_key((string) $baseKey));
+        if (($interval === false || $interval === null) && \function_exists('\dfehc_scoped_key')) {
+            $interval = \get_transient(\dfehc_scoped_key((string) $baseKey));
+        }
+        if (($interval === false || $interval === null) && \function_exists('\dfehc_key')) {
+            $interval = \get_transient(\dfehc_key((string) $baseKey));
+        }
         $heartbeat_enabled = !\get_option('dfehc_disable_heartbeat');

dynamic-front-end-heartbeat-control/trunk/defibrillator/load-estimator.php

-                      r3412283
+                      r3424156
             $duration = 0.5;
+        }
         $suffix    = self::scope_suffix();
         $baselineT = self::get_baseline_transient_name($suffix);
         $cacheTtl  = (int) \apply_filters('dfehc_load_cache_ttl', 90);
+        if ($cacheTtl < 1) {
+            $cacheTtl = 1;
+        }
         $cacheKey  = self::get_cache_key($suffix);
         $cached = self::get_scoped_transient($cacheKey);
+        if ($cached !== false && $cached !== null) {
+            return $cached;
+        }
+        if ($cached !== false && $cached !== null && \is_numeric($cached)) {
+            return (float) $cached;
+        }
         $sysAvg = self::try_sys_getloadavg();
         if ($sysAvg !== null) {
 …
             return $sysAvg;
+        }
         $baseline = self::get_baseline_value($baselineT);
         if ($baseline === false || $baseline === null || !\is_numeric($baseline) || $baseline <= 0) {
+        if ($baseline === false || $baseline === null || !\is_numeric($baseline) || (float) $baseline <= 0.0) {
             $baseline = self::maybe_calibrate($baselineT, $duration);
+        }
+        $baseline = (float) $baseline;
+        if ($baseline <= 0.0) {
+            $baseline = 1.0;
+        }
         $loopsPerSec = self::run_loop_avg($duration);
         if ($loopsPerSec <= 0) {
             return false;
+        }
         $loadRatio   = ($baseline * 0.125) / \max($loopsPerSec, 1);
         $loadPercent = \round(\min(100.0, \max(0.0, $loadRatio * 100.0)), 2);
         $loadPercent = (float) \apply_filters('dfehc_computed_load_percent', $loadPercent, $baseline, $loopsPerSec);
         self::update_spike_score($loadPercent, $suffix);
         self::set_scoped_transient_noautoload($cacheKey, $loadPercent, $cacheTtl);
         return $loadPercent;
+    }
 …
             return;
+        }
         $suffix  = self::scope_suffix();
         $seenKey = 'dfehc_seen_recently_' . $suffix;
         $ttl     = (int) \apply_filters('dfehc_seen_recently_ttl', 60);
+        if ($ttl < 1) {
+            $ttl = 1;
+        }
         if (\get_transient($seenKey) !== false) {
             return;
 …
         $cdKey  = 'dfehc_cron_cal_cd_' . $suffix;
         $cdTtl  = (int) \apply_filters('dfehc_cron_calibration_cooldown', 300);
+        if ($cdTtl < 1) {
+            $cdTtl = 1;
+        }
         if (\get_transient($cdKey) !== false) {
             return;
 …
         $raw = (float) $avg[0];
         $raw = (float) \apply_filters('dfehc_raw_sys_load', $raw);
         $cores = 0;
         if (\defined('DFEHC_CPU_CORES')) {
             $cores = (int) DFEHC_CPU_CORES;
-        } elseif (\function_exists('\dfehc_get_cpu_cores')) {
-            $cores = (int) \dfehc_get_cpu_cores();
         } elseif (\function_exists('dfehc_get_cpu_cores')) {
             $cores = (int) \dfehc_get_cpu_cores();
 …
             $cores = 1;
+        }
         return \min(100.0, \round(($raw / $cores) * 100.0, 2));
+    }
 …
+        }
         $duration += \mt_rand(0, 2) * 0.001;
         $warm = self::now();
         for ($i = 0; $i < 1000; $i++) { $warm += 0; }
         $start = self::now();
         $end   = $start + $duration;
         $cnt   = 0;
         $cap   = (int) \apply_filters('dfehc_loop_iteration_cap', 10000000);
+        if ($cap < 1000) {
+            $cap = 1000;
+        }
         $now   = $start;
         while ($now < $end && $cnt < $cap) {
             ++$cnt;
             $now = self::now();
+        }
         $elapsed = $now - $start;
         return $elapsed > 0 ? $cnt / $elapsed : 0.0;
 …
         $lockKey  = 'dfehc_calibrating_' . $suffix;
         $lock     = self::acquire_lock($lockKey, 30);
+        if (!$lock) {
+            $existing = self::get_baseline_value($baselineT);
+            if ($existing !== false && $existing !== null && \is_numeric($existing) && (float) $existing > 0.0) {
+                return (float) $existing;
+            }
+        }
         $baseline = self::run_loop_avg($duration);
         if ($baseline <= 0.0) {
             $baseline = 1.0;
+        }
         if ($lock) {
             $exp = (int) \apply_filters('dfehc_baseline_expiration', 7 * DAY_IN_SECONDS);
+            if ($exp < 60) {
+                $exp = 60;
+            }
             self::set_baseline_value($baselineT, $baseline, $exp);
+            self::release_lock($lock, $lockKey);
+        }
+            self::release_lock($lock);
+        }
         return $baseline;
+    }
 …
     private static function update_spike_score(float $loadPercent, string $suffix): void {
         $spikeKey   = self::get_spike_key($suffix);
+        $score      = (float) self::get_scoped_transient($spikeKey);
+        $scoreRaw   = self::get_scoped_transient($spikeKey);
+        $score      = \is_numeric($scoreRaw) ? (float) $scoreRaw : 0.0;
         $decay      = (float) \apply_filters('dfehc_spike_decay', 0.5);
         $increment  = (float) \apply_filters('dfehc_spike_increment', 1.0);
 …
         $trigger    = (float) \apply_filters('dfehc_spike_trigger', 90.0);
         $resetCdTtl = (int) \apply_filters('dfehc_baseline_reset_cooldown', 3600);
+        if ($resetCdTtl < 1) {
+            $resetCdTtl = 1;
+        }
         $resetCdKey = self::BASELINE_RESET_CD_PREFIX . $suffix;
         $scoreMax   = (float) \apply_filters('dfehc_spike_score_max', 20.0);
         if ($loadPercent > $trigger) {
             $score += $increment * (1 + (($loadPercent - $trigger) / 20.0));
 …
             $score = \max(0.0, $score - $decay);
+        }
         $score = \min($scoreMax, \max(0.0, $score));
         if ($score >= $threshold) {
             if (\get_transient($resetCdKey) === false) {
 …
+            }
+        }
         self::set_scoped_transient_noautoload($spikeKey, $score, (int) \apply_filters('dfehc_spike_score_ttl', HOUR_IN_SECONDS));
+    }
 …
         $baselineT = self::get_baseline_transient_name($suffix);
         $existing  = self::get_baseline_value($baselineT);
+        if ($existing !== false && $existing !== null && \is_numeric($existing) && $existing > 0) {
+            return;
+        }
+        if ($existing !== false && $existing !== null && \is_numeric($existing) && (float) $existing > 0.0) {
+            return;
+        }
         $lockKey = 'dfehc_calibrating_' . $suffix;
         $lock    = self::acquire_lock($lockKey, 30);
 …
             return;
+        }
+        $duration = (float) \apply_filters('dfehc_loop_duration', 0.025);
+        if (!\is_finite($duration) || $duration <= 0.0) {
+            $duration = 0.025;
+        }
+        if ($duration < 0.01) {
+            $duration = 0.01;
+        }
+        if ($duration > 0.5) {
+            $duration = 0.5;
+        }
+        $baseline = self::run_loop_avg($duration);
+        if ($baseline <= 0.0) {
+            $baseline = 1.0;
+        }
+        $exp = (int) \apply_filters('dfehc_baseline_expiration', 7 * DAY_IN_SECONDS);
+        self::set_baseline_value($baselineT, $baseline, $exp);
+        self::release_lock($lock, $lockKey);
+        try {
+            $duration = (float) \apply_filters('dfehc_loop_duration', 0.025);
+            if (!\is_finite($duration) || $duration <= 0.0) {
+                $duration = 0.025;
+            }
+            if ($duration < 0.01) {
+                $duration = 0.01;
+            }
+            if ($duration > 0.5) {
+                $duration = 0.5;
+            }
+            $baseline = self::run_loop_avg($duration);
+            if ($baseline <= 0.0) {
+                $baseline = 1.0;
+            }
+            $exp = (int) \apply_filters('dfehc_baseline_expiration', 7 * DAY_IN_SECONDS);
+            if ($exp < 60) {
+                $exp = 60;
+            }
+            self::set_baseline_value($baselineT, $baseline, $exp);
+        } finally {
+            self::release_lock($lock);
+        }
+    }
     private static function acquire_lock(string $key, int $ttl) {
+        $ttl = $ttl < 1 ? 1 : $ttl;
+        $scopedKey = $key;
         if (\class_exists('\WP_Lock')) {
             $lock = new \WP_Lock($key, $ttl);
+            $lock = new \WP_Lock($scopedKey, $ttl);
             return $lock->acquire() ? $lock : null;
+        }
         if (\function_exists('wp_cache_add') && \wp_cache_add($key, 1, DFEHC_CACHE_GROUP, $ttl)) {
             return (object) ['type' => 'cache', 'key' => $key];
+        }
         if (\get_transient($key) !== false) {
+        if (\function_exists('wp_cache_add') && \wp_cache_add($scopedKey, 1, DFEHC_CACHE_GROUP, $ttl)) {
+            return (object) ['type' => 'cache', 'key' => $scopedKey];
+        }
+        if (\get_transient($scopedKey) !== false) {
             return null;
+        }
         if (\set_transient($key, 1, $ttl)) {
             return (object) ['type' => 'transient', 'key' => $key];
+        if (\set_transient($scopedKey, 1, $ttl)) {
+            return (object) ['type' => 'transient', 'key' => $scopedKey];
+        }
         return null;
+    }
     private static function release_lock($lock, string $key): void {
+    private static function release_lock($lock): void {
         if ($lock instanceof \WP_Lock) {
             $lock->release();
 …
         if (\is_object($lock) && isset($lock->type, $lock->key)) {
             if ($lock->type === 'cache') {
+                \wp_cache_delete($key, DFEHC_CACHE_GROUP);
+                if (\function_exists('wp_cache_delete')) {
+                    \wp_cache_delete((string) $lock->key, DFEHC_CACHE_GROUP);
+                }
                 return;
+            }
             if ($lock->type === 'transient') {
                 \delete_transient($key);
+                \delete_transient((string) $lock->key);
                 return;
+            }
 …
             $url = \defined('WP_HOME') && WP_HOME ? WP_HOME : (\function_exists('home_url') ? \home_url() : '');
             $parts = \parse_url((string) $url);
+            $host = $parts['host'] ?? ($url ?: 'unknown');
+            $host = \is_array($parts) ? ($parts['host'] ?? '') : '';
+            if (!$host) {
+                $host = $url ?: 'unknown';
+            }
+        }
         $salt = \defined('DB_NAME') ? (string) DB_NAME : '';
 …
     private static function set_baseline_value(string $name, $value, int $exp): void {
+        if ($exp < 1) {
+            $exp = 1;
+        }
         if (\is_multisite()) {
             self::set_site_transient_noautoload($name, $value, $exp);
 …
     private static function set_scoped_transient_noautoload(string $key, $value, int $ttl): void {
+        if ($ttl < 1) {
+            $ttl = 1;
+        }
         if (\is_multisite()) {
             self::set_site_transient_noautoload($key, $value, $ttl);
 …
+        }
         $ttl = \max(1, $ttl + $jitter);
         if (\function_exists('wp_using_ext_object_cache') && \wp_using_ext_object_cache()) {
             \wp_cache_set($key, $value, DFEHC_CACHE_GROUP, $ttl);
             return;
+        }
         \set_transient($key, $value, $ttl);
         global $wpdb;
+        if (!isset($wpdb->options)) {
+            return;
+        }
+        if (!isset($wpdb) || !\is_object($wpdb) || !isset($wpdb->options)) {
+            return;
+        }
         $opt_key = "_transient_$key";
         $opt_key_to = "_transient_timeout_$key";
         $wpdb->suppress_errors(true);
+        $autoload = $wpdb->get_var($wpdb->prepare("SELECT autoload FROM {$wpdb->options} WHERE option_name=%s LIMIT 1", $opt_key));
+        if ($autoload === 'yes') {
+            $wpdb->update($wpdb->options, ['autoload' => 'no'], ['option_name' => $opt_key, 'autoload' => 'yes'], ['%s'], ['%s','%s']);
+        }
+        $autoload_to = $wpdb->get_var($wpdb->prepare("SELECT autoload FROM {$wpdb->options} WHERE option_name=%s LIMIT 1", $opt_key_to));
+        if ($autoload_to === 'yes') {
+            $wpdb->update($wpdb->options, ['autoload' => 'no'], ['option_name' => $opt_key_to, 'autoload' => 'yes'], ['%s'], ['%s','%s']);
+        }
+        $wpdb->suppress_errors(false);
+        try {
+            $autoload = $wpdb->get_var($wpdb->prepare("SELECT autoload FROM {$wpdb->options} WHERE option_name=%s LIMIT 1", $opt_key));
+            if ($autoload === 'yes') {
+                $wpdb->update($wpdb->options, ['autoload' => 'no'], ['option_name' => $opt_key, 'autoload' => 'yes'], ['%s'], ['%s','%s']);
+            }
+            $autoload_to = $wpdb->get_var($wpdb->prepare("SELECT autoload FROM {$wpdb->options} WHERE option_name=%s LIMIT 1", $opt_key_to));
+            if ($autoload_to === 'yes') {
+                $wpdb->update($wpdb->options, ['autoload' => 'no'], ['option_name' => $opt_key_to, 'autoload' => 'yes'], ['%s'], ['%s','%s']);
+            }
+        } finally {
+            $wpdb->suppress_errors(false);
+        }
+    }
 …
+        }
         $ttl = \max(1, $ttl + $jitter);
         if (\function_exists('wp_using_ext_object_cache') && \wp_using_ext_object_cache()) {
             \wp_cache_set($key, $value, DFEHC_CACHE_GROUP, $ttl);
             return;
+        }
         \set_site_transient($key, $value, $ttl);
+    }

dynamic-front-end-heartbeat-control/trunk/engine/server-load.php

-                      r3412883
+                      r3424156
     function dfehc_client_ip(): string
+    {
+        $ip = (string)($_SERVER['REMOTE_ADDR'] ?? '0.0.0.0');
+        $remote = (string) ($_SERVER['REMOTE_ADDR'] ?? '');
+        $remote = $remote !== '' ? $remote : '0.0.0.0';
+        $is_valid_ip = static function (string $ip, bool $publicOnly): bool {
+            $ip = trim($ip);
+            if ($ip === '') return false;
+            if ($publicOnly) {
+                return filter_var($ip, FILTER_VALIDATE_IP, FILTER_FLAG_NO_PRIV_RANGE | FILTER_FLAG_NO_RES_RANGE) !== false;
+            }
+            return filter_var($ip, FILTER_VALIDATE_IP) !== false;
+        };
+        $public_only = (bool) apply_filters('dfehc_client_ip_public_only', true);
         $trusted = (array) apply_filters('dfehc_trusted_proxies', []);
+        if ($trusted && in_array($ip, $trusted, true)) {
+            $headers = (array) apply_filters('dfehc_proxy_ip_headers', ['HTTP_X_FORWARDED_FOR', 'HTTP_CF_CONNECTING_IP', 'HTTP_X_REAL_IP']);
+        $trusted = array_values(array_filter(array_map('trim', $trusted), 'strlen'));
+        $remote_is_trusted = $trusted && in_array($remote, $trusted, true);
+        if ($remote_is_trusted) {
+            $headers = (array) apply_filters(
+                'dfehc_proxy_ip_headers',
+                ['HTTP_CF_CONNECTING_IP', 'HTTP_TRUE_CLIENT_IP', 'HTTP_X_REAL_IP', 'HTTP_X_FORWARDED_FOR']
+            );
             foreach ($headers as $h) {
+                if (!empty($_SERVER[$h])) {
+                    $raw = (string) $_SERVER[$h];
+                $h = (string) $h;
+                if ($h === '' || empty($_SERVER[$h])) {
+                    continue;
+                }
+                $raw = (string) $_SERVER[$h];
+                if ($h === 'HTTP_X_FORWARDED_FOR') {
                     $parts = array_map('trim', explode(',', $raw));
+                    $cand = end($parts);
+                    if ($cand) {
+                    foreach ($parts as $cand) {
+                        if ($is_valid_ip($cand, $public_only)) {
+                            return (string) apply_filters('dfehc_client_ip', $cand);
+                        }
+                    }
+                    foreach ($parts as $cand) {
+                        if ($is_valid_ip($cand, false)) {
+                            return (string) apply_filters('dfehc_client_ip', $cand);
+                        }
+                    }
+                } else {
+                    $cand = trim($raw);
+                    if ($is_valid_ip($cand, $public_only) || $is_valid_ip($cand, false)) {
                         return (string) apply_filters('dfehc_client_ip', $cand);
+                    }
 …
+            }
+        }
+        return (string) apply_filters('dfehc_client_ip', $ip);
+        if (!$is_valid_ip($remote, false)) {
+            $remote = '0.0.0.0';
+        }
+        return (string) apply_filters('dfehc_client_ip', $remote);
+    }
+}
 …
+{
     static $cached = null;
+    static $ts = 0;
+    static $last_probe_ts = 0;
     $retryAfter = (int) apply_filters('dfehc_cache_retry_after', 60);
+    if ($cached !== null && ($cached['type'] !== 'none' || $ts > time() - $retryAfter)) {
+        return $cached;
+    }
+    $ts = time();
+    $retryAfter = max(0, $retryAfter);
+    if (is_array($cached) && isset($cached['type'])) {
+        if ($cached['type'] !== 'none') {
+            return $cached;
+        }
+        if ($retryAfter > 0 && (time() - (int) $last_probe_ts) < $retryAfter) {
+            return $cached;
+        }
+    }
+    $last_probe_ts = time();
     global $wp_object_cache;
     if (is_object($wp_object_cache) && isset($wp_object_cache->redis) && $wp_object_cache->redis instanceof Redis) {
 …
         return $cached = ['client' => $wp_object_cache->mc, 'type' => 'memcached'];
+    }
     if (class_exists('Redis')) {
         try {
 …
                 $pass = apply_filters('dfehc_redis_auth', getenv('REDIS_PASSWORD') ?: null);
                 $user = apply_filters('dfehc_redis_user', getenv('REDIS_USERNAME') ?: null);
+                if ($user && $pass && method_exists($redis, 'auth')) {
+                    $redis->auth([$user, $pass]);
+                } elseif ($pass && method_exists($redis, 'auth')) {
+                    $redis->auth($pass);
+                }
+                if (method_exists($redis, 'auth')) {
+                    if ($user && $pass) {
+                        $ok = $redis->auth([$user, $pass]);
+                        if ($ok === false) {
+                            throw new RuntimeException('Redis auth failed');
+                        }
+                    } elseif ($pass) {
+                        $ok = $redis->auth($pass);
+                        if ($ok === false) {
+                            throw new RuntimeException('Redis auth failed');
+                        }
+                    }
+                }
                 return $cached = ['client' => $redis, 'type' => 'redis'];
+            }
 …
+        }
+    }
     if (class_exists('Memcached')) {
         try {
 …
                 $mc->addServer(dfehc_get_memcached_server(), dfehc_get_memcached_port());
+            }
             $user = getenv('MEMCACHED_USERNAME');
             $pass = getenv('MEMCACHED_PASSWORD');
 …
                 $mc->setSaslAuthData($user, $pass);
+            }
             $versions = $mc->getVersion();
             $first = is_array($versions) ? reset($versions) : false;
             $ok = $first && $first !== '0.0.0';
+            $ok = $first && $first !== '0.0.0' && $first !== '0.0.0.0';
             if ($ok) {
                 return $cached = ['client' => $mc, 'type' => 'memcached'];
 …
+        }
+    }
     return $cached = ['client' => null, 'type' => 'none'];
+}

dynamic-front-end-heartbeat-control/trunk/engine/server-response.php

-                      r3412283
+                      r3424156
 if (!function_exists('dfehc_client_ip')) {
+    function dfehc_client_ip(): string {
+        $ip = (string)($_SERVER['REMOTE_ADDR'] ?? '0.0.0.0');
+    function dfehc_client_ip(): string
+    {
+        $remote = (string) ($_SERVER['REMOTE_ADDR'] ?? '');
+        $remote = $remote !== '' ? $remote : '0.0.0.0';
+        $is_valid_ip = static function (string $ip, bool $publicOnly): bool {
+            $ip = trim($ip);
+            if ($ip === '') return false;
+            if ($publicOnly) {
+                return filter_var($ip, FILTER_VALIDATE_IP, FILTER_FLAG_NO_PRIV_RANGE | FILTER_FLAG_NO_RES_RANGE) !== false;
+            }
+            return filter_var($ip, FILTER_VALIDATE_IP) !== false;
+        };
+        $public_only = (bool) apply_filters('dfehc_client_ip_public_only', true);
         $trusted = (array) apply_filters('dfehc_trusted_proxies', []);
+        if ($trusted && in_array($ip, $trusted, true)) {
+            $headers = (array) apply_filters('dfehc_proxy_ip_headers', ['HTTP_X_FORWARDED_FOR', 'HTTP_CF_CONNECTING_IP', 'HTTP_X_REAL_IP']);
+        $trusted = array_values(array_filter(array_map('trim', $trusted), 'strlen'));
+        $remote_is_trusted = $trusted && in_array($remote, $trusted, true);
+        if ($remote_is_trusted) {
+            $headers = (array) apply_filters(
+                'dfehc_proxy_ip_headers',
+                ['HTTP_CF_CONNECTING_IP', 'HTTP_TRUE_CLIENT_IP', 'HTTP_X_REAL_IP', 'HTTP_X_FORWARDED_FOR']
+            );
             foreach ($headers as $h) {
+                if (!empty($_SERVER[$h])) {
+                    $raw = (string) $_SERVER[$h];
+                $h = (string) $h;
+                if ($h === '' || empty($_SERVER[$h])) {
+                    continue;
+                }
+                $raw = (string) $_SERVER[$h];
+                if ($h === 'HTTP_X_FORWARDED_FOR') {
                     $parts = array_map('trim', explode(',', $raw));
+                    $cand = end($parts);
+                    if ($cand) {
+                    foreach ($parts as $cand) {
+                        if ($is_valid_ip($cand, $public_only)) {
+                            return (string) apply_filters('dfehc_client_ip', $cand);
+                        }
+                    }
+                    foreach ($parts as $cand) {
+                        if ($is_valid_ip($cand, false)) {
+                            return (string) apply_filters('dfehc_client_ip', $cand);
+                        }
+                    }
+                } else {
+                    $cand = trim($raw);
+                    if ($is_valid_ip($cand, $public_only) || $is_valid_ip($cand, false)) {
                         return (string) apply_filters('dfehc_client_ip', $cand);
+                    }
 …
+            }
+        }
+        return (string) apply_filters('dfehc_client_ip', $ip);
+        if (!$is_valid_ip($remote, false)) {
+            $remote = '0.0.0.0';
+        }
+        return (string) apply_filters('dfehc_client_ip', $remote);
+    }
+}
 …
+        }
         $results['baseline_used'] = $baseline;
+        $results['baseline_used'] = is_array($baseline);
         if (is_array($baseline) && $results['method'] === 'http_loopback' && isset($results['main_response_ms'], $baseline['main_response_ms'])) {

dynamic-front-end-heartbeat-control/trunk/engine/system-load-fallback.php

-                      r3412283
+                      r3424156
 defined('DFEHC_SERVER_LOAD_TTL') || define('DFEHC_SERVER_LOAD_TTL', 60);
 defined('DFEHC_SENTINEL_NO_LOAD') || define('DFEHC_SENTINEL_NO_LOAD', 0.404);
+defined('DFEHC_SENTINEL_NO_LOAD') || define('DFEHC_SENTINEL_NO_LOAD', -1.0);
 defined('DFEHC_SYSTEM_LOAD_KEY') || define('DFEHC_SYSTEM_LOAD_KEY', 'dfehc_system_load_avg');
 defined('DFEHC_CACHE_GROUP') || define('DFEHC_CACHE_GROUP', 'dfehc');
 …
+        }
         $expiration = max(1, $expiration + $jitter);
         if (function_exists('wp_using_ext_object_cache') && wp_using_ext_object_cache()) {
             wp_cache_set($key, $value, DFEHC_CACHE_GROUP, $expiration);
             return;
+        }
         set_transient($key, $value, $expiration);
+        if (isset($GLOBALS['wpdb'])) {
+            global $wpdb;
+            if (!isset($wpdb->options)) {
+                return;
+            }
+            $wpdb->suppress_errors(true);
+            $wpdb->query($wpdb->prepare("UPDATE {$wpdb->options} SET autoload='no' WHERE option_name=%s AND autoload='yes' LIMIT 1", "_transient_$key"));
+            $wpdb->query($wpdb->prepare("UPDATE {$wpdb->options} SET autoload='no' WHERE option_name=%s AND autoload='yes' LIMIT 1", "_transient_timeout_$key"));
+            $wpdb->suppress_errors(false);
+        }
+        if (!isset($GLOBALS['wpdb'])) {
+            return;
+        }
+        global $wpdb;
+        if (!isset($wpdb->options)) {
+            return;
+        }
+        $opt_key = "_transient_$key";
+        $opt_key_to = "_transient_timeout_$key";
+        $wpdb->suppress_errors(true);
+        $autoload = $wpdb->get_var($wpdb->prepare("SELECT autoload FROM {$wpdb->options} WHERE option_name=%s LIMIT 1", $opt_key));
+        if ($autoload === 'yes') {
+            $wpdb->update($wpdb->options, ['autoload' => 'no'], ['option_name' => $opt_key, 'autoload' => 'yes'], ['%s'], ['%s', '%s']);
+        }
+        $autoload_to = $wpdb->get_var($wpdb->prepare("SELECT autoload FROM {$wpdb->options} WHERE option_name=%s LIMIT 1", $opt_key_to));
+        if ($autoload_to === 'yes') {
+            $wpdb->update($wpdb->options, ['autoload' => 'no'], ['option_name' => $opt_key_to, 'autoload' => 'yes'], ['%s'], ['%s', '%s']);
+        }
+        $wpdb->suppress_errors(false);
+    }
+}
 …
             return '';
+        }
         $can_proc = function_exists('proc_open') && !in_array('proc_open', $disabled, true);
         if ($can_proc) {
 …
             $process = @proc_open($cmd, $descriptorspec, $pipes);
             if (!is_resource($process)) return '';
+            foreach ($pipes as $p) { @stream_set_blocking($p, false); @stream_set_timeout($p, (int)ceil($timeoutSec)); }
+            $out = ''; $err = '';
+            foreach ($pipes as $p) {
+                @stream_set_blocking($p, false);
+                @stream_set_timeout($p, (int) ceil($timeoutSec));
+            }
+            $out = '';
             $start = microtime(true);
             $spins = 0;
             while (true) {
+                $out .= @stream_get_contents($pipes[1]) ?: '';
+                $err .= @stream_get_contents($pipes[2]) ?: '';
+                $out .= (string) (@stream_get_contents($pipes[1]) ?: '');
+                @stream_get_contents($pipes[2]);
                 $status = @proc_get_status($process);
+                if (!$status || !$status['running']) break;
+                if ((microtime(true) - $start) > $timeoutSec) { @proc_terminate($process); break; }
+                if (!$status || empty($status['running'])) {
+                    break;
+                }
+                if ((microtime(true) - $start) > $timeoutSec) {
+                    @proc_terminate($process);
+                    break;
+                }
                 $spins++;
                 usleep($spins > 10 ? 25000 : 10000);
+            }
+            foreach ($pipes as $p) { @fclose($p); }
+            foreach ($pipes as $p) {
+                @fclose($p);
+            }
             @proc_close($process);
             return trim($out);
+        }
         $can_shell = function_exists('shell_exec') && !in_array('shell_exec', $disabled, true);
         if ($can_shell) {
             return trim((string) @shell_exec($cmd));
+        }
         return '';
+    }
 …
     function dfehc_get_cpu_cores(): int {
         static $cached = null;
+        if ($cached !== null) return $cached;
+        if ($cached !== null) return (int) $cached;
         $tkey = dfehc_scoped_key('dfehc_cpu_cores');
         if (function_exists('wp_using_ext_object_cache') && wp_using_ext_object_cache()) {
             $oc = wp_cache_get($tkey, DFEHC_CACHE_GROUP);
 …
+            }
+        }
         $tc = get_transient($tkey);
         if ($tc !== false && (int) $tc > 0) {
             return $cached = (int) $tc;
+        }
         $disabled = array_map('trim', explode(',', (string) ini_get('disable_functions')));
         if (PHP_OS_FAMILY !== 'Windows' && function_exists('shell_exec') && !in_array('shell_exec', $disabled, true) && !ini_get('open_basedir')) {
             $val = trim((string) @shell_exec('getconf _NPROCESSORS_ONLN 2>/dev/null'));
 …
+            }
+        }
         if (PHP_OS_FAMILY === 'Windows' && !ini_get('open_basedir')) {
-            $csv = dfehc_exec_with_timeout('typeperf -sc 1 "\Processor(_Total)\% Processor Time" 2>NUL', 1.5);
-            if ($csv !== '') {
-                $wval = dfehc_exec_with_timeout('wmic cpu get NumberOfLogicalProcessors /value 2>NUL', 1.0);
-                if ($wval && preg_match('/NumberOfLogicalProcessors=(\d+)/i', $wval, $m) && (int) $m[1] > 0) {
-                    $cores = (int) $m[1];
-                    dfehc_set_transient_noautoload($tkey, $cores, (int) apply_filters('dfehc_cpu_cores_ttl', DAY_IN_SECONDS));
-                    return $cached = $cores;
+                }
+            }
             $wout = dfehc_exec_with_timeout('wmic cpu get NumberOfLogicalProcessors /value 2>NUL', 1.0);
             if ($wout && preg_match('/NumberOfLogicalProcessors=(\d+)/i', $wout, $m2) && (int) $m2[1] > 0) {
                 $cores = (int) $m2[1];
+            if ($wout && preg_match('/NumberOfLogicalProcessors=(\d+)/i', $wout, $m) && (int) $m[1] > 0) {
+                $cores = (int) $m[1];
                 dfehc_set_transient_noautoload($tkey, $cores, (int) apply_filters('dfehc_cpu_cores_ttl', DAY_IN_SECONDS));
                 return $cached = $cores;
+            }
+        }
         if (is_readable('/proc/cpuinfo')) {
             $cnt = preg_match_all('/^processor/m', (string) @file_get_contents('/proc/cpuinfo'));
 …
+            }
+        }
         dfehc_set_transient_noautoload($tkey, 1, (int) apply_filters('dfehc_cpu_cores_ttl', DAY_IN_SECONDS));
         return $cached = 1;
 …
         $ttl = (int) apply_filters('dfehc_system_load_ttl', DFEHC_SERVER_LOAD_TTL);
         $key = dfehc_scoped_key(DFEHC_SYSTEM_LOAD_KEY);
+        $as_percent = false;
         if (function_exists('wp_using_ext_object_cache') && wp_using_ext_object_cache()) {
             $vc = wp_cache_get($key, DFEHC_CACHE_GROUP);
 …
+            }
+        }
         $cache = get_transient($key);
         if ($cache !== false) {
 …
         if (function_exists('dfehc_get_server_load')) {
             $val = dfehc_get_server_load();
+            if ($val !== DFEHC_SENTINEL_NO_LOAD) {
+                dfehc_set_transient_noautoload($key, (float) $val, $ttl);
+                $ratio = (float) $val;
+                $as_percent = (bool) apply_filters('dfehc_system_load_return_percent', false, $ratio);
+                return $as_percent ? (float) round($ratio * 100, 2) : $ratio;
+            }
+        }
+        if (function_exists('sys_getloadavg')) {
+            if (is_numeric($val)) {
+                $v = (float) $val;
+                if ($v !== (float) DFEHC_SENTINEL_NO_LOAD && $v >= 0.0) {
+                    if ($v > 1.0) {
+                        $raw = $v / 100.0;
+                        $normalized_ratio = true;
+                        $source = 'dfehc_get_server_load_percent';
+                    } else {
+                        $raw = $v;
+                        $normalized_ratio = true;
+                        $source = 'dfehc_get_server_load_ratio';
+                    }
+                }
+            }
+        }
+        if ($raw === null && function_exists('sys_getloadavg')) {
             $arr = @sys_getloadavg();
             if ($arr && isset($arr[0])) {
 …
         if ($raw === null) {
             $sentinel_ttl = (int) apply_filters('dfehc_sentinel_ttl', 5);
             dfehc_set_transient_noautoload($key, DFEHC_SENTINEL_NO_LOAD, $sentinel_ttl);
+            dfehc_set_transient_noautoload($key, (float) DFEHC_SENTINEL_NO_LOAD, $sentinel_ttl);
             $ratio = (float) DFEHC_SENTINEL_NO_LOAD;
             $as_percent = (bool) apply_filters('dfehc_system_load_return_percent', false, $ratio);
 …
+        }
+        if (!is_finite($ratio)) {
+            $ratio = (float) DFEHC_SENTINEL_NO_LOAD;
+        }
         dfehc_set_transient_noautoload($key, $ratio, $ttl);
         $as_percent = (bool) apply_filters('dfehc_system_load_return_percent', false, $ratio);
         return $as_percent ? (float) round($ratio * 100, 2) : (float) $ratio;

dynamic-front-end-heartbeat-control/trunk/heartbeat-async.php

-                      r3412936
+                      r3424156
 if (!defined('DFEHC_CACHE_GROUP')) define('DFEHC_CACHE_GROUP', 'dfehc');
+function dfehc_max_server_load(): int { static $v; if ($v === null) { $v = (int) apply_filters('dfehc_max_server_load', 85); } return $v; }
+function dfehc_min_interval(): int { static $v; if ($v === null) { $v = (int) apply_filters('dfehc_min_interval', 15); } return $v; }
+function dfehc_max_interval(): int { static $v; if ($v === null) { $v = (int) apply_filters('dfehc_max_interval', 300); } return $v; }
+function dfehc_fallback_interval(): int { static $v; if ($v === null) { $v = (int) apply_filters('dfehc_fallback_interval', 60); } return $v; }
+if (!function_exists('dfehc_max_server_load')) {
+    function dfehc_max_server_load(): int { static $v; if ($v === null) { $v = (int) apply_filters('dfehc_max_server_load', 85); } return $v; }
+}
+if (!function_exists('dfehc_min_interval')) {
+    function dfehc_min_interval(): int { static $v; if ($v === null) { $v = (int) apply_filters('dfehc_min_interval', 15); } return $v; }
+}
+if (!function_exists('dfehc_max_interval')) {
+    function dfehc_max_interval(): int { static $v; if ($v === null) { $v = (int) apply_filters('dfehc_max_interval', 300); } return $v; }
+}
+if (!function_exists('dfehc_fallback_interval')) {
+    function dfehc_fallback_interval(): int { static $v; if ($v === null) { $v = (int) apply_filters('dfehc_fallback_interval', 60); } return $v; }
+}
 if (!function_exists('dfehc_host_token')) {
     function dfehc_host_token(): string
+    {
+        static $t = '';
+        if ($t !== '') return $t;
         $host = @php_uname('n') ?: (defined('WP_HOME') ? WP_HOME : (function_exists('home_url') ? home_url() : 'unknown'));
         $salt = defined('DB_NAME') ? (string) DB_NAME : '';
         return substr(md5((string) $host . $salt), 0, 10);
+        return $t = substr(md5((string) $host . $salt), 0, 10);
+    }
+}
 …
         dfehc_store_lockfree($key, $value, $expiration);
         global $wpdb;
+        if (!isset($wpdb) || !is_object($wpdb) || !isset($wpdb->options)) {
+            return;
+        }
         $opt_key = "_transient_$key";
         $opt_key_to = "_transient_timeout_$key";
 …
+    }
     protected function run_action(): void
+    public function run_action(): void
+    {
         $lock = dfehc_acquire_lock('dfehc_async_run', 30);
 …
 add_action('dfehc_prune_logs_hook', 'dfehc_prune_server_load_logs');
+if (!wp_next_scheduled('dfehc_prune_logs_hook')) {
+function dfehc_schedule_prune_logs(): void
+{
+    if (!function_exists('wp_next_scheduled') || !function_exists('wp_schedule_event')) {
+        return;
+    }
+    if (wp_next_scheduled('dfehc_prune_logs_hook')) {
+        return;
+    }
     $t = strtotime('today 03:00');
     if ($t < time()) {
 …
     wp_schedule_event($t, 'dfehc_daily', 'dfehc_prune_logs_hook');
+}
+add_action('init', 'dfehc_schedule_prune_logs', 1);
 add_filter('dfehc_required_capability', function () { return 'manage_options'; });

dynamic-front-end-heartbeat-control/trunk/heartbeat-controller.php

-                      r3412970
+                      r3424156
 Plugin URI: https://heartbeat.support
 Description: An enhanced solution to optimize the performance of your WordPress website. Stabilize your website's load averages and enhance the browsing experience for visitors during high-traffic fluctuations.
 Version: 1.2.996.2
+Version: 1.2.997
 Author: Codeloghin
 Author URI: https://codeloghin.com
 …
 require_once DFEHC_PLUGIN_PATH . 'settings.php';
+function dfehc_scoped_tkey(string $base): string
+{
+    if (function_exists('dfehc_scoped_key')) {
+        return dfehc_scoped_key($base);
+    }
+    $bid = function_exists('get_current_blog_id') ? (string) get_current_blog_id() : '0';
+    $host = @php_uname('n') ?: (defined('WP_HOME') ? WP_HOME : (function_exists('home_url') ? home_url() : 'unknown'));
+    $salt = defined('DB_NAME') ? (string) DB_NAME : '';
+    $tok = substr(md5((string) $host . $salt), 0, 10);
+    return "{$base}_{$bid}_{$tok}";
+}
+function dfehc_set_transient_noautoload(string $key, $value, int $expiration): void
+{
+    $jitter = function_exists('random_int') ? random_int(0, 5) : 0;
+    $expiration = max(1, $expiration + $jitter);
+    if (function_exists('wp_using_ext_object_cache') && wp_using_ext_object_cache()) {
+        wp_cache_set($key, $value, DFEHC_CACHE_GROUP, $expiration);
+        return;
+    }
+    set_transient($key, $value, $expiration);
+    if (isset($GLOBALS['wpdb'])) {
+        global $wpdb;
+        if (!isset($wpdb->options)) {
+if (!function_exists('dfehc_scoped_tkey')) {
+    function dfehc_scoped_tkey(string $base): string
+    {
+        if (function_exists('dfehc_scoped_key')) {
+            return dfehc_scoped_key($base);
+        }
+        $bid = function_exists('get_current_blog_id') ? (string) get_current_blog_id() : '0';
+        $host = @php_uname('n') ?: (defined('WP_HOME') ? WP_HOME : (function_exists('home_url') ? home_url() : 'unknown'));
+        $salt = defined('DB_NAME') ? (string) DB_NAME : '';
+        $tok = substr(md5((string) $host . $salt), 0, 10);
+        return "{$base}_{$bid}_{$tok}";
+    }
+}
+if (!function_exists('dfehc_set_transient_noautoload')) {
+    function dfehc_set_transient_noautoload(string $key, $value, int $expiration): void
+    {
+        $jitter = 0;
+        if (function_exists('random_int')) {
+            try {
+                $jitter = random_int(0, 5);
+            } catch (\Throwable $e) {
+                $jitter = 0;
+            }
+        }
+        $expiration = max(1, $expiration + $jitter);
+        if (function_exists('wp_using_ext_object_cache') && wp_using_ext_object_cache()) {
+            wp_cache_set($key, $value, DFEHC_CACHE_GROUP, $expiration);
             return;
+        }
+        $opt_key_val = '_transient_' . $key;
+        $opt_key_to  = '_transient_timeout_' . $key;
+        $wpdb->suppress_errors(true);
+        $autoload = $wpdb->get_var($wpdb->prepare("SELECT autoload FROM {$wpdb->options} WHERE option_name=%s LIMIT 1", $opt_key_val));
+        if ($autoload === 'yes') {
+            $wpdb->query($wpdb->prepare("UPDATE {$wpdb->options} SET autoload='no' WHERE option_name=%s AND autoload='yes' LIMIT 1", $opt_key_val));
+        }
+        $autoload_to = $wpdb->get_var($wpdb->prepare("SELECT autoload FROM {$wpdb->options} WHERE option_name=%s LIMIT 1", $opt_key_to));
+        if ($autoload_to === 'yes') {
+            $wpdb->query($wpdb->prepare("UPDATE {$wpdb->options} SET autoload='no' WHERE option_name=%s AND autoload='yes' LIMIT 1", $opt_key_to));
+        }
+        $wpdb->suppress_errors(false);
+        set_transient($key, $value, $expiration);
+        if (isset($GLOBALS['wpdb'])) {
+            global $wpdb;
+            if (!isset($wpdb) || !is_object($wpdb) || !isset($wpdb->options)) {
+                return;
+            }
+            $opt_key_val = '_transient_' . $key;
+            $opt_key_to  = '_transient_timeout_' . $key;
+            $wpdb->suppress_errors(true);
+            $autoload = $wpdb->get_var($wpdb->prepare("SELECT autoload FROM {$wpdb->options} WHERE option_name=%s LIMIT 1", $opt_key_val));
+            if ($autoload === 'yes') {
+                $wpdb->query($wpdb->prepare("UPDATE {$wpdb->options} SET autoload='no' WHERE option_name=%s AND autoload='yes' LIMIT 1", $opt_key_val));
+            }
+            $autoload_to = $wpdb->get_var($wpdb->prepare("SELECT autoload FROM {$wpdb->options} WHERE option_name=%s LIMIT 1", $opt_key_to));
+            if ($autoload_to === 'yes') {
+                $wpdb->query($wpdb->prepare("UPDATE {$wpdb->options} SET autoload='no' WHERE option_name=%s AND autoload='yes' LIMIT 1", $opt_key_to));
+            }
+            $wpdb->suppress_errors(false);
+        }
+    }
+}
 …
         class Dfehc_Get_Recommended_Heartbeat_Interval_Async extends Heartbeat_Async
+        {
+            protected $action = 'dfehc_get_recommended_interval_async';
             public function dispatch(): void
+            {
-                $this->action = 'dfehc_get_recommended_interval_async';
                 if (has_action($this->action)) {
                     do_action($this->action);
 …
+            }
             protected function run_action(): void
+            public function run_action(): void
+            {
                 $lock = function_exists('dfehc_acquire_lock') ? dfehc_acquire_lock('dfehc_interval_calculation_lock', (int) DFEHC_LOCK_TTL) : null;
 …
+{
     check_ajax_referer(DFEHC_NONCE_ACTION, 'nonce');
     $ip = (string) ($_SERVER['REMOTE_ADDR'] ?? '0.0.0.0');
+    $ip = function_exists('dfehc_client_ip') ? (string) dfehc_client_ip() : (string) ($_SERVER['REMOTE_ADDR'] ?? '0.0.0.0');
     $rlk = dfehc_scoped_tkey('dfehc_rl_' . md5($ip));
     $cnt = (int) get_transient($rlk);

dynamic-front-end-heartbeat-control/trunk/readme.txt

-                      r3412883
+                      r3424156
 Tested up to:      6.9
 Requires PHP:      7.2
 Stable tag:        1.2.996.2
+Stable tag:        1.2.997
 License:           GPLv2 or later
 License URI:       https://www.gnu.org/licenses/gpl-2.0.html
 …
 == Changelog ==
+= 1.2.997 =
+* General enhancements.
 = 1.2.996.2 =

dynamic-front-end-heartbeat-control/trunk/visitor/cookie-helper.php

-                      r3412283
+                      r3424156
     ]);
     $tokens = array_map(
+        static fn(string $s): string =>
+            '(?<![A-Za-z0-9])' . preg_quote($s, '/') . '(?![A-Za-z0-9])',
+        static function (string $s): string {
+            return '(?<![A-Za-z0-9])' . preg_quote($s, '/') . '(?![A-Za-z0-9])';
+        },
         $sigs
     );
 …
     function dfehc_client_ip(): string
+    {
+        $ip = (string) ($_SERVER['REMOTE_ADDR'] ?? '0.0.0.0');
+        return (string) apply_filters('dfehc_client_ip', $ip);
+        $remote = (string) ($_SERVER['REMOTE_ADDR'] ?? '');
+        $remote = trim($remote);
+        $trustedCidrs = (array) apply_filters('dfehc_trusted_proxies', []);
+        $isTrustedRemote = false;
+        if ($remote !== '' && $trustedCidrs) {
+            foreach ($trustedCidrs as $cidr) {
+                if (is_string($cidr) && dfehc_ip_in_cidr($remote, $cidr)) {
+                    $isTrustedRemote = true;
+                    break;
+                }
+            }
+        }
+        $cand = null;
+        if ($isTrustedRemote) {
+            $headers = (array) apply_filters('dfehc_proxy_ip_headers', ['HTTP_X_FORWARDED_FOR', 'HTTP_CF_CONNECTING_IP', 'HTTP_X_REAL_IP']);
+            foreach ($headers as $h) {
+                if (empty($_SERVER[$h])) {
+                    continue;
+                }
+                $raw = trim((string) $_SERVER[$h]);
+                if ($raw === '') {
+                    continue;
+                }
+                if ($h === 'HTTP_X_FORWARDED_FOR') {
+                    $picked = dfehc_select_client_ip_from_xff($raw, $trustedCidrs);
+                    if ($picked !== null) {
+                        $cand = $picked;
+                        break;
+                    }
+                    continue;
+                }
+                $raw = preg_replace('/%[0-9A-Za-z.\-]+$/', '', $raw);
+                if ($raw !== '' && filter_var($raw, FILTER_VALIDATE_IP)) {
+                    $cand = $raw;
+                    break;
+                }
+            }
+        }
+        if ($cand === null) {
+            $cand = $remote !== '' && filter_var($remote, FILTER_VALIDATE_IP) ? $remote : '0.0.0.0';
+        }
+        return (string) apply_filters('dfehc_client_ip', $cand);
+    }
+}
 …
         global $wpdb;
         if (!isset($wpdb->options)) {
+        if (!isset($wpdb) || !is_object($wpdb) || !isset($wpdb->options)) {
             return;
+        }
 …
         $opt_key_to = "_transient_timeout_$key";
         $wpdb->suppress_errors(true);
+        $autoload = $wpdb->get_var($wpdb->prepare("SELECT autoload FROM {$wpdb->options} WHERE option_name=%s LIMIT 1", $opt_key));
+        if ($autoload === 'yes') {
+            $wpdb->update(
+                $wpdb->options,
+                ['autoload' => 'no'],
+                ['option_name' => $opt_key, 'autoload' => 'yes'],
+                ['%s'],
+                ['%s', '%s']
+            );
+        }
+        $autoload_to = $wpdb->get_var($wpdb->prepare("SELECT autoload FROM {$wpdb->options} WHERE option_name=%s LIMIT 1", $opt_key_to));
+        if ($autoload_to === 'yes') {
+            $wpdb->update(
+                $wpdb->options,
+                ['autoload' => 'no'],
+                ['option_name' => $opt_key_to, 'autoload' => 'yes'],
+                ['%s'],
+                ['%s', '%s']
+            );
+        }
+        $wpdb->suppress_errors(false);
+        try {
+            $autoload = $wpdb->get_var($wpdb->prepare("SELECT autoload FROM {$wpdb->options} WHERE option_name=%s LIMIT 1", $opt_key));
+            if ($autoload === 'yes') {
+                $wpdb->update(
+                    $wpdb->options,
+                    ['autoload' => 'no'],
+                    ['option_name' => $opt_key, 'autoload' => 'yes'],
+                    ['%s'],
+                    ['%s', '%s']
+                );
+            }
+            $autoload_to = $wpdb->get_var($wpdb->prepare("SELECT autoload FROM {$wpdb->options} WHERE option_name=%s LIMIT 1", $opt_key_to));
+            if ($autoload_to === 'yes') {
+                $wpdb->update(
+                    $wpdb->options,
+                    ['autoload' => 'no'],
+                    ['option_name' => $opt_key_to, 'autoload' => 'yes'],
+                    ['%s'],
+                    ['%s', '%s']
+                );
+            }
+        } finally {
+            $wpdb->suppress_errors(false);
+        }
+    }
+}
 …
     if ($ip && function_exists('wp_using_ext_object_cache') && wp_using_ext_object_cache() && function_exists('wp_cache_incr')) {
         $rpmKey = dfehc_scoped_key('dfehc_iprpm_') . md5($ip);
+        $rpmTtl = 60 + (function_exists('random_int') ? random_int(0, 5) : 0);
+        $rpmTtl = 60;
+        if (function_exists('random_int')) {
+            try {
+                $rpmTtl += random_int(0, 5);
+            } catch (\Throwable $e) {
+            }
+        }
         if (false === wp_cache_add($rpmKey, 0, $group, $rpmTtl)) {
             wp_cache_set($rpmKey, (int) (wp_cache_get($rpmKey, $group) ?: 0), $group, $rpmTtl);
 …
     $existing = $_COOKIE[$name] ?? '';
     $val = $existing;
     if (!preg_match('/^[A-Fa-f0-9]{32,64}$/', (string) $val)) {
         if (function_exists('random_bytes')) {
+            $val = bin2hex(random_bytes(16));
+            try {
+                $val = bin2hex(random_bytes(16));
+            } catch (\Throwable $e) {
+                $val = bin2hex(pack('H*', substr(sha1(uniqid((string) mt_rand(), true)), 0, 32)));
+            }
         } else {
             $val = bin2hex(pack('H*', substr(sha1(uniqid((string) mt_rand(), true)), 0, 32)));
 …
     if (function_exists('wp_using_ext_object_cache') && wp_using_ext_object_cache() && function_exists('wp_cache_incr')) {
+        $vTtl = $lifetime + (function_exists('random_int') ? random_int(0, 5) : 0);
+        $vTtl = $lifetime;
+        if (function_exists('random_int')) {
+            try {
+                $vTtl += random_int(0, 5);
+            } catch (\Throwable $e) {
+            }
+        }
         if (false === wp_cache_add($scopedVisitorKey, 0, $group, $vTtl)) {
             wp_cache_set($scopedVisitorKey, (int) (wp_cache_get($scopedVisitorKey, $group) ?: 0), $group, $vTtl);
 …
+    }
     if ($client) {
+        $client->incr($scopedVisitorKey);
+        $client->expire($scopedVisitorKey, $lifetime);
+        return;
+        try {
+            $client->incr($scopedVisitorKey);
+            $client->expire($scopedVisitorKey, $lifetime);
+            return;
+        } catch (\Throwable $e) {
+        }
+    }
 …
+    }
     if ($mem) {
+        $valInc = $mem->increment($scopedVisitorKey, 1);
+        if ($valInc === false) {
+            $mem->set($scopedVisitorKey, 1, $lifetime);
+        } else {
+            $mem->touch($scopedVisitorKey, $lifetime);
+        }
+        return;
+        try {
+            $valInc = $mem->increment($scopedVisitorKey, 1);
+            if ($valInc === false) {
+                $mem->set($scopedVisitorKey, 1, $lifetime);
+            } else {
+                if (method_exists($mem, 'touch')) {
+                    $mem->touch($scopedVisitorKey, $lifetime);
+                } else {
+                    $mem->set($scopedVisitorKey, (int) $valInc, $lifetime);
+                }
+            }
+            return;
+        } catch (\Throwable $e) {
+        }
+    }
     $cnt  = (int) get_transient($scopedVisitorKey);
+    $vTtl = $lifetime + (function_exists('random_int') ? random_int(0, 5) : 0);
+    $vTtl = $lifetime;
+    if (function_exists('random_int')) {
+        try {
+            $vTtl += random_int(0, 5);
+        } catch (\Throwable $e) {
+        }
+    }
     dfehc_set_transient_noautoload($scopedVisitorKey, $cnt + 1, $vTtl);
+}

dynamic-front-end-heartbeat-control/trunk/visitor/manager.php

-                      r3412283
+                      r3424156
     function dfehc_set_transient_noautoload(string $key, $value, int $expiration): void {
         $group = defined('DFEHC_CACHE_GROUP') ? DFEHC_CACHE_GROUP : 'dfehc';
         if (function_exists('wp_using_ext_object_cache') && wp_using_ext_object_cache()) {
             if (function_exists('wp_cache_add')) {
 …
             return;
+        }
         set_transient($key, $value, $expiration);
         global $wpdb;
         if (!isset($wpdb->options)) return;
+        if (!isset($wpdb) || !is_object($wpdb) || !isset($wpdb->options)) return;
         $opt_key = "_transient_$key";
         $opt_key_to = "_transient_timeout_$key";
         $wpdb->suppress_errors(true);
+        $autoload = $wpdb->get_var($wpdb->prepare("SELECT autoload FROM {$wpdb->options} WHERE option_name=%s LIMIT 1", $opt_key));
+        if ($autoload === 'yes') {
+            $wpdb->update($wpdb->options, ['autoload' => 'no'], ['option_name' => $opt_key, 'autoload' => 'yes'], ['%s'], ['%s','%s']);
+        }
+        $autoload_to = $wpdb->get_var($wpdb->prepare("SELECT autoload FROM {$wpdb->options} WHERE option_name=%s LIMIT 1", $opt_key_to));
+        if ($autoload_to === 'yes') {
+            $wpdb->update($wpdb->options, ['autoload' => 'no'], ['option_name' => $opt_key_to, 'autoload' => 'yes'], ['%s'], ['%s','%s']);
+        }
+        $wpdb->suppress_errors(false);
+        try {
+            $autoload = $wpdb->get_var($wpdb->prepare("SELECT autoload FROM {$wpdb->options} WHERE option_name=%s LIMIT 1", $opt_key));
+            if ($autoload === 'yes') {
+                $wpdb->update($wpdb->options, ['autoload' => 'no'], ['option_name' => $opt_key, 'autoload' => 'yes'], ['%s'], ['%s','%s']);
+            }
+            $autoload_to = $wpdb->get_var($wpdb->prepare("SELECT autoload FROM {$wpdb->options} WHERE option_name=%s LIMIT 1", $opt_key_to));
+            if ($autoload_to === 'yes') {
+                $wpdb->update($wpdb->options, ['autoload' => 'no'], ['option_name' => $opt_key_to, 'autoload' => 'yes'], ['%s'], ['%s','%s']);
+            }
+        } finally {
+            $wpdb->suppress_errors(false);
+        }
+    }
+}
 …
         return null;
+    }
+}
+if (!function_exists('dfehc_release_lock')) {
     function dfehc_release_lock($lock): void {
         if ($lock instanceof WP_Lock) {
 …
         if (is_object($lock) && isset($lock->cache_key)) {
             $group = $lock->cache_group ?? apply_filters('dfehc_cache_group', defined('DFEHC_CACHE_GROUP') ? DFEHC_CACHE_GROUP : 'dfehc');
+            wp_cache_delete($lock->cache_key, $group);
+            if (function_exists('wp_cache_delete')) {
+                wp_cache_delete($lock->cache_key, $group);
+            }
             return;
+        }
 …
 function dfehc_add_intervals(array $s): array {
+    $s['dfehc_5_minutes'] ??= ['interval' => 300, 'display' => __('Every 5 minutes (DFEHC)', 'dfehc')];
+    $s['dfehc_daily'] ??= ['interval' => DAY_IN_SECONDS, 'display' => __('Daily (DFEHC)', 'dfehc')];
+    if (!isset($s['dfehc_5_minutes'])) {
+        $s['dfehc_5_minutes'] = ['interval' => 300, 'display' => __('Every 5 minutes (DFEHC)', 'dfehc')];
+    }
+    if (!isset($s['dfehc_daily'])) {
+        $s['dfehc_daily'] = ['interval' => DAY_IN_SECONDS, 'display' => __('Daily (DFEHC)', 'dfehc')];
+    }
     return $s;
+}
 …
 function dfehc_schedule_user_activity_processing(): void {
     $lock = dfehc_acquire_lock('dfehc_cron_sched_lock', 15);
+    if (!$lock) {
+        return;
+    }
     $aligned = time() - time() % 300 + 300;
+    if (!get_option('dfehc_activity_cron_scheduled') && !wp_next_scheduled('dfehc_process_user_activity')) {
+        $ok = wp_schedule_event($aligned, 'dfehc_5_minutes', 'dfehc_process_user_activity');
+        if ($ok) {
+            update_option('dfehc_activity_cron_scheduled', 1, false);
+        } else {
+            wp_schedule_single_event($aligned, 'dfehc_process_user_activity');
+        }
+    }
+    if (!wp_next_scheduled('dfehc_cleanup_user_activity')) {
+        $args = [0, (int) apply_filters('dfehc_cleanup_batch_size', 75)];
+        $ok2 = wp_schedule_event($aligned + 300, 'dfehc_daily', 'dfehc_cleanup_user_activity', $args);
+        if (!$ok2) {
+            wp_schedule_single_event($aligned + 300, 'dfehc_cleanup_user_activity', $args);
+        }
+    }
+    if ($lock) {
+    try {
+        if (!get_option('dfehc_activity_cron_scheduled') && !wp_next_scheduled('dfehc_process_user_activity')) {
+            $ok = wp_schedule_event($aligned, 'dfehc_5_minutes', 'dfehc_process_user_activity');
+            if ($ok && !is_wp_error($ok)) {
+                update_option('dfehc_activity_cron_scheduled', 1, false);
+            } else {
+                wp_schedule_single_event($aligned, 'dfehc_process_user_activity');
+            }
+        }
+        if (!wp_next_scheduled('dfehc_cleanup_user_activity')) {
+            $args = [0, (int) apply_filters('dfehc_cleanup_batch_size', 75)];
+            $ok2 = wp_schedule_event($aligned + 300, 'dfehc_daily', 'dfehc_cleanup_user_activity', $args);
+            if (!$ok2 || is_wp_error($ok2)) {
+                wp_schedule_single_event($aligned + 300, 'dfehc_cleanup_user_activity', $args);
+            }
+        }
+    } finally {
         dfehc_release_lock($lock);
+    }
 …
+    }
     $prev = (bool) ignore_user_abort(true);
+    $prev = (bool) ignore_user_abort(true);
     try {
 …
+    }
     global $wpdb;
+    if (!isset($wpdb) || !is_object($wpdb) || !isset($wpdb->users)) {
+        return;
+    }
     $meta_key = (string) apply_filters('dfehc_last_activity_meta_key', 'last_activity_time');
     $batch = (int) apply_filters('dfehc_activity_processing_batch_size', 75);
 …
     $max_writes = (int) apply_filters('dfehc_activity_max_writes_per_run', 500);
     foreach ($ids as $id) {
         if (!get_user_meta($id, $meta_key, true)) {
             update_user_meta($id, $meta_key, $now);
+        if (!get_user_meta((int) $id, $meta_key, true)) {
+            update_user_meta((int) $id, $meta_key, $now);
             $written++;
             if ($written >= $max_writes) {
 …
+        }
+    }
+    update_option($last_id_opt, end($ids), false);
+    $last = end($ids);
+    update_option($last_id_opt, $last ? (int) $last : (int) $last_id, false);
     update_option(dfehc_scoped_key('dfehc_last_activity_cron'), time(), false);
+}
 …
     static $cache = [];
     $meta_key = (string) apply_filters('dfehc_last_activity_meta_key', 'last_activity_time');
+    $uid = get_current_user_id();
+    $uid = (int) get_current_user_id();
+    if ($uid <= 0) {
+        return;
+    }
     $now = time();
     $interval = (int) apply_filters('dfehc_activity_update_interval', 900);
 …
+    }
     $prev = (bool) ignore_user_abort(true);
+    $prev = (bool) ignore_user_abort(true);
     if (function_exists('set_time_limit')) {
 …
     try {
         global $wpdb;
+        if (!isset($wpdb) || !is_object($wpdb) || !isset($wpdb->users)) {
+            return;
+        }
         $meta_key = (string) apply_filters('dfehc_last_activity_meta_key', 'last_activity_time');
         $batch_size = (int) apply_filters('dfehc_cleanup_batch_size', $batch_size);
 …
             $wpdb->prepare(
                 "SELECT ID FROM $wpdb->users WHERE ID > %d ORDER BY ID ASC LIMIT %d",
                 $last_id,
                 $batch_size
+                (int) $last_id,
+                (int) $batch_size
+            )
         );
 …
         foreach ($ids as $id) {
+            $id = (int) $id;
             $ts = (int) get_user_meta($id, $meta_key, true);
             if ($ts && $ts < $cutoff) {
 …
         if (count($ids) === $batch_size) {
+            $delay = 15;
+            if (function_exists('random_int')) {
+                try {
+                    $delay += random_int(0, 5);
+                } catch (\Throwable $e) {
+                    $delay += rand(0, 5);
+                }
+            } else {
+                $delay += rand(0, 5);
+            }
             wp_schedule_single_event(
                 time() + 15 + (function_exists('random_int') ? random_int(0, 5) : rand(0, 5)),
+                time() + $delay,
                 'dfehc_cleanup_user_activity',
                 [end($ids), $batch_size]
+                [(int) end($ids), (int) $batch_size]
             );
+        }
 …
     } finally {
+        ignore_user_abort((bool) $prev);
+        ignore_user_abort((bool) $prev);
         dfehc_release_lock($lock);
+    }
 …
     $grp = apply_filters('dfehc_cache_group', defined('DFEHC_CACHE_GROUP') ? DFEHC_CACHE_GROUP : 'dfehc');
     $ttl = (int) apply_filters('dfehc_total_visitors_ttl', HOUR_IN_SECONDS);
+    $ttl += function_exists('random_int') ? random_int(0, 5) : 0;
+    if (function_exists('random_int')) {
+        try {
+            $ttl += random_int(0, 5);
+        } catch (\Throwable $e) {
+        }
+    }
     if (function_exists('wp_using_ext_object_cache') && wp_using_ext_object_cache() && function_exists('wp_cache_incr')) {
 …
+    }
     if ($redis) {
+        $redis->incr($key);
+        $redis->expire($key, $ttl);
+        return;
+        try {
+            $redis->incr($key);
+            $redis->expire($key, $ttl);
+            return;
+        } catch (\Throwable $e) {
+        }
+    }
 …
+    }
     if ($mem) {
+        $inc = $mem->increment($key, 1);
+        if ($inc === false) {
+            $mem->set($key, 1, $ttl);
+        } else {
+            $mem->touch($key, $ttl);
+        }
+        return;
+        try {
+            $inc = $mem->increment($key, 1);
+            if ($inc === false) {
+                $mem->set($key, 1, $ttl);
+            } else {
+                if (method_exists($mem, 'touch')) {
+                    $mem->touch($key, $ttl);
+                } else {
+                    $mem->set($key, (int) $inc, $ttl);
+                }
+            }
+            return;
+        } catch (\Throwable $e) {
+        }
+    }
     $cnt = (int) get_transient($key);
-    if ($cnt === 0) {
-        dfehc_set_transient_noautoload($key, 0, $ttl);
-        $cnt = 0;
+    }
     dfehc_set_transient_noautoload($key, $cnt + 1, $ttl);
+}
 …
+    }
+    $regen_ttl = MINUTE_IN_SECONDS + (function_exists('random_int') ? random_int(0, 5) : 0);
+    $regen_ttl = (int) MINUTE_IN_SECONDS;
+    if (function_exists('random_int')) {
+        try {
+            $regen_ttl += random_int(0, 5);
+        } catch (\Throwable $e) {
+        }
+    }
     dfehc_set_transient_noautoload($regen_key, true, $regen_ttl);
     $total = dfehc_safe_cache_get('dfehc_total_visitors');
     $ttl = (int) apply_filters('dfehc_visitors_cache_ttl', 10 * MINUTE_IN_SECONDS);
+    $ttl += function_exists('random_int') ? random_int(0, 5) : 0;
+    if (function_exists('random_int')) {
+        try {
+            $ttl += random_int(0, 5);
+        } catch (\Throwable $e) {
+        }
+    }
     dfehc_set_transient_noautoload($cache_key, (int) $total, $ttl);
     update_option($stale_opt, (int) $total, false);
 …
     if (!wp_next_scheduled('dfehc_reset_total_visitors_event')) {
         $ok = wp_schedule_event($aligned + HOUR_IN_SECONDS, 'hourly', 'dfehc_reset_total_visitors_event');
         if (!$ok) {
+        if (!$ok || is_wp_error($ok)) {
             wp_schedule_single_event($aligned + HOUR_IN_SECONDS, 'dfehc_reset_total_visitors_event');
+        }
 …
     $ts = $aligned + HOUR_IN_SECONDS;
     $ok = wp_schedule_event($ts, 'hourly', 'dfehc_reset_total_visitors_event');
     if (!$ok) {
+    if (!$ok || is_wp_error($ok)) {
         wp_schedule_single_event($ts, 'dfehc_reset_total_visitors_event');
+    }

dynamic-front-end-heartbeat-control/trunk/widget.php

-                      r3303997
+                      r3424156
     if ($heartbeat_status === false) {
         $heartbeat_status = get_option('dfehc_disable_heartbeat') ? 'Stopped' : dfehc_get_server_health_status($server_load);
         set_transient('dfehc_heartbeat_health_status', $heartbeat_status, 60);
+        set_transient('dfehc_heartbeat_health_status', $heartbeat_status, 20);
+    }
 …
+    }
+    $min_interval = (int) get_option('dfehc_min_interval', 15);
+    $max_interval = (int) get_option('dfehc_max_interval', 300);
+    $max_response_time = (float) get_option('dfehc_max_response_time', 5.0);
+    $ema_alpha = (float) get_option('dfehc_ema_alpha', 0.35);
+    $min_interval = max(1, $min_interval);
+    $max_interval = max($min_interval, $max_interval);
+    $max_response_time = max(0.1, $max_response_time);
+    $ema_alpha = max(0.01, min(1.0, $ema_alpha));
+    $glow_rgb = '0, 204, 0';
+    if ($status_color === 'yellow') $glow_rgb = '255, 204, 0';
+    elseif ($status_color === 'red') $glow_rgb = '204, 0, 0';
+    elseif ($status_color === 'black') $glow_rgb = '0, 0, 0';
+    $server_load_text = '';
+    if (is_numeric($server_load)) {
+        $server_load_text = (string) round((float) $server_load, 2);
+    } elseif (is_scalar($server_load) && $server_load !== null) {
+        $server_load_text = (string) $server_load;
+    } else {
+        $server_load_text = function_exists('wp_json_encode') ? (string) wp_json_encode($server_load) : (string) json_encode($server_load);
+    }
+    $response_seconds = 0.0;
+    if (is_numeric($server_response_time)) {
+        $response_seconds = (float) $server_response_time;
+    } elseif (is_array($server_response_time)) {
+        if (isset($server_response_time['main_response_ms']) && is_numeric($server_response_time['main_response_ms'])) {
+            $response_seconds = ((float) $server_response_time['main_response_ms']) / 1000.0;
+        } elseif (isset($server_response_time['response_time']) && is_numeric($server_response_time['response_time'])) {
+            $response_seconds = (float) $server_response_time['response_time'];
+        } elseif (isset($server_response_time['response_ms']) && is_numeric($server_response_time['response_ms'])) {
+            $response_seconds = ((float) $server_response_time['response_ms']) / 1000.0;
+        }
+    } elseif (is_object($server_response_time)) {
+        $arr = (array) $server_response_time;
+        if (isset($arr['main_response_ms']) && is_numeric($arr['main_response_ms'])) {
+            $response_seconds = ((float) $arr['main_response_ms']) / 1000.0;
+        } elseif (isset($arr['response_time']) && is_numeric($arr['response_time'])) {
+            $response_seconds = (float) $arr['response_time'];
+        } elseif (isset($arr['response_ms']) && is_numeric($arr['response_ms'])) {
+            $response_seconds = ((float) $arr['response_ms']) / 1000.0;
+        }
+    }
+    $response_seconds = max(0.0, $response_seconds);
+    $response_display = (string) round($response_seconds, 3);
+    $recommended_interval_text = (string) round((float) $recommended_interval, 2);
+    $ajax_url = function_exists('admin_url') ? admin_url('admin-ajax.php') : '';
+    $ajax_nonce = function_exists('wp_create_nonce') ? wp_create_nonce('dfehc_widget_stats') : '';
     echo "<style>
         .heartbeat {
 …
 %, 100% { box-shadow: 0 0 5px {$status_color}, 0 0 10px {$status_color}; }
+        }
+        .dfehc-pulse-wrap {
+            --size: 30px;
+            --pulse-color: {$status_color};
+            --glow-rgb: {$glow_rgb};
+            display: flex;
+            justify-content: center;
+            align-items: center;
+            margin: 20px auto;
+            width: var(--size);
+            height: var(--size);
+        }
+        .dfehc-pulse {
+            position: relative;
+            width: var(--size);
+            height: var(--size);
+            border-radius: 50%;
+            background: var(--pulse-color);
+            overflow: hidden;
+            animation: dfehc-heartbeat 2s ease-in-out infinite, {$animation_name} 2s linear infinite;
+        }
+        .dfehc-pulse::before {
+            content: '';
+            position: absolute;
+            top: 50%;
+            left: 50%;
+            width: 190%;
+            height: 190%;
+            transform: translate(-50%, -50%) scale(0.9);
+            border-radius: 50%;
+            background: radial-gradient(circle, rgba(var(--glow-rgb), 0.22) 0%, rgba(var(--glow-rgb), 0.10) 34%, rgba(var(--glow-rgb), 0) 70%);
+            pointer-events: none;
+            opacity: 0.55;
+            filter: blur(0.2px);
+            animation: dfehc-glow-sync 2s ease-in-out infinite;
+        }
+        .dfehc-spark {
+            position: absolute;
+            top: 50%;
+            left: 50%;
+            width: 4%;
+            height: 4%;
+            border-radius: 50%;
+            background: radial-gradient(circle at center, #ffffff 0%, #eaffea 70%, #d4ffd4 100%);
+            box-shadow: 0 0 12px 2px #ffffff, 0 0 24px 6px rgba(var(--glow-rgb), 0.35);
+            transform-origin: 0 0;
+            animation: dfehc-orbit var(--duration,6s) linear forwards, dfehc-flash var(--duration,6s) ease-in-out forwards;
+            pointer-events: none;
+        }
+        @keyframes dfehc-heartbeat {
+%   { transform: scale(1); }
+%  { transform: scale(1.1); }
+%  { transform: scale(0.96); }
+%  { transform: scale(1.05); }
+% { transform: scale(1); }
+        }
+        @keyframes dfehc-glow-sync {
+%   { transform: translate(-50%, -50%) scale(0.92); opacity: 0.35; }
+%  { transform: translate(-50%, -50%) scale(1.18); opacity: 0.90; }
+%  { transform: translate(-50%, -50%) scale(1.02); opacity: 0.55; }
+%  { transform: translate(-50%, -50%) scale(1.12); opacity: 0.78; }
+% { transform: translate(-50%, -50%) scale(0.92); opacity: 0.35; }
+        }
+        @keyframes dfehc-orbit {
+            from { transform: rotate(0deg) translate(var(--radius, 0px)) scale(1); }
+            to   { transform: rotate(360deg) translate(var(--radius, 0px)) scale(1); }
+        }
+        @keyframes dfehc-flash {
+%, 95%, 100% { opacity: 0; box-shadow: 0 0 8px 2px #ffffff, 0 0 16px 4px rgba(var(--glow-rgb), 0.30); }
+%, 55%      { opacity: 0.7; box-shadow: 0 0 14px 3px #ffffff, 0 0 24px 6px rgba(var(--glow-rgb), 0.45); }
+        }
+        .dfehc-matrix {
+            width: 100%;
+            max-width: 520px;
+            margin: 14px auto 0;
+            border-radius: 10px;
+            border: 1px solid rgba(0,0,0,0.10);
+            background: rgba(255,255,255,0.75);
+            box-shadow: 0 8px 20px rgba(0,0,0,0.06);
+            overflow: hidden;
+            cursor: pointer;
+            user-select: none;
+            -webkit-tap-highlight-color: transparent;
+            transition: transform 120ms ease, box-shadow 120ms ease, background 120ms ease, opacity 120ms ease;
+        }
+        .dfehc-matrix:hover {
+            box-shadow: 0 10px 24px rgba(0,0,0,0.08);
+            transform: translateY(-1px);
+        }
+        .dfehc-matrix:active {
+            transform: translateY(0px) scale(0.99);
+            opacity: 0.98;
+        }
+        .dfehc-matrix.is-loading {
+            opacity: 0.65;
+        }
+        .dfehc-matrix-inner {
+            display: grid;
+            grid-template-columns: 1fr 1fr 1fr;
+            gap: 0;
+        }
+        .dfehc-matrix-cell {
+            padding: 10px 12px;
+            text-align: center;
+        }
+        .dfehc-matrix-cell + .dfehc-matrix-cell {
+            border-left: 1px solid rgba(0,0,0,0.08);
+        }
+        .dfehc-pulse.dfehc-ack {
+         animation-duration: 1.35s, 1.35s;
+        }
+        .dfehc-matrix-label {
+            font-size: 11px;
+            letter-spacing: 0.08em;
+            text-transform: uppercase;
+            color: rgba(0,0,0,0.55);
+            line-height: 1.2;
+            margin-bottom: 6px;
+        }
+        .dfehc-matrix-value {
+            font-size: 16px;
+            font-weight: 700;
+            color: #111;
+            line-height: 1.2;
+            font-variant-numeric: tabular-nums;
+            word-break: break-word;
+        }
+        .dfehc-matrix-unit {
+            font-size: 11px;
+            font-weight: 600;
+            color: rgba(0,0,0,0.55);
+            margin-left: 6px;
+        }
+        @media (max-width: 520px) {
+            .dfehc-matrix-inner {
+                grid-template-columns: 1fr;
+            }
+            .dfehc-matrix-cell + .dfehc-matrix-cell {
+                border-left: none;
+                border-top: 1px solid rgba(0,0,0,0.08);
+            }
+        }
+        @media (prefers-reduced-motion: reduce) {
+            .dfehc-pulse, .dfehc-pulse::before, .dfehc-spark { animation: none !important; }
+            .dfehc-matrix { transition: none !important; }
+        }
     </style>";
+    echo "<p style='text-align: center; font-size: 24px; margin-top: 20px;'>Systolic Pressure: <strong>{$server_load}</strong></p>";
+    echo "<div style='width: 30px; height: 30px; background-color: {$status_color}; margin: 20px auto; border-radius: 50%; animation: {$animation_name} 2s infinite;'></div>";
+    echo "<div class='dfehc-pulse-wrap'><div class='dfehc-pulse' aria-label='Heartbeat status indicator' style='margin-top: 20px;'></div></div>";
     echo "<p style='text-align: center; font-size: 24px; margin-top: 20px;'>Heartbeat: <strong>{$heartbeat_status}</strong></p>";
+    echo "<div class='dfehc-matrix' id='dfehc-matrix' role='button' tabindex='0' aria-label='Refresh current heartbeat metrics' style='margin-bottom: 20px;'>
+            <div class='dfehc-matrix-inner'>
+                <div class='dfehc-matrix-cell'>
+                    <div class='dfehc-matrix-label'>Current Load</div>
+                    <div class='dfehc-matrix-value' id='dfehc-stat-load'>{$server_load_text}</div>
+                </div>
+                <div class='dfehc-matrix-cell'>
+                    <div class='dfehc-matrix-label'>Response Time</div>
+                    <div class='dfehc-matrix-value'><span id='dfehc-stat-rt'>{$response_display}</span><span class='dfehc-matrix-unit'>s</span></div>
+                </div>
+                <div class='dfehc-matrix-cell'>
+                    <div class='dfehc-matrix-label'>Interval</div>
+                    <div class='dfehc-matrix-value'><span id='dfehc-stat-int'>{$recommended_interval_text}</span><span class='dfehc-matrix-unit'>s</span></div>
+                </div>
+            </div>
+          </div>";
+    echo "<script>
+(function() {
+    var pulse = document.querySelector('.dfehc-pulse');
+    var box = document.getElementById('dfehc-matrix');
+    var elLoad = document.getElementById('dfehc-stat-load');
+    var elRt = document.getElementById('dfehc-stat-rt');
+    var elInt = document.getElementById('dfehc-stat-int');
+    if (pulse) {
+        pulse.style.cursor = 'pointer';
+        pulse.setAttribute('role', 'button');
+        pulse.setAttribute('tabindex', '0');
+        pulse.setAttribute('aria-label', 'Refresh heartbeat animation');
+    }
+    window.DFEHC_METRICS = window.DFEHC_METRICS || {};
+    window.DFEHC_METRICS.recommended_interval = " . json_encode((float) $recommended_interval) . ";
+    window.DFEHC_METRICS.server_response_time = " . json_encode((float) $response_seconds) . ";
+    window.DFEHC_METRICS.min_interval = " . json_encode((int) $min_interval) . ";
+    window.DFEHC_METRICS.max_interval = " . json_encode((int) $max_interval) . ";
+    window.DFEHC_METRICS.max_response_time = " . json_encode((float) $max_response_time) . ";
+    window.DFEHC_METRICS.ema_alpha = " . json_encode((float) $ema_alpha) . ";
+    function clamp(v, lo, hi) {
+        v = Number(v);
+        if (!Number.isFinite(v)) return lo;
+        return Math.max(lo, Math.min(hi, v));
+    }
+    function getSeed() {
+        try {
+            if (window.crypto && window.crypto.getRandomValues) {
+                var a = new Uint32Array(1);
+                window.crypto.getRandomValues(a);
+                return a[0] >>> 0;
+            }
+        } catch (e) {}
+        return (Date.now() >>> 0) ^ ((Math.random() * 0xffffffff) >>> 0);
+    }
+    function mulberry32(seed) {
+        var t = seed >>> 0;
+        return function() {
+            t += 0x6D2B79F5;
+            var x = t;
+            x = Math.imul(x ^ (x >>> 15), x | 1);
+            x ^= x + Math.imul(x ^ (x >>> 7), x | 61);
+            return ((x ^ (x >>> 14)) >>> 0) / 4294967296;
+        };
+    }
+    var rng = mulberry32(getSeed());
+    function rnd() { return rng(); }
+    function jitterFactor(pct) {
+        var p = clamp(pct, 0, 0.75);
+        return 1 + ((rnd() * 2 - 1) * p);
+    }
+    var emaStress = null;
+    function ema(next, alpha) {
+        var a = clamp(alpha, 0.01, 1.0);
+        if (emaStress === null) {
+            emaStress = next;
+            return emaStress;
+        }
+        emaStress = a * next + (1 - a) * emaStress;
+        return emaStress;
+    }
+    function getMetrics() {
+        var m = (window.DFEHC_METRICS && typeof window.DFEHC_METRICS === 'object') ? window.DFEHC_METRICS : {};
+        var minInterval = clamp(m.min_interval != null ? m.min_interval : 15, 1, 3600);
+        var maxInterval = clamp(m.max_interval != null ? m.max_interval : 300, minInterval, 36000);
+        var recInterval = clamp(m.recommended_interval != null ? m.recommended_interval : maxInterval, minInterval, maxInterval);
+        var rt = Number(m.server_response_time != null ? m.server_response_time : 0);
+        if (!Number.isFinite(rt)) rt = 0;
+        var maxRT = clamp(m.max_response_time != null ? m.max_response_time : 5.0, 0.1, 120);
+        if (rt > (maxRT * 3) && rt <= 60000) rt = rt / 1000;
+        rt = clamp(rt, 0, 600);
+        return { minInterval: minInterval, maxInterval: maxInterval, recInterval: recInterval, rt: rt, maxRT: maxRT };
+    }
+    function computeStress() {
+        var mm = getMetrics();
+        var intervalNorm = (mm.recInterval - mm.minInterval) / Math.max(1e-9, (mm.maxInterval - mm.minInterval));
+        intervalNorm = clamp(intervalNorm, 0, 1);
+        var activity = clamp(1 - intervalNorm, 0, 1);
+        var rtNorm = clamp(mm.rt / mm.maxRT, 0, 1);
+        var raw = clamp((0.65 * activity) + (0.35 * rtNorm), 0, 1);
+        var alpha = (window.DFEHC_METRICS && window.DFEHC_METRICS.ema_alpha != null) ? window.DFEHC_METRICS.ema_alpha : 0.35;
+        var smoothed = ema(raw, alpha);
+        return clamp(smoothed, 0, 1);
+    }
+    function pickSpawnDelayMs(stress) {
+        var minMs = 900;
+        var maxMs = 9500;
+        var base = maxMs - (stress * (maxMs - 1800));
+        return clamp(base * jitterFactor(0.18), minMs, maxMs);
+    }
+    function pickSparkDurationSec(stress) {
+        var minS = 2.6;
+        var maxS = 8.4;
+        var base = maxS - (stress * (maxS - 3.2));
+        return clamp(base * jitterFactor(0.12), minS, maxS);
+    }
+    function pickRadiusPx(stress) {
+        var w = pulse ? (pulse.clientWidth || 30) : 30;
+        var lo = 0.15;
+        var hi = 0.35;
+        var bias = lo + (hi - lo) * (0.25 + 0.75 * stress);
+        var pct = clamp(bias * jitterFactor(0.10), lo, hi);
+        return w * pct;
+    }
+    var sparkTimer = null;
+    var firstTimer = null;
+    var ackTimer = null;
+    function clearTimers() {
+        if (sparkTimer) { window.clearTimeout(sparkTimer); sparkTimer = null; }
+        if (firstTimer) { window.clearTimeout(firstTimer); firstTimer = null; }
+        if (ackTimer) { window.clearTimeout(ackTimer); ackTimer = null; }
+    }
+    function removeSparks() {
+        if (!pulse) return;
+        var sparks = pulse.querySelectorAll('.dfehc-spark');
+        for (var i = 0; i < sparks.length; i++) {
+            if (sparks[i] && sparks[i].parentNode) sparks[i].parentNode.removeChild(sparks[i]);
+        }
+    }
+    function restartCssAnimations() {
+        if (!pulse) return;
+        var prev = pulse.style.animation;
+        pulse.style.animation = 'none';
+        pulse.offsetHeight;
+        pulse.style.animation = prev || '';
+    }
+    function ackBeat() {
+        if (!pulse) return;
+        pulse.classList.add('dfehc-ack');
+        if (ackTimer) window.clearTimeout(ackTimer);
+        ackTimer = window.setTimeout(function() {
+            if (pulse) pulse.classList.remove('dfehc-ack');
+        }, 220);
+    }
+    function spawnSpark() {
+        if (!pulse) return;
+        var stress = computeStress();
+        var spark = document.createElement('span');
+        spark.className = 'dfehc-spark';
+        var duration = pickSparkDurationSec(stress).toFixed(2) + 's';
+        var radiusPx = pickRadiusPx(stress).toFixed(2) + 'px';
+        spark.style.setProperty('--duration', duration);
+        spark.style.setProperty('--radius', radiusPx);
+        pulse.appendChild(spark);
+        spark.addEventListener('animationend', function() {
+            if (spark && spark.parentNode) spark.parentNode.removeChild(spark);
+        });
+        sparkTimer = window.setTimeout(spawnSpark, pickSpawnDelayMs(stress));
+    }
+    function startSparks() {
+        if (!pulse) return;
+        clearTimers();
+        var s = computeStress();
+        var firstDelay = clamp((800 + (1 - s) * 2400) * jitterFactor(0.22), 400, 4200);
+        firstTimer = window.setTimeout(spawnSpark, firstDelay);
+    }
+    function refreshAnimation() {
+        rng = mulberry32(getSeed());
+        emaStress = null;
+        removeSparks();
+        restartCssAnimations();
+        ackBeat();
+        startSparks();
+    }
+    startSparks();
+    if (pulse) {
+        pulse.addEventListener('click', function() {
+            refreshAnimation();
+        });
+        pulse.addEventListener('keydown', function(e) {
+            var k = e.key || e.keyCode;
+            if (k === 'Enter' || k === ' ' || k === 13 || k === 32) {
+                e.preventDefault();
+                refreshAnimation();
+            }
+        });
+    }
+    var ajaxUrl = " . json_encode((string) $ajax_url) . ";
+    var ajaxNonce = " . json_encode((string) $ajax_nonce) . ";
+    var inFlight = false;
+    function parseResponseSeconds(payload) {
+        if (payload == null) return 0;
+        if (typeof payload === 'number' && isFinite(payload)) return Math.max(0, payload);
+        if (typeof payload === 'string') {
+            var n = Number(payload);
+            if (isFinite(n)) return Math.max(0, n);
+            return 0;
+        }
+        if (typeof payload === 'object') {
+            if (payload.main_response_ms != null && isFinite(Number(payload.main_response_ms))) return Math.max(0, Number(payload.main_response_ms) / 1000);
+            if (payload.response_ms != null && isFinite(Number(payload.response_ms))) return Math.max(0, Number(payload.response_ms) / 1000);
+            if (payload.response_time != null && isFinite(Number(payload.response_time))) return Math.max(0, Number(payload.response_time));
+        }
+        return 0;
+    }
+    function parseLoad(payload) {
+        if (payload == null) return '';
+        if (typeof payload === 'number' && isFinite(payload)) return String(Math.round(payload * 100) / 100);
+        if (typeof payload === 'string') {
+            var n = Number(payload);
+            if (isFinite(n)) return String(Math.round(n * 100) / 100);
+            return payload;
+        }
+        if (typeof payload === 'object') {
+            if (payload.load != null && isFinite(Number(payload.load))) return String(Math.round(Number(payload.load) * 100) / 100);
+            if (payload.server_load != null && isFinite(Number(payload.server_load))) return String(Math.round(Number(payload.server_load) * 100) / 100);
+        }
+        try { return JSON.stringify(payload); } catch (e) { return ''; }
+    }
+    function parseInterval(payload) {
+        var n = Number(payload);
+        if (isFinite(n)) return Math.max(0, n);
+        return 0;
+    }
+    function updateUI(data) {
+        if (elLoad && data && data.server_load != null) elLoad.textContent = parseLoad(data.server_load);
+        if (elRt && data && data.server_response_time != null) {
+            var s = parseResponseSeconds(data.server_response_time);
+            elRt.textContent = (Math.round(s * 1000) / 1000).toFixed(3);
+            window.DFEHC_METRICS.server_response_time = s;
+        }
+        if (elInt && data && data.recommended_interval != null) {
+            var iv = parseInterval(data.recommended_interval);
+            elInt.textContent = (Math.round(iv * 100) / 100).toFixed(2);
+            window.DFEHC_METRICS.recommended_interval = iv;
+        }
+    }
+    function refreshStats() {
+        if (!ajaxUrl || inFlight) return;
+        inFlight = true;
+        if (box) box.classList.add('is-loading');
+        var fd = new FormData();
+        fd.append('action', 'dfehc_widget_refresh_stats');
+        fd.append('_ajax_nonce', ajaxNonce);
+        fetch(ajaxUrl, { method: 'POST', credentials: 'same-origin', body: fd })
+            .then(function(r) { return r.json(); })
+            .then(function(json) {
+                if (json && json.success && json.data) updateUI(json.data);
+            })
+            .catch(function() {})
+            .finally(function() {
+                inFlight = false;
+                if (box) box.classList.remove('is-loading');
+            });
+    }
+    function onActivate(e) {
+        if (e && e.type === 'keydown') {
+            var k = e.key || e.keyCode;
+            if (k !== 'Enter' && k !== ' ' && k !== 13 && k !== 32) return;
+            e.preventDefault();
+        }
+        refreshStats();
+    }
+    if (box) {
+        box.addEventListener('click', onActivate);
+        box.addEventListener('keydown', onActivate);
+    }
+})();
+</script>";
     $labels = [];
     $data = [];
 …
         foreach ($load_logs as $log) {
             if ($log['timestamp'] >= $timestamp && $log['timestamp'] < ($timestamp + $interval)) {
                 $load_sum += $log['load'];
+                $load_sum += is_numeric($log['load']) ? (float) $log['load'] : 0;
                 $count++;
+            }
 …
     </script>';
+}
+add_action('wp_ajax_dfehc_widget_refresh_stats', function() {
+    if (!current_user_can('manage_options')) {
+        wp_send_json_error(['message' => 'forbidden'], 403);
+    }
+    check_ajax_referer('dfehc_widget_stats');
+    $server_load = dfehc_get_server_load();
+    $server_response_time = dfehc_get_server_response_time();
+    $recommended_interval = dfehc_calculate_recommended_interval_user_activity($server_load);
+    $response_seconds = 0.0;
+    if (is_numeric($server_response_time)) {
+        $response_seconds = (float) $server_response_time;
+    } elseif (is_array($server_response_time)) {
+        if (isset($server_response_time['main_response_ms']) && is_numeric($server_response_time['main_response_ms'])) {
+            $response_seconds = ((float) $server_response_time['main_response_ms']) / 1000.0;
+        } elseif (isset($server_response_time['response_ms']) && is_numeric($server_response_time['response_ms'])) {
+            $response_seconds = ((float) $server_response_time['response_ms']) / 1000.0;
+        } elseif (isset($server_response_time['response_time']) && is_numeric($server_response_time['response_time'])) {
+            $response_seconds = (float) $server_response_time['response_time'];
+        }
+    } elseif (is_object($server_response_time)) {
+        $arr = (array) $server_response_time;
+        if (isset($arr['main_response_ms']) && is_numeric($arr['main_response_ms'])) {
+            $response_seconds = ((float) $arr['main_response_ms']) / 1000.0;
+        } elseif (isset($arr['response_ms']) && is_numeric($arr['response_ms'])) {
+            $response_seconds = ((float) $arr['response_ms']) / 1000.0;
+        } elseif (isset($arr['response_time']) && is_numeric($arr['response_time'])) {
+            $response_seconds = (float) $arr['response_time'];
+        }
+    }
+    $response_seconds = max(0.0, $response_seconds);
+    wp_send_json_success([
+        'server_load' => $server_load,
+        'server_response_time' => $response_seconds,
+        'recommended_interval' => (float) $recommended_interval,
+    ]);
+});
 function dfehc_add_heartbeat_health_dashboard_widget() {

Note: See TracChangeset for help on using the changeset viewer.

Trac UI Preferences

Plugin Directory

Context Navigation

Changeset 3424156

Legend:

dynamic-front-end-heartbeat-control/trunk/defibrillator/cli-helper.php

dynamic-front-end-heartbeat-control/trunk/defibrillator/load-estimator.php

dynamic-front-end-heartbeat-control/trunk/engine/server-load.php

dynamic-front-end-heartbeat-control/trunk/engine/server-response.php

dynamic-front-end-heartbeat-control/trunk/engine/system-load-fallback.php

dynamic-front-end-heartbeat-control/trunk/heartbeat-async.php

dynamic-front-end-heartbeat-control/trunk/heartbeat-controller.php

dynamic-front-end-heartbeat-control/trunk/readme.txt

dynamic-front-end-heartbeat-control/trunk/visitor/cookie-helper.php

dynamic-front-end-heartbeat-control/trunk/visitor/manager.php

dynamic-front-end-heartbeat-control/trunk/widget.php

Download in other formats: