path: root/src/main/scala/xyz/driver/pdsuicommon/utils/CustomSwaggerJsonFormats.scala

package xyz.driver.pdsuicommon.utils

import java.time.{LocalDate, LocalDateTime}

import io.swagger.models.properties.Property
import spray.json.JsValue
import xyz.driver.pdsuicommon.domain.{LongId, StringId, UuidId}
import xyz.driver.pdsuidomain.entities._
import xyz.driver.pdsuidomain.formats.json.listresponse._
import xyz.driver.core.swagger.CustomSwaggerJsonConverter._
import xyz.driver.entities.patient.CancerType
import xyz.driver.pdsuicommon.concurrent.BridgeUploadQueue
import xyz.driver.pdsuidomain.entities.export.patient.ExportPatientWithLabels
import xyz.driver.pdsuidomain.entities.export.trial.ExportTrialWithLabels
import xyz.driver.pdsuidomain.fakes.entities.common
import xyz.driver.pdsuidomain.formats.json.bridgeuploadqueue._
import xyz.driver.pdsuidomain.formats.json.record._
import xyz.driver.pdsuidomain.formats.json.document._
import xyz.driver.pdsuidomain.services.CriterionService.RichCriterion
import xyz.driver.pdsuidomain.services.ExtractedDataService.RichExtractedData

import scala.collection.immutable

object CustomSwaggerJsonFormats {

  trait MedicalRecordListResponse
  trait MedicalRecordIssueListResponse
  trait MedicalRecordHistoryListResponse
  trait DocumentListResponse
  trait DocumentIssueListResponse
  trait DocumentHistoryListResponse
  trait RichExtractedDataListResponse
  trait DocumentTypeListResponse
  trait ProviderTypeListResponse

  trait TrialListResponse
  trait TrialIssueListResponse
  trait TrialHistoryListResponse
  trait ArmListResponse
  trait InterventionWithArmsListResponse
  trait EligibilityArmWithDiseasesListResponse
  trait SlotArmListResponse
  trait RichCriterionListResponse
  trait InterventionTypeListResponse
  trait StudyDesignListResponse
  trait HypothesisListResponse

  trait PatientListResponse
  trait PatientIssueListResponse
  trait PatientHistoryListResponse
  trait PatientLabelListResponse
  trait RichPatientLabelListResponse
  trait RichPatientCriterionListResponse
  trait RichPatientEligibleTrialListResponse
  trait PatientHypothesisListResponse
  trait PatientLabelEvidenceViewListResponse

  trait QueueUploadItemListResponse

  val customCommonProperties = immutable.Map[Class[_], Property](
    classOf[LocalDateTime] -> stringProperty(example = Some("2010-12-31'T'18:59:59Z")),
    classOf[LocalDate]     -> stringProperty(example = Some("2010-12-31")),
    classOf[UuidId[_]]     -> stringProperty(example = Some("370b0450-35cb-4aab-ba74-0145be75add5")),
    classOf[StringId[_]]   -> stringProperty(),
    classOf[LongId[_]]     -> stringProperty(),
    classOf[CancerType]    -> stringProperty()
  )

  val customCommonObjectsExamples = immutable.Map[Class[_], JsValue](
    classOf[BridgeUploadQueue.Item] -> queueUploadItemFormat.write(common.nextBridgeUploadQueueItem()),
    classOf[ProviderType]           -> providerTypeFormat.write(common.nextProviderType()),
    classOf[DocumentType]           -> documentTypeFormat.write(common.nextDocumentType()),
    classOf[QueueUploadItemListResponse] -> listResponseWriter[BridgeUploadQueue.Item]
      .write(common.nextBridgeUploadQueueItemListResponse()),
    classOf[DocumentTypeListResponse] -> listResponseWriter[DocumentType].write(common.nextDocumentTypeListResponse()),
    classOf[ProviderTypeListResponse] -> listResponseWriter[ProviderType].write(common.nextProviderTypeListResponse())
  )

  object trialcuration {
    import xyz.driver.pdsuidomain.fakes.entities.trialcuration._
    import xyz.driver.pdsuidomain.fakes.entities.export
    import xyz.driver.pdsuidomain.formats.json.export._
    import xyz.driver.pdsuidomain.formats.json.arm._
    import xyz.driver.pdsuidomain.formats.json.slotarm._
    import xyz.driver.pdsuidomain.formats.json.eligibilityarm._
    import xyz.driver.pdsuidomain.formats.json.criterion._
    import xyz.driver.pdsuidomain.formats.json.intervention._
    import xyz.driver.pdsuidomain.formats.json.hypothesis._
    import xyz.driver.pdsuidomain.formats.json.studydesign._
    import xyz.driver.pdsuidomain.formats.json.trial._
    import xyz.driver.pdsuidomain.formats.json.trialhistory._
    import xyz.driver.pdsuidomain.formats.json.trialissue._

    val customTrialCurationProperties = immutable.Map[Class[_], Property](
      classOf[Trial.Status]        -> stringProperty(),
      classOf[TrialHistory.Action] -> stringProperty(),
      classOf[TrialHistory.State]  -> stringProperty()
    ) ++ customCommonProperties

    val customTrialCurationObjectsExamples = immutable.Map[Class[_], JsValue](
      classOf[Trial]                      -> trialFormat.write(nextTrial()),
      classOf[Arm]                        -> armFormat.write(nextArm()),
      classOf[TrialHistory]               -> trialHistoryFormat.write(nextTrialHistory()),
      classOf[TrialIssue]                 -> trialIssueWriter.write(nextTrialIssue()),
      classOf[RichCriterion]              -> richCriterionFormat.write(nextRichCriterion()),
      classOf[InterventionWithArms]       -> interventionFormat.write(nextInterventionWithArms()),
      classOf[InterventionType]           -> interventionTypeFormat.write(nextInterventionType()),
      classOf[Hypothesis]                 -> hypothesisFormat.write(nextHypothesis()),
      classOf[StudyDesign]                -> studyDesignFormat.write(nextStudyDesign()),
      classOf[ExportTrialWithLabels]      -> trialWithLabelsFormat.write(export.nextExportTrialWithLabels()),
      classOf[EligibilityArmWithDiseases] -> eligibilityArmWithDiseasesWriter.write(nextEligibilityArmWithDiseases()),
      classOf[SlotArm]                    -> slotArmFormat.write(nextSlotArm()),
      classOf[TrialListResponse]          -> listResponseWriter[Trial].write(nextTrialListResponse()),
      classOf[TrialIssueListResponse]     -> listResponseWriter[TrialIssue].write(nextTrialIssueListResponse()),
      classOf[TrialHistoryListResponse]   -> listResponseWriter[TrialHistory].write(nextTrialHistoryListResponse()),
      classOf[ArmListResponse]            -> listResponseWriter[Arm].write(nextArmListResponse()),
      classOf[InterventionWithArmsListResponse] -> listResponseWriter[InterventionWithArms].write(
        nextInterventionWithArmsListResponse()),
      classOf[EligibilityArmWithDiseasesListResponse] -> listResponseWriter[EligibilityArmWithDiseases].write(
        nextEligibilityArmWithDiseasesListResponse()),
      classOf[SlotArmListResponse]       -> listResponseWriter[SlotArm].write(nextSlotArmListResponse()),
      classOf[RichCriterionListResponse] -> listResponseWriter[RichCriterion].write(nextRichCriterionListResponse()),
      classOf[InterventionTypeListResponse] -> listResponseWriter[InterventionType].write(
        nextInterventionTypeListResponse()),
      classOf[StudyDesignListResponse] -> listResponseWriter[StudyDesign].write(nextStudyDesignListResponse()),
      classOf[HypothesisListResponse]  -> listResponseWriter[Hypothesis].write(nextHypothesesListResponse())
    )
  }

  object recordprocessing {
    import xyz.driver.pdsuidomain.fakes.entities.recordprocessing._
    import xyz.driver.pdsuidomain.fakes.entities.export
    import xyz.driver.pdsuidomain.formats.json.export._
    import xyz.driver.pdsuidomain.formats.json.documentissue._
    import xyz.driver.pdsuidomain.formats.json.documenthistory._
    import xyz.driver.pdsuidomain.formats.json.recordissue._
    import xyz.driver.pdsuidomain.formats.json.recordhistory._
    import xyz.driver.pdsuidomain.formats.json.extracteddata._

    val customRecordProcessingProperties = immutable.Map[Class[_], Property](
      classOf[MedicalRecord.Status]        -> stringProperty(),
      classOf[MedicalRecordHistory.Action] -> stringProperty(),
      classOf[MedicalRecordHistory.State]  -> stringProperty(),
      classOf[Document.Status]             -> stringProperty(),
      classOf[Document.RequiredType]       -> stringProperty(),
      classOf[DocumentHistory.Action]      -> stringProperty(),
      classOf[DocumentHistory.State]       -> stringProperty()
    ) ++ customCommonProperties

    val customRecordProcessingObjectsExamples = immutable.Map[Class[_], JsValue](
      classOf[Document]                  -> documentFormat.write(nextDocument()),
      classOf[DocumentIssue]             -> documentIssueFormat.write(nextDocumentIssue()),
      classOf[DocumentHistory]           -> documentHistoryFormat.write(nextDocumentHistory()),
      classOf[MedicalRecord]             -> recordFormat.write(nextMedicalRecord()),
      classOf[MedicalRecordIssue]        -> recordIssueFormat.write(nextMedicalRecordIssue()),
      classOf[MedicalRecordHistory]      -> recordHistoryFormat.write(nextMedicalRecordHistory()),
      classOf[RichExtractedData]         -> extractedDataFormat.write(nextRichExtractedData()),
      classOf[ExportPatientWithLabels]   -> patientWithLabelsFormat.write(export.nextExportPatientWithLabels()),
      classOf[MedicalRecordListResponse] -> listResponseWriter[MedicalRecord].write(nextMedicalRecordListResponse()),
      classOf[MedicalRecordIssueListResponse] -> listResponseWriter[MedicalRecordIssue].write(
        nextMedicalRecordIssueListResponse()),
      classOf[MedicalRecordHistoryListResponse] -> listResponseWriter[MedicalRecordHistory].write(
        nextMedicalRecordHistoryListResponse()),
      classOf[DocumentListResponse]      -> listResponseWriter[Document].write(nextDocumentListResponse()),
      classOf[DocumentIssueListResponse] -> listResponseWriter[DocumentIssue].write(nextDocumentIssueListResponse()),
      classOf[DocumentHistoryListResponse] -> listResponseWriter[DocumentHistory].write(
        nextDocumentHistoryListResponse()),
      classOf[RichExtractedDataListResponse] -> listResponseWriter[RichExtractedData].write(
        nextRichExtractedDataListResponse())
    ) ++ customCommonObjectsExamples
  }

  object treatmentmatching {
    import xyz.driver.pdsuidomain.fakes.entities.treatmentmatching._
    import xyz.driver.pdsuidomain.formats.json.patient._
    import xyz.driver.pdsuidomain.formats.json.patientcriterion._
    import xyz.driver.pdsuidomain.formats.json.patientdefiningcriteria._
    import xyz.driver.pdsuidomain.formats.json.patienteligibletrial._
    import xyz.driver.pdsuidomain.formats.json.patientlabel._
    import xyz.driver.pdsuidomain.formats.json.patienthypothesis._
    import xyz.driver.pdsuidomain.formats.json.patienthistory._
    import xyz.driver.pdsuidomain.formats.json.patientissue._

    val customTreatmentMatchingProperties = immutable.Map[Class[_], Property](
      classOf[Patient.Status]        -> stringProperty(),
      classOf[PatientHistory.Action] -> stringProperty(),
      classOf[PatientHistory.State]  -> stringProperty()
    ) ++ customCommonProperties

    val customTreatmentMatchingObjectsExamples = immutable.Map[Class[_], JsValue](
      classOf[Patient]                  -> patientFormat.write(nextPatient()),
      classOf[RichPatientLabel]         -> richPatientLabelFormat.write(nextRichPatientLabel()),
      classOf[PatientLabel]             -> patientLabelDefiningCriteriaWriter.write(nextPatientLabel()),
      classOf[RichPatientCriterion]     -> richPatientCriterionFormat.write(nextRichPatientCriterion()),
      classOf[DraftPatientCriterion]    -> draftPatientCriterionFormat.write(nextDraftPatientCriterion()),
      classOf[PatientLabelEvidenceView] -> patientLabelEvidenceWriter.write(nextPatientLabelEvidenceView()),
      classOf[RichPatientEligibleTrial] -> patientEligibleTrialWriter.write(nextRichPatientEligibleTrial()),
      classOf[PatientHypothesis]        -> patientHypothesisWriter.write(nextPatientHypothesis()),
      classOf[PatientHistory]           -> patientHistoryFormat.write(nextPatientHistory()),
      classOf[PatientIssue]             -> patientIssueWriter.write(nextPatientIssue()),
      classOf[PatientListResponse]      -> listResponseWriter[Patient].write(nextPatientListResponse()),
      classOf[PatientLabelListResponse] -> listResponseWriter[PatientLabel].write(nextPatientLabelListResponse()),
      classOf[RichPatientLabelListResponse] -> listResponseWriter[RichPatientLabel].write(
        nextRichPatientLabelListResponse()),
      classOf[RichPatientCriterionListResponse] -> listResponseWriter[RichPatientCriterion].write(
        nextRichPatientCriterionListResponse()),
      classOf[PatientLabelEvidenceViewListResponse] -> listResponseWriter[PatientLabelEvidenceView].write(
        nextPatientLabelEvidenceViewListResponse()),
      classOf[RichPatientEligibleTrialListResponse] -> listResponseWriter[RichPatientEligibleTrial].write(
        nextRichPatientEligibleTrialListResponse()),
      classOf[PatientHypothesisListResponse] -> listResponseWriter[PatientHypothesis].write(
        nextPatientHypothesisListResponse()),
      classOf[PatientIssueListResponse]   -> listResponseWriter[PatientIssue].write(nextPatientIssuesListResponse()),
      classOf[PatientHistoryListResponse] -> listResponseWriter[PatientHistory].write(nextPatientHistoryListResponse())
    ) ++ customCommonObjectsExamples
  }

}