libeufin

commit c70d0ae3f357898a1547881a09489563830722f9
parent 3c85267950af7a1a26ebf5a25dd1c011847ddd65
Author: Marcello Stanisci <stanisci.m@gmail.com>
Date:   Thu,  7 Nov 2019 17:22:46 +0100

implement /sendHia

Diffstat:
M
nexus/src/main/kotlin/Main.kt
 | 
88
+++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++--

1 file changed, 86 insertions(+), 2 deletions(-)
diff --git a/nexus/src/main/kotlin/Main.kt b/nexus/src/main/kotlin/Main.kt
@@ -42,11 +42,14 @@ import io.ktor.routing.post
 import io.ktor.routing.routing
 import io.ktor.server.engine.embeddedServer
 import io.ktor.server.netty.Netty
+import org.apache.xml.security.binding.xmldsig.RSAKeyValueType
 import org.jetbrains.exposed.sql.transactions.transaction
 import org.slf4j.LoggerFactory
 import tech.libeufin.sandbox.*
 import tech.libeufin.schema.ebics_h004.EbicsKeyManagementResponse
+import tech.libeufin.schema.ebics_h004.EbicsTypes
 import tech.libeufin.schema.ebics_h004.EbicsUnsecuredRequest
+import tech.libeufin.schema.ebics_h004.HIARequestOrderData
 import tech.libeufin.schema.ebics_s001.PubKeyValueType
 import tech.libeufin.schema.ebics_s001.SignaturePubKeyInfoType
 import tech.libeufin.schema.ebics_s001.SignaturePubKeyOrderData
@@ -274,8 +277,9 @@ fun main() {
                     iniRequest
                 ) ?: throw UnreachableBankError(HttpStatusCode.InternalServerError)
 
-                val returnCode = responseJaxb.value.body.returnCode.value
-                if (returnCode != "000000") throw EbicsError(returnCode)
+                if (responseJaxb.value.body.returnCode.value != "000000") {
+                    throw EbicsError(responseJaxb.value.body.returnCode.value)
+                }
 
                 call.respond(
                     HttpStatusCode.OK,
@@ -283,6 +287,86 @@ fun main() {
                 )
                 return@post
             }
+
+            post("/ebics/subscribers/{id}/sendHia") {
+
+                val id = expectId(call.parameters["id"]) // caught above
+                val hiaRequest = EbicsUnsecuredRequest()
+
+                val url = transaction {
+                    val subscriber = EbicsSubscriberEntity.findById(id) ?: throw SubscriberNotFoundError(HttpStatusCode.NotFound)
+                    val tmpAiKey = CryptoUtil.loadRsaPrivateKey(subscriber.authenticationPrivateKey.toByteArray())
+                    val tmpEncKey = CryptoUtil.loadRsaPrivateKey(subscriber.encryptionPrivateKey.toByteArray())
+
+                    hiaRequest.apply {
+                        version = "H004"
+                        revision = 1
+                        header = EbicsUnsecuredRequest.Header().apply {
+                            authenticate = true
+                            static = EbicsUnsecuredRequest.StaticHeaderType().apply {
+                                orderDetails = EbicsUnsecuredRequest.OrderDetails().apply {
+                                    orderAttribute = "DZNNN"
+                                    orderType = "HIA"
+                                    securityMedium = "0000"
+                                    hostID = subscriber.hostID
+                                    userID = subscriber.userID
+                                    partnerID = subscriber.partnerID
+                                    systemID = subscriber.systemID
+                                }
+                            }
+                            mutable = EbicsUnsecuredRequest.Header.EmptyMutableHeader()
+                        }
+                        body = EbicsUnsecuredRequest.Body().apply {
+                            dataTransfer = EbicsUnsecuredRequest.UnsecuredDataTransfer().apply {
+                                orderData = EbicsUnsecuredRequest.OrderData().apply {
+                                    value = EbicsOrderUtil.encodeOrderDataXml(
+                                        HIARequestOrderData().apply {
+                                            authenticationPubKeyInfo = EbicsTypes.AuthenticationPubKeyInfoType().apply {
+                                                pubKeyValue = EbicsTypes.PubKeyValueType().apply {
+                                                    rsaKeyValue = RSAKeyValueType().apply {
+                                                        exponent = tmpAiKey.publicExponent.toByteArray()
+                                                        modulus = tmpAiKey.modulus.toByteArray()
+                                                    }
+                                                }
+                                                authenticationVersion = "X002"
+                                            }
+                                            encryptionPubKeyInfo = EbicsTypes.EncryptionPubKeyInfoType().apply {
+                                                pubKeyValue = EbicsTypes.PubKeyValueType().apply {
+                                                    rsaKeyValue = RSAKeyValueType().apply {
+                                                        exponent = tmpEncKey.publicExponent.toByteArray()
+                                                        modulus = tmpEncKey.modulus.toByteArray()
+                                                    }
+                                                }
+                                                encryptionVersion = "E002"
+
+                                            }
+                                            partnerID = subscriber.partnerID
+                                            userID = subscriber.userID
+                                        }
+                                    )
+                                }
+                            }
+                        }
+                    }
+
+                    subscriber.ebicsURL
+                }
+
+                val responseJaxb = client.postToBank<EbicsKeyManagementResponse, EbicsUnsecuredRequest>(
+                    url,
+                    hiaRequest
+                ) ?: throw UnreachableBankError(HttpStatusCode.InternalServerError)
+
+                if (responseJaxb.value.body.returnCode.value != "000000") {
+                    throw EbicsError(responseJaxb.value.body.returnCode.value)
+                }
+
+                call.respond(
+                    HttpStatusCode.OK,
+                    NexusError("Sandbox accepted the keys!")
+                )
+                return@post
+            }
         }
     }