fixing up the test app
This commit is contained in:
+7
-16
@@ -9,18 +9,18 @@ import Database.HDBC
|
|||||||
import Database.HDBC.PostgreSQL
|
import Database.HDBC.PostgreSQL
|
||||||
|
|
||||||
import Data.String.Conversions (cs)
|
import Data.String.Conversions (cs)
|
||||||
import Control.Exception.Base (bracket, finally, tryJust)
|
import Control.Exception.Base (bracket, finally)
|
||||||
import Control.Monad (when)
|
|
||||||
|
|
||||||
import Network.HTTP.Types.Header (Header, ByteRange, renderByteRange,
|
import Network.HTTP.Types.Header (Header, ByteRange, renderByteRange,
|
||||||
hRange, hAuthorization)
|
hRange, hAuthorization)
|
||||||
import Codec.Binary.Base64.String (encode)
|
import Codec.Binary.Base64.String (encode)
|
||||||
import Data.CaseInsensitive (CI(..))
|
import Data.CaseInsensitive (CI(..))
|
||||||
import Text.Regex.TDFA ((=~))
|
import Text.Regex.TDFA ((=~))
|
||||||
import qualified Data.HashMap.Strict as Hash
|
|
||||||
import qualified Data.ByteString.Char8 as BS
|
import qualified Data.ByteString.Char8 as BS
|
||||||
import Network.Wai.Middleware.Cors (cors)
|
import Network.Wai.Middleware.Cors (cors)
|
||||||
|
|
||||||
|
import Middleware(clientErrors, withSavepoint, authenticated)
|
||||||
|
|
||||||
import Dbapi (app, corsPolicy, AppConfig(..))
|
import Dbapi (app, corsPolicy, AppConfig(..))
|
||||||
import PgQuery(addUser)
|
import PgQuery(addUser)
|
||||||
|
|
||||||
@@ -59,24 +59,16 @@ withUser name pass role action conn = do
|
|||||||
withApp :: ActionWith Application -> ActionWith Connection
|
withApp :: ActionWith Application -> ActionWith Connection
|
||||||
withApp action conn = do
|
withApp action conn = do
|
||||||
runRaw conn "begin;"
|
runRaw conn "begin;"
|
||||||
action $ cors corsPolicy $ app "dbapi_anonymous" conn
|
action $ cors corsPolicy $ authenticated "dbapi_anonymous" app conn
|
||||||
rollback conn
|
rollback conn
|
||||||
|
|
||||||
appWithFixture :: ActionWith Application -> IO ()
|
appWithFixture :: ActionWith Application -> IO ()
|
||||||
appWithFixture action = withDatabaseConnection $ \c -> do
|
appWithFixture action = withDatabaseConnection $ \c -> do
|
||||||
result <- tryJust transactionAborted $ do
|
|
||||||
runRaw c "begin;"
|
runRaw c "begin;"
|
||||||
action $ cors corsPolicy $ app "dbapi_anonymous" c
|
action $ cors corsPolicy . clientErrors $
|
||||||
|
(authenticated "dbapi_anonymous" . withSavepoint) app c
|
||||||
rollback c
|
rollback c
|
||||||
|
|
||||||
when (isLeft result) $
|
|
||||||
putStrLn "note: commands ignored after aborted transaction"
|
|
||||||
|
|
||||||
where
|
|
||||||
transactionAborted :: SqlError -> Maybe ()
|
|
||||||
transactionAborted e =
|
|
||||||
if seState e == "25P02" then Just () else Nothing
|
|
||||||
|
|
||||||
rangeHdrs :: ByteRange -> [Header]
|
rangeHdrs :: ByteRange -> [Header]
|
||||||
rangeHdrs r = [rangeUnit, (hRange, renderByteRange r)]
|
rangeHdrs r = [rangeUnit, (hRange, renderByteRange r)]
|
||||||
|
|
||||||
@@ -84,8 +76,7 @@ rangeUnit :: Header
|
|||||||
rangeUnit = ("Range-Unit" :: CI BS.ByteString, "items")
|
rangeUnit = ("Range-Unit" :: CI BS.ByteString, "items")
|
||||||
|
|
||||||
getHeader :: CI BS.ByteString -> [Header] -> Maybe BS.ByteString
|
getHeader :: CI BS.ByteString -> [Header] -> Maybe BS.ByteString
|
||||||
getHeader name headers =
|
getHeader = lookup
|
||||||
Hash.lookup name $ Hash.fromList headers
|
|
||||||
|
|
||||||
matchHeader :: CI BS.ByteString -> String -> [Header] -> Bool
|
matchHeader :: CI BS.ByteString -> String -> [Header] -> Bool
|
||||||
matchHeader name valRegex headers =
|
matchHeader name valRegex headers =
|
||||||
|
|||||||
Reference in New Issue
Block a user