module DatabaseSpec (spec) where

import Protolude

import           Data.Function                        (id)
import qualified Hasql.Connection                     as H
import Test.Hspec

import PostgresWebsockets.Database

spec :: Spec
spec =
  describe "waitForNotifications" $
    it "does trigger action upon notification" $ do
      conOrError <- H.acquire "postgres://localhost/postgres_ws_test"
      let con = either (panic . show) id conOrError :: H.Connection
      notification <- liftIO newEmptyMVar

      race_
        (waitForNotifications (curry $ putMVar notification) con)
        (do listen con $ toPgIdentifier "test"

            conOrError2 <- H.acquire "postgres://localhost/postgres_ws_test"
            let con2 = either (panic . show) id conOrError2 :: H.Connection
            void $ notify con2 (toPgIdentifier "test") "hello there"

            readMVar notification `shouldReturn` ("test", "hello there"))