BrowseReadsMock.hs

module Test.BrowseReadsMock (spec) where

import Control.Monad.IO.Class (liftIO)
import Data.IORef (modifyIORef', newIORef, readIORef)
import Data.UUID qualified as UUID
import Data.Vector qualified as V
import Effectful (runEff)
import Effectful.Dispatch.Dynamic (interpret_)
import Kiroku.Store.Effect (Store (..))
import Kiroku.Store.Read
import Kiroku.Store.Types
import Test.Hspec

spec :: Spec
spec = describe "browse reads mock" $ it "dispatches each public wrapper exactly once with its parameters" $ do
  calls <- newIORef ([] :: [String])
  let page = either (error . show) (\size -> size) (mkBrowsePageSize 7)
      runner = interpret_ $ \case
        ListStreams category prefix cursor size -> do
          liftIO $ (category, prefix, cursor, size) `shouldBe` (Just (CategoryName "orders"), Just "orders-", Just (StreamName "orders-1"), page)
          liftIO $ modifyIORef' calls (<> ["streams"])
          pure V.empty
        ListCategories cursor size -> do
          liftIO $ (cursor, size) `shouldBe` (Just (CategoryName "orders"), page)
          liftIO $ modifyIORef' calls (<> ["categories"])
          pure V.empty
        GetEvent eid -> do
          liftIO $ eid `shouldBe` EventId UUID.nil
          liftIO $ modifyIORef' calls (<> ["event"])
          pure Nothing
        _ -> error "unexpected browse mock operation"
  _ <- runEff $ runner $ do
    _ <- listStreams (Just (CategoryName "orders")) (Just "orders-") (Just (StreamName "orders-1")) page
    _ <- listCategories (Just (CategoryName "orders")) page
    getEvent (EventId UUID.nil)
  readIORef calls `shouldReturn` ["streams", "categories", "event"]