eventsource-geteventstore-store 1.0.1 → 1.0.2
raw patch · 5 files changed
+22/−12 lines, 5 filesdep ~eventstorePVP ok
version bump matches the API change (PVP)
Dependency ranges changed: eventstore
API changes (from Hackage documentation)
Files
- CHANGELOG.md +4/−0
- eventsource-geteventstore-store.cabal +3/−3
- library/EventSource/Store/GetEventStore.hs +10/−6
- package.yaml +2/−2
- stack.yaml +3/−1
CHANGELOG.md view
@@ -1,4 +1,8 @@ 1.0.1 =====+* Fix GHC 8.2.1 and Stackage LTS-9 build.++1.0.1+===== * Support `linkEvent` in `SavedEvent`.
eventsource-geteventstore-store.cabal view
@@ -1,9 +1,9 @@--- This file has been generated from package.yaml by hpack version 0.15.0.+-- This file has been generated from package.yaml by hpack version 0.17.1. -- -- see: https://github.com/sol/hpack name: eventsource-geteventstore-store-version: 1.0.1+version: 1.0.2 synopsis: GetEventStore store implementation. description: GetEventStore store implementation. category: Eventsourcing@@ -35,7 +35,7 @@ build-depends: base >=4.9 && <5 , protolude >=0.1.10 && <0.2- , eventstore ==0.14.*+ , eventstore >=0.14 && <0.16 , eventsource-api >= 1.1 , aeson , mtl
library/EventSource/Store/GetEventStore.hs view
@@ -123,19 +123,23 @@ defaultBatchSize = 500 --------------------------------------------------------------------------------+toGESStreamName :: StreamName -> GES.StreamName+toGESStreamName (StreamName name) = GES.StreamName name++-------------------------------------------------------------------------------- instance Store GetEventStore where- appendEvents (GetEventStore conn) (StreamName name) ver xs = liftIO $ do+ appendEvents (GetEventStore conn) name ver xs = liftIO $ do events <- traverse makeEvent xs- w <- GES.sendEvents conn name (toGesExpVer ver) events+ w <- GES.sendEvents conn (toGESStreamName name) (toGesExpVer ver) events return $ fmap (EventNumber . GES.writeNextExpectedVersion) w - readBatch (GetEventStore conn) (StreamName name) b = liftIO $ do+ readBatch (GetEventStore conn) name b = liftIO $ do let EventNumber n = batchFrom b- w <- GES.readStreamEventsForward conn name n (batchSize b) True+ w <- GES.readStreamEventsForward conn (toGESStreamName name) n (batchSize b) True return $ fmap (fmap fromGesSlice . fromGesReadResult) w - subscribe (GetEventStore conn) (StreamName name) = liftIO $ do- sub <- GES.subscribe conn name True+ subscribe (GetEventStore conn) name = liftIO $ do+ sub <- GES.subscribe conn (toGESStreamName name) True sid <- freshSubscriptionId return $ Subscription sid $ liftIO $
package.yaml view
@@ -17,7 +17,7 @@ dependencies: - base >=4.9 && <5 - protolude >=0.1.10 && <0.2- - eventstore ==0.14.*+ - eventstore >=0.14 && <0.16 - eventsource-api >= 1.1 - aeson - mtl@@ -45,4 +45,4 @@ - -with-rtsopts=-N main: Main.hs source-dirs: test-suite-version: '1.0.1'+version: '1.0.2'
stack.yaml view
@@ -15,7 +15,7 @@ # resolver: # name: custom-snapshot # location: "./custom-snapshot.yaml"-resolver: lts-7.14+resolver: lts-9.0 # User packages to be built. # Various formats can be used as shown in the example below.@@ -37,6 +37,8 @@ # will not be run. This is useful for tweaking upstream packages. packages: - '.'+- '../api'+ # Dependency packages to be pulled from upstream that are not in the resolver # (e.g., acme-missiles-0.3) extra-deps: []