Added asciinema

Author: irinakomarchenko

.gitignore

@@ -28,6 +28,7 @@ replay_pid*
 *.iml
 *.iws
 *.ipr
+*.cast
 out/
 
 # Maven
@@ -40,7 +41,6 @@ release.properties
 dependency-reduced-pom.xml
 buildNumber.properties
 .mvn/timing.properties
-# https://github.com/takari/maven-wrapper#usage-without-binary-jar
 .mvn/wrapper/maven-wrapper.jar
 
 # OS-specific

README.md

@@ -65,4 +65,7 @@ java -jar target/user-service-spring.jar
 
 ### 7. Пример работы приложения
 ![img_1.png](readme-resources/img_1.png)
-![img_2.png](readme-resources/img_2.png)
+![img_2.png](readme-resources/img_2.png)
+
+[![asciicast](https://asciinema.org/a/724582.svg)](https://asciinema.org/a/724582)
+

notification-service/src/main/java/notificationservice/dto/UserEventNotificDto.java

@@ -4,6 +4,6 @@
 
 @Data
 public class UserEventNotificDto {
-    private String operation; // "CREATE" или "DELETE"
+    private String operation;
     private String email;
 }

pom.xml

@@ -58,7 +58,16 @@
     </dependencies>
 
     <build>
-        <plugins>
+        <pluginManagement>
+            <plugins>
+                <plugin>
+                    <groupId>org.springframework.boot</groupId>
+                    <artifactId>spring-boot-maven-plugin</artifactId>
+                    <version>${spring-boot.version}</version>
+                </plugin>
+            </plugins>
+        </pluginManagement>
+            <plugins>
             <plugin>
                 <groupId>org.apache.maven.plugins</groupId>
                 <artifactId>maven-surefire-plugin</artifactId>

user-service/src/main/java/myuserservice/UserServiceSpringApplication.java

@@ -4,9 +4,11 @@
 import org.springframework.boot.SpringApplication;
 import org.springframework.boot.autoconfigure.EnableAutoConfiguration;
 import org.springframework.boot.autoconfigure.SpringBootApplication;
+import org.springframework.scheduling.annotation.EnableScheduling;
 
 @SpringBootApplication
 @EnableAutoConfiguration
+@EnableScheduling
 public class UserServiceSpringApplication {
 
     public static void main(String[] args) {

user-service/src/main/java/myuserservice/entity/OutboxEventType.java

@@ -0,0 +1,6 @@
+package myuserservice.entity;
+
+public enum OutboxEventType {
+    CREATE,
+    DELETE
+}

user-service/src/main/java/myuserservice/entity/OutboxMessage.java

@@ -1,6 +1,9 @@
 package myuserservice.entity;
+
 import jakarta.persistence.Column;
 import jakarta.persistence.Entity;
+import jakarta.persistence.EnumType;
+import jakarta.persistence.Enumerated;
 import jakarta.persistence.GeneratedValue;
 import jakarta.persistence.GenerationType;
 import jakarta.persistence.Id;
@@ -23,7 +26,9 @@ public class OutboxMessage {
     @Id
     @GeneratedValue(strategy = GenerationType.IDENTITY)
     private Long id;
-    private String eventType;
+
+    @Enumerated(EnumType.STRING)
+    private OutboxEventType eventType;
 
     @Column(columnDefinition = "TEXT")
     private String payload;

user-service/src/main/java/myuserservice/service/UserServiceImpl.java

@@ -4,6 +4,7 @@
 import lombok.RequiredArgsConstructor;
 import myuserservice.dto.UserDto;
 import myuserservice.dto.UserEventDto;
+import myuserservice.entity.OutboxEventType;
 import myuserservice.mapper.UserMapper;
 import myuserservice.entity.OutboxMessage;
 import myuserservice.entity.User;
@@ -41,7 +42,7 @@ public UserDto createUser(UserDto userDto) {
         log.info("Пользователь добавлен: {}", saved);
 
 
-        saveOutboxEvent("CREATE", saved.getEmail());
+        saveOutboxEvent(OutboxEventType.CREATE, saved.getEmail());
 
         return UserMapper.toDto(saved);
     }
@@ -83,19 +84,19 @@ public void deleteUser(Long id) {
         userRepository.deleteById(id);
         log.info("Пользователь с id {} удалён", id);
 
-        saveOutboxEvent("DELETE", user.getEmail());
+        saveOutboxEvent(OutboxEventType.DELETE, user.getEmail());
     }
 
-    private void saveOutboxEvent(String operation, String email) {
+    private void saveOutboxEvent(OutboxEventType eventType, String email) {
         try {
             UserEventDto event = UserEventDto.builder()
-                    .operation(operation)
+                    .operation(eventType.name())
                     .email(email)
                     .build();
             String payload = objectMapper.writeValueAsString(event);
 
             OutboxMessage outbox = OutboxMessage.builder()
-                    .eventType(operation)
+                    .eventType(eventType)
                     .payload(payload)
                     .createdAt(LocalDateTime.now())
                     .processed(false)

user-service/src/main/resources/application.properties

@@ -11,3 +11,5 @@ spring.http.encoding.charset=UTF-8
 spring.http.encoding.enabled=true
 spring.http.encoding.force=true
 spring.kafka.bootstrap-servers=localhost:9092
+
+

user-service/src/test/java/myuserservice/integration/UserServiceIntegrationTest.java

@@ -1,6 +1,7 @@
 package myuserservice.integration;
 
 import myuserservice.dto.UserDto;
+import myuserservice.entity.OutboxEventType;
 import myuserservice.entity.User;
 import myuserservice.repository.OutboxRepository;
 import myuserservice.repository.UserRepository;
@@ -54,7 +55,7 @@ void testUserCreate_savesOutboxMessage() {
         var dto = UserDto.builder().name("Zoe").email("[email protected]").age(38).build();
         userService.createUser(dto);
         var messages = outboxRepository.findAll();
-        assertThat(messages).anyMatch(m -> m.getEventType().equals("CREATE"));
+        assertThat(messages).anyMatch(m -> m.getEventType().equals(OutboxEventType.CREATE));
     }