Spray based Employee Service implementation

SprayEmployeeServiceComp.scala

trait SprayEmployeeServiceCompImpl extends EmployeeServiceComp with Configuration {

  this: CakezActorSystem =>

  val employeeService = new SprayEmployeeService

  class SprayEmployeeService extends EmployeeService {

    def logger = LoggerFactory.getLogger(this.getClass)

    override def POST(employee: Employee): Future[Unit] = {
      import system.dispatcher
      import com.pagero.cakez.protocols.EmployeeProtocol._

      logger.debug(s"POST employee with id: ${employee.emp_id} name: ${employee.name}")

      val pipeline = sendReceive
      val response = pipeline {
        Post(s"http://$apiHost:$apiPort/api/v1/users/", employee)
      }

      response.map(_.entity.asInstanceOf[Unit])
    }

    override def GET(id: Int): Future[Employee] = {
      import system.dispatcher
      import com.pagero.cakez.protocols.EmployeeProtocol._

      logger.debug("GET employee with id: " + id)

      val pipeline = sendReceive ~> unmarshal[Employee]
      val response: Future[Employee] = pipeline {
        Get(s"http://$apiHost:$apiPort/api/v1/users/$id/?format=json")
      }

      response
    }
  }

}