BAEL-9234: Eventuate Tram (#18587)

* BAEL-9234: repackaged springmodulith code

* BAEL-9234: refactoring

* BAEL-9234: eventuate code samples

Author: etrandafir93

spring-boot-modules/spring-boot-libraries-3/drawio/eventuate-tram.drawio

@@ -16,6 +16,11 @@
             <groupId>org.springframework.boot</groupId>
             <artifactId>spring-boot-starter-data-jpa</artifactId>
         </dependency>
+        <dependency>
+            <groupId>org.springframework.boot</groupId>
+            <artifactId>spring-boot-starter-web</artifactId>
+        </dependency>
+
         <dependency>
             <groupId>org.springframework.kafka</groupId>
             <artifactId>spring-kafka</artifactId>
@@ -27,6 +32,17 @@
             <version>${postgresql.version}</version>
         </dependency>
 
+        <dependency>
+            <groupId>io.eventuate.tram.core</groupId>
+            <artifactId>eventuate-tram-spring-jdbc-kafka</artifactId>
+            <version>${eventuate.tram.version}</version>
+        </dependency>
+        <dependency>
+            <groupId>io.eventuate.tram.core</groupId>
+            <artifactId>eventuate-tram-spring-events</artifactId>
+            <version>${eventuate.tram.version}</version>
+        </dependency>
+
         <dependency>
             <groupId>org.springframework.modulith</groupId>
             <artifactId>spring-modulith-events-api</artifactId>
@@ -84,6 +100,12 @@
             <scope>test</scope>
         </dependency>
 
+        <dependency>
+            <groupId>net.javacrumbs.json-unit</groupId>
+            <artifactId>json-unit-assertj</artifactId>
+            <version>${json-unit-assertj.version}</version>
+            <scope>test</scope>
+        </dependency>
         <dependency>
             <groupId>org.awaitility</groupId>
             <artifactId>awaitility</artifactId>
@@ -112,7 +134,23 @@
         <postgresql.version>42.3.1</postgresql.version>
         <h2.version>2.2.224</h2.version>
         <jolokia-support-spring.version>2.2.1</jolokia-support-spring.version>
+        <eventuate.tram.version>0.36.0.RELEASE</eventuate.tram.version>
+        <json-unit-assertj.version>3.5.0</json-unit-assertj.version>
     </properties>
 
+    <build>
+        <plugins>
+            <plugin>
+                <groupId>org.apache.maven.plugins</groupId>
+                <artifactId>maven-compiler-plugin</artifactId>
+                <version>3.8.1</version>
+                <configuration>
+                    <source>21</source>
+                    <target>21</target>
+                </configuration>
+            </plugin>
+        </plugins>
+    </build>
+
 </project>
 

spring-boot-modules/spring-boot-libraries-3/pom.xml

@@ -1,8 +1,11 @@
-package com.baeldung.springmodulith;
+package com.baeldung;
 
 import org.springframework.boot.SpringApplication;
 import org.springframework.boot.autoconfigure.SpringBootApplication;
 
+/**
+ * use the appropriate profile: eventuate|modulith
+ */
 @SpringBootApplication
 public class Application {
 

spring-boot-modules/spring-boot-libraries-3/src/main/java/com/baeldung/springmodulith/Application.java renamed to spring-boot-modules/spring-boot-libraries-3/src/main/java/com/baeldung/Application.java

@@ -0,0 +1,32 @@
+package com.baeldung.eventuate.tram;
+
+import org.springframework.http.HttpStatus;
+import org.springframework.http.ResponseEntity;
+import org.springframework.web.bind.annotation.PathVariable;
+import org.springframework.web.bind.annotation.PostMapping;
+import org.springframework.web.bind.annotation.RequestBody;
+import org.springframework.web.bind.annotation.RestController;
+
+import com.baeldung.eventuate.tram.domain.CommentService;
+import com.baeldung.eventuate.tram.domain.Comment;
+
+@RestController
+public class CommentsController {
+
+    private final CommentService commentService;
+
+    public CommentsController(CommentService service) {
+        this.commentService = service;
+    }
+
+    @PostMapping("/api/articles/{slug}/comments")
+    public ResponseEntity<Long> addComment(@RequestBody AddCommentDto dto, @PathVariable String slug) {
+        Comment comment = new Comment(dto.text(), slug, dto.commentAuthor());
+        long id = commentService.save(comment);
+        return ResponseEntity.status(HttpStatus.CREATED)
+            .body(id);
+    }
+
+    record AddCommentDto(String text, String commentAuthor) {
+    }
+}

spring-boot-modules/spring-boot-libraries-3/src/main/java/com/baeldung/eventuate/tram/CommentsController.java

@@ -0,0 +1,13 @@
+package com.baeldung.eventuate.tram;
+
+import org.springframework.context.annotation.Configuration;
+import org.springframework.context.annotation.Import;
+
+import io.eventuate.tram.spring.events.publisher.TramEventsPublisherConfiguration;
+import io.eventuate.tram.spring.messaging.producer.jdbc.TramMessageProducerJdbcConfiguration;
+
+@Configuration
+@Import({ TramEventsPublisherConfiguration.class, TramMessageProducerJdbcConfiguration.class })
+class EventuateConfig {
+
+}

spring-boot-modules/spring-boot-libraries-3/src/main/java/com/baeldung/eventuate/tram/EventuateConfig.java

@@ -0,0 +1,42 @@
+package com.baeldung.eventuate.tram.domain;
+
+import jakarta.persistence.Entity;
+import jakarta.persistence.GeneratedValue;
+import jakarta.persistence.GenerationType;
+import jakarta.persistence.Id;
+
+@Entity
+public class Comment {
+
+    @Id
+    @GeneratedValue(strategy = GenerationType.IDENTITY)
+    private Long id;
+    private String text;
+    private String articleSlug;
+    private String commentAuthor;
+
+    public Comment(String text, String articleSlug, String commentAuthor) {
+        this.text = text;
+        this.articleSlug = articleSlug;
+        this.commentAuthor = commentAuthor;
+    }
+
+    Comment() {
+    }
+
+    public Long getId() {
+        return id;
+    }
+
+    public String getText() {
+        return text;
+    }
+
+    public String getArticleSlug() {
+        return articleSlug;
+    }
+
+    public String getCommentAuthor() {
+        return commentAuthor;
+    }
+}

spring-boot-modules/spring-boot-libraries-3/src/main/java/com/baeldung/eventuate/tram/domain/Comment.java

@@ -0,0 +1,6 @@
+package com.baeldung.eventuate.tram.domain;
+
+import io.eventuate.tram.events.common.DomainEvent;
+
+record CommentAddedEvent(Long id, String articleSlug) implements DomainEvent {
+}

spring-boot-modules/spring-boot-libraries-3/src/main/java/com/baeldung/eventuate/tram/domain/CommentAddedEvent.java

@@ -0,0 +1,6 @@
+package com.baeldung.eventuate.tram.domain;
+
+import org.springframework.data.jpa.repository.JpaRepository;
+
+public interface CommentRepository extends JpaRepository<Comment, Long> {
+}

spring-boot-modules/spring-boot-libraries-3/src/main/java/com/baeldung/eventuate/tram/domain/CommentRepository.java

@@ -0,0 +1,35 @@
+package com.baeldung.eventuate.tram.domain;
+
+import static java.util.Collections.singletonList;
+
+import org.slf4j.Logger;
+import org.slf4j.LoggerFactory;
+import org.springframework.stereotype.Service;
+
+import io.eventuate.tram.events.publisher.DomainEventPublisher;
+import jakarta.transaction.Transactional;
+
+@Service
+public class CommentService {
+
+    private static final Logger log = LoggerFactory.getLogger(CommentService.class);
+
+    private final CommentRepository comments;
+    private final DomainEventPublisher domainEvents;
+
+    public CommentService(CommentRepository commentRepository, DomainEventPublisher domainEvents) {
+        this.comments = commentRepository;
+        this.domainEvents = domainEvents;
+    }
+
+    @Transactional
+    public Long save(Comment comment) {
+        Comment saved = this.comments.save(comment);
+        log.info("Comment created: {}", saved);
+
+        CommentAddedEvent commentAdded = new CommentAddedEvent(saved.getId(), saved.getArticleSlug());
+        domainEvents.publish("baeldung.comment.added", saved.getId(), singletonList(commentAdded));
+        return saved.getId();
+    }
+
+}

spring-boot-modules/spring-boot-libraries-3/src/main/java/com/baeldung/eventuate/tram/domain/CommentService.java

@@ -1,4 +1,4 @@
-package com.baeldung.springmodulith.application.events.orders;
+package com.baeldung.spring.modulith.events.orders;
 
 import java.time.Instant;
 import java.util.List;