diff options
| author | Antoine A <> | 2024-01-17 13:09:55 +0000 |
|---|---|---|
| committer | Antoine A <> | 2024-01-17 13:09:55 +0000 |
| commit | 5463134c614fd119c162f233885ca56cab497c2a (patch) | |
| tree | 7d33e1031b7f5f3d1cd243a4168328aba3873e79 | |
| parent | 5efc69c41f736fc383e78567fd2446792525420f (diff) | |
| download | libeufin-5463134c614fd119c162f233885ca56cab497c2a.tar.gz libeufin-5463134c614fd119c162f233885ca56cab497c2a.tar.bz2 libeufin-5463134c614fd119c162f233885ca56cab497c2a.zip | |
Fix ebics-fetch parse without import feature
| -rw-r--r-- | nexus/src/main/kotlin/tech/libeufin/nexus/EbicsFetch.kt | 8 |
1 files changed, 4 insertions, 4 deletions
diff --git a/nexus/src/main/kotlin/tech/libeufin/nexus/EbicsFetch.kt b/nexus/src/main/kotlin/tech/libeufin/nexus/EbicsFetch.kt index d4feaf98..05952d21 100644 --- a/nexus/src/main/kotlin/tech/libeufin/nexus/EbicsFetch.kt +++ b/nexus/src/main/kotlin/tech/libeufin/nexus/EbicsFetch.kt @@ -340,7 +340,7 @@ fun firstLessThanSecond( } private fun ingestDocument( - db: Database, + db: Database?, currency: String, content: ByteArray, whichDocument: SupportedDocument @@ -364,10 +364,10 @@ private fun ingestDocument( runBlocking { incomingPayments.forEach { - ingestIncomingPayment(db, it) + if (db != null) ingestIncomingPayment(db, it) else logger.debug("$it") } outgoingPayments.forEach { - ingestOutgoingPayment(db, it) + if (db != null) ingestOutgoingPayment(db, it) else logger.debug("$it") } } } catch (e: Exception) { @@ -513,7 +513,7 @@ class EbicsFetch: CliktCommand("Fetches bank records. Defaults to camt.054 noti if (parse || import) { logger.debug("Reading from STDIN, running in debug mode. Not involving the database.") val stdin = generateSequence(::readLine).joinToString("\n").toByteArray() - ingestDocument(db, cfg.currency, stdin, whichDoc) // TODO no db + ingestDocument(if (import) db else null, cfg.currency, stdin, whichDoc) return@cliCmd } |