Warp 서버에서 MonadThrow 인스턴스를 ResourceT Monad Transformer에 추가하는 방법

Question

Warp를 사용하여 간단한 역방향 프록시 서버를 구축하려고합니다. (다른 대부분의 기성 옵션이 있기 때문에).

지금까지, 내 ​​코드는 주로 워프 문서에서 해제됩니다

(파일로 출력을 쓰기는 중간 시험, 다시 문서에서 해제됩니다) :

import Network.Wai as W 
import Network.Wai.Handler.Warp 
import Network.HTTP.Types 
import Network.HTTP.Conduit as H 
import qualified Data.Conduit as C 
import Data.Conduit.Binary (sinkFile) 
import Blaze.ByteString.Builder.ByteString 
import Control.Monad.Trans.Resource 
import Control.Monad.IO.Class 

proxApp req = do 
    let hd = headerAccept "Some header" 
    {-liftIO $ logReq req-} 
    pRequest <- parseUrl "http://some_website.com" 
    H.withManager $ \manager -> do 
     Response _ _ _ src <- http pRequest manager 
     src C.$$ sinkFile "test.html" 
    return $ ResponseBuilder status200 [hd] $ fromByteString "OK\n" 

main = do 
    putStrLn "Setting up reverse proxy on 8080" 
    run 8080 proxApp 

내가 내 Network.HTTP 작업을 실행하려고

ResourceT Monad, 컴파일러는 MonadThrow의 인스턴스가되어야합니다. 필자의 어려움은이를 모나드 스택에 추가하거나 인스턴스를 ResourceT에 추가하는 방법이다. 나는 HTTP 라인을 제거하면

No instance for (MonadThrow 
        (conduit-0.1.1.1:Control.Monad.Trans.Resource.ResourceT IO)) 
    arising from a use of `proxApp' 
Possible fix: 
    add an instance declaration for 
    (MonadThrow 
    (conduit-0.1.1.1:Control.Monad.Trans.Resource.ResourceT IO)) 
In the second argument of `run', namely `proxApp' 
In a stmt of a 'do' block: run 8080 proxApp 
In the expression: 
    do { putStrLn "Setting up reverse proxy on 8080"; 
     run 8080 proxApp } 

가하는 MonadThrow 인스턴스가 더 이상 필요하지, 모든 것이 잘 작동 : 아래의 코드와 컴파일러 오류가 없습니다.

MonadThrow의 인스턴스로 새 사용자 지정 모나드를 정의하는 경우 서버를 실제로 사용하려면 어떻게해야합니까? 내 스택 에서이 예외 처리를 소개하는 적절한 방법을 찾고 (또는 심지어 컴파일러를 만족).

감사/O는

Answer 1

이것은 (당신 import Control.Monad.Trans.Resource 그래서 당신이 얻을 경우 ResourceT)를 수행해야합니다 모든 응답에 대한

instance (MonadThrow m) => MonadThrow (ResourceT m) where 
    monadThrow = lift . monadThrow 

Answer 2

감사합니다. warp-1.2.0.1에서 완벽하게 작동하는 아래 코드로 마무리되었습니다.

proxApp req = do 
    liftIO $ logReq req 
    pRequest <- parseUrl "http://some_website.com" 
    H.withManager $ \manager -> do 
     Response status version headers src <- http pRequest manager 
     body <- src C.$$ responseSink 
     liftIO $ putStrLn $ show status 
     return $ ResponseBuilder status headers body 

responseSink = C.sinkState 
    (fromByteString "") 
    (\acc a -> return $ C.StateProcessing $ mappend acc $ fromByteString a) 
    (\acc -> return acc)