libeufin

commit b39c7a19aab086279959b6c16a292d3111b532aa
parent 1656ff8ac1ff4a70121b8ae67933a165b3dfa516
Author: MS <ms@taler.net>
Date:   Mon,  8 Jun 2020 17:30:10 +0200

enabling Taler ingestion task, and get it tested.

Diffstat:
M
integration-tests/test-taler-facade.py
 | 
14
+++++++++++++-
M
nexus/src/main/kotlin/tech/libeufin/nexus/Main.kt
 | 
2
+-
M
nexus/src/main/kotlin/tech/libeufin/nexus/taler.kt
 | 
1
+

3 files changed, 15 insertions(+), 2 deletions(-)
diff --git a/integration-tests/test-taler-facade.py b/integration-tests/test-taler-facade.py
@@ -170,6 +170,18 @@ assertResponse(
 
 )
 
+print("Sleeping 5s, to let the automatic tasks ingest the history.")
+sleep(5)
+
+resp = assertResponse(
+    get(
+        "http://localhost:5001/facades/my-facade/taler/history/outgoing?delta=5",
+        headers=dict(Authorization=USER_AUTHORIZATION_HEADER)
+    )
+)
+
+print(resp.text)
+
 # Checks if that crashes the _incoming_ history too.  It does NOT!
 #assertResponse(
 #    post(
@@ -182,5 +194,5 @@ assertResponse(
 #        headers=dict(Authorization=USER_AUTHORIZATION_HEADER)
 #    )
 #)
-
+print("auth header: " + USER_AUTHORIZATION_HEADER)
 input("press enter to stop the test:")
diff --git a/nexus/src/main/kotlin/tech/libeufin/nexus/Main.kt b/nexus/src/main/kotlin/tech/libeufin/nexus/Main.kt
@@ -266,7 +266,7 @@ fun schedulePeriodicWork() {
             logger.debug("Outer background job")
             try {
                 downloadTalerFacadesTransactions()
-                // ingestTalerTransactions()
+                ingestTalerTransactions()
                 submitPreparedPaymentsViaEbics()
             } catch (e: Exception) {
                 val sw = StringWriter()
diff --git a/nexus/src/main/kotlin/tech/libeufin/nexus/taler.kt b/nexus/src/main/kotlin/tech/libeufin/nexus/taler.kt
@@ -467,6 +467,7 @@ fun ingestTalerTransactions() {
                     HttpStatusCode.InternalServerError,
                     "Payment '${it.unstructuredRemittanceInformation}' shows in history, but was never requested!"
                 )
+                logger.debug("Payment: ${it.unstructuredRemittanceInformation} was requested, and gets now marked as 'confirmed'")
                 talerRequested.rawConfirmed = it
             }
             lastId = it.id.value