legg til Processing service

ebms-provider/src/main/kotlin/no/nav/emottak/ebms/processing/ProcessingService.kt

@@ -0,0 +1,74 @@
+package no.nav.emottak.ebms.processing
+
+import io.ktor.server.plugins.BadRequestException
+import kotlinx.coroutines.runBlocking
+import no.nav.emottak.ebms.HttpClientUtil
+import no.nav.emottak.ebms.model.EbMSBaseMessage
+import no.nav.emottak.ebms.model.EbMSError
+import no.nav.emottak.ebms.model.EbMSMessageError
+import no.nav.emottak.ebms.model.EbMSPayloadMessage
+import no.nav.emottak.ebms.model.EbmsAcknowledgment
+import no.nav.emottak.ebms.postPayloadRequest
+import no.nav.emottak.melding.model.Header
+import no.nav.emottak.melding.model.Party
+import no.nav.emottak.melding.model.PayloadRequest
+import org.oasis_open.committees.ebxml_msg.schema.msg_header_2_0.Acknowledgment
+import org.oasis_open.committees.ebxml_msg.schema.msg_header_2_0.MessageHeader
+
+class ProcessingService() {
+
+    var httpClient = HttpClientUtil()
+
+
+    private fun paylodMessage(payloadMessage: EbMSPayloadMessage) {
+        val payloads = payloadMessage.attachments
+        val header = payloadMessage.messageHeader.payloadRequestHeader()
+        payloads.forEach { payload ->
+            val payloadRequest = PayloadRequest(
+                header = header,
+                payload = payload.dataSource
+            )
+            //TODO do something with the response?
+            runBlocking {
+                httpClient.postPayloadRequest(payloadRequest)
+            }
+        }
+    }
+
+    private fun acknowledgment(acknowledgment: Acknowledgment) {
+
+    }
+
+    private fun fail(fail:EbMSError) {
+
+    }
+
+    fun process(message: EbMSBaseMessage) {
+        when (message) {
+            is EbmsAcknowledgment ->  message.process()
+            is EbMSMessageError -> message.process()
+            is EbMSPayloadMessage -> message.process()
+            }
+        }
+    }
+
+
+fun MessageHeader.payloadRequestHeader(): Header {
+    return Header(
+        messageId = this.messageData.messageId ?: throw BadRequestException("MessageID mangler fra header"),
+        cpaId = this.cpaId ?: throw BadRequestException("CPAID mangler fra header"),
+        conversationId = this.conversationId,
+        to = Party(
+            partyType = this.to.partyId.firstOrNull()?.type ?: throw BadRequestException("Melding mangler to partyId"),
+            partyId = this.to.partyId.firstOrNull()?.type ?: throw BadRequestException("Melding mangler to partyId"),
+            role = this.to.role ?: throw BadRequestException("Melding mangler role for en eller flere parter")
+        ),
+        from = Party(
+            partyType = this.from.partyId.firstOrNull()?.type ?: throw BadRequestException("Melding mangler from partyId"),
+            partyId = this.from.partyId.firstOrNull()?.type ?: throw BadRequestException("Melding mangler from partyId"),
+            role = this.from.role ?: throw BadRequestException("Melding mangler role for en eller flere parter")
+        ),
+        service = this.service.value ?: throw BadRequestException("Service mangler fra header"),
+        action = this.action
+    )
+}