refactor: use the Event.Sorcery module namespace

bindings/haskell/benchmark/Main.hs

@@ -17,14 +17,14 @@ import Data.Maybe (Maybe (..))
 import Data.Text qualified as Text
 import Data.Unrestricted.Linear (Ur)
 import Data.Word (Word64)
-import EventSorcery.Engine (
+import Event.Sorcery.Engine (
   EngineError,
   OpenOptions (OpenOptions),
   Store,
   closeStore,
   openStore,
  )
-import EventSorcery.Job (
+import Event.Sorcery.Job (
   ClaimBudget (ClaimBudget),
   ClaimedJob,
   JobClaimDetails,
@@ -43,7 +43,7 @@ import EventSorcery.Job (
   mkJobId,
   settlementToken,
  )
-import EventSorcery.Stream (
+import Event.Sorcery.Stream (
   AggregateId (AggregateId),
   AggregateType (AggregateType),
   EventType (EventType),

bindings/haskell/event-sorcery.cabal

@@ -47,33 +47,33 @@ common strict
 library acquisition
   import:          strict
   hs-source-dirs:  src
-  exposed-modules: EventSorcery.Engine.Acquisition
+  exposed-modules: Event.Sorcery.Engine.Acquisition
   build-depends:   base >=4.18 && <5
 
 library
   import:          strict
   hs-source-dirs:  src
   exposed-modules:
-    EventSorcery.Aggregate
-    EventSorcery.Dispatch
-    EventSorcery.Dispatch.TestSupport
-    EventSorcery.Dispatch.Worker
-    EventSorcery.Engine
-    EventSorcery.Engine.Internal.FFI
-    EventSorcery.Job
-    EventSorcery.Job.Execution
-    EventSorcery.Job.Worker
-    EventSorcery.Snapshot
-    EventSorcery.Store
-    EventSorcery.Stream
+    Event.Sorcery.Aggregate
+    Event.Sorcery.Dispatch
+    Event.Sorcery.Dispatch.TestSupport
+    Event.Sorcery.Dispatch.Worker
+    Event.Sorcery.Engine
+    Event.Sorcery.Engine.Internal.FFI
+    Event.Sorcery.Job
+    Event.Sorcery.Job.Execution
+    Event.Sorcery.Job.Worker
+    Event.Sorcery.Snapshot
+    Event.Sorcery.Store
+    Event.Sorcery.Stream
 
   other-modules:
-    EventSorcery.Dispatch.Internal
-    EventSorcery.Engine.Acquisition
-    EventSorcery.Engine.Internal
-    EventSorcery.Job.Definition
-    EventSorcery.Job.Worker.Definition
-    EventSorcery.Job.Worker.Internal
+    Event.Sorcery.Dispatch.Internal
+    Event.Sorcery.Engine.Acquisition
+    Event.Sorcery.Engine.Internal
+    Event.Sorcery.Job.Definition
+    Event.Sorcery.Job.Worker.Definition
+    Event.Sorcery.Job.Worker.Internal
 
   extra-libraries: event_sorcery_ffi
   build-depends:
@@ -106,7 +106,7 @@ test-suite engine-spec
   type:           exitcode-stdio-1.0
   hs-source-dirs: test
   main-is:        EngineSpec.hs
-  other-modules:  EventSorcery.Engine.AcquisitionSpec
+  other-modules:  Event.Sorcery.Engine.AcquisitionSpec
   ghc-options:    -threaded -with-rtsopts=-N
   build-depends:
     , base                       >=4.18 && <5

bindings/haskell/src/EventSorcery/Aggregate.hs → bindings/haskell/src/Event/Sorcery/Aggregate.hs

@@ -1,6 +1,6 @@
 {-# LANGUAGE FunctionalDependencies #-}
 
-module EventSorcery.Aggregate (
+module Event.Sorcery.Aggregate (
   DecodeCause (..),
   DispatchIntent,
   Dispatches (..),
@@ -21,8 +21,8 @@ import Data.Proxy (Proxy)
 import Data.Text (Text)
 import Data.Type.Equality (type (~))
 import Data.Word (Word16)
-import EventSorcery.Dispatch (DispatchOutcome, JobDispatch)
-import EventSorcery.Job.Definition (
+import Event.Sorcery.Dispatch (DispatchOutcome, JobDispatch)
+import Event.Sorcery.Job.Definition (
   Job (..),
   JobId,
  )

bindings/haskell/src/EventSorcery/Dispatch.hs → bindings/haskell/src/Event/Sorcery/Dispatch.hs

@@ -1,4 +1,4 @@
-module EventSorcery.Dispatch (
+module Event.Sorcery.Dispatch (
   DispatchEvent (..),
   DispatchFailure (..),
   DispatchOutcome,
@@ -23,7 +23,7 @@ module EventSorcery.Dispatch (
 ) where
 
 import Data.Word (Word32)
-import EventSorcery.Dispatch.Internal (
+import Event.Sorcery.Dispatch.Internal (
   DispatchEvent (..),
   DispatchFailure (..),
   DispatchOutcome,
@@ -39,7 +39,7 @@ import EventSorcery.Dispatch.Internal (
   originateDispatch,
   settleDispatch,
  )
-import EventSorcery.Job.Definition (JobId)
+import Event.Sorcery.Job.Definition (JobId)
 
 
 dispatchJob :: JobDispatch job -> job

bindings/haskell/src/EventSorcery/Dispatch/Internal.hs → bindings/haskell/src/Event/Sorcery/Dispatch/Internal.hs

@@ -1,4 +1,4 @@
-module EventSorcery.Dispatch.Internal (
+module Event.Sorcery.Dispatch.Internal (
   DispatchEvent (..),
   DispatchFailure (..),
   DispatchOutcome (..),
@@ -19,7 +19,7 @@ module EventSorcery.Dispatch.Internal (
 
 import Data.Text (Text)
 import Data.Word (Word32)
-import EventSorcery.Job.Definition (
+import Event.Sorcery.Job.Definition (
   DeadReason,
   Job (JobError, JobOutput),
   JobId,

bindings/haskell/src/EventSorcery/Dispatch/TestSupport.hs → bindings/haskell/src/Event/Sorcery/Dispatch/TestSupport.hs

@@ -1,15 +1,15 @@
-module EventSorcery.Dispatch.TestSupport (
+module Event.Sorcery.Dispatch.TestSupport (
   confirmedOutcome,
   failedOutcome,
 ) where
 
 import Data.Word (Word32)
-import EventSorcery.Dispatch.Internal (
+import Event.Sorcery.Dispatch.Internal (
   DispatchFailure,
   DispatchOutcome,
  )
-import EventSorcery.Dispatch.Internal qualified as Internal
-import EventSorcery.Job.Definition (
+import Event.Sorcery.Dispatch.Internal qualified as Internal
+import Event.Sorcery.Job.Definition (
   Job (JobError, JobOutput),
   JobId,
  )

bindings/haskell/src/EventSorcery/Dispatch/Worker.hs → bindings/haskell/src/Event/Sorcery/Dispatch/Worker.hs

@@ -1,4 +1,4 @@
-module EventSorcery.Dispatch.Worker (
+module Event.Sorcery.Dispatch.Worker (
   DeliveryPolicy,
   DispatchWorker,
   OriginDeliveryError (..),
@@ -12,38 +12,38 @@ module EventSorcery.Dispatch.Worker (
 ) where
 
 import Data.Word (Word32)
-import EventSorcery.Aggregate (
+import Event.Sorcery.Aggregate (
   Dispatches (injectDispatchOutcome),
   EventSourced,
  )
-import EventSorcery.Dispatch (DispatchFailure (..), DispatchOutcome)
-import EventSorcery.Dispatch.Internal qualified as Dispatch
-import EventSorcery.Job (
+import Event.Sorcery.Dispatch (DispatchFailure (..), DispatchOutcome)
+import Event.Sorcery.Dispatch.Internal qualified as Dispatch
+import Event.Sorcery.Job (
   DeadReason (RetriesExhausted),
   Job (JobError, JobOutput),
   JobId,
   JobInstant,
  )
-import EventSorcery.Job.Execution (
+import Event.Sorcery.Job.Execution (
   DurableJob (renderJobError),
   JobAttempt (JobAttempt),
  )
-import EventSorcery.Job.Worker (
+import Event.Sorcery.Job.Worker (
   JobRunError,
   JobRunResult,
   JobWorker,
  )
-import EventSorcery.Job.Worker.Internal (
+import Event.Sorcery.Job.Worker.Internal (
   SettlementStrategy (..),
   VerdictDelivery (..),
   runJobOnceWith,
  )
-import EventSorcery.Store (
+import Event.Sorcery.Store (
   Store,
   StoreError (..),
   executeCommand,
  )
-import EventSorcery.Stream (StreamKey)
+import Event.Sorcery.Stream (StreamKey)
 import Prelude (Either (..), IO, pure)
 
 

bindings/haskell/src/EventSorcery/Engine.hs → bindings/haskell/src/Event/Sorcery/Engine.hs

@@ -1,9 +1,9 @@
 -- | The engine feature: opening a store, closing it, and the ABI it speaks.
 --
 -- The lifecycle plumbing and the call marshalling stay in
--- "EventSorcery.Engine.Internal"; this module is the consumer-facing half of
+-- "Event.Sorcery.Engine.Internal"; this module is the consumer-facing half of
 -- the feature, including the error vocabulary every engine call answers with.
-module EventSorcery.Engine (
+module Event.Sorcery.Engine (
   AbiVersionDetail (..),
   AggregateId (..),
   AggregateType (..),
@@ -29,7 +29,7 @@ module EventSorcery.Engine (
   supportedAbiMajor,
 ) where
 
-import EventSorcery.Engine.Internal (
+import Event.Sorcery.Engine.Internal (
   AbiVersionDetail (..),
   AggregateId (..),
   AggregateType (..),

bindings/haskell/src/EventSorcery/Engine/Acquisition.hs → bindings/haskell/src/Event/Sorcery/Engine/Acquisition.hs

@@ -1,4 +1,4 @@
-module EventSorcery.Engine.Acquisition (
+module Event.Sorcery.Engine.Acquisition (
   StoreAcquisition (..),
   acquireStore,
 ) where

bindings/haskell/src/EventSorcery/Engine/Internal.hs → bindings/haskell/src/Event/Sorcery/Engine/Internal.hs

@@ -1,10 +1,10 @@
 -- | The engine feature: the store handle, its lifecycle, and the ABI it speaks.
 --
--- "EventSorcery.Engine" re-exports the consumer-facing half of this module.
+-- "Event.Sorcery.Engine" re-exports the consumer-facing half of this module.
 -- The call marshalling and the errors every call can answer with stay here so
 -- the stream and job features can issue engine calls without republishing the
 -- ABI plumbing to consumers.
-module EventSorcery.Engine.Internal (
+module Event.Sorcery.Engine.Internal (
   AbiVersionDetail (..),
   AggregateId (..),
   AggregateType (..),
@@ -67,19 +67,19 @@ import Data.ByteString.Unsafe (unsafeUseAsCStringLen)
 import Data.Text (Text)
 import Data.Text qualified as Text
 import Data.Word (Word32, Word64, Word8)
-import EventSorcery.Engine.Acquisition (
+import Event.Sorcery.Engine.Acquisition (
   StoreAcquisition (..),
   acquireStore,
  )
-import EventSorcery.Engine.Internal.FFI (
+import Event.Sorcery.Engine.Internal.FFI (
   EsBuf (..),
   EsStore,
   esAbiVersion,
   esBufFree,
   esClose,
   esOpen,
  )
-import EventSorcery.Job.Definition (JobId (..))
+import Event.Sorcery.Job.Definition (JobId (..))
 import Foreign.C.Types (CInt, CSize)
 import Foreign.Concurrent qualified as Foreign
 import Foreign.ForeignPtr (ForeignPtr, withForeignPtr)

bindings/haskell/src/EventSorcery/Engine/Internal/FFI.hs → bindings/haskell/src/Event/Sorcery/Engine/Internal/FFI.hs

@@ -1,4 +1,4 @@
-module EventSorcery.Engine.Internal.FFI (
+module Event.Sorcery.Engine.Internal.FFI (
   EsBuf (..),
   EsStore,
   esAbiVersion,

bindings/haskell/src/EventSorcery/Job.hs → bindings/haskell/src/Event/Sorcery/Job.hs

@@ -4,13 +4,13 @@
 -- Everything a consumer needs to enqueue a job, take a claim on it and settle
 -- that claim is here, down to the wire codecs the engine and this binding
 -- agree on. The engine handle and the errors every call can answer with belong
--- to "EventSorcery.Engine" and are re-exported so a job worker needs this one
+-- to "Event.Sorcery.Engine" and are re-exported so a job worker needs this one
 -- import.
 --
 -- Committing events together with a job intent belongs to this feature rather
 -- than to the stream: what the caller is buying is that the events and the
 -- intent land in one transaction, and the intent is the half a job can refuse.
-module EventSorcery.Job (
+module Event.Sorcery.Job (
   AbiVersionDetail (..),
   AggregateId (..),
   AggregateType (..),
@@ -101,7 +101,7 @@ import Data.List.NonEmpty qualified as NonEmpty
 import Data.Text (Text)
 import Data.Unrestricted.Linear (Ur (Ur))
 import Data.Word (Word32, Word64, Word8)
-import EventSorcery.Engine.Internal (
+import Event.Sorcery.Engine.Internal (
   AbiVersionDetail (..),
   AggregateId (..),
   AggregateType (..),
@@ -123,7 +123,7 @@ import EventSorcery.Engine.Internal (
   withInputBuffer,
   withOpenStore,
  )
-import EventSorcery.Engine.Internal.FFI (
+import Event.Sorcery.Engine.Internal.FFI (
   EsBuf,
   EsStore,
   esCommitWithJob,
@@ -136,15 +136,15 @@ import EventSorcery.Engine.Internal.FFI (
   esJobRenew,
   esJobRetry,
  )
-import EventSorcery.Job.Definition (
+import Event.Sorcery.Job.Definition (
   DeadReason (..),
   Job (..),
   JobDecodeError (..),
   jobIdText,
   jobType,
   mkJobId,
  )
-import EventSorcery.Stream (
+import Event.Sorcery.Stream (
   ProposedEvent,
   StreamIdentity,
   encodeProposedEvent,

bindings/haskell/src/EventSorcery/Job/Definition.hs → bindings/haskell/src/Event/Sorcery/Job/Definition.hs

@@ -1,6 +1,6 @@
 {-# LANGUAGE AllowAmbiguousTypes #-}
 
-module EventSorcery.Job.Definition (
+module Event.Sorcery.Job.Definition (
   DeadReason (..),
   Job (..),
   JobDecodeError (..),

bindings/haskell/src/EventSorcery/Job/Execution.hs → bindings/haskell/src/Event/Sorcery/Job/Execution.hs

@@ -1,4 +1,4 @@
-module EventSorcery.Job.Execution (
+module Event.Sorcery.Job.Execution (
   DurableJob (..),
   JobAttempt (..),
   JobContext (..),
@@ -11,7 +11,7 @@ module EventSorcery.Job.Execution (
 import Data.Kind (Type)
 import Data.Text (Text)
 import Data.Word (Word32)
-import EventSorcery.Job (
+import Event.Sorcery.Job (
   Job (JobError, JobOutput),
   JobExecutionRoute (ReconcileExecution, SubmitExecution),
   JobId,

bindings/haskell/src/EventSorcery/Job/Worker.hs → bindings/haskell/src/Event/Sorcery/Job/Worker.hs

@@ -1,4 +1,4 @@
-module EventSorcery.Job.Worker (
+module Event.Sorcery.Job.Worker (
   AttemptLimit,
   JobRunError (..),
   JobRunResult (..),
@@ -11,9 +11,9 @@ module EventSorcery.Job.Worker (
   runJobOnce,
 ) where
 
-import EventSorcery.Job (Job (JobError, JobOutput), JobId, JobInstant)
-import EventSorcery.Job.Execution (DurableJob)
-import EventSorcery.Job.Worker.Definition (
+import Event.Sorcery.Job (Job (JobError, JobOutput), JobId, JobInstant)
+import Event.Sorcery.Job.Execution (DurableJob)
+import Event.Sorcery.Job.Worker.Definition (
   AttemptLimit,
   JobRunError (..),
   JobRunResult (..),
@@ -24,7 +24,7 @@ import EventSorcery.Job.Worker.Definition (
   renewalSchedule,
   renewingJobWorker,
  )
-import EventSorcery.Job.Worker.Internal (
+import Event.Sorcery.Job.Worker.Internal (
   genericSettlement,
   runJobOnceWith,
  )