aggiunti test esercizio 5

Author: matteobaglini

04_driven_pull/src/test/java/io/doubleloop/drivenpull/DefaultDailyBalanceServiceTest.java

@@ -3,7 +3,6 @@
 import org.junit.jupiter.api.BeforeEach;
 import org.junit.jupiter.api.Test;
 import org.springframework.beans.factory.annotation.Autowired;
-import org.springframework.boot.test.autoconfigure.web.servlet.AutoConfigureMockMvc;
 import org.springframework.boot.test.context.SpringBootTest;
 import org.springframework.boot.testcontainers.service.connection.ServiceConnection;
 import org.testcontainers.containers.MongoDBContainer;
@@ -16,7 +15,6 @@
 import static org.assertj.core.api.Assertions.assertThat;
 
 @SpringBootTest
-@AutoConfigureMockMvc
 @Testcontainers
 class DefaultDailyBalanceServiceTest {
   @Container

05_driven_push/pom.xml

@@ -64,6 +64,17 @@
             <artifactId>junit-jupiter</artifactId>
             <scope>test</scope>
         </dependency>
+        <dependency>
+            <groupId>org.testcontainers</groupId>
+            <artifactId>mongodb</artifactId>
+            <scope>test</scope>
+        </dependency>
+        <dependency>
+            <groupId>org.testcontainers</groupId>
+            <artifactId>rabbitmq</artifactId>
+            <version>1.20.3</version>
+            <scope>test</scope>
+        </dependency>
     </dependencies>
 
 </project>

05_driven_push/src/main/java/io/doubleloop/drivenpush/DemoMessageConsumer.java

@@ -15,12 +15,22 @@ public class DemoMessageConsumer {
 
   private final Jsonb jsonb;
 
+  private PostMessageCommand lastPostMessage;
+
   public DemoMessageConsumer(Jsonb jsonb) {
     this.jsonb = jsonb;
   }
 
   public void receiveMessage(String message) {
-    final var post = jsonb.fromJson(message, PostMessageCommand.class);
-    log.info("Received: {}", post);
+    lastPostMessage = jsonb.fromJson(message, PostMessageCommand.class);
+    log.info("Received: {}", lastPostMessage);
+  }
+
+  public PostMessageCommand getLastPostMessage() {
+    return lastPostMessage;
+  }
+
+  public void resetLastPostMessage() {
+    lastPostMessage = null;
   }
 }

05_driven_push/src/main/java/io/doubleloop/drivenpush/PostMessageCommand.java

@@ -1,5 +1,7 @@
 package io.doubleloop.drivenpush;
 
+import java.util.Objects;
+
 public class PostMessageCommand {
 
   private String userId;
@@ -29,6 +31,18 @@ public void setContent(String content) {
     this.content = content;
   }
 
+  @Override
+  public boolean equals(Object o) {
+    if (o == null || getClass() != o.getClass()) return false;
+    PostMessageCommand that = (PostMessageCommand) o;
+    return Objects.equals(userId, that.userId) && Objects.equals(content, that.content);
+  }
+
+  @Override
+  public int hashCode() {
+    return Objects.hash(userId, content);
+  }
+
   @Override
   public String toString() {
     return "PostMessageCommand{" +

05_driven_push/src/main/java/io/doubleloop/drivenpush/SeedDatabase.java

@@ -10,9 +10,9 @@ public class SeedDatabase implements CommandLineRunner {
 
   private static final Logger log = LoggerFactory.getLogger(SeedDatabase.class);
 
-  private final SpringUserRepository repository;
+  private final SpringMongoUserRepository repository;
 
-  public SeedDatabase(SpringUserRepository repository) {
+  public SeedDatabase(SpringMongoUserRepository repository) {
     this.repository = repository;
   }
 

05_driven_push/src/main/java/io/doubleloop/drivenpush/SpringUserRepository.java renamed to 05_driven_push/src/main/java/io/doubleloop/drivenpush/SpringMongoUserRepository.java

@@ -2,5 +2,5 @@
 
 import org.springframework.data.mongodb.repository.MongoRepository;
 
-public interface SpringUserRepository extends MongoRepository<User, String>, UserRepository {
+public interface SpringMongoUserRepository extends MongoRepository<User, String>, UserRepository {
 }

05_driven_push/src/main/resources/application.properties

@@ -1,4 +1,4 @@
 spring.rabbitmq.host=localhost
 spring.rabbitmq.port=5672
+spring.rabbitmq.username=myuser
 spring.rabbitmq.password=secret
-spring.rabbitmq.username=myuser

05_driven_push/src/test/java/io/doubleloop/drivenpush/DefaultPostServiceTest.java

@@ -0,0 +1,91 @@
+package io.doubleloop.drivenpush;
+
+import org.junit.jupiter.api.BeforeAll;
+import org.junit.jupiter.api.BeforeEach;
+import org.junit.jupiter.api.Test;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.boot.test.context.SpringBootTest;
+import org.springframework.boot.testcontainers.service.connection.ServiceConnection;
+import org.testcontainers.containers.MongoDBContainer;
+import org.testcontainers.containers.RabbitMQContainer;
+import org.testcontainers.junit.jupiter.Container;
+import org.testcontainers.junit.jupiter.Testcontainers;
+
+import static java.lang.Thread.sleep;
+import static org.assertj.core.api.Assertions.assertThat;
+import static org.assertj.core.api.Assertions.assertThatThrownBy;
+
+@SpringBootTest
+@Testcontainers
+class DefaultPostServiceTest {
+
+  @Container
+  @ServiceConnection
+  private static MongoDBContainer container = new MongoDBContainer("mongo:latest");
+
+  @Container
+  static final RabbitMQContainer rabbitMQContainer = new RabbitMQContainer("rabbitmq:latest")
+      .withUser("guest", "guest")
+      .withExposedPorts(5672);
+
+  @Autowired
+  private DemoMessageConsumer consumer;
+
+  @Autowired
+  private SpringMongoUserRepository userRepository;
+  @Autowired
+  private PostService postService;
+
+  @BeforeAll
+  static void setup() {
+    System.setProperty("spring.rabbitmq.host", rabbitMQContainer.getHost());
+    System.setProperty("spring.rabbitmq.port", rabbitMQContainer.getAmqpPort().toString());
+    System.setProperty("spring.rabbitmq.username", "guest");
+    System.setProperty("spring.rabbitmq.password", "guest");
+  }
+
+  @BeforeEach
+  void setUp() {
+    userRepository.deleteAll();
+    consumer.resetLastPostMessage();
+  }
+
+  @Test
+  void userPostMessage() throws Exception {
+    final var user = userRepository.save(new User("[email protected]", false));
+
+    final var command = new PostMessageCommand();
+    command.setUserId(user.getId());
+    command.setContent("test");
+
+    postService.postMessage(command);
+
+    sleep(100);
+    final var post = consumer.getLastPostMessage();
+    assertThat(post).isEqualTo(command);
+  }
+
+  @Test
+  void blockedUserPostMessage() throws Exception {
+    final var user = userRepository.save(new User("[email protected]", true));
+
+    final var command = new PostMessageCommand();
+    command.setUserId(user.getId());
+    command.setContent("test");
+
+    assertThatThrownBy(() -> postService.postMessage(command))
+        .isInstanceOf(IllegalArgumentException.class);
+  }
+
+  @Test
+  void unknownUserPostMessage() throws Exception {
+    final var user = userRepository.save(new User("[email protected]", true));
+
+    final var command = new PostMessageCommand();
+    command.setUserId("unknown");
+    command.setContent("test");
+
+    assertThatThrownBy(() -> postService.postMessage(command))
+        .isInstanceOf(IllegalArgumentException.class);
+  }
+}

pom.xml

@@ -97,6 +97,11 @@
                 <version>1.19.8</version>
                 <scope>test</scope>
             </dependency>
+            <dependency>
+                <groupId>org.testcontainers</groupId>
+                <artifactId>rabbitmq</artifactId>
+                <scope>test</scope>
+            </dependency>
             <dependency>
                 <groupId>org.wiremock.integrations</groupId>
                 <artifactId>wiremock-spring-boot</artifactId>