wire up the telescope implementation to the admin control panel

Author: tayloraswift

Sources/GitHubAPI/GraphQL.Response.swift

@@ -4,16 +4,10 @@ extension GraphQL
 {
     /// A GraphQL response wrapper, which contains a single field named ``data``.
     @frozen public
-    struct Response<Data> where Data:JSONDecodable
+    enum Response<Data> where Data:JSONDecodable
     {
-        public
-        var data:Data
-
-        @inlinable internal
-        init(data:Data)
-        {
-            self.data = data
-        }
+        case success(Data)
+        case failure(ServerError)
     }
 }
 extension GraphQL.Response:JSONObjectDecodable
@@ -22,11 +16,19 @@ extension GraphQL.Response:JSONObjectDecodable
     enum CodingKey:String, Sendable
     {
         case data
+        case errors
     }
 
     @inlinable public
     init(json:JSON.ObjectDecoder<CodingKey>) throws
     {
-        self.init(data: try json[.data].decode())
+        if  let data:Data = try json[.data]?.decode()
+        {
+            self = .success(data)
+        }
+        else
+        {
+            self = .failure(.init(json: try json[.errors].decode()))
+        }
     }
 }

Sources/GitHubAPI/GraphQL.ServerError.swift

@@ -0,0 +1,17 @@
+import JSON
+
+extension GraphQL
+{
+    @frozen public
+    struct ServerError:Error
+    {
+        @usableFromInline
+        let json:JSON.Array
+
+        @inlinable internal
+        init(json:JSON.Array)
+        {
+            self.json = json
+        }
+    }
+}

Sources/GitHubClient/GitHubClient.Connection.swift

@@ -62,8 +62,11 @@ extension GitHubClient<GitHub.API>.Connection
                 json.utf8 += buffer.readableBytesView
             }
 
-            let wrapper:GraphQL.Response<Response> = try json.decode()
-            return wrapper.data
+            switch try json.decode(GraphQL.Response<Response>.self)
+            {
+            case .success(let data):    return data
+            case .failure(let error):   throw error
+            }
 
         case 403?:
             if  let second:String = response.headers?["x-ratelimit-reset"].first,

Sources/Swiftinit/Tree/Swiftinit.API.Post.swift

@@ -8,6 +8,8 @@ extension Swiftinit.API
         case packageIndex = "package-index"
         case packageIndexTag = "package-index-tag"
 
+        case telescope = "telescope"
+
         case uplinkAll = "uplink-all"
         case uplink
         case unlink

Sources/SwiftinitPages/Surfaces/Administration/Swiftinit.AdminPage.swift

@@ -196,6 +196,30 @@ extension Swiftinit.AdminPage:Swiftinit.AdministrativePage
             }
         }
 
+        main[.form]
+        {
+            $0.enctype = "\(MediaType.application(.x_www_form_urlencoded))"
+            $0.action = "\(Swiftinit.API[.telescope])"
+            $0.method = "post"
+        }
+            content:
+        {
+            $0[.p]
+            {
+                $0[.input]
+                {
+                    $0.type = "number"
+                    $0.name = "days"
+                    $0.placeholder = "days"
+                }
+            }
+
+            $0[.p]
+            {
+                $0[.button] { $0.type = "submit" } = "Activate Package Telescope"
+            }
+        }
+
         //  Destructive actions.
         for action:Action in
         [

Sources/SwiftinitServer/Endpoints/Interactive/Swiftinit.AdminEndpoint.swift

@@ -13,6 +13,7 @@ extension Swiftinit
     {
         case perform(Swiftinit.AdminPage.Action, MultipartForm?)
         case recode(Swiftinit.AdminPage.Recode.Target)
+        case telescope(days:Int)
     }
 }
 extension Swiftinit.AdminEndpoint:RestrictedEndpoint
@@ -69,6 +70,12 @@ extension Swiftinit.AdminEndpoint:RestrictedEndpoint
 
         case .perform(.upload, nil):
             return nil
+
+        case .telescope(days: let days):
+            let updates:Mongo.Updates = try await server.db.crawlingWindows.create(days: days,
+                with: session)
+
+            return .ok("Updated \(updates.modified) of \(updates.selected) crawling windows.")
         }
 
         return .ok(page.resource(format: server.format))

Sources/SwiftinitServer/Plugins/GitHub.RepoNode.swift

@@ -135,7 +135,11 @@ extension GitHub.RepoNode:JSONObjectDecodable
             archived: try json[.archived].decode(),
             disabled: try json[.disabled].decode(),
             fork: try json[.fork].decode(),
-            homepage: try json[.homepage]?.decode(as: String.self) { $0.isEmpty ? nil : $0 },
+            //  Yes, `String?`, the GitHub API does occasionally return explicit null.
+            homepage: try json[.homepage]?.decode(as: String?.self)
+            {
+                $0.map { $0.isEmpty ? nil : $0 } ?? nil
+            },
             about: try json[.about]?.decode(to: String?.self),
             created: try json[.created].decode(),
             updated: try json[.updated].decode(),

Sources/SwiftinitServer/Plugins/GitHubClient.Connection (ext).swift

@@ -80,15 +80,15 @@ extension GitHubClient<GitHub.API>.Connection
     }
 
     func search(repos search:String,
-        limit:Int = 1000,
+        limit:Int = 100,
         pat:String) async throws -> GitHubPlugin.RepoTelescopeResponse
     {
         let query:JSON = .object
         {
             $0["query"] = """
             query
             {
-                search(query: \(search), type: REPOSITORY, first: \(limit))
+                search(query: "\(search)", type: REPOSITORY, first: \(limit))
                 {
                     nodes
                     {

Sources/SwiftinitServer/Swiftinit.AnyEndpoint.swift

@@ -348,6 +348,13 @@ extension Swiftinit.AnyEndpoint
                         tag: tag))
                 }
 
+            case .telescope:
+                if  let days:String = form["days"],
+                    let days:Int = .init(days)
+                {
+                    return .interactive(Swiftinit.AdminEndpoint.telescope(days: days))
+                }
+
             case .uplinkAll:
                 return .procedural(Swiftinit.GlobalUplinkEndpoint.init(
                     queue: form["queue"] == "true"))