module Data.Conduit.Process.TypedSpec (spec) where

import Test.Hspec
import Data.Conduit
import Data.Conduit.Process.Typed
import qualified Data.Conduit.List as CL
import qualified Data.ByteString as B

spec :: Spec
spec = do
  it "cat works" $ do
    let fp = "ChangeLog.md"
        pc = setStdout createSource $ proc "cat" [fp]
    bs <- B.readFile fp
    bss <- withProcess_ pc $ \p -> runConduit $ getStdout p .| CL.consume
    B.concat bss `shouldBe` bs
  it "cat works with withLoggedProcess_" $ do
    let fp = "ChangeLog.md"
        pc = proc "cat" [fp]
    bs <- B.readFile fp
    bss <- withLoggedProcess_ pc $ \p -> runConduit $ getStdout p .| CL.consume
    B.concat bss `shouldBe` bs
  it "failing process throws" $ do
    (withLoggedProcess_ (proc "cat" ["does not exist"]) $ \p -> do
      runConduit $ getStdout p .| CL.mapM_ (error "shouldn't have data"))
      `shouldThrow` anyException
  it "failing process throws" $ do
    (withProcess_ (proc "cat" ["does not exist"]) $ const $ return ())
      `shouldThrow` anyException