변경, 추가 이벤트의 워딩을 Command 로 변경

Author: gracefulife

profile/src/main/java/com/example/research/profile/entity/cache/Profile.java

@@ -1,7 +1,7 @@
 package com.example.research.profile.entity.cache;
 
-import com.example.research.profile.entity.event.ProfileChangedEvent;
-import com.example.research.profile.entity.event.ProfileSavedEvent;
+import com.example.research.profile.entity.command.ProfileChangedCommand;
+import com.example.research.profile.entity.command.ProfileSavedCommand;
 import com.example.research.profile.entity.storage.ProfileEvent;
 
 import org.springframework.data.annotation.Id;
@@ -36,13 +36,13 @@ public static Profile from(com.example.research.profile.entity.storage.Profile p
   }
 
   // 생성 이벤트에서 왔으므로, 항상 active
-  public static Profile from(ProfileSavedEvent event) {
+  public static Profile from(ProfileSavedCommand event) {
     return from(event.getId(), event.getName(), event.getAge(),
         event.getSex(), true, Collections.emptySet());
   }
 
   // TODO active 상태
-  public static Profile from(ProfileChangedEvent event) {
+  public static Profile from(ProfileChangedCommand event) {
     return from(event.getId(), event.getName(), event.getAge(),
         event.getSex(), true, Collections.emptySet());
   }

profile/src/main/java/com/example/research/profile/entity/command/Command.java

@@ -0,0 +1,9 @@
+package com.example.research.profile.entity.command;
+
+import java.io.Serializable;
+
+public interface Command<ID> extends Serializable {
+  String getTag();
+
+  ID getId();
+}

profile/src/main/java/com/example/research/profile/entity/event/ProfileChangedEvent.java renamed to profile/src/main/java/com/example/research/profile/entity/command/ProfileChangedCommand.java

@@ -1,4 +1,4 @@
-package com.example.research.profile.entity.event;
+package com.example.research.profile.entity.command;
 
 import com.example.research.profile.entity.storage.Profile;
 
@@ -11,17 +11,17 @@
 @Data
 @NoArgsConstructor
 @AllArgsConstructor
-public class ProfileChangedEvent extends ProfileEvent {
-  public static final String TAG = ProfileChangedEvent.class.getSimpleName();
+public class ProfileChangedCommand extends ProfileCommand {
+  public static final String TAG = ProfileChangedCommand.class.getSimpleName();
 
   String id;
   String name;
   Integer age;
   String sex; // man, woman
   LocalDateTime createdAt;
 
-  public static ProfileChangedEvent from(Profile storeProfile) {
-    return new ProfileChangedEvent(
+  public static ProfileChangedCommand from(Profile storeProfile) {
+    return new ProfileChangedCommand(
         storeProfile.getId(),
         storeProfile.getName(), storeProfile.getAge(),
         storeProfile.getSex(), storeProfile.getCreatedAt()

profile/src/main/java/com/example/research/profile/entity/command/ProfileCommand.java

@@ -0,0 +1,4 @@
+package com.example.research.profile.entity.command;
+
+public abstract class ProfileCommand implements Command<String> {
+}

profile/src/main/java/com/example/research/profile/entity/event/ProfileSavedEvent.java renamed to profile/src/main/java/com/example/research/profile/entity/command/ProfileSavedCommand.java

@@ -1,4 +1,4 @@
-package com.example.research.profile.entity.event;
+package com.example.research.profile.entity.command;
 
 import com.example.research.profile.entity.storage.Profile;
 
@@ -12,17 +12,17 @@
 @ToString
 @Getter
 @RequiredArgsConstructor
-public class ProfileSavedEvent extends ProfileEvent {
-  public static final String TAG = ProfileSavedEvent.class.getSimpleName();
+public class ProfileSavedCommand extends ProfileCommand {
+  public static final String TAG = ProfileSavedCommand.class.getSimpleName();
 
   @NonNull String id;
   @NonNull String name;
   @NonNull Integer age;
   @NonNull String sex; // man, woman
   @NonNull LocalDateTime createdAt;
 
-  public static ProfileSavedEvent from(Profile storeProfile) {
-    return new ProfileSavedEvent(
+  public static ProfileSavedCommand from(Profile storeProfile) {
+    return new ProfileSavedCommand(
         storeProfile.getId(),
         storeProfile.getName(), storeProfile.getAge(),
         storeProfile.getSex(), storeProfile.getCreatedAt()

profile/src/main/java/com/example/research/profile/entity/event/Event.java

@@ -1,6 +1,7 @@
 package com.example.research.profile.entity.storage;
 
 import com.example.research.profile.core.StoredEvent;
+import com.example.research.profile.entity.command.ProfileCommand;
 
 import java.time.LocalDateTime;
 
@@ -43,7 +44,7 @@ public ProfileEvent() {
     this.createdAt = LocalDateTime.now();
   }
 
-  public static ProfileEvent from(com.example.research.profile.entity.event.ProfileEvent event,
+  public static ProfileEvent from(ProfileCommand event,
                                   Long latestVersion, String payload) {
     ProfileEvent profileEvent = new ProfileEvent();
     profileEvent.identifier = event.getId();

profile/src/main/java/com/example/research/profile/entity/event/ProfileEvent.java

@@ -1,6 +1,6 @@
 package com.example.research.profile.v1.profile;
 
-import com.example.research.profile.entity.event.ProfileEvent;
+import com.example.research.profile.entity.command.ProfileCommand;
 import com.example.research.profile.entity.storage.ProfileEventStoreRepository;
 import com.example.research.profile.entity.storage.ProfileStorageRepository;
 import com.fasterxml.jackson.core.JsonProcessingException;
@@ -26,7 +26,7 @@ public class ProfileEventHandler {
 
   @Async
   @Transactional
-  public CompletableFuture<com.example.research.profile.entity.storage.ProfileEvent> save(ProfileEvent event) {
+  public CompletableFuture<com.example.research.profile.entity.storage.ProfileEvent> save(ProfileCommand event) {
     return CompletableFuture.supplyAsync(() -> {
       Long latestVersion = profileEventStoreRepository
           .findTopByIdentifierOrderByNoDesc(event.getId())
@@ -40,7 +40,7 @@ public CompletableFuture<com.example.research.profile.entity.storage.ProfileEven
     });
   }
 
-  private String generatePayload(ProfileEvent event) {
+  private String generatePayload(ProfileCommand event) {
     String payload;
     try {
       payload = objectMapper.writeValueAsString(event);

profile/src/main/java/com/example/research/profile/entity/storage/ProfileEvent.java

@@ -2,8 +2,8 @@
 
 import com.example.research.profile.entity.cache.Profile;
 import com.example.research.profile.entity.cache.ProfileRepository;
-import com.example.research.profile.entity.event.ProfileChangedEvent;
-import com.example.research.profile.entity.event.ProfileSavedEvent;
+import com.example.research.profile.entity.command.ProfileChangedCommand;
+import com.example.research.profile.entity.command.ProfileSavedCommand;
 import com.example.research.profile.entity.storage.ProfileStorageRepository;
 
 import org.springframework.beans.factory.annotation.Autowired;
@@ -23,7 +23,7 @@ public class ProfileEventListener {
   @Autowired ProfileRepository profileRepository;
   @Autowired ProfileStorageRepository profileStorageRepository;
 
-  @EventListener public void onProfileSavedEventReceived(ProfileSavedEvent event) {
+  @EventListener public void onProfileSavedEventReceived(ProfileSavedCommand event) {
     log.info("onProfileSavedEventReceived received : {}" + event);
     profileRepository.save(Profile.from(event))
         .flatMap(profile -> Mono.fromCompletionStage(profileEventHandler.save(event)))
@@ -32,7 +32,7 @@ public class ProfileEventListener {
         .subscribe();
   }
 
-  @EventListener public void onProfileChangedEventReceived(ProfileChangedEvent event) {
+  @EventListener public void onProfileChangedEventReceived(ProfileChangedCommand event) {
     log.info("onProfileChangedEventReceived received : {}" + event);
 
     Mono.fromCompletionStage(profileEventHandler.save(event))