Merge pull request #5357 from IntersectMBO/coot/submitTxToMempool-result

tx-submission v2: return results in submitTxToMempool

Author: coot

ouroboros-network/changelog.d/20260504_123032_coot_submitTxToMempool_result.md

@@ -0,0 +1,23 @@
+<!--
+A new scriv changelog fragment.
+
+Uncomment the section that is right (remove the HTML comment wrapper).
+For top level release notes, leave all the headers commented out.
+-->
+
+### Breaking
+
+- `submitTxToMempool` returns the `TxMempoolResult`
+
+<!--
+### Non-Breaking
+
+- A bullet item for the Non-Breaking category.
+
+-->
+<!--
+### Patch
+
+- A bullet item for the Patch category.
+
+-->

ouroboros-network/lib/Ouroboros/Network/TxSubmission/Inbound/V2/Registry.hs

@@ -8,6 +8,7 @@ module Ouroboros.Network.TxSubmission.Inbound.V2.Registry
   ( TxChannels (..)
   , TxChannelsVar
   , TxMempoolSem
+  , TxMempoolResult (..)
   , SharedTxStateVar
   , newSharedTxStateVar
   , newTxChannelsVar
@@ -85,7 +86,7 @@ data PeerTxAPI m txid tx = PeerTxAPI {
     -- ^ handle received txs
 
     submitTxToMempool     :: Tracer m (TraceTxSubmissionInbound txid tx)
-                          -> txid -> tx -> m ()
+                          -> txid -> tx -> m TxMempoolResult
     -- ^ submit the given (txid, tx) to the mempool.
   }
 
@@ -248,7 +249,7 @@ withPeer tracer
     -- PeerTxAPI
     --
 
-    submitTxToMempool :: Tracer m (TraceTxSubmissionInbound txid tx) -> txid -> tx -> m ()
+    submitTxToMempool :: Tracer m (TraceTxSubmissionInbound txid tx) -> txid -> tx -> m TxMempoolResult
     submitTxToMempool txTracer txid tx =
         bracket_ (atomically $ waitTSem mempoolSem)
                  (atomically $ signalTSem mempoolSem)
@@ -261,6 +262,7 @@ withPeer tracer
             case res of
               TxAccepted -> traceWith txTracer (TraceTxInboundAddedToMempool [txid] duration)
               TxRejected -> traceWith txTracer (TraceTxInboundRejectedFromMempool [txid] duration)
+            return res
 
       where
         -- add the tx to the mempool