Add the unit test for the VideoPublisher

Author: JavierCane

build.gradle

@@ -6,15 +6,17 @@ targetCompatibility = 1.11
 
 repositories {
     mavenCentral()
+    jcenter()
 }
 
 dependencies {
     // Prod
-    implementation('io.projectreactor:reactor-bus:2.0.8.RELEASE')
+    implementation 'io.projectreactor:reactor-bus:2.0.8.RELEASE'
 
     // Test
-    testCompile('org.junit.jupiter:junit-jupiter-api:5.3.2')
-    testRuntime('org.junit.jupiter:junit-jupiter-engine:5.3.2')
+    testCompile "org.mockito:mockito-core:2.+"
+    testCompile 'org.junit.jupiter:junit-jupiter-api:5.+'
+    testRuntime 'org.junit.jupiter:junit-jupiter-engine:5.+'
 }
 
 test {

src/main/java/tv/codely/context/video/module/video/domain/VideoDescription.java

@@ -10,4 +10,19 @@ public VideoDescription(final String 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();
+    }
 }

src/main/java/tv/codely/context/video/module/video/domain/VideoPublished.java

@@ -24,4 +24,22 @@ public String title() {
     public String description() {
         return description;
     }
+
+    @Override
+    public boolean equals(Object o) {
+        if (this == o) return true;
+        if (o == null || getClass() != o.getClass()) return false;
+
+        VideoPublished that = (VideoPublished) o;
+
+        if (!title.equals(that.title)) return false;
+        return description.equals(that.description);
+    }
+
+    @Override
+    public int hashCode() {
+        int result = title.hashCode();
+        result = 31 * result + description.hashCode();
+        return result;
+    }
 }

src/main/java/tv/codely/context/video/module/video/domain/VideoTitle.java

@@ -10,4 +10,19 @@ public VideoTitle(String 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;
+
+        VideoTitle that = (VideoTitle) o;
+
+        return value.equals(that.value);
+    }
+
+    @Override
+    public int hashCode() {
+        return value.hashCode();
+    }
 }

src/test/java/tv/codely/context/video/module/video/application/publish/VideoPublisherShould.java

@@ -1,27 +1,28 @@
 package tv.codely.context.video.module.video.application.publish;
 
 import org.junit.jupiter.api.Test;
-import tv.codely.context.notification.module.push.application.create.SendPushToSubscribersOnVideoPublished;
-import tv.codely.shared.application.DomainEventSubscriber;
+import tv.codely.context.video.module.video.domain.VideoPublished;
 import tv.codely.shared.domain.EventBus;
-import tv.codely.shared.infrastructure.bus.ReactorEventBus;
 
-import java.util.Set;
+import java.util.List;
+
+import static org.mockito.Mockito.mock;
+import static org.mockito.Mockito.verify;
 
 final class VideoPublisherShould {
-	@Test
-	void publish_the_video_published_domain_event() {
-		final Set<DomainEventSubscriber> subscribers = Set.of(
-			new SendPushToSubscribersOnVideoPublished()
-		);
-		final EventBus eventBus = new ReactorEventBus(subscribers);
-		final var videoPublisher = new VideoPublisher(eventBus);
+    @Test
+    void publish_the_video_published_domain_event() {
+        final EventBus eventBus = mock(EventBus.class);
+        final var videoPublisher = new VideoPublisher(eventBus);
+
+        final var videoTitle = "\uD83C\uDF89 New YouTube.com/CodelyTV video title";
+        final var videoDescription = "This should be the video description \uD83D\uDE42";
 
-		final var videoTitle = "\uD83C\uDF89 New YouTube.com/CodelyTV video title";
-		final var videoDescription = "This should be the video description \uD83D\uDE42";
+        videoPublisher.publish(videoTitle, videoDescription);
 
-		videoPublisher.publish(videoTitle, videoDescription);
+        final var expectedVideoCreated = new VideoPublished(videoTitle, videoDescription);
 
-	}
+        verify(eventBus).publish(List.of(expectedVideoCreated));
+    }
 
 }