Admin report endpoint

api/Sources/Api/Models/Models+Duet.swift

@@ -13,6 +13,15 @@ extension Model {
     try await Current.db.create(self)
   }
 
+  @discardableResult
+  func upsert() async throws -> Self {
+    if (try? await Current.db.query(Self.self).byId(id).first()) != nil {
+      return try await create()
+    } else {
+      return try await save()
+    }
+  }
+
   func delete() async throws {
     try await Current.db.query(Self.self).byId(id).delete()
   }

api/Sources/Api/PairQL/SuperAdmin/QueryAdmins.swift

@@ -0,0 +1,95 @@
+import DuetSQL
+import Gertie
+import PairQL
+
+struct QueryAdmins: Pair {
+  static var auth: ClientAuth = .superAdmin
+
+  struct AdminData: PairOutput {
+    struct Child: PairNestable {
+      struct Installation: PairNestable {
+        let userId: Int
+        let appVersion: String
+        let filterVersion: String
+        let modelIdentifier: String
+        let appReleaseChannel: ReleaseChannel
+        let createdAt: Date
+      }
+
+      let name: String
+      let keyloggingEnabled: Bool
+      let screenshotsEnabled: Bool
+      let numKeychains: Int
+      let numKeys: Int
+      let numActivityItems: Int
+      let installations: [Installation]
+      let createdAt: Date
+    }
+
+    let id: Admin.Id
+    let email: EmailAddress
+    let subscriptionId: Admin.SubscriptionId?
+    let subscriptionStatus: Admin.SubscriptionStatus
+    let numNotifications: Int
+    let numKeychains: Int
+    let children: [Child]
+    let createdAt: Date
+  }
+
+  typealias Output = [AdminData]
+}
+
+// resolver
+
+extension QueryAdmins: NoInputResolver {
+  static func resolve(in context: Context) async throws -> Output {
+    let admins = try await Admin.query().all()
+    return try await admins.concurrentMap { admin in
+      async let notifications = admin.notifications()
+      async let keychains = admin.keychains()
+      async let children = admin.users()
+      return .init(
+        id: admin.id,
+        email: admin.email,
+        subscriptionId: admin.subscriptionId,
+        subscriptionStatus: admin.subscriptionStatus,
+        numNotifications: (try await notifications).count,
+        numKeychains: (try await keychains).count,
+        children: try await (try await children).concurrentMap { child in
+          async let keychains = child.keychains()
+          async let devices = child.devices()
+          var numKeys = 0
+          for keychain in try await keychains {
+            let keys = try await keychain.keys()
+            numKeys += keys.count
+          }
+          let deviceIds = try await devices.map(\.id)
+          async let screenshots = Screenshot.query().where(.userDeviceId |=| deviceIds).all()
+          async let keystrokes = KeystrokeLine.query().where(.userDeviceId |=| deviceIds).all()
+          let numActivityItems = (try await screenshots).count + (try await keystrokes).count
+          return .init(
+            name: child.name,
+            keyloggingEnabled: child.keyloggingEnabled,
+            screenshotsEnabled: child.screenshotsEnabled,
+            numKeychains: (try await keychains).count,
+            numKeys: numKeys,
+            numActivityItems: numActivityItems,
+            installations: try await (try await devices).concurrentMap { device in
+              let adminDevice = try await device.adminDevice()
+              return .init(
+                userId: device.numericId,
+                appVersion: device.appVersion,
+                filterVersion: adminDevice.filterVersion?.string ?? "unknown",
+                modelIdentifier: adminDevice.modelIdentifier,
+                appReleaseChannel: adminDevice.appReleaseChannel,
+                createdAt: device.createdAt
+              )
+            },
+            createdAt: child.createdAt
+          )
+        },
+        createdAt: admin.createdAt
+      )
+    }
+  }
+}

api/Sources/Api/PairQL/SuperAdmin/SuperAdmin.swift

@@ -7,12 +7,16 @@ enum SuperAdminRoute: PairRoute {
 
 enum AuthedSuperAdminRoute: PairRoute {
   case createRelease(CreateRelease.Input)
+  case queryAdmins
 
   static let router = OneOf {
     Route(/Self.createRelease) {
       Operation(CreateRelease.self)
       Body(.input(CreateRelease.self))
     }
+    Route(/Self.queryAdmins) {
+      Operation(QueryAdmins.self)
+    }
   }
 }
 
@@ -36,6 +40,9 @@ extension SuperAdminRoute: RouteResponder {
     case .createRelease(let input):
       let output = try await CreateRelease.resolve(with: input, in: context)
       return try await respond(with: output)
+    case .queryAdmins:
+      let output = try await QueryAdmins.resolve(in: context)
+      return try await respond(with: output)
     }
   }
 }

duet/Sources/Duet/Relation.swift

@@ -131,6 +131,15 @@ public enum OptionalChild<C: Duet.Identifiable> {
       return loaded
     }
   }
+
+  public mutating func useLoaded(or load: () async throws -> C?) async throws -> C? {
+    guard case .loaded(let loaded) = self else {
+      let optionalChild = try await load()
+      self = .loaded(optionalChild)
+      return optionalChild
+    }
+    return loaded
+  }
 }
 
 public func connect<P: Duet.Identifiable, C: Duet.Identifiable>(