Uses port from SRVRecord (#324)

orlandos-nl · Oct 19, 2023 · f05069c · f05069c
1 parent a85a674
commit f05069c
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/Sources/MongoClient/Cluster.swift b/Sources/MongoClient/Cluster.swift
@@ -332,7 +332,7 @@ public final class MongoCluster: MongoConnectionPool, @unchecked Sendable {
     private func resolveSRV(_ host: ConnectionSettings.Host, on client: DNSClient) async throws -> [ConnectionSettings.Host] {
         let prefix = "_mongodb._tcp."
         return try await client.getSRVRecords(from: prefix + host.hostname).get().map { record in
-            return ConnectionSettings.Host(hostname: record.resource.domainName.string, port: host.port)
+            return ConnectionSettings.Host(hostname: record.resource.domainName.string, port: Int(record.resource.port))
         }
     }