slow queries

src/Recorders/SlowQueries.php

@@ -37,32 +37,37 @@ public function __construct(
      */
     public function record(QueryExecuted $event): void
     {
-        $now = CarbonImmutable::now();
-
-        if ($event->time < $this->config->get('pulse.recorders.'.self::class.'.threshold')) {
-            return;
-        }
-
-        if (! $this->shouldSample() || $this->shouldIgnore($event->sql)) {
-            return;
-        }
-
-        $location = $this->config->get('pulse.recorders.'.self::class.'.location') ? $this->getLocation() : null;
-
-        $key = json_encode([$event->sql, $location], flags: JSON_THROW_ON_ERROR);
-
-        $this->pulse->record(
-            type: 'slow_query',
-            key: $key,
-            value: (int) $event->time,
-            timestamp: $now->subMilliseconds((int) $event->time),
-        )->max()->count();
+        [$timestampMs, $duration, $sql, $location] = [
+            CarbonImmutable::now()->getTimestampMs(),
+            (int) $event->time,
+            $event->sql,
+            $this->config->get('pulse.recorders.'.self::class.'.location')
+                ? $this->resolveLocation()
+                : null,
+        ];
+
+        $this->pulse->lazy(function () use ($timestampMs, $duration, $sql, $location) {
+            if (
+                $this->underThreshold($duration) ||
+                ! $this->shouldSample() ||
+                $this->shouldIgnore($sql)
+            ) {
+                return;
+            }
+
+            $this->pulse->record(
+                type: 'slow_query',
+                key: json_encode([$sql, $location], flags: JSON_THROW_ON_ERROR),
+                value: $duration,
+                timestamp: $timestampMs - $duration,
+            )->max()->count();
+        });
     }
 
     /**
-     * Get the location of the query.
+     * Resolve the location of the query.
      */
-    protected function getLocation(): string
+    protected function resolveLocation(): string
     {
         $backtrace = collect(debug_backtrace(DEBUG_BACKTRACE_IGNORE_ARGS))->skip(2);