[libeufin] branch master updated: enabling Taler ingestion task, and get it tested.

[gnunet]

This is an automated email from the git hooks/post-receive script.

ms pushed a commit to branch master
in repository libeufin.

The following commit(s) were added to refs/heads/master by this push:
     new b39c7a1  enabling Taler ingestion task, and get it tested.
b39c7a1 is described below

commit b39c7a19aab086279959b6c16a292d3111b532aa
Author: MS <ms@taler.net>
AuthorDate: Mon Jun 8 17:30:10 2020 +0200

    enabling Taler ingestion task, and get it tested.
---
 integration-tests/test-taler-facade.py             | 14 +++++++++++++-
 nexus/src/main/kotlin/tech/libeufin/nexus/Main.kt  |  2 +-
 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
index 9c8b6fe..e0ed0e1 100755
--- 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
index 18c1bfa..1f5e59b 100644
--- 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
index 7b42ff0..bee7cbf 100644
--- 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

-- 
To stop receiving notification emails like this one, please contact
gnunet@gnunet.org.