X-Git-Url: http://git.cielonegro.org/gitweb.cgi?a=blobdiff_plain;f=Network%2FHTTP%2FLucu%2FAbortion.hs;h=62677e82baea3117f808dc541925611e6c6be2a6;hb=0aa4f6d758fc12fba468f7cd399bbcc48f693d1e;hp=6e74bea21d40d8d473a28645aecdf13c8278fbb2;hpb=3b680675dec6d5b922356daf2ad715f1cea26e4a;p=Lucu.git diff --git a/Network/HTTP/Lucu/Abortion.hs b/Network/HTTP/Lucu/Abortion.hs index 6e74bea..62677e8 100644 --- a/Network/HTTP/Lucu/Abortion.hs +++ b/Network/HTTP/Lucu/Abortion.hs @@ -1,13 +1,14 @@ {-# LANGUAGE - DeriveDataTypeable + Arrows + , DeriveDataTypeable + , TypeOperators , UnicodeSyntax #-} -{-# OPTIONS_HADDOCK prune #-} - -- |Aborting the computation of 'Network.HTTP.Lucu.Resource.Resource' -- in any 'Prelude.IO' monads or arrows. module Network.HTTP.Lucu.Abortion ( Abortion(..) + , abort , abortPurely , abortSTM @@ -15,39 +16,42 @@ module Network.HTTP.Lucu.Abortion , abortPage ) where -import Control.Arrow +import Blaze.ByteString.Builder (Builder) +import qualified Blaze.ByteString.Builder.Char.Utf8 as BB import Control.Arrow.ArrowIO +import Control.Arrow.ListArrow +import Control.Arrow.Unicode import Control.Concurrent.STM import Control.Exception import Control.Monad.Trans -import qualified Data.ByteString.Char8 as C8 +import Data.Ascii (Ascii, CIAscii) +import Data.Text (Text) import qualified Data.Text as T -import Data.Text.Encoding import Data.Typeable import Network.HTTP.Lucu.Config import Network.HTTP.Lucu.DefaultPage import Network.HTTP.Lucu.Headers import Network.HTTP.Lucu.Request import Network.HTTP.Lucu.Response +import Prelude.Unicode import Text.XML.HXT.Arrow.WriteDocument import Text.XML.HXT.Arrow.XmlArrow import Text.XML.HXT.Arrow.XmlState data Abortion = Abortion { - aboStatus :: !StatusCode - , aboHeaders :: !Headers - , aboMessage :: !(Maybe String) - } deriving (Eq, Show, Typeable, Exception) + aboStatus ∷ !StatusCode + , aboHeaders ∷ !Headers + , aboMessage ∷ !(Maybe Text) + } deriving (Eq, Show, Typeable) ---instance Exception Abortion +instance Exception Abortion -- |Computation of @'abort' status headers msg@ aborts the -- 'Network.HTTP.Lucu.Resource.Resource' monad with given status, -- additional response headers, and optional message string. -- --- What this really does is to throw a special --- 'Control.Exception.Exception'. The exception will be caught by the --- Lucu system. +-- What this really does is to throw an instance of 'Exception'. The +-- exception will be caught by the Lucu system. -- -- 1. If the 'Network.HTTP.Lucu.Resource.Resource' is in the /Deciding -- Header/ or any precedent states, it is possible to use the @@ -56,60 +60,57 @@ data Abortion = Abortion { -- -- 2. Otherwise the HTTP response can't be modified anymore so the -- only possible thing the system can do is to dump it to the --- stderr. See --- 'Network.HTTP.Lucu.Config.cnfDumpTooLateAbortionToStderr'. +-- stderr. See 'cnfDumpTooLateAbortionToStderr'. -- --- Note that the status code doesn't have to be an error code so you --- can use this action for redirection as well as error reporting e.g. +-- Note that the status code doesn't necessarily have to be an error +-- code so you can use this action for redirection as well as error +-- reporting e.g. -- -- > abort MovedPermanently -- > [("Location", "http://example.net/")] -- > (Just "It has been moved to example.net") -abort :: MonadIO m ⇒ StatusCode → [ (String, String) ] → Maybe String → m a -abort status headers msg - = status `seq` headers `seq` msg `seq` - let abo = Abortion status (toHeaders $ map pack headers) msg - in - liftIO $ throwIO abo - where - pack (x, y) = (C8.pack x, C8.pack y) +abort ∷ MonadIO m ⇒ StatusCode → [ (CIAscii, Ascii) ] → Maybe Text → m a +{-# INLINE abort #-} +abort status headers + = liftIO ∘ throwIO ∘ Abortion status (toHeaders headers) -- |This is similar to 'abort' but computes it with -- 'System.IO.Unsafe.unsafePerformIO'. -abortPurely :: StatusCode → [ (String, String) ] → Maybe String → a -abortPurely = ((unsafePerformIO .) .) . abort +abortPurely ∷ StatusCode → [ (CIAscii, Ascii) ] → Maybe Text → a +{-# INLINE abortPurely #-} +abortPurely status headers + = throw ∘ Abortion status (toHeaders headers) -- |Computation of @'abortSTM' status headers msg@ just computes -- 'abort' in a 'Control.Monad.STM.STM' monad. -abortSTM :: StatusCode → [ (String, String) ] → Maybe String → STM a -abortSTM status headers msg - = status `seq` headers `seq` msg `seq` - unsafeIOToSTM $! abort status headers msg +abortSTM ∷ StatusCode → [ (CIAscii, Ascii) ] → Maybe Text → STM a +{-# INLINE abortSTM #-} +abortSTM status headers + = throwSTM ∘ Abortion status (toHeaders headers) -- | Computation of @'abortA' -< (status, (headers, msg))@ just -- computes 'abort' in an 'Control.Arrow.ArrowIO.ArrowIO'. -abortA :: ArrowIO a ⇒ a (StatusCode, ([ (String, String) ], Maybe String)) c -abortA - = arrIO3 abort +abortA ∷ ArrowIO (⇝) ⇒ (StatusCode, ([ (CIAscii, Ascii) ], Maybe Text)) ⇝ c +{-# INLINE abortA #-} +abortA = proc (status, (headers, msg)) → + arrIO throwIO ⤙ Abortion status (toHeaders headers) msg -- aboMessage が Just なら單に mkDefaultPage に渡すだけで良いので樂だが、 -- Nothing の場合は getDefaultPage を使ってデフォルトのメッセージを得な -- ければならない。 -abortPage :: Config → Maybe Request → Response → Abortion → String +abortPage ∷ Config → Maybe Request → Response → Abortion → Builder abortPage conf reqM res abo - = conf `seq` reqM `seq` res `seq` abo `seq` - case aboMessage abo of + = case aboMessage abo of Just msg - → let [html] = unsafePerformIO - $ runX ( mkDefaultPage conf (aboStatus abo) (txt msg) - >>> - writeDocumentToString [ withIndent True ] - ) - in - html + → let [html] = runLA ( mkDefaultPage conf (aboStatus abo) (txt $ T.unpack msg) + ⋙ + writeDocumentToString [ withIndent True ] + ) () + in + BB.fromString html Nothing → let res' = res { resStatus = aboStatus abo } - res'' = foldl (.) id [setHeader name value - | (name, value) <- fromHeaders $ aboHeaders abo] res' + res'' = foldl (∘) id [setHeader name value + | (name, value) ← fromHeaders $ aboHeaders abo] res' in getDefaultPage conf reqM res''