chore: adapt to flapdoodle.embed.mongo 4.x

Author: ydylla

src/main/groovy/com/sourcemuse/gradle/plugin/flapdoodle/adapters/CustomFlapdoodleRuntimeConfig.groovy

@@ -1,64 +1,74 @@
 package com.sourcemuse.gradle.plugin.flapdoodle.adapters
 
-import static com.sourcemuse.gradle.plugin.LogDestination.CONSOLE
-import static com.sourcemuse.gradle.plugin.LogDestination.FILE
-import static com.sourcemuse.gradle.plugin.LogDestination.NONE
-
 import com.sourcemuse.gradle.plugin.GradleMongoPluginExtension
 import com.sourcemuse.gradle.plugin.LogDestination
-import de.flapdoodle.embed.mongo.packageresolver.Command
-import de.flapdoodle.embed.mongo.config.MongodProcessOutputConfig
-import de.flapdoodle.embed.process.config.process.ProcessOutput
 import de.flapdoodle.embed.process.io.NamedOutputStreamProcessor
-import de.flapdoodle.embed.process.io.NullProcessor
-import de.flapdoodle.embed.process.io.Processors
-import de.flapdoodle.embed.process.io.Slf4jLevel
+import de.flapdoodle.embed.process.io.ProcessOutput
+import de.flapdoodle.reverse.State
+import de.flapdoodle.reverse.StateID
+import de.flapdoodle.reverse.StateLookup
+import de.flapdoodle.reverse.Transition
 import groovy.transform.TupleConstructor
 import org.gradle.api.GradleScriptException
 import org.gradle.api.Project
 
-@TupleConstructor
-class ProcessOutputFactory {
-    Project project
-
-    ProcessOutput getProcessOutput(GradleMongoPluginExtension pluginExtension) {
-        def logDestination = pluginExtension.logging.toUpperCase() as LogDestination
+import static com.sourcemuse.gradle.plugin.LogDestination.CONSOLE
+import static com.sourcemuse.gradle.plugin.LogDestination.FILE
+import static com.sourcemuse.gradle.plugin.LogDestination.NONE
 
-        if (logDestination == CONSOLE) {
-            return MongodProcessOutputConfig.getDefaultInstance(Command.MongoD)
-        }
+@TupleConstructor
+class ProcessOutputFactory implements Transition<ProcessOutput> {
+  Project project
+  GradleMongoPluginExtension pluginExtension
 
-        if (logDestination == FILE) {
-            def logFile = new File(pluginExtension.logFilePath)
-            def logFilePath = logFile.isAbsolute() ? logFile.absolutePath :
-                    createRelativeFilePathFromBuildDir(logFile)
+  ProcessOutput getProcessOutput() {
+    def logDestination = pluginExtension.logging.toUpperCase() as LogDestination
 
-            def fileOutputStreamProcessor = new FileOutputStreamProcessor(logFilePath)
+    if (logDestination == CONSOLE) {
+      return ProcessOutput.namedConsole("mongod")
+    }
 
-            return ProcessOutput.builder()
-				.output(new NamedOutputStreamProcessor('[mongod output]', fileOutputStreamProcessor))
-                .error(new NamedOutputStreamProcessor('[mongod error]', fileOutputStreamProcessor))
-                .commands(new NamedOutputStreamProcessor('[mongod commands]', fileOutputStreamProcessor))
-				.build()
-        }
+    if (logDestination == FILE) {
+      def logFile = new File(pluginExtension.logFilePath)
+      def logFilePath = logFile.isAbsolute() ? logFile.absolutePath :
+        createRelativeFilePathFromBuildDir(logFile)
 
-        if (logDestination == NONE) {
-            def nullProcessor = new NullProcessor()
-            return ProcessOutput.builder()
-				.output(nullProcessor)
-				.error(nullProcessor)
-				.commands(nullProcessor)
-				.build()
-        }
+      def fileOutputStreamProcessor = new FileOutputStreamProcessor(logFilePath)
 
-        throw new GradleScriptException(
-                "Unrecognized 'logging' option: ${pluginExtension.logging}. " +
-                        "Choose one of ${LogDestination.values().collect { it.toString().toLowerCase() }.join(', ')}.",
-                new IllegalArgumentException()
-        )
+      return ProcessOutput.builder()
+        .output(new NamedOutputStreamProcessor('[mongod output]', fileOutputStreamProcessor))
+        .error(new NamedOutputStreamProcessor('[mongod error]', fileOutputStreamProcessor))
+        .commands(new NamedOutputStreamProcessor('[mongod commands]', fileOutputStreamProcessor))
+        .build()
     }
 
-    private String createRelativeFilePathFromBuildDir(File logFile) {
-        project.buildDir.absolutePath + File.separatorChar + logFile.path
+    if (logDestination == NONE) {
+      return ProcessOutput.silent()
     }
+
+    throw new GradleScriptException(
+      "Unrecognized 'logging' option: ${pluginExtension.logging}. " +
+        "Choose one of ${LogDestination.values().collect { it.toString().toLowerCase() }.join(', ')}.",
+      new IllegalArgumentException()
+    )
+  }
+
+  private String createRelativeFilePathFromBuildDir(File logFile) {
+    project.buildDir.absolutePath + File.separatorChar + logFile.path
+  }
+
+  @Override
+  StateID<ProcessOutput> destination() {
+    return StateID.of(ProcessOutput.class)
+  }
+
+  @Override
+  Set<StateID<?>> sources() {
+    return Set.of()
+  }
+
+  @Override
+  State<ProcessOutput> result(StateLookup lookup) {
+    return State.of(getProcessOutput())
+  }
 }