diff --git a/Sources/HealthChecks/MongoHealthChecks/MongoRequest.swift b/Sources/HealthChecks/MongoHealthChecks/MongoRequest.swift index 7b99def..6af95b8 100644 --- a/Sources/HealthChecks/MongoHealthChecks/MongoRequest.swift +++ b/Sources/HealthChecks/MongoHealthChecks/MongoRequest.swift @@ -38,18 +38,12 @@ public final class MongoRequest: MongoRequestSendable { // WARNING: - This method create new connection every time, when you use it /// Get mongo connection - /// - Parameter url: `String` + /// - Parameter host: `String` + /// - Parameter port: `String` /// - Returns: `String` public func getConnection(by host: String, and port: String) async throws -> String { - - let connect = try await app.client.get(URI(string: "http://\(host):\(port)" + "?compressors=disabled&gssapiServiceName=mongodb")) -// await app.mongoCluster?.disconnect() -// app.mongoCluster = nil -// app.mongoCluster = try? MongoCluster(lazyConnectingTo: ConnectionSettings(url)) -// let connection = "\(app.mongoCluster?.connectionState ?? .disconnected)" -// await app.mongoCluster?.disconnect() -// app.mongoCluster = nil - + let uri = URI(string: "http://\(host):\(port)" + "?compressors=disabled&gssapiServiceName=mongodb") + let connect = try await app.client.get(uri) return "\(connect.status)" } } diff --git a/Sources/HealthChecks/MongoHealthChecks/MongoRequestSendable.swift b/Sources/HealthChecks/MongoHealthChecks/MongoRequestSendable.swift index 07cc7de..93dc134 100644 --- a/Sources/HealthChecks/MongoHealthChecks/MongoRequestSendable.swift +++ b/Sources/HealthChecks/MongoHealthChecks/MongoRequestSendable.swift @@ -27,6 +27,8 @@ import Vapor /// Groups func for get mongo request public protocol MongoRequestSendable { /// Get connection description + /// - Parameter host: `String` + /// - Parameter port: `String` /// - Returns: `String` func getConnection(by host: String, and port: String) async throws -> String }