Skip to content

Commit

Permalink
fix: fix
Browse files Browse the repository at this point in the history
  • Loading branch information
gulivero1773 committed Jun 12, 2024
1 parent a8d8991 commit df6044f
Showing 1 changed file with 10 additions and 3 deletions.
13 changes: 10 additions & 3 deletions Sources/HealthChecks/MongoHealthChecks/MongoRequest.swift
Original file line number Diff line number Diff line change
Expand Up @@ -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))
}
}

0 comments on commit df6044f

Please sign in to comment.