aboutsummaryrefslogtreecommitdiff
path: root/src/main/scala/xyz/driver/pdsuidomain/services/rest/RestMedicalRecordService.scala
diff options
context:
space:
mode:
authorJakob Odersky <jakob@driver.xyz>2017-07-24 16:24:12 -0700
committerJakob Odersky <jakob@driver.xyz>2017-07-25 15:43:56 -0700
commite22a94604d6090d88801ec52c39f4eab500e80e1 (patch)
treee20332a9693a4c2d00d32cf67438ef4ba74f9356 /src/main/scala/xyz/driver/pdsuidomain/services/rest/RestMedicalRecordService.scala
parent23192326cfc82e726b03f23396f2587ca4f606f5 (diff)
downloadrest-query-e22a94604d6090d88801ec52c39f4eab500e80e1.tar.gz
rest-query-e22a94604d6090d88801ec52c39f4eab500e80e1.tar.bz2
rest-query-e22a94604d6090d88801ec52c39f4eab500e80e1.zip
Implement ReP rest services
Diffstat (limited to 'src/main/scala/xyz/driver/pdsuidomain/services/rest/RestMedicalRecordService.scala')
-rw-r--r--src/main/scala/xyz/driver/pdsuidomain/services/rest/RestMedicalRecordService.scala119
1 files changed, 119 insertions, 0 deletions
diff --git a/src/main/scala/xyz/driver/pdsuidomain/services/rest/RestMedicalRecordService.scala b/src/main/scala/xyz/driver/pdsuidomain/services/rest/RestMedicalRecordService.scala
new file mode 100644
index 0000000..f2b0f2d
--- /dev/null
+++ b/src/main/scala/xyz/driver/pdsuidomain/services/rest/RestMedicalRecordService.scala
@@ -0,0 +1,119 @@
+package xyz.driver.pdsuidomain.services.rest
+
+import akka.NotUsed
+import akka.stream.scaladsl.Source
+import akka.util.ByteString
+import scala.concurrent.{ExecutionContext, Future}
+
+import akka.http.scaladsl.marshalling.Marshal
+import akka.http.scaladsl.model._
+import akka.stream.Materializer
+import xyz.driver.core.rest.{Pagination => _, _}
+import xyz.driver.pdsuicommon.auth._
+import xyz.driver.pdsuicommon.db._
+import xyz.driver.pdsuicommon.domain._
+import xyz.driver.pdsuidomain.entities._
+import xyz.driver.pdsuidomain.formats.json.ListResponse
+import xyz.driver.pdsuidomain.formats.json.record.ApiRecord
+import xyz.driver.pdsuidomain.services.MedicalRecordService
+
+class RestMedicalRecordService(transport: ServiceTransport, baseUri: Uri)(
+ implicit protected val materializer: Materializer,
+ protected val exec: ExecutionContext)
+ extends MedicalRecordService with RestHelper {
+
+ import xyz.driver.pdsuicommon.serialization.PlayJsonSupport._
+ import xyz.driver.pdsuidomain.services.MedicalRecordService._
+
+ def getById(recordId: LongId[MedicalRecord])(
+ implicit requestContext: AuthenticatedRequestContext): Future[GetByIdReply] = {
+ val request = HttpRequest(HttpMethods.GET, endpointUri(baseUri, s"/v1/record/$recordId"))
+ for {
+ response <- transport.sendRequestGetResponse(requestContext)(request)
+ reply <- apiResponse[ApiRecord](response)
+ } yield {
+ GetByIdReply.Entity(reply.toDomain)
+ }
+ }
+
+ def getPdfSource(recordId: LongId[MedicalRecord])(
+ implicit requestContext: AuthenticatedRequestContext): Future[Source[ByteString, NotUsed]] = {
+
+ val request = HttpRequest(HttpMethods.GET, endpointUri(baseUri, s"/v1/record/${recordId}/source"))
+
+ for {
+ response <- transport.sendRequestGetResponse(requestContext)(request)
+ reply <- apiResponse[HttpEntity](response)
+ } yield {
+ reply.dataBytes.mapMaterializedValue(_ => NotUsed)
+ }
+ }
+
+ def getAll(filter: SearchFilterExpr = SearchFilterExpr.Empty,
+ sorting: Option[Sorting] = None,
+ pagination: Option[Pagination] = None)(
+ implicit requestContext: AuthenticatedRequestContext): Future[GetListReply] = {
+
+ val request = HttpRequest(
+ HttpMethods.GET,
+ endpointUri(baseUri, "/v1/record", filterQuery(filter) ++ sortingQuery(sorting) ++ paginationQuery(pagination)))
+ for {
+ response <- transport.sendRequestGetResponse(requestContext)(request)
+ reply <- apiResponse[ListResponse[ApiRecord]](response)
+ } yield {
+ GetListReply.EntityList(reply.items.map(_.toDomain), reply.meta.itemsCount, reply.meta.lastUpdate)
+ }
+ }
+
+ def create(draftRecord: MedicalRecord)(implicit requestContext: AnonymousRequestContext): Future[CreateReply] = {
+ for {
+ entity <- Marshal(ApiRecord.fromDomain(draftRecord)).to[RequestEntity]
+ request = HttpRequest(HttpMethods.POST, endpointUri(baseUri, "/v1/record")).withEntity(entity)
+ response <- transport.sendRequestGetResponse(requestContext)(request)
+ reply <- apiResponse[ApiRecord](response)
+ } yield {
+ CreateReply.Created(reply.toDomain)
+ }
+ }
+
+ def update(origRecord: MedicalRecord, draftRecord: MedicalRecord)(
+ implicit requestContext: AuthenticatedRequestContext): Future[UpdateReply] = {
+ val id = origRecord.id.toString
+ for {
+ entity <- Marshal(ApiRecord.fromDomain(draftRecord)).to[RequestEntity]
+ request = HttpRequest(HttpMethods.PATCH, endpointUri(baseUri, s"/v1/record/$id")).withEntity(entity)
+ response <- transport.sendRequestGetResponse(requestContext)(request)
+ reply <- apiResponse[ApiRecord](response)
+ } yield {
+ UpdateReply.Updated(reply.toDomain)
+ }
+ }
+
+ private def editAction(orig: MedicalRecord, action: String)(
+ implicit requestContext: AuthenticatedRequestContext): Future[UpdateReply] = {
+ val id = orig.id.toString
+ val request = HttpRequest(HttpMethods.POST, endpointUri(baseUri, s"/v1/record/$id/$action"))
+ for {
+ response <- transport.sendRequestGetResponse(requestContext)(request)
+ reply <- apiResponse[ApiRecord](response)
+ } yield {
+ UpdateReply.Updated(reply.toDomain)
+ }
+ }
+
+ def start(orig: MedicalRecord)(implicit requestContext: AuthenticatedRequestContext): Future[UpdateReply] =
+ editAction(orig, "start")
+ def submit(orig: MedicalRecord)(implicit requestContext: AuthenticatedRequestContext): Future[UpdateReply] =
+ editAction(orig, "submit")
+ def restart(orig: MedicalRecord)(implicit requestContext: AuthenticatedRequestContext): Future[UpdateReply] =
+ editAction(orig, "restart")
+ def flag(orig: MedicalRecord)(implicit requestContext: AuthenticatedRequestContext): Future[UpdateReply] =
+ editAction(orig, "flag")
+ def resolve(orig: MedicalRecord)(implicit requestContext: AuthenticatedRequestContext): Future[UpdateReply] =
+ editAction(orig, "resolve")
+ def unassign(orig: MedicalRecord)(implicit requestContext: AuthenticatedRequestContext): Future[UpdateReply] =
+ editAction(orig, "unassign")
+ def archive(orig: MedicalRecord)(implicit requestContext: AuthenticatedRequestContext): Future[UpdateReply] =
+ editAction(orig, "archive")
+
+}