commit 5463134c614fd119c162f233885ca56cab497c2a
parent 5efc69c41f736fc383e78567fd2446792525420f
Author: Antoine A <>
Date: Wed, 17 Jan 2024 13:09:55 +0000
Fix ebics-fetch parse without import feature
Diffstat:
1 file 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
@@ -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
}