SubscriptionDeadLettersMock.hs

module Test.SubscriptionDeadLettersMock (spec) where

import Control.Monad.IO.Class (liftIO)
import Data.IORef
import Data.Vector qualified as V
import Effectful (runEff)
import Effectful.Dispatch.Dynamic (interpret_)
import Kiroku.Store
import Test.Hspec

spec :: Spec
spec = describe "SubscriptionDeadLetters mock interpreter" $ it "dispatches the public wrapper once with the entire query and returns the interpreter page" $ do
  calls <- newIORef (0 :: Int)
  let query = (defaultSubscriptionDeadLetterQuery (SubscriptionName "mock")) {consumerGroupMember = Just 9, after = Just (SubscriptionDeadLetterCursor (GlobalPosition 21) 7)}
      expected = SubscriptionDeadLetterPage V.empty (Just (SubscriptionDeadLetterCursor (GlobalPosition 10) 3))
      runner = interpret_ $ \case
        ListSubscriptionDeadLetters actual -> do
          liftIO $ actual `shouldBe` query
          liftIO $ modifyIORef' calls (+ 1)
          pure expected
        _ -> error "unexpected Store operation"
  runEff (runner (subscriptionDeadLetters query)) `shouldReturn` expected
  readIORef calls `shouldReturn` 1