mirror of
https://github.com/hasura/graphql-engine.git
synced 2024-12-16 18:42:30 +03:00
b658df1c43
PR-URL: https://github.com/hasura/graphql-engine-mono/pull/4772 Co-authored-by: Gil Mizrahi <8547573+soupi@users.noreply.github.com> GitOrigin-RevId: 5c6c9056952574462d5b309774331a909a7eac6d
55 lines
1.6 KiB
Haskell
55 lines
1.6 KiB
Haskell
-- | TestEnvironment shared by tests. We intentionally use an abstract type to
|
|
-- wrap up the values we need for tests, with accessors. This way, the
|
|
-- tests are less liable to refactorings when we add or change the
|
|
-- testEnvironment.
|
|
module Harness.TestEnvironment
|
|
( TestEnvironment (..),
|
|
Server (..),
|
|
getServer,
|
|
serverUrl,
|
|
stopServer,
|
|
)
|
|
where
|
|
|
|
import Control.Concurrent (ThreadId, killThread)
|
|
import Data.Word
|
|
import Hasura.Prelude
|
|
import System.Log.FastLogger qualified as FL
|
|
|
|
-- | A testEnvironment that's passed to all tests.
|
|
data TestEnvironment = TestEnvironment
|
|
{ server :: Server,
|
|
logger :: FL.LogStr -> IO (),
|
|
loggerCleanup :: IO ()
|
|
}
|
|
|
|
instance Show TestEnvironment where
|
|
show TestEnvironment {server} = "<TestEnvironment: " ++ urlPrefix server ++ ":" ++ show (port server) ++ " >"
|
|
|
|
-- | Information about a server that we're working with.
|
|
data Server = Server
|
|
{ -- | The port to connect on.
|
|
port :: Word16,
|
|
-- | The full URI prefix e.g. http://localhost
|
|
urlPrefix :: String,
|
|
-- | The thread that the server is running on, so we can stop it later.
|
|
threadId :: ThreadId
|
|
}
|
|
|
|
-- | Retrieve the 'Server' associated with some 'TestEnvironment'.
|
|
getServer :: TestEnvironment -> Server
|
|
getServer TestEnvironment {server} = server
|
|
|
|
-- | Extracts the full URL prefix and port number from a given 'Server'.
|
|
--
|
|
-- @
|
|
-- > serverUrl (Server 8080 "http://localhost" someThreadId)
|
|
-- "http://localhost:8080"
|
|
-- @
|
|
serverUrl :: Server -> String
|
|
serverUrl Server {urlPrefix, port} = urlPrefix ++ ":" ++ show port
|
|
|
|
-- | Forcibly stop a given 'Server'.
|
|
stopServer :: Server -> IO ()
|
|
stopServer Server {threadId} = killThread threadId
|