Add migrationLogLevel configuration (#756)

* Add migrationLogLevel configuration * Use .any() instead of .next() for ELG
vapor · Feb 12, 2023 · 4db22cc · 4db22cc
1 parent 44155a5
commit 4db22cc
Show file tree

Hide file tree

Showing 2 changed files with 13 additions and 4 deletions.
diff --git a/Package.swift b/Package.swift
@@ -10,7 +10,7 @@ let package = Package(
         .library(name: "Fluent", targets: ["Fluent"]),
     ],
     dependencies: [
-        .package(url: "https://github.com/vapor/fluent-kit.git", from: "1.36.0"),
+        .package(url: "https://github.com/vapor/fluent-kit.git", from: "1.38.0"),
         .package(url: "https://github.com/vapor/vapor.git", from: "4.50.0"),
     ],
     targets: [

diff --git a/Sources/Fluent/FluentProvider.swift b/Sources/Fluent/FluentProvider.swift
@@ -52,7 +52,8 @@ extension Application {
             databases: self.databases,
             migrations: self.migrations,
             logger: self.logger,
-            on: self.eventLoopGroup.next()
+            on: self.eventLoopGroup.any(),
+            migrationLogLevel: self.fluent.migrationLogLevel
         )
     }
 
@@ -76,13 +77,15 @@ extension Application {
         final class Storage {
             let databases: Databases
             let migrations: Migrations
+            var migrationLogLevel: Logger.Level
 
-            init(threadPool: NIOThreadPool, on eventLoopGroup: EventLoopGroup) {
+            init(threadPool: NIOThreadPool, on eventLoopGroup: EventLoopGroup, migrationLogLevel: Logger.Level) {
                 self.databases = Databases(
                     threadPool: threadPool,
                     on: eventLoopGroup
                 )
                 self.migrations = .init()
+                self.migrationLogLevel = migrationLogLevel
             }
         }
 
@@ -128,11 +131,17 @@ extension Application {
         func initialize() {
             self.application.storage[Key.self] = .init(
                 threadPool: self.application.threadPool,
-                on: self.application.eventLoopGroup
+                on: self.application.eventLoopGroup,
+                migrationLogLevel: .info
             )
             self.application.lifecycle.use(Lifecycle())
             self.application.commands.use(MigrateCommand(), as: "migrate")
         }
+
+        public var migrationLogLevel: Logger.Level {
+            get { self.storage.migrationLogLevel }
+            nonmutating set { self.storage.migrationLogLevel = newValue }
+        }
 
         public var history: History {
             .init(fluent: self)