Docker compose dev service

Fix amqp username prop

Author: ozangunalp

core/deployment/src/main/java/io/quarkus/deployment/Feature.java

@@ -17,6 +17,7 @@ public enum Feature {
     AWT,
     CACHE,
     CDI,
+    COMPOSE,
     CONFIG_YAML,
     CONFLUENT_REGISTRY_AVRO,
     CONFLUENT_REGISTRY_JSON,

core/deployment/src/main/java/io/quarkus/deployment/builditem/DevServicesComposeProjectBuildItem.java

@@ -0,0 +1,115 @@
+package io.quarkus.deployment.builditem;
+
+import java.util.Arrays;
+import java.util.Collections;
+import java.util.List;
+import java.util.Map;
+import java.util.Objects;
+import java.util.Optional;
+import java.util.stream.Stream;
+
+import io.quarkus.builder.item.SimpleBuildItem;
+import io.quarkus.deployment.dev.devservices.ContainerInfo;
+import io.quarkus.deployment.dev.devservices.ImageName;
+import io.quarkus.deployment.dev.devservices.RunningContainer;
+
+/**
+ * BuildItem for running services provided by compose
+ */
+public final class DevServicesComposeProjectBuildItem extends SimpleBuildItem {
+
+    public static final String COMPOSE_IGNORE = "io.quarkus.devservices.compose.ignore";
+
+    private final String project;
+
+    private final Map<String, List<RunningContainer>> composeServices;
+
+    private final Map<String, String> config;
+
+    public DevServicesComposeProjectBuildItem() {
+        this(null, Collections.emptyMap(), Collections.emptyMap());
+    }
+
+    public DevServicesComposeProjectBuildItem(String project,
+            Map<String, List<RunningContainer>> composeServices,
+            Map<String, String> config) {
+        this.project = project;
+        this.composeServices = composeServices;
+        this.config = config;
+    }
+
+    public String getProject() {
+        return project;
+    }
+
+    public Map<String, String> getConfig() {
+        return config;
+    }
+
+    public Map<String, List<RunningContainer>> getComposeServices() {
+        return composeServices;
+    }
+
+    /**
+     * Locate a running container by image partial and port
+     * The container image partial can be a substring of the full image name
+     *
+     * @param imagePartials image partials
+     * @param port exposed port
+     * @return the running container or null if not found
+     */
+    public Optional<RunningContainer> locate(List<String> imagePartials, int port) {
+        return locateContainers(imagePartials)
+                .filter(r -> Optional.ofNullable(r.containerInfo().exposedPorts())
+                        .map(ports -> Arrays.stream(ports)
+                                .anyMatch(p -> Objects.equals(p.privatePort(), port)))
+                        .isPresent())
+                .findFirst();
+    }
+
+    /**
+     * Locate a running container by image partial
+     * The container image partial can be a substring of the full image name
+     * Ignored services are not returned
+     *
+     * @param imagePartials image partials
+     * @return the list of running containers
+     */
+    public List<RunningContainer> locate(List<String> imagePartials) {
+        return locateContainers(imagePartials).toList();
+    }
+
+    /**
+     * Locate the first running container by image partial
+     * The container image partial can be a substring of the full image name
+     * Ignored services are not returned
+     *
+     * @param imagePartials image partials
+     * @return the first running container
+     */
+    public Optional<RunningContainer> locateFirst(List<String> imagePartials) {
+        return locateContainers(imagePartials).findFirst();
+    }
+
+    private Stream<RunningContainer> locateContainers(List<String> imagePartials) {
+        return imagePartials.stream()
+                .flatMap(imagePartial -> composeServices.values().stream().flatMap(List::stream)
+                        // Ignore service if contains ignore label
+                        .filter(c -> !isContainerIgnored(c.containerInfo()))
+                        .filter(runningContainer -> {
+                            String imageName = runningContainer.containerInfo().imageName();
+                            return imageName.contains(imagePartial)
+                                    || ImageName.parse(imageName).withLibraryPrefix().toString().contains(imagePartial);
+                        }));
+    }
+
+    /**
+     * Ignored services are not returned by locate
+     *
+     * @param containerInfo container info
+     * @return true if the container should be ignored
+     */
+    public static boolean isContainerIgnored(ContainerInfo containerInfo) {
+        return Boolean.parseBoolean(containerInfo.labels().get(COMPOSE_IGNORE));
+    }
+}

core/deployment/src/main/java/io/quarkus/deployment/dev/devservices/ComposeBuildTimeConfig.java

@@ -0,0 +1,17 @@
+package io.quarkus.deployment.dev.devservices;
+
+import io.quarkus.runtime.annotations.ConfigDocSection;
+import io.quarkus.runtime.annotations.ConfigPhase;
+import io.quarkus.runtime.annotations.ConfigRoot;
+import io.smallrye.config.ConfigMapping;
+
+@ConfigRoot(phase = ConfigPhase.BUILD_TIME)
+@ConfigMapping(prefix = "quarkus.compose")
+public interface ComposeBuildTimeConfig {
+
+    /**
+     * Compose dev services config
+     */
+    @ConfigDocSection(generated = true)
+    ComposeDevServicesBuildTimeConfig devservices();
+}

core/deployment/src/main/java/io/quarkus/deployment/dev/devservices/ComposeDevServicesBuildTimeConfig.java

@@ -0,0 +1,98 @@
+package io.quarkus.deployment.dev.devservices;
+
+import java.util.List;
+import java.util.Map;
+import java.util.Optional;
+
+import io.quarkus.runtime.annotations.ConfigGroup;
+import io.smallrye.config.WithDefault;
+
+@ConfigGroup
+public interface ComposeDevServicesBuildTimeConfig {
+
+    /**
+     * Compose dev service enabled or disabled
+     */
+    @WithDefault("true")
+    boolean enabled();
+
+    /**
+     * List of file paths relative to the project root for Compose dev service configuration,
+     * if not provided will look for compose files in the project root
+     */
+    Optional<List<String>> files();
+
+    /**
+     * Name of the compose project, used to discover running containers,
+     * if not provided a project name will be generated
+     */
+    Optional<String> projectName();
+
+    /**
+     * Compose profiles to activate
+     */
+    Optional<List<String>> profiles();
+
+    /**
+     * List of additional options to pass to compose command
+     */
+    Optional<List<String>> options();
+
+    /**
+     * Whether to run compose down and stop containers at shutdown
+     */
+    @WithDefault("true")
+    boolean stopContainers();
+
+    /**
+     * Whether to use test containers Ryuk resource reaper to clean up containers
+     */
+    @WithDefault("true")
+    boolean ryukEnabled();
+
+    /**
+     * Whether to remove volumes on compose down
+     */
+    @WithDefault("true")
+    boolean removeVolumes();
+
+    /**
+     * Which images to remove on compose down
+     * <p>
+     * Locally built images, without custom tags are removed by default.
+     */
+    Optional<RemoveImages> removeImages();
+
+    /**
+     * --rmi option for compose down
+     */
+    enum RemoveImages {
+        ALL,
+        LOCAL
+    }
+
+    /**
+     * Env variables to pass to all Compose instances
+     */
+    Map<String, String> envVariables();
+
+    /**
+     * Scale configuration for services: Configure the number of instances for specific services
+     */
+    Map<String, Integer> scale();
+
+    /**
+     * Whether to tail container logs to the console
+     */
+    @WithDefault("false")
+    boolean followContainerLogs();
+
+    /**
+     * Whether to build images before starting containers.
+     * <p>
+     * When not provided, Compose images are built per-service `pull-policy`.
+     * When `true`, forces build of all images before starting containers.
+     * When `false`, skips re-building images before starting containers.
+     */
+    Optional<Boolean> build();
+}