Initial spray service

src/main/scala/se/citerus/dddsample/infrastructure/BookingServiceActor.scala

@@ -0,0 +1,22 @@
+package se.citerus.dddsample.infrastructure
+
+import java.time.ZonedDateTime
+import java.util.UUID
+
+import akka.actor.Actor
+import se.citerus.dddsample.domain.model.cargo.TrackingId
+import se.citerus.dddsample.domain.model.location.UnLocode
+import se.citerus.dddsample.infrastructure.BookingServiceActor.{Book, BookingRegistered}
+
+class BookingServiceActor extends Actor {
+
+  override def receive: Receive = {
+    case Book(origin, destination, arrivalTime) =>
+      sender() ! BookingRegistered(new TrackingId(UUID.randomUUID().toString))
+  }
+}
+
+object BookingServiceActor {
+  case class Book(origin: UnLocode, destination: UnLocode, arrivalTime: ZonedDateTime)
+  case class BookingRegistered(trackingId: TrackingId)
+}

src/main/scala/se/citerus/dddsample/infrastructure/Boot.scala

@@ -0,0 +1,25 @@
+package se.citerus.dddsample.infrastructure
+
+import akka.actor.{ActorSystem, Props}
+import akka.io.IO
+import akka.pattern.ask
+import akka.util.Timeout
+import spray.can.Http
+
+import scala.concurrent.duration._
+
+object Boot extends App {
+
+  // we need an ActorSystem to host our application in
+  implicit val system = ActorSystem("dddsample")
+
+  val bookingService = system.actorOf(Props[BookingServiceActor], "booking-service")
+
+  // create and start our service actor
+  val service = system.actorOf(Props(classOf[CargoAdminActor], bookingService), "cargo-admin")
+
+  implicit val timeout = Timeout(5.seconds)
+  // start a new HTTP server on port 8080 with our service actor as the handler
+  IO(Http) ? Http.Bind(service, interface = "localhost", port = 13337)
+
+}

src/main/scala/se/citerus/dddsample/infrastructure/CargoAdminActor.scala

@@ -0,0 +1,45 @@
+package se.citerus.dddsample.infrastructure
+
+import java.time.ZonedDateTime
+
+import akka.actor.{Actor, ActorRef}
+import akka.pattern.ask
+import akka.util.Timeout
+import se.citerus.dddsample.domain.model.location.UnLocode
+import se.citerus.dddsample.infrastructure.BookingServiceActor.Book
+import spray.routing.HttpService
+
+import scala.concurrent.Future
+
+import scala.concurrent.duration._
+
+class CargoAdminActor(val bookingServiceActor: ActorRef) extends Actor with CargoAdminResource {
+
+  def actorRefFactory = context
+  def receive = runRoute(cargoAdminRoute)
+
+}
+
+trait CargoAdminResource extends HttpService { this: Actor =>
+
+  import spray.httpx.marshalling.BasicMarshallers._
+
+  import scala.concurrent.ExecutionContext.Implicits.global
+
+  implicit val timeout = Timeout(5.seconds)
+
+  val bookingServiceActor: ActorRef
+
+  val cargoAdminRoute =
+    path("admin" / "book") {
+      post {
+        parameters('origin, 'destination, 'arrivalTime) { (origin, destination, arrivalTime) =>
+          complete(book(origin, destination, arrivalTime).map(_.toString))
+        }
+      }
+    }
+
+  def book(origin: String, destination: String, arrivalTime: String): Future[Any] =
+    bookingServiceActor ? Book(new UnLocode(origin), new UnLocode(destination), ZonedDateTime.parse(arrivalTime))
+
+}