Publish UserRegistered domain event

Author: JavierCane

src/main/tv/codely/scala_http_api/entry_point/ScalaHttpApi.scala

@@ -31,7 +31,7 @@ object ScalaHttpApi {
     implicit val executionContext: ExecutionContext = sharedDependencies.executionContext
 
     val container = new EntryPointDependencyContainer(
-      new UserModuleDependencyContainer(sharedDependencies.doobieDbConnection),
+      new UserModuleDependencyContainer(sharedDependencies.doobieDbConnection, sharedDependencies.messagePublisher),
       new VideoModuleDependencyContainer(sharedDependencies.doobieDbConnection, sharedDependencies.messagePublisher)
     )
 

src/main/tv/codely/scala_http_api/module/shared/infrastructure/marshaller/MessageJsonFormatMarshaller.scala

@@ -3,18 +3,22 @@ package tv.codely.scala_http_api.module.shared.infrastructure.marshaller
 import spray.json._
 import spray.json.{DefaultJsonProtocol, DeserializationException, JsString, JsValue, RootJsonFormat, SerializationException}
 import tv.codely.scala_http_api.module.shared.domain.Message
+import tv.codely.scala_http_api.module.user.domain.UserRegistered
 import tv.codely.scala_http_api.module.video.domain.VideoCreated
 import tv.codely.scala_http_api.module.video.infrastructure.marshaller.VideoCreatedJsonFormatMarshaller._
+import tv.codely.scala_http_api.module.user.infrastructure.marshaller.UserRegisteredJsonFormatMarshaller._
 
 object MessageJsonFormatMarshaller extends DefaultJsonProtocol {
   implicit object MessageMarshaller extends RootJsonFormat[Message] {
     override def write(m: Message): JsValue = m match {
-      case vc: VideoCreated => vc.toJson
-      case unknown          => throw new SerializationException(s"Unknown message type to write <${unknown.getClass}>")
+      case vc: VideoCreated   => vc.toJson
+      case ur: UserRegistered => ur.toJson
+      case unknown            => throw new SerializationException(s"Unknown message type to write <${unknown.getClass}>")
     }
 
     override def read(jv: JsValue): Message = jv.asJsObject.getFields("type") match {
-      case Seq(JsString("codelytv_scala_api.video_created")) => jv.convertTo[VideoCreated]
+      case Seq(JsString("codelytv_scala_api.video_created"))   => jv.convertTo[VideoCreated]
+      case Seq(JsString("codelytv_scala_api.user_registered")) => jv.convertTo[UserRegistered]
       case Seq(JsString(unknown)) =>
         throw DeserializationException(s"Unknown message type to read <$unknown>")
     }

src/main/tv/codely/scala_http_api/module/user/application/register/UserRegisterer.scala

@@ -1,11 +1,14 @@
 package tv.codely.scala_http_api.module.user.application.register
 
-import tv.codely.scala_http_api.module.user.domain.{User, UserId, UserName, UserRepository}
+import tv.codely.scala_http_api.module.shared.domain.MessagePublisher
+import tv.codely.scala_http_api.module.user.domain._
 
-final class UserRegisterer(repository: UserRepository) {
+final class UserRegisterer(repository: UserRepository, publisher: MessagePublisher) {
   def register(id: UserId, name: UserName): Unit = {
     val user = User(id, name)
 
     repository.save(user)
+
+    publisher.publish(UserRegistered(user))
   }
 }

src/main/tv/codely/scala_http_api/module/user/domain/UserRegistered.scala

@@ -0,0 +1,13 @@
+package tv.codely.scala_http_api.module.user.domain
+
+import tv.codely.scala_http_api.module.shared.domain.Message
+
+object UserRegistered {
+  def apply(id: String, name: String): UserRegistered = apply(UserId(id), UserName(name))
+
+  def apply(user: User): UserRegistered = apply(user.id, user.name)
+}
+
+final case class UserRegistered(id: UserId, name: UserName) extends Message {
+  override val subType: String = "user_registered"
+}

src/main/tv/codely/scala_http_api/module/user/infrastructure/dependency_injection/UserModuleDependencyContainer.scala

@@ -1,5 +1,6 @@
 package tv.codely.scala_http_api.module.user.infrastructure.dependency_injection
 
+import tv.codely.scala_http_api.module.shared.domain.MessagePublisher
 import tv.codely.scala_http_api.module.shared.infrastructure.persistence.doobie.DoobieDbConnection
 import tv.codely.scala_http_api.module.user.application.register.UserRegisterer
 import tv.codely.scala_http_api.module.user.application.search.UsersSearcher
@@ -9,10 +10,11 @@ import tv.codely.scala_http_api.module.user.infrastructure.repository.DoobieMySq
 import scala.concurrent.ExecutionContext
 
 final class UserModuleDependencyContainer(
-    doobieDbConnection: DoobieDbConnection
+    doobieDbConnection: DoobieDbConnection,
+    messagePublisher: MessagePublisher
 )(implicit executionContext: ExecutionContext) {
   val repository: UserRepository = new DoobieMySqlUserRepository(doobieDbConnection)
 
   val usersSearcher: UsersSearcher   = new UsersSearcher(repository)
-  val userRegisterer: UserRegisterer = new UserRegisterer(repository)
+  val userRegisterer: UserRegisterer = new UserRegisterer(repository, messagePublisher)
 }

src/main/tv/codely/scala_http_api/module/user/infrastructure/marshaller/UserAttributesJsonFormatMarshaller.scala

@@ -0,0 +1,25 @@
+package tv.codely.scala_http_api.module.user.infrastructure.marshaller
+
+import java.util.UUID
+
+import spray.json.{DefaultJsonProtocol, DeserializationException, JsString, JsValue, JsonFormat}
+import tv.codely.scala_http_api.module.shared.infrastructure.marshaller.UuidJsonFormatMarshaller._
+import tv.codely.scala_http_api.module.user.domain.{UserId, UserName}
+import spray.json._
+
+object UserAttributesJsonFormatMarshaller extends DefaultJsonProtocol {
+  implicit object UserIdMarshaller extends JsonFormat[UserId] {
+    override def write(value: UserId): JsValue = value.value.toJson
+
+    override def read(value: JsValue): UserId = UserId(value.convertTo[UUID])
+  }
+
+  implicit object UserNameMarshaller extends JsonFormat[UserName] {
+    override def write(value: UserName): JsValue = JsString(value.value)
+
+    override def read(value: JsValue): UserName = value match {
+      case JsString(name) => UserName(name)
+      case _              => throw DeserializationException("Expected 1 string for UserName")
+    }
+  }
+}

src/main/tv/codely/scala_http_api/module/user/infrastructure/marshaller/UserJsonFormatMarshaller.scala

@@ -1,27 +1,9 @@
 package tv.codely.scala_http_api.module.user.infrastructure.marshaller
 
-import java.util.UUID
-
-import spray.json.{DeserializationException, JsString, JsValue, JsonFormat, RootJsonFormat}
+import spray.json.{DefaultJsonProtocol, RootJsonFormat}
 import tv.codely.scala_http_api.module.user.domain.{User, UserId, UserName}
-import tv.codely.scala_http_api.module.shared.infrastructure.marshaller.UuidJsonFormatMarshaller._
-import spray.json._
+import UserAttributesJsonFormatMarshaller._
 
 object UserJsonFormatMarshaller extends DefaultJsonProtocol {
-  implicit object UserIdMarshaller extends JsonFormat[UserId] {
-    override def write(value: UserId): JsValue = value.value.toJson
-
-    override def read(value: JsValue): UserId = UserId(value.convertTo[UUID])
-  }
-
-  implicit object UserNameMarshaller extends JsonFormat[UserName] {
-    override def write(value: UserName): JsValue = JsString(value.value)
-
-    override def read(value: JsValue): UserName = value match {
-      case JsString(name) => UserName(name)
-      case _              => throw DeserializationException("Expected 1 string for UserName")
-    }
-  }
-
   implicit val userFormat: RootJsonFormat[User] = jsonFormat2(User.apply(_: UserId, _: UserName))
 }

src/main/tv/codely/scala_http_api/module/user/infrastructure/marshaller/UserRegisteredJsonFormatMarshaller.scala

@@ -0,0 +1,22 @@
+package tv.codely.scala_http_api.module.user.infrastructure.marshaller
+
+import spray.json.{DefaultJsonProtocol, DeserializationException, JsObject, JsString, JsValue, RootJsonFormat}
+import tv.codely.scala_http_api.module.user.domain.UserRegistered
+import UserAttributesJsonFormatMarshaller._
+import spray.json._
+
+object UserRegisteredJsonFormatMarshaller extends DefaultJsonProtocol {
+  implicit object UserRegisteredJsonFormat extends RootJsonFormat[UserRegistered] {
+    override def write(ur: UserRegistered): JsValue = JsObject(
+      "type" -> JsString(ur.`type`),
+      "id"   -> ur.id.toJson,
+      "name" -> ur.name.toJson
+    )
+
+    override def read(value: JsValue): UserRegistered =
+      value.asJsObject.getFields("id", "name") match {
+        case Seq(JsString(id), JsString(name)) => UserRegistered(id, name)
+        case unknown                           => throw DeserializationException(s"Error reading VideoCreated JSON <$unknown>")
+      }
+  }
+}

src/main/tv/codely/scala_http_api/module/video/application/create/VideoCreator.scala

@@ -7,8 +7,8 @@ final class VideoCreator(repository: VideoRepository, publisher: MessagePublishe
   def create(id: VideoId, title: VideoTitle, duration: VideoDuration, category: VideoCategory): Unit = {
     val video = Video(id, title, duration, category)
 
-    publisher.publish(VideoCreated(video))
-
     repository.save(video)
+
+    publisher.publish(VideoCreated(video))
   }
 }

src/main/tv/codely/scala_http_api/module/shared/infrastructure/marshaller/VideoAttributesJsonFormatMarshaller.scala renamed to src/main/tv/codely/scala_http_api/module/video/infrastructure/marshaller/VideoAttributesJsonFormatMarshaller.scala

@@ -1,11 +1,10 @@
-package tv.codely.scala_http_api.module.shared.infrastructure.marshaller
+package tv.codely.scala_http_api.module.video.infrastructure.marshaller
 
 import java.util.UUID
 
-import spray.json.{DeserializationException, JsNumber, JsString, JsValue, JsonFormat}
-import tv.codely.scala_http_api.module.video.domain._
+import spray.json.{DeserializationException, JsNumber, JsString, JsValue, JsonFormat, _}
 import tv.codely.scala_http_api.module.shared.infrastructure.marshaller.UuidJsonFormatMarshaller._
-import spray.json._
+import tv.codely.scala_http_api.module.video.domain._
 
 object VideoAttributesJsonFormatMarshaller {
   implicit object VideoIdMarshaller extends JsonFormat[VideoId] {

src/main/tv/codely/scala_http_api/module/video/infrastructure/marshaller/VideoCreatedJsonFormatMarshaller.scala

@@ -2,7 +2,7 @@ package tv.codely.scala_http_api.module.video.infrastructure.marshaller
 
 import spray.json.{DefaultJsonProtocol, DeserializationException, JsString, JsValue, RootJsonFormat}
 import tv.codely.scala_http_api.module.video.domain._
-import tv.codely.scala_http_api.module.shared.infrastructure.marshaller.VideoAttributesJsonFormatMarshaller._
+import VideoAttributesJsonFormatMarshaller._
 import spray.json._
 
 object VideoCreatedJsonFormatMarshaller extends DefaultJsonProtocol {

src/main/tv/codely/scala_http_api/module/video/infrastructure/marshaller/VideoJsonFormatMarshaller.scala

@@ -1,7 +1,7 @@
 package tv.codely.scala_http_api.module.video.infrastructure.marshaller
 
 import spray.json.{DefaultJsonProtocol, RootJsonFormat}
-import tv.codely.scala_http_api.module.shared.infrastructure.marshaller.VideoAttributesJsonFormatMarshaller._
+import VideoAttributesJsonFormatMarshaller._
 import tv.codely.scala_http_api.module.video.domain._
 
 object VideoJsonFormatMarshaller extends DefaultJsonProtocol {

src/test/tv/codely/scala_http_api/entry_point/AcceptanceSpec.scala

@@ -25,7 +25,10 @@ protected[entry_point] abstract class AcceptanceSpec
 
   private val sharedDependencies = new SharedModuleDependencyContainer(actorSystemName, dbConfig, publisherConfig)
 
-  protected val userDependencies = new UserModuleDependencyContainer(sharedDependencies.doobieDbConnection)
+  protected val userDependencies = new UserModuleDependencyContainer(
+    sharedDependencies.doobieDbConnection,
+    sharedDependencies.messagePublisher
+  )
   protected val videoDependencies = new VideoModuleDependencyContainer(
     sharedDependencies.doobieDbConnection,
     sharedDependencies.messagePublisher

src/test/tv/codely/scala_http_api/module/user/UserIntegrationTestCase.scala

@@ -5,7 +5,7 @@ import tv.codely.scala_http_api.module.user.domain.UserRepository
 import tv.codely.scala_http_api.module.user.infrastructure.dependency_injection.UserModuleDependencyContainer
 
 protected[user] trait UserIntegrationTestCase extends IntegrationTestCase {
-  private val container = new UserModuleDependencyContainer(doobieDbConnection)
+  private val container = new UserModuleDependencyContainer(doobieDbConnection, messagePublisher)
 
   protected val repository: UserRepository = container.repository
 }

src/test/tv/codely/scala_http_api/module/user/application/register/UserRegistererShould.scala

@@ -1,16 +1,20 @@
 package tv.codely.scala_http_api.module.user.application.register
 
+import tv.codely.scala_http_api.module.shared.infrastructure.MessagePublisherMock
 import tv.codely.scala_http_api.module.user.UserUnitTestCase
-import tv.codely.scala_http_api.module.user.domain.UserStub
+import tv.codely.scala_http_api.module.user.domain.{UserRegisteredStub, UserStub}
 
-final class UserRegistererShould extends UserUnitTestCase {
-  private val registerer = new UserRegisterer(repository)
+final class UserRegistererShould extends UserUnitTestCase with MessagePublisherMock {
+  private val registerer = new UserRegisterer(repository, messagePublisher)
 
-  "save a user" in {
+  "register a user" in {
     val user = UserStub.random
+    val userRegistered = UserRegisteredStub(user)
 
     repositoryShouldSave(user)
 
+    publisherShouldPublish(userRegistered)
+
     registerer.register(user.id, user.name).shouldBe(())
   }
 }

src/test/tv/codely/scala_http_api/module/user/domain/UserRegisteredStub.scala

@@ -0,0 +1,12 @@
+package tv.codely.scala_http_api.module.user.domain
+
+object UserRegisteredStub {
+  def apply(
+      id: UserId = UserIdStub.random,
+      name: UserName = UserNameStub.random
+  ): UserRegistered = UserRegistered(id, name)
+
+  def apply(user: User): UserRegistered = apply(user.id, user.name)
+
+  def random: UserRegistered = apply()
+}