Generate test app when RabbitMQ Streams is selected

See spring-iogh-1611

Author: eddumelendez

start-site/src/main/java/io/spring/start/site/extension/dependency/springamqp/SpringAmqpProjectGenerationConfiguration.java

@@ -1,5 +1,5 @@
 /*
- * Copyright 2012 - present the original author or authors.
+ * Copyright 2012-2023 the original author or authors.
  *
  * Licensed under the Apache License, Version 2.0 (the "License");
  * you may not use this file except in compliance with the License.
@@ -16,6 +16,7 @@
 
 package io.spring.start.site.extension.dependency.springamqp;
 
+import io.spring.initializr.generator.buildsystem.Build;
 import io.spring.initializr.generator.condition.ConditionalOnPlatformVersion;
 import io.spring.initializr.generator.condition.ConditionalOnRequestedDependency;
 import io.spring.initializr.generator.project.ProjectGenerationConfiguration;
@@ -34,39 +35,51 @@
  * Configuration for generation of projects that depend on Spring AMQP.
  *
  * @author Stephane Nicoll
+ * @author Eddú Meléndez
  */
 @ProjectGenerationConfiguration
 class SpringAmqpProjectGenerationConfiguration {
 
 	@Configuration(proxyBeanMethods = false)
-	@ConditionalOnRequestedDependency("amqp")
 	static class AmqpConfiguration {
 
 		@Bean
 		@ConditionalOnPlatformVersion("[3.5.0,4.0.0-RC1]")
+		@ConditionalOnRequestedDependency("amqp")
 		SpringRabbitTestBuildCustomizer springAmqpTestBuildCustomizer() {
 			return new SpringRabbitTestBuildCustomizer();
 		}
 
 		@Bean
 		@ConditionalOnRequestedDependency("testcontainers")
-		ServiceConnectionsCustomizer rabbitServiceConnectionsCustomizer(DockerServiceResolver serviceResolver,
-				Testcontainers testcontainers) {
-			Container container = testcontainers.getContainer(SupportedContainer.RABBITMQ);
-			return (serviceConnections) -> serviceResolver
-				.doWith("rabbit", (service) -> serviceConnections.addServiceConnection(
-						ServiceConnection.ofContainer("rabbit", service, container.className(), container.generic())));
+		ServiceConnectionsCustomizer rabbitServiceConnectionsCustomizer(Build build,
+				DockerServiceResolver serviceResolver, Testcontainers testcontainers) {
+			return (serviceConnections) -> {
+				if (isAmqpEnabled(build)) {
+					Container container = testcontainers.getContainer(SupportedContainer.RABBITMQ);
+					serviceResolver.doWith("rabbit",
+							(service) -> serviceConnections.addServiceConnection(ServiceConnection.ofContainer("rabbit",
+									service, container.className(), container.generic())));
+				}
+			};
 		}
 
 		@Bean
 		@ConditionalOnRequestedDependency("docker-compose")
-		ComposeFileCustomizer rabbitComposeFileCustomizer(DockerServiceResolver serviceResolver) {
-			return (composeFile) -> serviceResolver.doWith("rabbit",
-					(service) -> composeFile.services()
+		ComposeFileCustomizer rabbitComposeFileCustomizer(Build build, DockerServiceResolver serviceResolver) {
+			return (composeFile) -> {
+				if (isAmqpEnabled(build)) {
+					serviceResolver.doWith("rabbit", (service) -> composeFile.services()
 						.add("rabbitmq",
 								service.andThen((builder) -> builder.environment("RABBITMQ_DEFAULT_USER", "myuser")
 									.environment("RABBITMQ_DEFAULT_PASS", "secret")
 									.ports(5672))));
+				}
+			};
+		}
+
+		private boolean isAmqpEnabled(Build build) {
+			return build.dependencies().has("amqp") || build.dependencies().has("amqp-streams");
 		}
 
 	}

start-site/src/test/java/io/spring/start/site/extension/dependency/springamqp/SpringAmqpProjectGenerationConfigurationTests.java

@@ -37,6 +37,7 @@
  *
  * @author Stephane Nicoll
  * @author Moritz Halbritter
+ * @author Eddú Meléndez
  */
 class SpringAmqpProjectGenerationConfigurationTests extends AbstractExtensionTests {
 
@@ -73,4 +74,17 @@ void springAmqpWithDockerCompose() {
 		assertThat(composeFile(request)).hasSameContentAs(new ClassPathResource("compose/rabbitmq.yaml"));
 	}
 
+	@Test
+	void springAmqpStreamsWithoutDockerCompose() {
+		ProjectRequest request = createProjectRequest("web", "amqp-streams");
+		ProjectStructure structure = generateProject(request);
+		assertThat(structure.getProjectDirectory().resolve("compose.yaml")).doesNotExist();
+	}
+
+	@Test
+	void springAmqpStreamsWithDockerCompose() {
+		ProjectRequest request = createProjectRequest("docker-compose", "amqp-streams");
+		assertThat(composeFile(request)).hasSameContentAs(new ClassPathResource("compose/rabbitmq.yaml"));
+	}
+
 }