diff options
author | MS <ms@taler.net> | 2020-06-06 02:05:50 +0200 |
---|---|---|
committer | MS <ms@taler.net> | 2020-06-06 02:05:50 +0200 |
commit | accd4f5052a33abff75ecdec6b9b95bf9f37daae (patch) | |
tree | f82d2053040fc43503fc094d5a8ab2a4f1bcaf2f /nexus/src/main/kotlin | |
parent | 30df1e0c3d84ccaace6c01a25451eb51a6796387 (diff) | |
download | libeufin-accd4f5052a33abff75ecdec6b9b95bf9f37daae.tar.gz libeufin-accd4f5052a33abff75ecdec6b9b95bf9f37daae.tar.bz2 libeufin-accd4f5052a33abff75ecdec6b9b95bf9f37daae.zip |
automatic payment submission
Diffstat (limited to 'nexus/src/main/kotlin')
-rw-r--r-- | nexus/src/main/kotlin/tech/libeufin/nexus/Main.kt | 5 | ||||
-rw-r--r-- | nexus/src/main/kotlin/tech/libeufin/nexus/taler.kt | 2 |
2 files changed, 5 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 38097082..d4af549b 100644 --- a/nexus/src/main/kotlin/tech/libeufin/nexus/Main.kt +++ b/nexus/src/main/kotlin/tech/libeufin/nexus/Main.kt @@ -264,8 +264,9 @@ fun schedulePeriodicWork() { logger.debug("Outer background job") try { delay(Duration.ofSeconds(1)) - downloadTalerFacadesTransactions(this) + downloadTalerFacadesTransactions() ingestTalerTransactions() + submitPreparedPaymentsViaEbics() } catch (e: Exception) { logger.info("==== Background job exception ====\n${e.message}======") } @@ -274,7 +275,7 @@ fun schedulePeriodicWork() { } /** Crawls all the facades, and requests history for each of its creators. */ -suspend fun downloadTalerFacadesTransactions(myScope: CoroutineScope) { +suspend fun downloadTalerFacadesTransactions() { val httpClient = HttpClient() val work = mutableListOf<Pair<String, String>>() transaction { diff --git a/nexus/src/main/kotlin/tech/libeufin/nexus/taler.kt b/nexus/src/main/kotlin/tech/libeufin/nexus/taler.kt index 15e45bed..0b9f4854 100644 --- a/nexus/src/main/kotlin/tech/libeufin/nexus/taler.kt +++ b/nexus/src/main/kotlin/tech/libeufin/nexus/taler.kt @@ -402,6 +402,8 @@ suspend fun submitPreparedPaymentsViaEbics() { val pain001document = createPain001document(it) val subscriberDetails = getEbicsSubscriberDetailsInternal(subscriberEntity) workQueue.add(EbicsSubmission(subscriberDetails, pain001document)) + // FIXME: the payment must be flagger AFTER the submission happens. + it.submitted = true } } } |