Merge pull request #235 from tayloraswift/ci-events-api

CI documentation state change events

Sources/HTTP/HTTP.swift

@@ -1,7 +1,7 @@
 /// Enumerates supported HTTP versions. This type also serves as a namespace for other
 /// HTTP-related types.
 @frozen public
-enum HTTP
+enum HTTP:Comparable
 {
     case http1_1
     case http2

Sources/HTTPServer/HTTP.ServerIntegralRequest.swift

@@ -13,8 +13,8 @@ extension HTTP
         init?(get uri:URI, headers:HPACKHeaders, origin:IP.Origin)
         init?(get uri:URI, headers:HTTPHeaders, origin:IP.Origin)
 
-        init?(post path:URI, headers:HPACKHeaders, origin:IP.Origin, body:borrowing [UInt8])
-        init?(post path:URI, headers:HTTPHeaders, origin:IP.Origin, body:borrowing [UInt8])
+        init?(post uri:URI, headers:HPACKHeaders, origin:IP.Origin, body:borrowing [UInt8])
+        init?(post uri:URI, headers:HTTPHeaders, origin:IP.Origin, body:borrowing [UInt8])
     }
 }
 extension HTTP.ServerIntegralRequest

Sources/HTTPServer/HTTP.ServerLoop.swift

@@ -44,7 +44,7 @@ extension HTTP.ServerLoop
         from binding:(address:String, port:Int),
         as authority:Authority,
         on threads:MultiThreadedEventLoopGroup,
-        policy:(some HTTP.ServerPolicy)? = nil) async throws
+        policy:(any HTTP.ServerPolicy)? = nil) async throws
         where Authority:HTTP.ServerAuthority
     {
         let bootstrap:ServerBootstrap = .init(group: threads)

Sources/HTTPServer/HTTP.ServerPolicy.swift

@@ -3,7 +3,7 @@ import IP
 extension HTTP
 {
     public
-    protocol ServerPolicy:Sendable
+    protocol ServerPolicy:AnyObject, Sendable
     {
         /// Loads the latest available policy list.
         func load() -> IP.Policylist?

Sources/HTTPServer/IP.Owner.swift

@@ -22,7 +22,7 @@ extension IP
         case known
 
         /// The IP address could not be mapped to an owner because the tables have
-        /// not been initialized yet. This is a distinct state from the nil case, because
+        /// not been initialized yet. This is a distinct state from the ``known`` case, because
         /// the IP might still belong to one of the enumerated services.
         case unknown
     }

Sources/UnidocDB/Mongo.Session (ext).swift

@@ -1,3 +1,5 @@
+import BSON
+import Durations
 import MongoDB
 
 extension Mongo.Session
@@ -20,6 +22,38 @@ extension Mongo.Session
     }
 }
 extension Mongo.Session
+{
+    @inlinable public
+    func observe<Source, Delta>(collection:Source,
+        every interval:Milliseconds = 30_000,
+        since start:inout BSON.Timestamp?,
+        yield:(Mongo.ChangeEvent<Delta>) async throws -> ()) async throws where
+        Source:Mongo.CollectionModel<Delta.Model>,
+        Delta:Mongo.MasterCodingDelta,
+        Delta:Sendable,
+        Delta.Model.CodingKey:Sendable,
+        Delta.Model:BSONDecodable
+    {
+        try await self.run(
+            command: Mongo.Aggregate<Mongo.Cursor<Mongo.ChangeEvent<Delta>>>.init(Source.name,
+                tailing: .init(timeout: interval, awaits: true))
+            {
+                $0[stage: .changeStream] { $0[.startAtOperationTime] = start }
+            },
+            against: collection.database)
+        {
+            for try await events:[Mongo.ChangeEvent<Delta>] in $0
+            {
+                for event:Mongo.ChangeEvent<Delta> in events
+                {
+                    try await yield(event)
+                    start = event.clusterTime
+                }
+            }
+        }
+    }
+}
+extension Mongo.Session
 {
     //  This should be part of the swift-mongodb package. An incredibly interesting statement,
     //  considering this method is private.