eventstore 1.3.1 → 1.3.2

raw patch · 3 files changed

+26/−9 lines, 3 filesPVP ok

version bump matches the API change (PVP)

API changes (from Hackage documentation)

Files

• CHANGELOG.markdown +8/−1
• Database/EventStore/Internal/ConnectionManager.hs +16/−6
• eventstore.cabal +2/−2

@@ -1,4 +1,11 @@-1.4.0+1.3.2+-----+* Bug fix: Driver could end in a situation where it receives a close-connection message during+  Authentication/Identification phase. Close-connection message was wrongly ignored letting pending+  operations unanwsered at call-site. If the user forced the result of an operation, it could have lead the+  current thread to block indefinately. The client state-machine switched to a wrong state.++1.3.1 ----- * Better encoding of streaming interface ReadError. * Expose more internal functions of the streaming interface.

@@ -577,9 +577,14 @@ isSameConnection :: Internal -> Connection -> EventStore Bool isSameConnection Internal{..} conn = go <$> readIORef _stage   where-    go (Connected known)                             = known == conn-    go (Connecting _ (ConnectionEstablishing known)) = known == conn-    go _                                             = False+    go (Connected known) = known == conn+    go (Connecting _ state) =+      case state of+        ConnectionEstablishing known -> known == conn+        Authentication _ _ known -> known == conn+        Identification _ _ known -> known == conn+        _ -> False+    go _ = False  -------------------------------------------------------------------------------- onConnectionError :: Internal -> ConnectionError -> EventStore ()@@ -624,9 +629,14 @@ lookingUpConnection :: IORef Stage -> EventStore (Maybe Connection) lookingUpConnection ref = go <$> readIORef ref   where-    go (Connected conn)                             = Just conn-    go (Connecting _ (ConnectionEstablishing conn)) = Just conn-    go _                                            = Nothing+    go (Connected conn) = Just conn+    go (Connecting _ state) =+      case state of+        ConnectionEstablishing conn -> Just conn+        Authentication _ _ conn -> Just conn+        Identification _ _ conn -> Just conn+        _ -> Nothing+    go _ = Nothing  -------------------------------------------------------------------------------- lookingUpConnectionWhenConnected :: IORef Stage -> EventStore (Maybe Connection)

@@ -4,10 +4,10 @@ -- -- see: https://github.com/sol/hpack ----- hash: 1183167359a5b717d35d6bbd4ca75dcce93e5223d77d575319cd5fe83124a473+-- hash: 171ce48c5ca32c8763beafe10906ae6d4b555cfc1b24872d3f56cef12b1d761d  name:           eventstore-version:        1.3.1+version:        1.3.2 synopsis:       EventStore TCP Client description:    EventStore TCP Client <https://eventstore.org> category:       Database