StreamHeadIsolation.hs

module Test.StreamHeadIsolation (spec) where

import Control.Monad (forM_)
import Data.Text qualified as T
import Data.Text.IO qualified as T
import Hasql.Statement qualified as Statement
import Kiroku.Store.SQL qualified as SQL
import Paths_kiroku_store (getDataFileName)
import Test.Hspec

spec :: Spec
spec = describe "stream head legacy isolation" $ do
  forM_ statements $ \(name, actual) ->
    it ("preserves " <> name <> " byte for byte") $ do
      path <- getDataFileName ("test/fixtures/stream-head-isolation/" <> name <> ".sql")
      expected <- T.readFile path
      actual `shouldBe` expected
  it "keeps the six metadata and eleven event result columns" $ do
    columnCount (Statement.toSql SQL.getStreamStmt) `shouldBe` 6
    columnCount (Statement.toSql SQL.readAllForwardStmt) `shouldBe` 11
  where
    columnCount = length . T.splitOn "," . fst . T.breakOn "FROM" . snd . T.breakOn "SELECT"
    statements =
      [ ("getStreamStmt", Statement.toSql SQL.getStreamStmt),
        ("readStreamForwardStmt", Statement.toSql SQL.readStreamForwardStmt),
        ("readStreamBackwardStmt", Statement.toSql SQL.readStreamBackwardStmt),
        ("readAllForwardStmt", Statement.toSql SQL.readAllForwardStmt),
        ("readAllBackwardStmt", Statement.toSql SQL.readAllBackwardStmt),
        ("readCategoryForwardStmt", Statement.toSql SQL.readCategoryForwardStmt),
        ("readCategoryForwardConsumerGroupStmt", Statement.toSql SQL.readCategoryForwardConsumerGroupStmt),
        ("appendExpectedVersion", Statement.toSql SQL.appendExpectedVersion),
        ("appendStreamExists", Statement.toSql SQL.appendStreamExists),
        ("appendNoStream", Statement.toSql SQL.appendNoStream),
        ("appendAnyVersion", Statement.toSql SQL.appendAnyVersion),
        ("linkToStreamStmt", Statement.toSql SQL.linkToStreamStmt)
      ]