Isolate TWG /transfer problem, in a test case.

After receiving the CCT order, the Sandbox hands
at inserting EbicsUploadTransactionEntity into the
database.

2 files changed, 9 insertions, 2 deletions

diff --git a/nexus/src/main/kotlin/tech/libeufin/nexus/Main.kt b/nexus/src/main/kotlin/tech/libeufin/nexus/Main.kt
index d4af549b..a8837a79 100644
--- a/nexus/src/main/kotlin/tech/libeufin/nexus/Main.kt
+++ b/nexus/src/main/kotlin/tech/libeufin/nexus/Main.kt
@@ -67,6 +67,8 @@ import org.slf4j.event.Level
 import tech.libeufin.util.*
 import tech.libeufin.util.CryptoUtil.hashpw
 import tech.libeufin.util.ebics_h004.HTDResponseOrderData
+import java.io.PrintWriter
+import java.io.StringWriter
 import java.lang.NumberFormatException
 import java.net.URLEncoder
 import java.time.Duration
@@ -265,10 +267,13 @@ fun schedulePeriodicWork() {
             try {
                 delay(Duration.ofSeconds(1))
                 downloadTalerFacadesTransactions()
-                ingestTalerTransactions()
+                // ingestTalerTransactions()
                 submitPreparedPaymentsViaEbics()
             } catch (e: Exception) {
-                logger.info("==== Background job exception ====\n${e.message}======")
+                val sw = StringWriter()
+                val pw = PrintWriter(sw)
+                e.printStackTrace(pw)
+                logger.info("==== Background job exception ====\n${sw}======")
             }
         }
     }
diff --git a/nexus/src/main/kotlin/tech/libeufin/nexus/taler.kt b/nexus/src/main/kotlin/tech/libeufin/nexus/taler.kt
index 0b9f4854..00231454 100644
--- a/nexus/src/main/kotlin/tech/libeufin/nexus/taler.kt
+++ b/nexus/src/main/kotlin/tech/libeufin/nexus/taler.kt
@@ -376,6 +376,7 @@ suspend fun submitPreparedPaymentsViaEbics() {
         val subscriberDetails: EbicsClientSubscriberDetails,
         val pain001document: String
     )
+    logger.debug("auto-submitter started")
     val workQueue = mutableListOf<EbicsSubmission>()
     transaction {
         TalerFacadeStateEntity.all().forEach {
@@ -400,6 +401,7 @@ suspend fun submitPreparedPaymentsViaEbics() {
             )
             PreparedPaymentEntity.find { PreparedPaymentsTable.debitorIban eq bankAccount.iban }.forEach {
                 val pain001document = createPain001document(it)
+                logger.debug("Preparing payment: ${pain001document}")
                 val subscriberDetails = getEbicsSubscriberDetailsInternal(subscriberEntity)
                 workQueue.add(EbicsSubmission(subscriberDetails, pain001document))
                 // FIXME: the payment must be flagger AFTER the submission happens.