From df6044fa3bcff00b4078683f9fba792438d10fbb Mon Sep 17 00:00:00 2001 From: Mykola Buhaiov Date: Wed, 12 Jun 2024 10:13:44 +0300 Subject: [PATCH] fix: fix --- .../MongoHealthChecks/MongoRequest.swift | 13 ++++++++++--- 1 file changed, 10 insertions(+), 3 deletions(-) diff --git a/Sources/HealthChecks/MongoHealthChecks/MongoRequest.swift b/Sources/HealthChecks/MongoHealthChecks/MongoRequest.swift index 90327f6..f0caf68 100644 --- a/Sources/HealthChecks/MongoHealthChecks/MongoRequest.swift +++ b/Sources/HealthChecks/MongoHealthChecks/MongoRequest.swift @@ -42,8 +42,15 @@ public final class MongoRequest: MongoRequestSendable { /// - Parameter port: `String` /// - Returns: `String` public func getConnection(by host: String, and port: String) async throws -> String { - let uri = URI(string: "https://\(host):\(port)" + "?compressors=disabled&gssapiServiceName=mongodb") - let connect = try await app.client.get(uri) - return "\(connect.status)" + let connection = "\(app.mongoCluster?.connectionState ?? .disconnected)" + return connection + } +} + +extension Application { + /// Initialize MongoDB + /// - Parameter connectionString: URI as `String`. Example: "mongodb://localhost/myapp + public func initializeMongoCluster(connectionString: String) async throws { + self.mongoCluster = try await MongoCluster(connectingTo: ConnectionSettings(connectionString)) } }