Remove sync prefixes

Author: kmahar

Examples/Docs/Sources/DocsExamples/main.swift

@@ -6,7 +6,7 @@ import MongoSwift
 /// Examples used for the MongoDB documentation on Causal Consistency.
 /// - SeeAlso: https://docs.mongodb.com/manual/core/read-isolation-consistency-recency/#examples
 private func causalConsistency() throws {
-    let client1 = try SyncMongoClient()
+    let client1 = try MongoClient()
 
     // Start Causal Consistency Example 1
     let s1 = try client1.startSession(options: ClientSessionOptions(causalConsistency: true))
@@ -24,7 +24,7 @@ private func causalConsistency() throws {
     try items.insertOne(["sku": "nuts-111", "name": "Pecans", "start": .datetime(currentDate)], session: s1)
     // End Causal Consistency Example 1
 
-    let client2 = try SyncMongoClient()
+    let client2 = try MongoClient()
 
     // Start Causal Consistency Example 2
     try client2.withSession(options: ClientSessionOptions(causalConsistency: true)) { s2 in
@@ -44,7 +44,7 @@ private func causalConsistency() throws {
 /// Examples used for the MongoDB documentation on Change Streams.
 /// - SeeAlso: https://docs.mongodb.com/manual/changeStreams/
 private func changeStreams() throws {
-    let client = try SyncMongoClient()
+    let client = try MongoClient()
     let db = client.db("example")
 
     // The following examples assume that you have connected to a MongoDB replica set and have

Sources/AtlasConnectivity/main.swift

@@ -12,7 +12,7 @@ for config in configs {
     }
 
     do {
-        let client = try SyncMongoClient(uri)
+        let client = try MongoClient(uri)
         // run isMaster
         let db = client.db("test")
         _ = try db.runCommand(["isMaster": 1])

Sources/MongoSwift/APM.swift

@@ -481,7 +481,7 @@ private func postNotification<T: MongoEvent>(
     guard let context = contextFunc(event) else {
         fatalError("Missing context for \(type)")
     }
-    let client = Unmanaged<SyncMongoClient>.fromOpaque(context).takeUnretainedValue()
+    let client = Unmanaged<MongoClient>.fromOpaque(context).takeUnretainedValue()
     let notification = Notification(name: type.eventName, userInfo: ["event": eventStruct])
     client.notificationCenter.post(notification)
 }
@@ -518,7 +518,7 @@ extension Notification.Name {
 /// An extension of `ConnectionPool` to add monitoring capability for commands and server discovery and monitoring.
 extension ConnectionPool {
     /// Internal function to install monitoring callbacks for this pool.
-    internal func initializeMonitoring(commandMonitoring: Bool, serverMonitoring: Bool, client: SyncMongoClient) {
+    internal func initializeMonitoring(commandMonitoring: Bool, serverMonitoring: Bool, client: MongoClient) {
         guard let callbacks = mongoc_apm_callbacks_new() else {
             fatalError("failed to initialize new mongoc_apm_callbacks_t")
         }
@@ -542,8 +542,8 @@ extension ConnectionPool {
             mongoc_apm_set_server_heartbeat_failed_cb(callbacks, serverHeartbeatFailed)
         }
 
-        // we can pass the SyncMongoClient as unretained because the callbacks are stored on clientHandle, so if the
-        // callback is being executed, this pool and therefore its parent `SyncMongoClient` must still be valid.
+        // we can pass the MongoClient as unretained because the callbacks are stored on clientHandle, so if the
+        // callback is being executed, this pool and therefore its parent `MongoClient` must still be valid.
         switch self.mode {
         case let .single(clientHandle):
             mongoc_client_set_apm_callbacks(clientHandle, callbacks, Unmanaged.passUnretained(client).toOpaque())

Sources/MongoSwift/BSON/CodingStrategies.swift

@@ -37,9 +37,8 @@ public struct BSONCoderOptions: CodingStrategyProvider {
 
 /**
  * Enum representing the various encoding/decoding strategy pairs for `Date`s.
- * Set these on a `MongoClient`, `MongoDatabase`, or `MongoCollection`, or a `SyncMongoClient`, `SyncMongoDatabase`, or
- * `SyncMongoCollection`, so that the strategies will be applied when converting `Date`s between their BSON
- * representations and their representations in (non `Document`) `Codable` types.
+ * Set these on a `MongoClient`, `MongoDatabase`, or `MongoCollection` so that the strategies will be applied when
+ * converting `Date`s between their BSON representations and their representations in (non `Document`) `Codable` types.
  *
  * As per the BSON specification, the default strategy is to encode `Date`s as BSON datetime objects.
  *
@@ -123,9 +122,8 @@ public enum DateCodingStrategy: RawRepresentable {
 
 /**
  * Enum representing the various encoding/decoding strategy pairs for `Date`s.
- * Set these on a `MongoClient`, `MongoDatabase`, or `MongoCollection`, or a `SyncMongoClient`, `SyncMongoDatabase`, or
- * `SyncMongoCollection`, so that the strategies will be applied when converting `UUID`s between their BSON
- * representations and their representations in (non `Document`) `Codable` types.
+ * Set these on a `MongoClient`, `MongoDatabase`, or `MongoCollection` so that the strategies will be applied when
+ * converting `UUID`s between their BSON representations and their representations in (non `Document`) `Codable` types.
  *
  * As per the BSON specification, the default strategy is to encode `UUID`s as BSON binary types with the UUID
  * subtype.
@@ -164,9 +162,8 @@ public enum UUIDCodingStrategy: RawRepresentable {
 
 /**
  * Enum representing the various encoding/decoding strategy pairs for `Date`s.
- * Set these on a `MongoClient`, `MongoDatabase`, or `MongoCollection`, or a `SyncMongoClient`, `SyncMongoDatabase`, or
- * `SyncMongoCollection`, so that the strategies will be applied when converting `Data`s between their BSON
- * representations and their representations in (non `Document`) `Codable` types.
+ * Set these on a `MongoClient`, `MongoDatabase`, or `MongoCollection` so that the strategies will be applied when
+ * converting `Data`s between their BSON representations and their representations in (non `Document`) `Codable` types.
  *
  * As per the BSON specification, the default strategy is to encode `Data`s as BSON binary types with the generic
  * binary subtype.

Sources/MongoSwift/ChangeStream.swift

@@ -24,9 +24,9 @@ public struct ResumeToken: Codable, Equatable {
     }
 }
 
-/// A synchronous MongoDB change stream.
+/// A MongoDB change stream.
 /// - SeeAlso: https://docs.mongodb.com/manual/changeStreams/
-public class SyncChangeStream<T: Codable>: Sequence, IteratorProtocol {
+public class ChangeStream<T: Codable>: Sequence, IteratorProtocol {
     /// Enum for tracking the state of a change stream.
     internal enum State {
         /// Indicates that the change stream is still open. Stores a pointer to the `mongoc_change_stream_t`, along
@@ -35,8 +35,8 @@ public class SyncChangeStream<T: Codable>: Sequence, IteratorProtocol {
         case open(
             changeStream: OpaquePointer,
             connection: Connection,
-            client: SyncMongoClient,
-            session: SyncClientSession?
+            client: MongoClient,
+            session: ClientSession?
         )
         case closed
     }
@@ -139,16 +139,16 @@ public class SyncChangeStream<T: Codable>: Sequence, IteratorProtocol {
     }
 
     /**
-     * Initializes a `SyncChangeStream`.
+     * Initializes a `ChangeStream`.
      * - Throws:
      *   - `ServerError.commandError` if an error occurred on the server when creating the `mongoc_change_stream_t`.
      *   - `UserError.invalidArgumentError` if the `mongoc_change_stream_t` was created with invalid options.
      */
     internal init(
         stealing changeStream: OpaquePointer,
         connection: Connection,
-        client: SyncMongoClient,
-        session: SyncClientSession?,
+        client: MongoClient,
+        session: ClientSession?,
         decoder: BSONDecoder,
         options: ChangeStreamOptions?
     ) throws {

Sources/MongoSwift/ChangeStreamDocument.swift

@@ -37,7 +37,7 @@ public enum OperationType: String, Codable {
     case rename
 }
 
-/// The response document type from a `ChangeStream` or a `SyncChangeStream`.
+/// The response document type from a `ChangeStream`.
 public struct ChangeStreamEvent<T: Codable>: Codable {
     /// Describes the type of operation for this change.
     public let operationType: OperationType

Sources/MongoSwift/ChangeStreamOptions.swift

@@ -26,7 +26,7 @@ public enum FullDocument: RawRepresentable, Codable {
     }
 }
 
-/// Options to use when creating a `ChangeStream` or `SyncChangeStream`.
+/// Options to use when creating a `ChangeStream`.
 public struct ChangeStreamOptions: Codable {
     /// The number of documents to return per batch. If omitted, the server will use its default batch size.
     /// - SeeAlso: https://docs.mongodb.com/manual/reference/command/aggregate

Sources/MongoSwift/ClientSession.swift

@@ -1,7 +1,7 @@
 import Foundation
 import mongoc
 
-/// Options to use when creating a `ClientSession` or `SyncClientSession`.
+/// Options to use when creating a `ClientSession`.
 public struct ClientSessionOptions {
     /// Whether to enable causal consistency for this session. By default, causal consistency is enabled.
     ///
@@ -33,7 +33,7 @@ private func withSessionOpts<T>(
  * A MongoDB client session.
  * This class represents a logical session used for ordering sequential operations.
  *
- * To create a client session, use `startSession` or `withSession` on a `MongoClient` or a `SyncMongoClient`.
+ * To create a client session, use `startSession` or `withSession` on a `MongoClient`.
  *
  * If `causalConsistency` is not set to `false` when starting a session, read and write operations that use the session
  * will be provided causal consistency guarantees depending on the read and write concerns used. Using "majority"
@@ -57,7 +57,7 @@ private func withSessionOpts<T>(
  *   - https://docs.mongodb.com/manual/core/read-isolation-consistency-recency/#sessions
  *   - https://docs.mongodb.com/manual/core/causal-consistency-read-write-concerns/
  */
-public final class SyncClientSession {
+public final class ClientSession {
     /// Error thrown when an inactive session is used.
     internal static let SessionInactiveError = UserError.logicError(message: "Tried to use an inactive session")
     /// Error thrown when a user attempts to use a session with a client it was not created from.
@@ -86,7 +86,7 @@ public final class SyncClientSession {
     }
 
     /// The client used to start this session.
-    public let client: SyncMongoClient
+    public let client: MongoClient
 
     /// The session ID of this session.
     public let id: Document
@@ -125,7 +125,7 @@ public final class SyncClientSession {
     public let options: ClientSessionOptions?
 
     /// Initializes a new client session.
-    internal init(client: SyncMongoClient, options: ClientSessionOptions? = nil) throws {
+    internal init(client: MongoClient, options: ClientSessionOptions? = nil) throws {
         self.options = options
         self.client = client
 
@@ -147,12 +147,12 @@ public final class SyncClientSession {
 
     /// Retrieves this session's underlying connection. Throws an error if the provided client was not the client used
     /// to create this session, or if this session has been ended.
-    internal func getConnection(forUseWith client: SyncMongoClient) throws -> Connection {
+    internal func getConnection(forUseWith client: MongoClient) throws -> Connection {
         guard case let .active(_, connection) = self.state else {
-            throw SyncClientSession.SessionInactiveError
+            throw ClientSession.SessionInactiveError
         }
         guard self.client == client else {
-            throw SyncClientSession.ClientMismatchError
+            throw ClientSession.ClientMismatchError
         }
         return connection
     }
@@ -205,7 +205,7 @@ public final class SyncClientSession {
     ///   - `UserError.logicError` if this session is inactive
     internal func append(to doc: inout Document) throws {
         guard case let .active(session, _) = self.state else {
-            throw SyncClientSession.SessionInactiveError
+            throw ClientSession.SessionInactiveError
         }
 
         var error = bson_error_t()