eventium-postgresql-0.7.0: src/Eventium/ProjectionCache/Postgresql.hs

module Eventium.ProjectionCache.Postgresql
  ( postgresqlVersionedProjectionCache,
    postgresqlGlobalProjectionCache,
    postgresqlCheckpointStore,
    CheckpointName (..),
    migrateProjectionSnapshot,
  )
where

import Control.Monad.IO.Class (MonadIO)
import Database.Persist.Sql (SqlPersistT)
import Eventium.EventSubscription (CheckpointStore)
import Eventium.ProjectionCache.Sql (CheckpointName (..), ProjectionName, migrateProjectionSnapshot, sqlCheckpointStore, sqlGlobalProjectionCache, sqlVersionedProjectionCache)
import Eventium.ProjectionCache.Types (ProjectionCache)
import Eventium.Store.Class (EventVersion, SequenceNumber)
import Eventium.Store.Sql.JSONString (JSONString)
import Eventium.UUID (UUID)

-- | PostgreSQL-backed 'ProjectionCache' for per-entity snapshots.
-- Alias for 'sqlVersionedProjectionCache'.
postgresqlVersionedProjectionCache ::
  (MonadIO m) =>
  ProjectionName ->
  ProjectionCache UUID EventVersion (SqlPersistT m) JSONString
postgresqlVersionedProjectionCache = sqlVersionedProjectionCache

-- | PostgreSQL-backed 'ProjectionCache' for global blob snapshots.
-- Alias for 'sqlGlobalProjectionCache'.
postgresqlGlobalProjectionCache ::
  (MonadIO m) =>
  ProjectionName ->
  ProjectionCache () SequenceNumber (SqlPersistT m) JSONString
postgresqlGlobalProjectionCache = sqlGlobalProjectionCache

-- | PostgreSQL-backed 'CheckpointStore' for tracking subscription position.
-- Alias for 'sqlCheckpointStore'.
postgresqlCheckpointStore ::
  (MonadIO m) =>
  CheckpointName ->
  CheckpointStore (SqlPersistT m) SequenceNumber
postgresqlCheckpointStore = sqlCheckpointStore