fix: fix method for get mongo connection

Services/MongoComponents/Sources/Extensions/Application+Extensions.swift

@@ -23,6 +23,7 @@
 //
 
 import Vapor
+import MongoKitten
 
 extension Application {
     /// A `MongoComponentsKey` conform to StorageKey protocol
@@ -37,3 +38,22 @@ extension Application {
         set { storage[MongoComponentsKey.self] = newValue }
     }
 }
+
+extension Application {
+    /// A `MongoClusterKey` conform to StorageKey protocol
+    public struct MongoClusterKey: StorageKey {
+        /// Less verbose typealias for `MongoCluster`.
+        public typealias Value = MongoCluster
+    }
+
+    /// Setup `mongoCluster` in application storage
+    public var mongoCluster: MongoCluster? {
+        get { storage[MongoClusterKey.self] }
+        set { storage[MongoClusterKey.self] = newValue }
+    }
+
+    /*
+     /// For example setup mongo cluster need use method like this:
+     app.mongoCluster = try await MongoCluster(connectingTo: ConnectionSettings(connectionString))
+     */
+}

Services/MongoComponents/Sources/MongoComponents.swift

@@ -30,14 +30,12 @@ public struct MongoComponents: MongoComponentsProtocol {
     public let app: Application
 
     public func getConnection(by url: String) async -> MongoConnectionState {
-        do {
-            let mongoCluster = try await MongoCluster(connectingTo: ConnectionSettings(url))
-            let result = mongoCluster.connectionState
-            app.logger.debug("Connect to mongo have result: \(result)")
-            return result
-        } catch {
-            app.logger.error("ERROR: Connection to mongo db fail with error: \(error)")
+        let result = app.mongoCluster?.connectionState
+        app.logger.debug("Connect to mongo have result: \(String(describing: result))")
+        guard let result else {
+            app.logger.error("ERROR: Connection to mongo not found. Result: \(String(describing: result))")
             return .disconnected
         }
+        return result
     }
 }