@@ -51,8 +51,8 @@ import Data.Maybe (fromJust)
5151import Data.Void (Void )
5252import qualified Network.Mux as Mux
5353import Network.TypedProtocol.Peer (Peer (.. ))
54- import Network.TypedProtocol.Stateful.Codec ()
55- import qualified Network.TypedProtocol.Stateful.Peer as St
54+ -- import Network.TypedProtocol.Stateful.Codec ()
55+ -- import qualified Network.TypedProtocol.Stateful.Peer as St
5656import Ouroboros.Consensus.Block (CodecConfig , HasHeader , Point , StandardHash , castPoint )
5757import Ouroboros.Consensus.Config (TopLevelConfig , configCodec )
5858import Ouroboros.Consensus.Ledger.Query (BlockQuery , BlockSupportsLedgerQuery , QueryFootprint (.. ), ShowQuery )
@@ -92,8 +92,7 @@ import Ouroboros.Network.IOManager (IOManager)
9292import qualified Ouroboros.Network.IOManager as IOManager
9393import Ouroboros.Network.Magic (NetworkMagic )
9494import Ouroboros.Network.Mux (OuroborosApplicationWithMinimalCtx )
95- import Ouroboros.Network.NodeToClient (NodeToClientVersionData (.. ))
96- import qualified Ouroboros.Network.NodeToClient as NodeToClient
95+ import Ouroboros.Network.NodeToClient
9796import Ouroboros.Network.NodeToNode (Versions )
9897import Ouroboros.Network.Protocol.ChainSync.Server (
9998 ChainSyncServer (.. ),
@@ -107,6 +106,7 @@ import qualified Ouroboros.Network.Protocol.LocalStateQuery.Type as LocalStateQu
107106import Ouroboros.Network.Snocket (LocalAddress , LocalSnocket , LocalSocket (.. ))
108107import qualified Ouroboros.Network.Snocket as Snocket
109108import Ouroboros.Network.Util.ShowProxy (Proxy (.. ), ShowProxy (.. ))
109+ import Ouroboros.Network.Socket
110110
111111{- HLINT ignore "Use readTVarIO" -}
112112
@@ -213,16 +213,16 @@ runLocalServer ::
213213 StrictTVar IO (ChainProducerState blk ) ->
214214 IO ()
215215runLocalServer iom codecConfig netMagic localDomainSock chainProdState =
216+ withSnocket nullTracer noAttenuation Map. empty $ \ localSocket localSnocket -> do
217+
216218 withSnocket iom localDomainSock $ \ localSocket localSnocket -> do
217- networkState <- NodeToClient. newNetworkMutableState
218219 _ <-
219- NodeToClient. withServer
220+ runServer
220221 localSnocket
221- NodeToClient. nullNetworkServerTracers -- debuggingNetworkServerTracers
222- networkState
222+ nullNetworkConnectTracers -- debuggingNetworkServerTracers
223223 localSocket
224224 (versions chainProdState)
225- NodeToClient. networkErrorPolicies
225+ networkErrorPolicies
226226 pure ()
227227 where
228228 versions ::
@@ -263,8 +263,7 @@ runLocalServer iom codecConfig netMagic localDomainSock chainProdState =
263263 nullTracer -- TODO add a tracer!
264264 (cChainSyncCodec codecs)
265265 channel
266- $ chainSyncServerPeer
267- $ chainSyncServer state codecConfig blockVersion
266+ (chainSyncServerPeer $ chainSyncServer state codecConfig blockVersion)
268267
269268 txSubmitServer ::
270269 localPeer ->
@@ -282,12 +281,11 @@ runLocalServer iom codecConfig netMagic localDomainSock chainProdState =
282281 Channel IO ByteString ->
283282 IO (() , Maybe ByteString )
284283 stateQueryServer _them channel =
285- St. runPeer
284+ runPeer
286285 nullTracer
287286 (cStateQueryCodec codecs)
288287 channel
289- LocalStateQuery. StateIdle
290- (St. Effect (forever $ threadDelay 3_600_000_000 ))
288+ (LocalStateQuery. StateIdle (Effect (forever $ threadDelay 3_600_000_000 )))
291289
292290 txMonitorServer ::
293291 localPeer ->
0 commit comments