[DO NOT MERGE] frisby/issue 1701 demo sandbox exe

leiosdemo202510-first-script

@@ -0,0 +1,40 @@
+#! /bin/bash
+rm -f tmp/my.db tmp/up.db tmp/my.lfst tmp/demo tmp/reqs
+set -eux
+cabal build exe:leiosdemo202510
+ln -s $(cabal list-bin exe:leiosdemo202510) tmp/demo
+tmp/demo generate tmp/up.db tmp/my.lfst tmp/myManifest.json
+cp tmp/{up,my}.db
+sqlite3 tmp/my.db "SELECT ebSlot, PRINTF('%X', ebId), ebId FROM ebPoints ORDER BY ebId ASC" # dump points
+sqlite3 tmp/my.db 'SELECT ebId, MAX(txOffset) FROM ebTxs GROUP BY ebId' # dump sizes
+tmp/demo fetch-logic-iteration tmp/my.db tmp/my.lfst | tee -a tmp/reqs
+sqlite3 tmp/my.db 'UPDATE ebTxs SET txBytes = NULL WHERE ebId = -9223372036843241473'
+tmp/demo fetch-logic-iteration tmp/my.db tmp/my.lfst | tee -a tmp/reqs
+tmp/demo MsgLeiosBlockTxsOffer tmp/my.lfst Alice -9223372036848484353 -9223372036843241473
+tmp/demo fetch-logic-iteration tmp/my.db tmp/my.lfst | tee -a tmp/reqs
+tmp/demo fetch-logic-iteration tmp/my.db tmp/my.lfst | tee -a tmp/reqs
+tmp/demo MsgLeiosBlockTxsOffer tmp/my.lfst Bob -9223372036848484353 -9223372036843241473
+tmp/demo fetch-logic-iteration tmp/my.db tmp/my.lfst | tee -a tmp/reqs
+tmp/demo fetch-logic-iteration tmp/my.db tmp/my.lfst | tee -a tmp/reqs
+sqlite3 tmp/my.db 'UPDATE ebTxs SET txBytes = NULL WHERE ebId = -9223372036848484353'
+tmp/demo fetch-logic-iteration tmp/my.db tmp/my.lfst | tee -a tmp/reqs
+tmp/demo fetch-logic-iteration tmp/my.db tmp/my.lfst | tee -a tmp/reqs
+jq . tmp/my.lfst
+sqlite3 tmp/my.db 'SELECT ebId FROM ebTxs WHERE txBytes IS NULL GROUP BY ebId' # dump incompletes
+set +x
+cat tmp/reqs | grep -e MSG | grep -e Alice | cut -d' ' -f3- | while IFS= read -r line; do
+    set -x
+    tmp/demo MsgLeiosBlockTxsRequest tmp/up.db $line | xxd -plain -revert >tmp/foo.bin
+    tmp/demo MsgLeiosBlockTxs tmp/my.db tmp/my.lfst Alice tmp/foo.bin
+    set +x
+    jq . tmp/my.lfst
+    sqlite3 tmp/my.db 'SELECT ebId FROM ebTxs WHERE txBytes IS NULL GROUP BY ebId' # dump incompletes
+done
+cat tmp/reqs | grep -e MSG | grep -e Bob | cut -d' ' -f3- | while IFS= read -r line; do
+    set -x
+    tmp/demo MsgLeiosBlockTxsRequest tmp/up.db $line | xxd -plain -revert >tmp/foo.bin
+    tmp/demo MsgLeiosBlockTxs tmp/my.db tmp/my.lfst Bob tmp/foo.bin
+    jq . tmp/my.lfst
+    sqlite3 tmp/my.db 'SELECT ebId FROM ebTxs WHERE txBytes IS NULL GROUP BY ebId' # dump incompletes
+    set +x
+done

ouroboros-consensus-diffusion/src/ouroboros-consensus-diffusion/Ouroboros/Consensus/Network/NodeToNode.hs

@@ -124,6 +124,8 @@ import           Ouroboros.Network.TxSubmission.Mempool.Reader
 import           Ouroboros.Network.TxSubmission.Outbound
 
 
+import qualified Ouroboros.Network.Mux as ON
+
 {-------------------------------------------------------------------------------
   Handlers
 -------------------------------------------------------------------------------}
@@ -838,6 +840,28 @@ initiator miniProtocolParameters version versionData Apps {..} =
         })
       version
       versionData
+ <>
+    mempty { ON.withHot = ON.WithHot [
+              ON.MiniProtocol {
+                ON.miniProtocolNum    = leiosNotifyMiniProtocolNum,
+                ON.miniProtocolStart  = ON.StartOnDemand,
+                ON.miniProtocolLimits = ON.MiniProtocolLimits {
+                    ON.maximumIngressQueue = addSafetyMargin $ 1 * 2 ^ (20 :: Int)   -- 1 mebibyte
+                    },
+                ON.miniProtocolRun    = InitiatorProtocolOnly (MiniProtocolCb undefined)
+              }
+            , ON.MiniProtocol {
+                ON.miniProtocolNum    = leiosFetchMiniProtocolNum,
+                ON.miniProtocolStart  = ON.StartOnDemand,
+                ON.miniProtocolLimits = ON.MiniProtocolLimits {
+                    ON.maximumIngressQueue = addSafetyMargin $ 50 * 2 ^ (20 :: Int)   -- 50 mebibytes
+                    },
+                ON.miniProtocolRun    = InitiatorProtocolOnly (MiniProtocolCb undefined)
+              }
+            ]
+           }
+  where
+    addSafetyMargin x = x + x `div` 10
 
 -- | A bi-directional network application.
 --
@@ -878,3 +902,32 @@ initiatorAndResponder miniProtocolParameters version versionData Apps {..} =
         })
       version
       versionData
+ <>
+    mempty { ON.withHot = ON.WithHot [
+              ON.MiniProtocol {
+                ON.miniProtocolNum    = leiosNotifyMiniProtocolNum,
+                ON.miniProtocolStart  = ON.StartOnDemand,
+                ON.miniProtocolLimits = ON.MiniProtocolLimits {
+                    ON.maximumIngressQueue = addSafetyMargin $ 1 * 2 ^ (20 :: Int)   -- 1 mebibyte
+                    },
+                ON.miniProtocolRun    = InitiatorAndResponderProtocol (MiniProtocolCb undefined) (MiniProtocolCb undefined)
+              }
+            , ON.MiniProtocol {
+                ON.miniProtocolNum    = leiosFetchMiniProtocolNum,
+                ON.miniProtocolStart  = ON.StartOnDemand,
+                ON.miniProtocolLimits = ON.MiniProtocolLimits {
+                    ON.maximumIngressQueue = addSafetyMargin $ 50 * 2 ^ (20 :: Int)   -- 50 mebibytes
+                    },
+                ON.miniProtocolRun    = InitiatorAndResponderProtocol (MiniProtocolCb undefined) (MiniProtocolCb undefined)
+              }
+            ]
+           }
+  where
+    addSafetyMargin x = x + x `div` 10
+
+
+leiosNotifyMiniProtocolNum :: MiniProtocolNum
+leiosNotifyMiniProtocolNum = MiniProtocolNum 18
+
+leiosFetchMiniProtocolNum :: MiniProtocolNum
+leiosFetchMiniProtocolNum = MiniProtocolNum 19