diff options
Diffstat (limited to 'src/main/scala/xyz/driver/pdsuidomain/storage')
-rw-r--r-- | src/main/scala/xyz/driver/pdsuidomain/storage/MedicalRecordDocumentStorage.scala | 26 | ||||
-rw-r--r-- | src/main/scala/xyz/driver/pdsuidomain/storage/RequestStorage.scala | 48 |
2 files changed, 0 insertions, 74 deletions
diff --git a/src/main/scala/xyz/driver/pdsuidomain/storage/MedicalRecordDocumentStorage.scala b/src/main/scala/xyz/driver/pdsuidomain/storage/MedicalRecordDocumentStorage.scala deleted file mode 100644 index 192512f..0000000 --- a/src/main/scala/xyz/driver/pdsuidomain/storage/MedicalRecordDocumentStorage.scala +++ /dev/null @@ -1,26 +0,0 @@ -package xyz.driver.pdsuidomain.storage - -import com.google.cloud.storage.StorageOptions -import com.typesafe.scalalogging.StrictLogging -import xyz.driver.pdsuidomain.entities.MedicalRecord.PdfSource - -import scala.concurrent.{ExecutionContext, Future, blocking} - -object MedicalRecordDocumentStorage extends StrictLogging { - private val storage = StorageOptions.getDefaultInstance.getService - - def fetchPdf(bucket: String, path: String)(implicit ec: ExecutionContext): Future[PdfSource] = { - logger.trace(s"fetchPdf(bucket=$bucket, path=$path)") - Future { - blocking { - Option(storage.get(bucket, path)) match { - case Some(blob) => - PdfSource.Channel(() => blob.reader()) - case None => - logger.error(s"Failed to find the pdf file $path in bucket: $bucket") - PdfSource.Empty - } - } - } - } -} diff --git a/src/main/scala/xyz/driver/pdsuidomain/storage/RequestStorage.scala b/src/main/scala/xyz/driver/pdsuidomain/storage/RequestStorage.scala deleted file mode 100644 index 6aa49a1..0000000 --- a/src/main/scala/xyz/driver/pdsuidomain/storage/RequestStorage.scala +++ /dev/null @@ -1,48 +0,0 @@ -package xyz.driver.pdsuidomain.storage - -import xyz.driver.pdsuicommon.domain.{LongId, UuidId} -import xyz.driver.pdsuicommon.logging._ -import xyz.driver.pdsuidomain.entities.{Arm, Patient} - -import scala.collection.concurrent.TrieMap - -object RequestStorage { - type Key = (UuidId[Patient], String) - type Value = Set[LongId[Arm]] -} - -class RequestStorage extends PhiLogging { - import RequestStorage._ - - private val storage = new TrieMap[Key, Value]() - - def put(patientId: UuidId[Patient], disease: String, ineligibleArms: Set[LongId[Arm]]): Unit = { - logger.debug(phi"put($patientId, ${Unsafe(disease)}, $ineligibleArms") - val key = (patientId, disease.toLowerCase) - get(patientId, disease.toLowerCase) match { - case Some(oldValue) => - logger.trace(phi"Requested ineligible arms=$oldValue, replace it") - storage.replace(key, oldValue, ineligibleArms) - case None => - logger.trace(phi"Put request into storage") - storage.put(key, ineligibleArms) - } - } - - def get(patientId: UuidId[Patient], disease: String): Option[Value] = { - logger.debug(phi"get($patientId, ${Unsafe(disease)}") - val key = (patientId, disease.toLowerCase) - storage.get(key) - } - - def contains(patientId: UuidId[Patient], disease: String, value: Set[LongId[Arm]]): Boolean = { - logger.debug(phi"contains(key=($patientId,${Unsafe(disease)}), value=$value") - get(patientId, disease.toLowerCase).contains(value) - } - - def remove(patientId: UuidId[Patient], disease: String): Unit = { - logger.debug(phi"remove($patientId,${Unsafe(disease)}") - val key = (patientId, disease.toLowerCase) - storage.remove(key) - } -} |