[libeufin] branch master updated (73b6118 -> 0e0cc55)

[gnunet]

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

dold pushed a change to branch master
in repository libeufin.

    from 73b6118  improve camt modeling/parsing
     new e5321b2  fix resource leak
     new 0e0cc55  pass through type correctly

The 2 revisions listed above as "new" are entirely new to this
repository and will be described in separate emails.  The revisions
listed as "add" were already present in the repository and have only
been added to this reference.


Summary of changes:
 nexus/src/main/kotlin/tech/libeufin/nexus/Main.kt | 17 ++++++++---------
 1 file changed, 8 insertions(+), 9 deletions(-)

diff --git a/nexus/src/main/kotlin/tech/libeufin/nexus/Main.kt 
b/nexus/src/main/kotlin/tech/libeufin/nexus/Main.kt
index dc811d8..17f4519 100644
--- a/nexus/src/main/kotlin/tech/libeufin/nexus/Main.kt
+++ b/nexus/src/main/kotlin/tech/libeufin/nexus/Main.kt
@@ -260,14 +260,14 @@ fun ApplicationRequest.hasBody(): Boolean {
     return false
 }
 
-fun moreFrequentBackgroundTasks() {
+fun moreFrequentBackgroundTasks(httpClient: HttpClient) {
     GlobalScope.launch {
         while (true) {
             logger.debug("More frequent background job")
             ingestTalerTransactions()
             submitPreparedPaymentsViaEbics()
             try {
-                downloadTalerFacadesTransactions("C52")
+                downloadTalerFacadesTransactions(httpClient,"C52")
             } catch (e: Exception) {
                 val sw = StringWriter()
                 val pw = PrintWriter(sw)
@@ -279,12 +279,12 @@ fun moreFrequentBackgroundTasks() {
     }
 }
 
-fun lessFrequentBackgroundTasks() {
+fun lessFrequentBackgroundTasks(httpClient: HttpClient) {
     GlobalScope.launch {
         while (true) {
             logger.debug("Less frequent background job")
             try {
-                downloadTalerFacadesTransactions("C53")
+                downloadTalerFacadesTransactions(httpClient,"C53")
             } catch (e: Exception) {
                 val sw = StringWriter()
                 val pw = PrintWriter(sw)
@@ -297,8 +297,7 @@ fun lessFrequentBackgroundTasks() {
 }
 
 /** Crawls all the facades, and requests history for each of its creators. */
-suspend fun downloadTalerFacadesTransactions(type: String) {
-    val httpClient = HttpClient()
+suspend fun downloadTalerFacadesTransactions(httpClient: HttpClient, type: 
String) {
     val work = mutableListOf<Pair<String, String>>()
     transaction {
         TalerFacadeStateEntity.all().forEach {
@@ -361,7 +360,7 @@ suspend fun fetchTransactionsInternal(
     when (res.connectionType) {
         "ebics" -> {
             fetchEbicsC5x(
-                "C53",
+                type,
                 client,
                 res.connectionName,
                 ct.start,
@@ -449,8 +448,8 @@ fun serverMain(dbName: String) {
             return@intercept
         }
 
-        lessFrequentBackgroundTasks()
-        moreFrequentBackgroundTasks()
+        lessFrequentBackgroundTasks(client)
+        moreFrequentBackgroundTasks(client)
         routing {
             /**
              * Shows information about the requesting user.

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