Merge pull request #3077 from SwiftPackageIndex/add-mon-001-check-to-alerting

Add MON-001 check to alerting

Author: finestructure

Sources/App/Commands/Alerting.swift

@@ -48,7 +48,9 @@ enum Alerting {
             Current.logger().info("Validation time interval: \(timePeriod.hours)h, limit: \(limit)")
 
             let builds = try await Alerting.fetchBuilds(on: context.application.db, timePeriod: timePeriod, limit: limit)
-            try await Alerting.runChecks(for: builds)
+            try await Alerting.runBuildChecks(for: builds)
+            try await Alerting.runMonitoring001Check(on: context.application.db, timePeriod: timePeriod)
+                .log(check: "CHECK_MON_001")
         }
     }
 }
@@ -84,7 +86,7 @@ extension Alerting {
         }
     }
 
-    static func runChecks(for builds: [BuildInfo]) async throws {
+    static func runBuildChecks(for builds: [BuildInfo]) async throws {
         // to do
         // - [ ] doc gen is configured but it failed
 
@@ -128,6 +130,49 @@ extension Alerting {
             .map(BuildInfo.init)
         return builds
     }
+
+    struct Mon001Row: Decodable, CustomStringConvertible {
+        var owner: String
+        var repository: String
+        var status: Package.Status?
+        var processingStage: Package.ProcessingStage?
+        var updatedAt: Date
+
+        enum CodingKeys: String, CodingKey {
+            case owner
+            case repository
+            case status
+            case processingStage = "processing_stage"
+            case updatedAt = "updated_at"
+        }
+
+        var description: String {
+            "\(owner)/\(repository) \(status.map { $0.rawValue } ?? "-") \(processingStage.map { $0.rawValue } ?? "-") \(updatedAt)"
+        }
+    }
+
+    static func runMonitoring001Check(on database: Database, timePeriod: TimeAmount) async throws -> Alerting.Validation {
+        guard let db = database as? SQLDatabase else {
+            fatalError("Database must be an SQLDatabase ('as? SQLDatabase' must succeed)")
+        }
+        let rows = try await db.raw("""
+            SELECT
+              r.owner,
+              r.name AS "repository",
+              p.status,
+              p.processing_stage,
+              r.updated_at
+            FROM
+              repositories r
+              JOIN packages p ON r.package_id = p.id
+            WHERE
+              r.updated_at < now() - INTERVAL \(literal: "\(timePeriod.hours) hours")
+            ORDER BY
+              updated_at
+            """)
+            .all(decoding: Mon001Row.self)
+        return rows.isValid()
+    }
 }
 
 
@@ -222,6 +267,17 @@ extension [Alerting.BuildInfo] {
 }
 
 
+extension [Alerting.Mon001Row] {
+    func isValid() -> Alerting.Validation {
+        if isEmpty {
+            return .ok
+        } else {
+            return .failed(reasons: sorted(by: { $0.updatedAt < $1.updatedAt }).map { "Outdated package: \($0)" })
+        }
+    }
+}
+
+
 private extension TimeAmount {
     var timeInterval: TimeInterval {
         Double(nanoseconds) * 1e-9

Tests/AppTests/AlertingTests.swift

@@ -135,6 +135,20 @@ class AlertingTests: XCTestCase {
                            .failed(reasons: ["Global success rate of 40.1% out of bounds"]))
         }
     }
+
+    func test_Mon001Row_isValid() throws {
+        XCTAssertEqual([Alerting.Mon001Row]().isValid(), .ok)
+        XCTAssertEqual(
+            [
+                Alerting.Mon001Row(owner: "bar", repository: "2", status: .ok, processingStage: .analysis, updatedAt: .t1),
+                Alerting.Mon001Row(owner: "foo", repository: "1", status: nil, processingStage: nil, updatedAt: .t0)
+            ].isValid(),
+            .failed(reasons: [
+                "Outdated package: foo/1 - - 1970-01-01 00:00:00 +0000",
+                "Outdated package: bar/2 ok analysis 1970-01-01 00:00:01 +0000"
+            ])
+        )
+    }
 }