From 07282ade7457faec52662e963eabf509d6472f32 Mon Sep 17 00:00:00 2001
From: Alexander <alexander.bryksin@yandex.ru>
Date: Thu, 14 Apr 2022 10:33:21 +0300
Subject: [PATCH] feature: add bank account mongo projection handle events
 methods

---
 .../BankAccountMongoProjection.java           | 53 ++++++++++++++++++-
 .../exceptions/UnknownEventTypeException.java | 10 ++++
 2 files changed, 62 insertions(+), 1 deletion(-)
 create mode 100644 src/main/java/com/eventsourcing/exceptions/UnknownEventTypeException.java

diff --git a/src/main/java/com/eventsourcing/bankAccount/projection/BankAccountMongoProjection.java b/src/main/java/com/eventsourcing/bankAccount/projection/BankAccountMongoProjection.java
index 811544d..935edf5 100644
--- a/src/main/java/com/eventsourcing/bankAccount/projection/BankAccountMongoProjection.java
+++ b/src/main/java/com/eventsourcing/bankAccount/projection/BankAccountMongoProjection.java
@@ -1,8 +1,14 @@
 package com.eventsourcing.bankAccount.projection;
 
 
+import com.eventsourcing.bankAccount.events.AddressUpdatedEvent;
+import com.eventsourcing.bankAccount.events.BalanceDepositedEvent;
+import com.eventsourcing.bankAccount.events.BankAccountCreatedEvent;
+import com.eventsourcing.bankAccount.events.EmailChangedEvent;
 import com.eventsourcing.es.Event;
+import com.eventsourcing.es.Projection;
 import com.eventsourcing.es.SerializerUtils;
+import com.eventsourcing.exceptions.UnknownEventTypeException;
 import lombok.RequiredArgsConstructor;
 import lombok.extern.slf4j.Slf4j;
 import org.springframework.beans.factory.annotation.Value;
@@ -17,7 +23,7 @@ import java.util.Arrays;
 @Service
 @Slf4j
 @RequiredArgsConstructor
-public class BankAccountMongoProjection {
+public class BankAccountMongoProjection implements Projection {
 
     @Value(value = "${microservice.kafka.topics.bank-account-event-store:bank-account-event-store}")
     private String bankAccountTopicName;
@@ -32,6 +38,7 @@ public class BankAccountMongoProjection {
 
         try {
             final Event[] events = SerializerUtils.deserializeEventsFromJsonBytes(data);
+            Arrays.stream(events).toList().forEach(this::when);
             ack.acknowledge();
             log.info("ack events: {}", Arrays.toString(events));
         } catch (Exception e) {
@@ -40,4 +47,48 @@ public class BankAccountMongoProjection {
             log.error("bankAccountMongoProjectionListener: {}", e.getMessage());
         }
     }
+
+    @Override
+    public void when(Event event) {
+        final var aggregateId = event.getAggregateId();
+        log.info("(when) >>>>> aggregateId: {}", aggregateId);
+
+        switch (event.getEventType()) {
+            case BankAccountCreatedEvent.BANK_ACCOUNT_CREATED_V1 ->
+                    handle(SerializerUtils.deserializeFromJsonBytes(event.getData(), BankAccountCreatedEvent.class));
+            case EmailChangedEvent.EMAIL_CHANGED_V1 ->
+                    handle(SerializerUtils.deserializeFromJsonBytes(event.getData(), EmailChangedEvent.class));
+            case AddressUpdatedEvent.ADDRESS_UPDATED_V1 ->
+                    handle(SerializerUtils.deserializeFromJsonBytes(event.getData(), AddressUpdatedEvent.class));
+            case BalanceDepositedEvent.BALANCE_DEPOSITED ->
+                    handle(SerializerUtils.deserializeFromJsonBytes(event.getData(), BalanceDepositedEvent.class));
+            default -> throw new UnknownEventTypeException(event.getEventType());
+        }
+    }
+
+
+    private void handle(BankAccountCreatedEvent event) {
+        log.info("(when) BankAccountCreatedEvent: {}, aggregateID: {}", event, event.getAggregateId());
+
+//        final var document = BankAccountDocument.builder()
+//                .aggregateId(event.getAggregateId())
+//                .email(event.getEmail())
+//                .address(event.getAddress())
+//                .userName(event.getUserName())
+//                .balance(BigDecimal.valueOf(0))
+//                .build();
+    }
+
+    private void handle(EmailChangedEvent event) {
+        log.info("(when) EmailChangedEvent: {}, aggregateID: {}", event, event.getAggregateId());
+    }
+
+    private void handle(AddressUpdatedEvent event) {
+        log.info("(when) AddressUpdatedEvent: {}, aggregateID: {}", event, event.getAggregateId());
+    }
+
+    private void handle(BalanceDepositedEvent event) {
+        log.info("(when) BalanceDepositedEvent: {}, aggregateID: {}", event, event.getAggregateId());
+
+    }
 }
diff --git a/src/main/java/com/eventsourcing/exceptions/UnknownEventTypeException.java b/src/main/java/com/eventsourcing/exceptions/UnknownEventTypeException.java
new file mode 100644
index 0000000..d53dc55
--- /dev/null
+++ b/src/main/java/com/eventsourcing/exceptions/UnknownEventTypeException.java
@@ -0,0 +1,10 @@
+package com.eventsourcing.exceptions;
+
+public class UnknownEventTypeException extends RuntimeException {
+    public UnknownEventTypeException() {
+    }
+
+    public UnknownEventTypeException(String eventType) {
+        super("unknown event type: " + eventType);
+    }
+}