commit fdb0dd338087815af47f84278c4f5bebcf8fa415
parent 89ae2f42ce0e08663f6508c316fbc54606b1810b
Author: Antoine A <>
Date: Fri, 1 Aug 2025 16:21:51 +0200
nexus: improve documentation and ack cmd
Diffstat:
3 files changed, 10 insertions(+), 3 deletions(-)
diff --git a/contrib/nexus.conf b/contrib/nexus.conf
@@ -87,7 +87,7 @@ CHECKPOINT_TIME_OF_DAY = 19:00
FREQUENCY = 30m
# Wether to wait for manual acknowledgement before submiting transactions
-# manual_ack = NO
+# MANUAL_ACK = NO
[nexus-httpd]
# How "libeufin-nexus serve" serves its API, this can either be tcp or unix
diff --git a/nexus/src/main/kotlin/tech/libeufin/nexus/cli/List.kt b/nexus/src/main/kotlin/tech/libeufin/nexus/cli/List.kt
@@ -108,7 +108,10 @@ class ListOutgoing: TalerCmd("outgoing") {
class ListInitiated: TalerCmd("initiated") {
override fun help(context: Context) = "List initiated transactions"
- private val awaitingAck by option().flag()
+ private val awaitingAck by option(
+ "--ack", "--awaiting-ack",
+ help = "Only list transactions awaiting manual acknowledgement",
+ ).flag()
override fun run() = cliCmd(logger) {
nexusConfig(config).withDb { db, cfg ->
diff --git a/nexus/src/main/kotlin/tech/libeufin/nexus/cli/Manual.kt b/nexus/src/main/kotlin/tech/libeufin/nexus/cli/Manual.kt
@@ -140,7 +140,11 @@ class AckCmd: TalerCmd("ack") {
override fun run() = cliCmd(logger) {
nexusConfig(config).withDb { db, cfg ->
for (id in ids) {
- db.initiated.ack(id)
+ if (db.initiated.ack(id)) {
+ logger.info("Mark $id as acknowledge for submission")
+ } else {
+ logger.warn("Unknown transaction $id")
+ }
}
}
}