Remove mandatory networkId from follow function

Author: noonio

hydra-chain-observer/src/Hydra/Blockfrost/ChainObserver.hs

@@ -69,7 +69,7 @@ blockfrostClient ::
   NodeClient IO
 blockfrostClient tracer projectPath blockConfirmations = do
   NodeClient
-    { follow = \_ startChainFrom observerHandler -> do
+    { follow = \startChainFrom observerHandler -> do
         prj <- Blockfrost.projectFromFile projectPath
 
         Blockfrost.Block{_blockHash = (Blockfrost.BlockHash genesisBlockHash)} <-

hydra-chain-observer/src/Hydra/ChainObserver.hs

@@ -19,11 +19,10 @@ main observerHandler = do
     traceWith tracer KnownScripts{scriptInfo = Contract.scriptInfo}
     case opts of
       DirectOpts DirectOptions{networkId, nodeSocket, startChainFrom} -> do
-        let NodeClient{follow} = ouroborusClient tracer nodeSocket
-        follow networkId startChainFrom observerHandler
+        let NodeClient{follow} = ouroborusClient tracer nodeSocket networkId
+        follow startChainFrom observerHandler
       BlockfrostOpts BlockfrostOptions{projectPath, startChainFrom} -> do
         -- FIXME: should be configurable
         let blockConfirmations = 1
             NodeClient{follow} = blockfrostClient tracer projectPath blockConfirmations
-        -- FIXME
-        follow (error "not-used") startChainFrom observerHandler
+        follow startChainFrom observerHandler

hydra-chain-observer/src/Hydra/ChainObserver/NodeClient.hs

@@ -43,7 +43,7 @@ defaultObserverHandler :: Applicative m => ObserverHandler m
 defaultObserverHandler = const $ pure ()
 
 newtype NodeClient m = NodeClient
-  { follow :: NetworkId -> Maybe ChainPoint -> ObserverHandler m -> m ()
+  { follow :: Maybe ChainPoint -> ObserverHandler m -> m ()
   }
 
 type ChainObserverLog :: Type

hydra-chain-observer/src/Hydra/Ouroborus/ChainObserver.hs

@@ -46,10 +46,11 @@ import Ouroboros.Network.Protocol.ChainSync.Client (
 ouroborusClient ::
   Tracer IO ChainObserverLog ->
   SocketPath ->
+  NetworkId ->
   NodeClient IO
-ouroborusClient tracer nodeSocket =
+ouroborusClient tracer nodeSocket networkId =
   NodeClient
-    { follow = \networkId startChainFrom observerHandler -> do
+    { follow = \startChainFrom observerHandler -> do
         traceWith tracer ConnectingToNode{nodeSocket, networkId}
         chainPoint <- case startChainFrom of
           Nothing -> queryTip networkId nodeSocket