create an endpoint for PUT-ing raw symbolgraphs to the server

Author: tayloraswift

Sources/HTTPServer/Channels/HTTPServerOperation.swift

@@ -18,19 +18,33 @@ protocol HTTPServerOperation:Sendable
         address:SocketAddress?,
         headers:HTTPHeaders,
         body:[UInt8])
+
+    init?(put uri:String,
+        address:SocketAddress?,
+        headers:HTTPHeaders,
+        body:[UInt8])
 }
 extension HTTPServerOperation
 {
     @inlinable public
-    init?(_ uri:String,
+    init?(get uri:String,
         address:SocketAddress?,
         headers:HTTPHeaders)
     {
         nil
     }
 
     @inlinable public
-    init?(_ uri:String,
+    init?(post uri:String,
+        address:SocketAddress?,
+        headers:HTTPHeaders,
+        body:[UInt8])
+    {
+        nil
+    }
+
+    @inlinable public
+    init?(put uri:String,
         address:SocketAddress?,
         headers:HTTPHeaders,
         body:[UInt8])

Sources/HTTPServer/Channels/ServerInterfaceHandler.swift

@@ -77,7 +77,7 @@ extension ServerInterfaceHandler:ChannelInboundHandler, RemovableChannelHandler
                     self.send(message: .init(status: .badRequest), context: context)
                 }
 
-            case .POST:
+            case .POST, .PUT:
                 self.request = (head, .init())
 
             case _:
@@ -119,10 +119,27 @@ extension ServerInterfaceHandler:ChannelInboundHandler, RemovableChannelHandler
 
             self.request = nil
 
-            if  let operation:Server.Operation = .init(post: head.uri,
+            let operation:Server.Operation?
+
+            switch head.method
+            {
+            case .POST:
+                operation = .init(post: head.uri,
                     address: self.address,
                     headers: head.headers,
                     body: body)
+
+            case .PUT:
+                operation = .init(put: head.uri,
+                    address: self.address,
+                    headers: head.headers,
+                    body: body)
+
+            case _:
+                fatalError("unreachable: collected buffers for method \(head.method)!")
+            }
+
+            if  let operation:Server.Operation
             {
                 self.server.submit(operation, promise: self.accept(context: context))
             }

Sources/Media/MediaSubtype.swift

@@ -3,6 +3,7 @@ enum MediaSubtype:String, Equatable, Hashable, Sendable
 {
     case apng
     case avif
+    case bson
     case css
     case gif
     case html
@@ -75,6 +76,7 @@ extension MediaSubtype
         {
         case .apng:                     return "apng"
         case .avif:                     return "avif"
+        case .bson:                     return "bson"
         case .css:                      return "css"
         case .gif:                      return "gif"
         case .html:                     return "html"

Sources/UnidocDB/Packages/UnidocDatabase.Graphs.swift

@@ -64,8 +64,8 @@ extension UnidocDatabase.Graphs
     {
         switch try await self.upsert(some: graph, with: session)
         {
-        case nil:   return .insert
-        case  _?:   return .update
+        case nil:   return .update
+        case  _?:   return .insert
         }
     }
 }

Sources/UnidocPages/API/Site.API.Put.swift

@@ -0,0 +1,11 @@
+extension Site.API
+{
+    @frozen public
+    enum Put:String
+    {
+        case symbolgraph
+    }
+}
+extension Site.API.Put:StaticAPI
+{
+}

Sources/UnidocServer/InteractiveOperation.swift renamed to Sources/UnidocServer/InteractiveEndpoint.swift

@@ -1,14 +1,14 @@
 import HTTP
 import UnidocPages
 
-protocol InteractiveOperation:Sendable
+protocol InteractiveEndpoint:Sendable
 {
     var statisticalType:WritableKeyPath<ServerTour.Stats.ByType, Int> { get }
 
-    func load(from server:Server.State,
-        with cookies:Server.Request.Cookies) async throws -> ServerResponse?
+    func load(from server:Server.InteractiveState,
+        with cookies:Server.Cookies) async throws -> ServerResponse?
 }
-extension InteractiveOperation
+extension InteractiveEndpoint
 {
     var statisticalType:WritableKeyPath<ServerTour.Stats.ByType, Int>
     {

Sources/UnidocServer/Operations/AnyForm.swift

@@ -7,17 +7,17 @@ import SymbolGraphs
 import UnidocDB
 import UnidocPages
 
-extension Server.Operation
+extension Server.Endpoint
 {
     enum Admin
     {
         case perform(Site.Admin.Action, MultipartForm?)
         case recode(Site.Admin.Recode)
     }
 }
-extension Server.Operation.Admin:RestrictedOperation
+extension Server.Endpoint.Admin:RestrictedEndpoint
 {
-    func load(from server:Server.State) async throws -> ServerResponse?
+    func load(from server:Server.InteractiveState) async throws -> ServerResponse?
     {
         let session:Mongo.Session = try await .init(from: server.db.sessions)
         let page:Site.Admin.Action.Complete

Sources/UnidocServer/Operations/Server.Operation.Admin.swift renamed to Sources/UnidocServer/Operations/Server.Endpoint.Admin.swift

@@ -2,16 +2,16 @@ import HTTP
 import MongoDB
 import UnidocPages
 
-extension Server.Operation
+extension Server.Endpoint
 {
     enum AdminDashboard
     {
         case status
     }
 }
-extension Server.Operation.AdminDashboard:RestrictedOperation
+extension Server.Endpoint.AdminDashboard:RestrictedEndpoint
 {
-    func load(from server:Server.State) async throws -> ServerResponse?
+    func load(from server:Server.InteractiveState) async throws -> ServerResponse?
     {
         let page:Site.Admin = .init(configuration: try await server.db.sessions.run(
                 command: Mongo.ReplicaSetGetConfiguration.init(),

Sources/UnidocServer/Operations/Server.Operation.AdminDashboard.swift renamed to Sources/UnidocServer/Operations/Server.Endpoint.AdminDashboard.swift

@@ -0,0 +1,45 @@
+extension Server.Endpoint
+{
+    struct AuthParameters
+    {
+        /// Only used for testing, never sent by GitHub.
+        var token:String?
+        /// Defined and sent by GitHub.
+        var state:String?
+        /// Defined and sent by GitHub.
+        var code:String?
+
+        private
+        init()
+        {
+            self.token = nil
+            self.state = nil
+            self.code = nil
+        }
+    }
+}
+extension Server.Endpoint.AuthParameters
+{
+    init(_ parameters:[(key:String, value:String)]?)
+    {
+        self.init()
+
+        guard
+        let parameters:[(key:String, value:String)]
+        else
+        {
+            return
+        }
+
+        for (key, value):(String, String) in parameters
+        {
+            switch key
+            {
+            case "token":   self.token = value
+            case "state":   self.state = value
+            case "code":    self.code = value
+            case _:         continue
+            }
+        }
+    }
+}