minor renaming

Author: ffakenz

hydra-node/src/Hydra/Events/Rotation.hs

@@ -17,14 +17,14 @@ type EventStore e m = (EventSource e m, EventSink e m)
 type Checkpointer e = [e] -> e
 
 -- | Creates an event store that rotates according to given config and 'Checkpointer'.
-newRotatedEventStore ::
+mkRotatedEventStore ::
   (HasEventId e, MonadSTM m, MonadUnliftIO m) =>
   RotationConfig ->
   Checkpointer e ->
   LogId ->
   EventStore e m ->
   m (EventStore e m)
-newRotatedEventStore config checkpointer logId eventStore = do
+mkRotatedEventStore config checkpointer logId eventStore = do
   logIdV <- newTVarIO logId
   -- Rules for any event store:
   -- - sourceEvents will be called in the beginning of the application and whenever the api server wans to load history
@@ -86,13 +86,13 @@ prepareRotatedEventStore ::
   m (EventStore (StateEvent tx) m)
 prepareRotatedEventStore rotationConfig initialChainState eventStore = do
   now <- getCurrentTime
-  let checkpointer = newChechpointer initialChainState now
+  let checkpointer = mkChechpointer initialChainState now
   -- FIXME!
   let logId = 0
-  newRotatedEventStore rotationConfig checkpointer logId eventStore
+  mkRotatedEventStore rotationConfig checkpointer logId eventStore
 
-newChechpointer :: IsChainState tx => ChainStateType tx -> UTCTime -> Checkpointer (StateEvent tx)
-newChechpointer initialChainState time events =
+mkChechpointer :: IsChainState tx => ChainStateType tx -> UTCTime -> Checkpointer (StateEvent tx)
+mkChechpointer initialChainState time events =
   StateEvent
     { eventId = maybe 0 (succ . last) (nonEmpty $ (\StateEvent{eventId} -> eventId) <$> events)
     , stateChanged =

hydra-node/test/Hydra/Events/RotationSpec.hs

@@ -28,11 +28,11 @@ spec = parallel $ do
         failAfter 1 $ do
           now <- getCurrentTime
           let initialChainState = SimpleChainState{slot = ChainSlot 0}
-          let checkpointer = newChechpointer initialChainState now
+          let checkpointer = mkChechpointer initialChainState now
           let logId = 0
           let rotationConfig = RotateAfter 4
           eventStore <- createMockSourceSink
-          rotatingEventStore <- newRotatedEventStore rotationConfig checkpointer logId eventStore
+          rotatingEventStore <- mkRotatedEventStore rotationConfig checkpointer logId eventStore
           testHydrate rotatingEventStore []
             >>= notConnect
             >>= primeWith inputsToOpenHead
@@ -55,7 +55,7 @@ spec = parallel $ do
           toInteger (length unrotatedHistory) `shouldBe` totalEvents
           let logId = 0
           let rotationConfig = RotateAfter x
-          (rotatedEventSource, _) <- newRotatedEventStore rotationConfig trivialCheckpoint logId eventStore
+          (rotatedEventSource, _) <- mkRotatedEventStore rotationConfig trivialCheckpoint logId eventStore
           rotatedHistory <- getEvents rotatedEventSource
           length rotatedHistory `shouldBe` 1
 
@@ -68,7 +68,7 @@ spec = parallel $ do
         let rotationConfig = RotateAfter x
         mockEventStore <- createMockSourceSink
         let logId = 0
-        rotatingEventStore <- newRotatedEventStore rotationConfig trivialCheckpoint logId mockEventStore
+        rotatingEventStore <- mkRotatedEventStore rotationConfig trivialCheckpoint logId mockEventStore
         let (eventSource, EventSink{putEvent}) = rotatingEventStore
         let totalEvents = toInteger x * y
         let events = TrivialEvent . fromInteger <$> [1 .. totalEvents]
@@ -88,7 +88,7 @@ spec = parallel $ do
           let rotationConfig = RotateAfter x
           mockEventStore <- createMockSourceSink
           let logId = 0
-          rotatingEventStore <- newRotatedEventStore rotationConfig trivialCheckpoint logId mockEventStore
+          rotatingEventStore <- mkRotatedEventStore rotationConfig trivialCheckpoint logId mockEventStore
           let (eventSource, EventSink{putEvent}) = rotatingEventStore
           let totalEvents = toInteger x + toInteger y
           let events = TrivialEvent . fromInteger <$> [1 .. totalEvents]