Merge pull request #2 from CodelyTV/reactor

Add a simple implementation of an event bus using reactor

Co-authored-by: Javier Ferrer <javier.mailserio@gmail.com>

Author: JavierCane

.gitignore

@@ -1,6 +1,7 @@
 # Gradle
 .gradle
 build/
+out/
 
 # Ignore Gradle GUI config
 gradle-app.setting

README.md

@@ -21,6 +21,8 @@ Take a look, play and have fun with it!
     `./gradlew assemble --warning-mode all`
     2. Run the tests and plugins verification tasks:
     `./gradlew check --warning-mode all`
+    3. Execute the main application entrypoint:
+    `./gradlew run --warning-mode all`
 4. Start developing!
 
 ## 🤔 How to update dependencies

build.gradle

@@ -1,15 +1,22 @@
 apply plugin: 'java'
+apply plugin: 'application'
 
 sourceCompatibility = 1.11
 targetCompatibility = 1.11
 
 repositories {
     mavenCentral()
+    jcenter()
 }
 
 dependencies {
-    testCompile('org.junit.jupiter:junit-jupiter-api:5.3.2')
-    testRuntime('org.junit.jupiter:junit-jupiter-engine:5.3.2')
+    // Prod
+    implementation 'io.projectreactor:reactor-bus:2.0.8.RELEASE'
+
+    // Test
+    testCompile "org.mockito:mockito-core:2.+"
+    testCompile 'org.junit.jupiter:junit-jupiter-api:5.+'
+    testRuntime 'org.junit.jupiter:junit-jupiter-engine:5.+'
 }
 
 test {
@@ -22,4 +29,8 @@ test {
     reports {
         html.enabled = true
     }
-}
+}
+
+application {
+    mainClassName = "tv.codely.context.video.module.video.infrastructure.VideoPublisherCliController"
+}

src/main/java/tv/codely/context/notification/module/push/application/create/SendPushToSubscribersOnVideoPublished.java

@@ -0,0 +1,22 @@
+package tv.codely.context.notification.module.push.application.create;
+
+import tv.codely.context.video.module.video.domain.VideoPublished;
+import tv.codely.shared.application.DomainEventSubscriber;
+
+public class SendPushToSubscribersOnVideoPublished implements DomainEventSubscriber<VideoPublished> {
+    @Override
+    public Class<VideoPublished> subscribedTo() {
+        return VideoPublished.class;
+    }
+
+    @Override
+    public void consume(VideoPublished event) {
+        System.out.println(
+            String.format(
+                "Hey! There is a new video with title <%s> and description <%s>",
+                event.title(),
+                event.description()
+            )
+        );
+    }
+}

src/main/java/tv/codely/context/notification/module/push/application/find/.gitkeep

@@ -0,0 +1,23 @@
+package tv.codely.context.video.module.video.application.publish;
+
+import tv.codely.context.video.module.video.domain.Video;
+import tv.codely.context.video.module.video.domain.VideoDescription;
+import tv.codely.context.video.module.video.domain.VideoTitle;
+import tv.codely.shared.domain.EventBus;
+
+public final class VideoPublisher {
+    private final EventBus eventBus;
+
+    public VideoPublisher(EventBus eventBus) {
+        this.eventBus = eventBus;
+    }
+
+    public void publish(String rawTitle, String rawDescription) {
+        final var title = new VideoTitle(rawTitle);
+        final var description = new VideoDescription(rawDescription);
+
+        final var video = Video.publish(title, description);
+
+        eventBus.publish(video.pullDomainEvents());
+    }
+}

src/main/java/tv/codely/context/notification/module/push/domain/.gitkeep

@@ -0,0 +1,23 @@
+package tv.codely.context.video.module.video.domain;
+
+import tv.codely.shared.domain.AggregateRoot;
+
+public final class Video extends AggregateRoot {
+    private final VideoTitle title;
+    private final VideoDescription description;
+
+    private Video(VideoTitle title, VideoDescription description) {
+        this.title = title;
+        this.description = description;
+    }
+
+    public static Video publish(VideoTitle title, VideoDescription description) {
+        var video = new Video(title, description);
+
+        var videoCreated = new VideoPublished(title.value(), description.value());
+
+        video.record(videoCreated);
+
+        return video;
+    }
+}

src/main/java/tv/codely/context/notification/module/push/infrastructure/.gitkeep

@@ -0,0 +1,28 @@
+package tv.codely.context.video.module.video.domain;
+
+public final class VideoDescription {
+    private final String value;
+
+    public VideoDescription(final String value) {
+        this.value = value;
+    }
+
+    public String value() {
+        return value;
+    }
+
+    @Override
+    public boolean equals(Object o) {
+        if (this == o) return true;
+        if (o == null || getClass() != o.getClass()) return false;
+
+        VideoDescription that = (VideoDescription) o;
+
+        return value.equals(that.value);
+    }
+
+    @Override
+    public int hashCode() {
+        return value.hashCode();
+    }
+}