mirror of
https://github.com/Start9Labs/registry.git
synced 2026-03-26 10:21:51 +00:00
74 lines
2.4 KiB
Haskell
74 lines
2.4 KiB
Haskell
{-# LANGUAGE QuasiQuotes #-}
|
|
{-# LANGUAGE RankNTypes #-}
|
|
{-# LANGUAGE KindSignatures #-}
|
|
|
|
module TestImport
|
|
( module TestImport
|
|
, module X
|
|
)
|
|
where
|
|
|
|
import Startlude hiding ( Handler )
|
|
import Application ( makeFoundation
|
|
, makeLogWare
|
|
)
|
|
import Foundation as X
|
|
import Test.Hspec as X
|
|
import Yesod.Default.Config2 ( useEnv
|
|
, loadYamlSettings
|
|
)
|
|
import Yesod.Test as X
|
|
import Yesod.Core.Unsafe ( fakeHandlerGetLogger )
|
|
import Database.Persist.Sql
|
|
import Text.Shakespeare.Text ( st )
|
|
import Yesod.Core
|
|
import qualified Data.Text as T
|
|
import Database.Esqueleto.Internal.Internal
|
|
import Database.Persist.Sql.Types.Internal
|
|
|
|
runHandler :: Handler a -> YesodExample RegistryCtx a
|
|
runHandler handler = do
|
|
app <- getTestYesod
|
|
fakeHandlerGetLogger appLogger app handler
|
|
|
|
withApp :: SpecWith (TestApp RegistryCtx) -> Spec
|
|
withApp = before $ do
|
|
settings <- loadYamlSettings ["config/settings.yml"] [] useEnv
|
|
foundation <- makeFoundation settings
|
|
wipeDB foundation
|
|
logWare <- liftIO $ makeLogWare foundation
|
|
return (foundation, logWare)
|
|
|
|
getTables :: DB [Text]
|
|
getTables = do
|
|
tables <- rawSql
|
|
[st|
|
|
SELECT table_name
|
|
FROM information_schema.tables
|
|
WHERE table_schema = 'public'
|
|
AND table_type = 'BASE TABLE';
|
|
|]
|
|
[]
|
|
|
|
return $ fmap unSingle tables
|
|
|
|
wipeDB :: RegistryCtx -> IO ()
|
|
wipeDB app = runDBWithApp app $ do
|
|
tables <- getTables
|
|
sqlBackend <- ask
|
|
|
|
let escapedTables = map (T.unpack . connEscapeRawName sqlBackend . unDBName . DBName) tables
|
|
query = "TRUNCATE TABLE " ++ intercalate ", " escapedTables
|
|
rawExecute (T.pack query) []
|
|
|
|
runDBtest :: SqlPersistM a -> YesodExample RegistryCtx a
|
|
runDBtest query = do
|
|
app <- getTestYesod
|
|
liftIO $ runDBWithApp app query
|
|
|
|
runDBWithApp :: RegistryCtx -> SqlPersistM a -> IO a
|
|
runDBWithApp app query = runSqlPersistMPool query (appConnPool app)
|
|
|
|
-- A convenient synonym for database access functions
|
|
type DB a = forall (m :: * -> *) . (MonadUnliftIO m) => ReaderT SqlBackend m a
|