diff options
author | MS <ms@taler.net> | 2020-06-08 17:30:10 +0200 |
---|---|---|
committer | MS <ms@taler.net> | 2020-06-08 17:30:10 +0200 |
commit | b39c7a19aab086279959b6c16a292d3111b532aa (patch) | |
tree | d5e8d37052b2e00e4c72cb732ff942517174bccf | |
parent | 1656ff8ac1ff4a70121b8ae67933a165b3dfa516 (diff) | |
download | libeufin-b39c7a19aab086279959b6c16a292d3111b532aa.tar.gz libeufin-b39c7a19aab086279959b6c16a292d3111b532aa.tar.bz2 libeufin-b39c7a19aab086279959b6c16a292d3111b532aa.zip |
enabling Taler ingestion task, and get it tested.
-rwxr-xr-x | integration-tests/test-taler-facade.py | 14 | ||||
-rw-r--r-- | nexus/src/main/kotlin/tech/libeufin/nexus/Main.kt | 2 | ||||
-rw-r--r-- | 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 9c8b6fec..e0ed0e1d 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 18c1bfa8..1f5e59b5 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 7b42ff02..bee7cbf6 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 |