diffusion: run diffusion in an abstract monad

Also introduce `DiffusionInterfaces` record which provides all the interfaces (e.g. snockets, dns resolver, etc) needed to run data diffusion.
IntersectMBO · Jul 20, 2021 · 2854cdb · 2854cdb
1 parent 98a5b32
commit 2854cdb
Show file tree

Hide file tree

Showing 3 changed files with 375 additions and 264 deletions.
diff --git a/ouroboros-network/src/Ouroboros/Network/Diffusion.hs b/ouroboros-network/src/Ouroboros/Network/Diffusion.hs
@@ -121,7 +121,7 @@ newtype DiffusionTracers =
                 (P2P.DiffusionTracersExtra
                        RemoteAddress NodeToNodeVersion   NodeToNodeVersionData
                        LocalAddress  NodeToClientVersion NodeToClientVersionData
-                       IO))
+                       IOException IO))
         RemoteAddress NodeToNodeVersion
         LocalAddress  NodeToClientVersion
         IO)
@@ -334,12 +334,12 @@ mkDiffusionTracersP2P
   -> Tracer
        IO
        (DebugPeerSelection
-          SockAddr (P2P.NodeToNodePeerConnectionHandle 'InitiatorMode SockAddr Void))
+          SockAddr (P2P.NodeToNodePeerConnectionHandle 'InitiatorMode SockAddr IO Void))
   -> Tracer
        IO
        (DebugPeerSelection
           SockAddr
-          (P2P.NodeToNodePeerConnectionHandle 'InitiatorResponderMode SockAddr ()))
+          (P2P.NodeToNodePeerConnectionHandle 'InitiatorResponderMode SockAddr IO ()))
   -> Tracer IO PeerSelectionCounters
   -> Tracer IO (PeerSelectionActionsTrace SockAddr)
   -> Tracer