fix(cli): add command to start controller

Author: fhussonnois

cli/src/main/java/io/kestra/cli/commands/servers/ControllerCommand.java

@@ -0,0 +1,39 @@
+package io.kestra.cli.commands.servers;
+
+import io.kestra.core.models.ServerType;
+import io.kestra.core.utils.Await;
+import io.kestra.core.worker.Controller;
+import io.micronaut.context.ApplicationContext;
+import jakarta.inject.Inject;
+import picocli.CommandLine.Command;
+
+import java.util.Map;
+
+@Command(
+    name = "controller",
+    description = "Start the Kestra a controller for workers"
+)
+public class ControllerCommand extends AbstractServerCommand {
+
+    @Inject
+    private ApplicationContext applicationContext;
+
+    @SuppressWarnings("unused")
+    public static Map<String, Object> propertiesOverrides() {
+        return Map.of(
+            "kestra.server-type", ServerType.CONTROLLER
+        );
+    }
+
+    @Override
+    public Integer call() throws Exception {
+        super.call();
+
+        Controller controller = applicationContext.getBean(Controller.class);
+        controller.start();
+
+        Await.until(() -> !this.applicationContext.isRunning());
+
+        return 0;
+    }
+}

cli/src/main/java/io/kestra/cli/commands/servers/ServerCommand.java

@@ -17,6 +17,7 @@
         StandAloneCommand.class,
         WebServerCommand.class,
         WorkerCommand.class,
+        ControllerCommand.class,
         LocalCommand.class
     }
 )

cli/src/test/java/io/kestra/cli/AppTest.java

@@ -31,7 +31,7 @@ void testHelp() {
     }
 
     @ParameterizedTest
-    @ValueSource(strings = {"standalone", "executor", "indexer", "scheduler", "webserver", "worker", "local"})
+    @ValueSource(strings = {"standalone", "executor", "indexer", "scheduler", "webserver", "worker", "controller", "local"})
     void testServerCommandHelp(String serverType) {
         final ByteArrayOutputStream out = new ByteArrayOutputStream();
         System.setOut(new PrintStream(out));