fix: Fix alarms for domain heartbeat failures

src/controllers/Domains.php

@@ -94,14 +94,8 @@ public function show(Request $request): Response
 
         $domain = models\Domain::requireFromRequest($request);
 
-        $alarms = models\Alarm::listByDomainIdOrderByDescCreatedAt($domain->id);
-        $last_heartbeat = models\Heartbeat::findLastHeartbeatByDomainId($domain->id);
-        $last_heartbeat_at = $last_heartbeat->created_at ?? null;
-
         return Response::ok('domains/show.phtml', [
             'domain' => $domain,
-            'last_heartbeat_at' => $last_heartbeat_at,
-            'alarms' => $alarms,
         ]);
     }
 

src/jobs/CheckAlarms.php

@@ -38,7 +38,7 @@ public function perform(): void
         $results = [];
 
         foreach ($domains as $domain) {
-            $heartbeat = models\Heartbeat::findLastHeartbeatByDomainId($domain->id);
+            $heartbeat = $domain->lastHeartbeat();
             if (!$heartbeat) {
                 continue;
             }

src/models/Domain.php

@@ -40,7 +40,7 @@ public function setId(string $url): void
 
     public function status(): string
     {
-        $last_heartbeat = Heartbeat::findLastHeartbeatByDomainId($this->id);
+        $last_heartbeat = $this->lastHeartbeat();
         if ($last_heartbeat) {
             if ($last_heartbeat->created_at <= \Minz\Time::ago(5, 'minutes')) {
                 return 'unknown';
@@ -54,6 +54,24 @@ public function status(): string
         }
     }
 
+    /**
+     * @return Alarm[]
+     */
+    public function alarms(): array
+    {
+        return Alarm::listByDomainIdOrderByDescCreatedAt($this->id);
+    }
+
+    public function lastHeartbeat(): ?Heartbeat
+    {
+        return Heartbeat::findLastHeartbeatByDomainId($this->id);
+    }
+
+    public function lastSuccessfulHeartbeat(): ?Heartbeat
+    {
+        return Heartbeat::findLastSuccessfulHeartbeatByDomainId($this->id);
+    }
+
     /**
      * @return self[]
      */

src/models/Heartbeat.php

@@ -51,6 +51,27 @@ public static function initError(string $domain_id, string $details): self
     }
 
     public static function findLastHeartbeatByDomainId(string $domain_id): ?self
+    {
+        $sql = <<<'SQL'
+            SELECT * FROM heartbeats
+            WHERE domain_id = ?
+            ORDER BY created_at DESC
+            LIMIT 1
+        SQL;
+
+        $database = Database::get();
+        $statement = $database->prepare($sql);
+        $statement->execute([$domain_id]);
+
+        $result = $statement->fetch();
+        if (is_array($result)) {
+            return self::fromDatabaseRow($result);
+        } else {
+            return null;
+        }
+    }
+
+    public static function findLastSuccessfulHeartbeatByDomainId(string $domain_id): ?self
     {
         $sql = <<<'SQL'
             SELECT * FROM heartbeats

src/views/domains/show.phtml

@@ -25,9 +25,10 @@
     </p>
 <?php endif; ?>
 
-<?php if ($last_heartbeat_at): ?>
+<?php $last_successful_heartbeat = $domain->lastSuccessfulHeartbeat(); ?>
+<?php if ($last_successful_heartbeat): ?>
     <p class="paragraph--centered paragraph--muted">
-        <?= _f('Last ping on %s', _d($last_heartbeat_at, 'EEE d MMM YYYY, HH:mm:ss')) ?>
+        <?= _f('Last ping on %s', _d($last_successful_heartbeat->created_at, 'EEE d MMM YYYY, HH:mm:ss')) ?>
     </p>
 <?php endif; ?>
 
@@ -37,6 +38,7 @@
     </a>
 </p>
 
+<?php $alarms = $domain->alarms(); ?>
 <?php if ($alarms): ?>
     <h2 id="alarms"><?= _('Alarms') ?></h2>