Add analytics context

Author: rgomezcasas

gradle/wrapper/gradle-wrapper.properties

@@ -1,5 +1,6 @@
+#Mon Dec 23 16:15:02 CET 2019
+distributionUrl=https\://services.gradle.org/distributions/gradle-6.0.1-all.zip
 distributionBase=GRADLE_USER_HOME
 distributionPath=wrapper/dists
-distributionUrl=https\://services.gradle.org/distributions/gradle-6.0.1-bin.zip
-zipStoreBase=GRADLE_USER_HOME
 zipStorePath=wrapper/dists
+zipStoreBase=GRADLE_USER_HOME

settings.gradle

@@ -3,6 +3,9 @@ rootProject.name = 'java-ddd-skeleton'
 include ':shared'
 project(':shared').projectDir = new File('src/shared')
 
+include ':analytics'
+project(':analytics').projectDir = new File('src/analytics')
+
 include ':backoffice'
 project(':backoffice').projectDir = new File('src/backoffice')
 

src/analytics/main/tv/codely/analytics/domain_events/application/store/DomainEventStorer.java

@@ -0,0 +1,22 @@
+package tv.codely.analytics.domain_events.application.store;
+
+import tv.codely.analytics.domain_events.domain.*;
+
+public final class DomainEventStorer {
+    private DomainEventsRepository repository;
+
+    public DomainEventStorer(DomainEventsRepository repository) {
+        this.repository = repository;
+    }
+
+    public void store(
+        AnalyticsDomainEventId id,
+        AnalyticsDomainEventAggregateId aggregateId,
+        AnalyticsDomainEventName name,
+        AnalyticsDomainEventBody body
+    ) {
+        AnalyticsDomainEvent domainEvent = new AnalyticsDomainEvent(id, aggregateId, name, body);
+
+        repository.save(domainEvent);
+    }
+}

src/analytics/main/tv/codely/analytics/domain_events/application/store/StoreDomainEventOnOccurred.java

@@ -0,0 +1,28 @@
+package tv.codely.analytics.domain_events.application.store;
+
+import org.springframework.context.event.EventListener;
+import tv.codely.analytics.domain_events.domain.AnalyticsDomainEventAggregateId;
+import tv.codely.analytics.domain_events.domain.AnalyticsDomainEventBody;
+import tv.codely.analytics.domain_events.domain.AnalyticsDomainEventId;
+import tv.codely.analytics.domain_events.domain.AnalyticsDomainEventName;
+import tv.codely.shared.domain.bus.event.DomainEvent;
+import tv.codely.shared.domain.bus.event.DomainEventSubscriber;
+
+@DomainEventSubscriber({DomainEvent.class})
+public final class StoreDomainEventOnOccurred {
+    private final DomainEventStorer storer;
+
+    public StoreDomainEventOnOccurred(DomainEventStorer storer) {
+        this.storer = storer;
+    }
+
+    @EventListener
+    public void on(DomainEvent event) {
+        AnalyticsDomainEventId          id          = new AnalyticsDomainEventId(event.eventId());
+        AnalyticsDomainEventAggregateId aggregateId = new AnalyticsDomainEventAggregateId(event.aggregateId());
+        AnalyticsDomainEventName        name        = new AnalyticsDomainEventName(event.eventName());
+        AnalyticsDomainEventBody        body        = new AnalyticsDomainEventBody(event.toPrimitives());
+
+        storer.store(id, aggregateId, name, body);
+    }
+}

src/analytics/main/tv/codely/analytics/domain_events/domain/AnalyticsDomainEvent.java

@@ -0,0 +1,37 @@
+package tv.codely.analytics.domain_events.domain;
+
+public final class AnalyticsDomainEvent {
+    private final AnalyticsDomainEventId          id;
+    private final AnalyticsDomainEventAggregateId aggregateId;
+    private final AnalyticsDomainEventName        name;
+    private final AnalyticsDomainEventBody        body;
+
+    public AnalyticsDomainEvent(
+        AnalyticsDomainEventId id,
+        AnalyticsDomainEventAggregateId aggregateId,
+        AnalyticsDomainEventName name,
+        AnalyticsDomainEventBody body
+    ) {
+
+        this.id          = id;
+        this.aggregateId = aggregateId;
+        this.name        = name;
+        this.body        = body;
+    }
+
+    public AnalyticsDomainEventId getId() {
+        return id;
+    }
+
+    public AnalyticsDomainEventAggregateId getAggregateId() {
+        return aggregateId;
+    }
+
+    public AnalyticsDomainEventName getName() {
+        return name;
+    }
+
+    public AnalyticsDomainEventBody getBody() {
+        return body;
+    }
+}

src/analytics/main/tv/codely/analytics/domain_events/domain/AnalyticsDomainEventAggregateId.java

@@ -0,0 +1,9 @@
+package tv.codely.analytics.domain_events.domain;
+
+import tv.codely.shared.domain.Identifier;
+
+public final class AnalyticsDomainEventAggregateId extends Identifier {
+    public AnalyticsDomainEventAggregateId(String value) {
+        super(value);
+    }
+}

src/analytics/main/tv/codely/analytics/domain_events/domain/AnalyticsDomainEventBody.java

@@ -0,0 +1,16 @@
+package tv.codely.analytics.domain_events.domain;
+
+import java.io.Serializable;
+import java.util.HashMap;
+
+public final class AnalyticsDomainEventBody {
+    private HashMap<String, Serializable> value;
+
+    public HashMap<String, Serializable> getValue() {
+        return value;
+    }
+
+    public AnalyticsDomainEventBody(HashMap<String, Serializable> value) {
+        this.value = value;
+    }
+}

src/analytics/main/tv/codely/analytics/domain_events/domain/AnalyticsDomainEventId.java

@@ -0,0 +1,9 @@
+package tv.codely.analytics.domain_events.domain;
+
+import tv.codely.shared.domain.Identifier;
+
+public final class AnalyticsDomainEventId extends Identifier {
+    public AnalyticsDomainEventId(String value) {
+        super(value);
+    }
+}

src/analytics/main/tv/codely/analytics/domain_events/domain/AnalyticsDomainEventName.java

@@ -0,0 +1,9 @@
+package tv.codely.analytics.domain_events.domain;
+
+import tv.codely.shared.domain.StringValueObject;
+
+public final class AnalyticsDomainEventName extends StringValueObject {
+    public AnalyticsDomainEventName(String value) {
+        super(value);
+    }
+}

src/analytics/main/tv/codely/analytics/domain_events/domain/DomainEventsRepository.java

@@ -0,0 +1,5 @@
+package tv.codely.analytics.domain_events.domain;
+
+public interface DomainEventsRepository {
+    void save(AnalyticsDomainEvent event);
+}