nexus: wire gateway /history/outgoing

4 files changed, 56 insertions, 10 deletions

diff --git a/nexus/src/main/kotlin/tech/libeufin/nexus/EbicsFetch.kt b/nexus/src/main/kotlin/tech/libeufin/nexus/EbicsFetch.kt
index e5f18595..8e876f20 100644
--- a/nexus/src/main/kotlin/tech/libeufin/nexus/EbicsFetch.kt
+++ b/nexus/src/main/kotlin/tech/libeufin/nexus/EbicsFetch.kt
@@ -95,7 +95,10 @@ suspend fun ingestOutgoingPayment(
     db: Database,
     payment: OutgoingPayment
 ) {
-    val result = db.payment.registerOutgoing(payment)
+    val metadata: Pair<ShortHashCode, ExchangeUrl>? = payment.wireTransferSubject?.let { 
+        runCatching { parseOutgoingTxMetadata(it) }.getOrNull()
+    }
+    val result = db.payment.registerOutgoing(payment, metadata?.first, metadata?.second)
     if (result.new) {
         if (result.initiated)
             logger.info("$payment")
@@ -106,8 +109,6 @@ suspend fun ingestOutgoingPayment(
     }
 }
 
-private val PATTERN = Regex("[a-z0-9A-Z]{52}")
-
 /**
  * Ingests an incoming payment.  Stores the payment into valid talerable ones
  * or bounces it, according to the subject.
diff --git a/nexus/src/main/kotlin/tech/libeufin/nexus/api/WireGatewayApi.kt b/nexus/src/main/kotlin/tech/libeufin/nexus/api/WireGatewayApi.kt
index 7879522c..6073072b 100644
--- a/nexus/src/main/kotlin/tech/libeufin/nexus/api/WireGatewayApi.kt
+++ b/nexus/src/main/kotlin/tech/libeufin/nexus/api/WireGatewayApi.kt
@@ -81,9 +81,9 @@ fun Routing.wireGatewayApi(db: Database, cfg: NexusConfig) {
     get("/taler-wire-gateway/history/incoming") {
         historyEndpoint(::IncomingHistory, ExchangeDAO::incomingHistory)
     }
-    /*get("/taler-wire-gateway/history/outgoing") {
+    get("/taler-wire-gateway/history/outgoing") {
         historyEndpoint(::OutgoingHistory, ExchangeDAO::outgoingHistory)
-    }*/
+    }
     post("/taler-wire-gateway/admin/add-incoming") {
         val req = call.receive<AddIncomingRequest>()
         cfg.checkCurrency(req.amount)
diff --git a/nexus/src/main/kotlin/tech/libeufin/nexus/db/ExchangeDAO.kt b/nexus/src/main/kotlin/tech/libeufin/nexus/db/ExchangeDAO.kt
index 6d65e444..e2ccd7b8 100644
--- a/nexus/src/main/kotlin/tech/libeufin/nexus/db/ExchangeDAO.kt
+++ b/nexus/src/main/kotlin/tech/libeufin/nexus/db/ExchangeDAO.kt
@@ -52,6 +52,38 @@ class ExchangeDAO(private val db: Database) {
             )
         }
 
+    /** Query [exchangeId] history of taler outgoing transactions  */
+    suspend fun outgoingHistory(
+        params: HistoryParams
+    ): List<OutgoingTransaction> 
+        // Outgoing transactions can be initiated or recovered. We take the first data to
+        // reach database : the initiation first else the recovered transaction.
+        = db.poolHistoryGlobal(params, db::listenOutgoing,  """
+            SELECT
+                talerable_outgoing_transaction_id
+                ,COALESCE(iot.initiation_time, ot.execution_time) AS execution_time
+                ,(COALESCE(iot.amount, ot.amount)).val AS amount_val
+                ,(COALESCE(iot.amount, ot.amount)).frac AS amount_frac
+                ,COALESCE(iot.credit_payto_uri, ot.credit_payto_uri) AS credit_payto_uri
+                ,wtid
+                ,exchange_base_url
+            FROM talerable_outgoing_transactions AS tot
+                LEFT OUTER JOIN outgoing_transactions AS ot
+                    ON tot.outgoing_transaction_id=ot.outgoing_transaction_id
+                LEFT OUTER JOIN initiated_outgoing_transactions AS iot
+                    ON tot.initiated_outgoing_transaction_id=iot.initiated_outgoing_transaction_id
+            WHERE
+        """, "talerable_outgoing_transaction_id") {
+            OutgoingTransaction(
+                row_id = it.getLong("talerable_outgoing_transaction_id"),
+                date = it.getTalerTimestamp("execution_time"),
+                amount = it.getAmount("amount", db.bankCurrency),
+                credit_account = it.getString("credit_payto_uri"),
+                wtid = ShortHashCode(it.getBytes("wtid")),
+                exchange_base_url = it.getString("exchange_base_url")
+            )
+        }
+
     /** Result of taler transfer transaction creation */
     sealed interface TransferResult {
         /** Transaction [id] and wire transfer [timestamp] */
diff --git a/nexus/src/main/kotlin/tech/libeufin/nexus/db/PaymentDAO.kt b/nexus/src/main/kotlin/tech/libeufin/nexus/db/PaymentDAO.kt
index 05548b99..4609def8 100644
--- a/nexus/src/main/kotlin/tech/libeufin/nexus/db/PaymentDAO.kt
+++ b/nexus/src/main/kotlin/tech/libeufin/nexus/db/PaymentDAO.kt
@@ -19,10 +19,8 @@
 
 package tech.libeufin.nexus.db
 
-import tech.libeufin.common.EddsaPublicKey
-import tech.libeufin.common.TalerAmount
+import tech.libeufin.common.*
 import tech.libeufin.common.db.one
-import tech.libeufin.common.micros
 import tech.libeufin.nexus.IncomingPayment
 import tech.libeufin.nexus.OutgoingPayment
 import java.time.Instant
@@ -37,10 +35,14 @@ class PaymentDAO(private val db: Database) {
     )
 
     /** Register an outgoing payment reconciling it with its initiated payment counterpart if present */
-    suspend fun registerOutgoing(paymentData: OutgoingPayment): OutgoingRegistrationResult = db.conn {        
+    suspend fun registerOutgoing(
+        paymentData: OutgoingPayment, 
+        wtid: ShortHashCode?,
+        baseUrl: ExchangeUrl?,
+    ): OutgoingRegistrationResult = db.conn {        
         val stmt = it.prepareStatement("""
             SELECT out_tx_id, out_initiated, out_found
-            FROM register_outgoing((?,?)::taler_amount,?,?,?,?)
+            FROM register_outgoing((?,?)::taler_amount,?,?,?,?,?,?)
         """)
         val executionTime = paymentData.executionTime.micros()
         stmt.setLong(1, paymentData.amount.value)
@@ -49,6 +51,17 @@ class PaymentDAO(private val db: Database) {
         stmt.setLong(4, executionTime)
         stmt.setString(5, paymentData.creditPaytoUri)
         stmt.setString(6, paymentData.messageId)
+        if (wtid != null) {
+            stmt.setBytes(7, wtid.raw)
+        } else {
+            stmt.setNull(7, java.sql.Types.NULL)
+        }
+        if (baseUrl != null) {
+            stmt.setString(8, baseUrl.url)
+        } else {
+            stmt.setNull(8, java.sql.Types.NULL)
+        }
+  
         stmt.one {
             OutgoingRegistrationResult(
                 it.getLong("out_tx_id"),