1 files changed, 10 insertions, 4 deletions
diff --git a/src/main/kotlin/dev/dnpm/etl/processor/web/MtbFileController.kt b/src/main/kotlin/dev/dnpm/etl/processor/web/MtbFileRestController.kt
index cf0e693..9b441f6 100644
--- a/src/main/kotlin/dev/dnpm/etl/processor/web/MtbFileController.kt
+++ b/src/main/kotlin/dev/dnpm/etl/processor/web/MtbFileRestController.kt
@@ -19,6 +19,7 @@
 
 package dev.dnpm.etl.processor.web
 
+import de.ukw.ccc.bwhc.dto.Consent
 import de.ukw.ccc.bwhc.dto.MtbFile
 import dev.dnpm.etl.processor.services.RequestProcessor
 import org.slf4j.LoggerFactory
@@ -26,16 +27,21 @@ import org.springframework.http.ResponseEntity
 import org.springframework.web.bind.annotation.*
 
 @RestController
-class MtbFileController(
+class MtbFileRestController(
     private val requestProcessor: RequestProcessor,
 ) {
 
-    private val logger = LoggerFactory.getLogger(MtbFileController::class.java)
+    private val logger = LoggerFactory.getLogger(MtbFileRestController::class.java)
 
     @PostMapping(path = ["/mtbfile"])
     fun mtbFile(@RequestBody mtbFile: MtbFile): ResponseEntity<Void> {
-        logger.debug("Accepted MTB File for processing")
-        requestProcessor.processMtbFile(mtbFile)
+        if (mtbFile.consent.status == Consent.Status.ACTIVE) {
+            logger.debug("Accepted MTB File for processing")
+            requestProcessor.processMtbFile(mtbFile)
+        } else {
+            logger.debug("Accepted MTB File and process deletion")
+            requestProcessor.processDeletion(mtbFile.patient.id)
+        }
         return ResponseEntity.accepted().build()
     }