tmp-postgres-1.7.1.0: src/Database/Postgres/Temp/Internal/Partial.hs
{-# OPTIONS_HADDOCK prune #-}
{-| This module provides types and functions for combining partial
configs into a complete configs to ultimately make a 'Plan'.
This module has two classes of types.
Types like 'PartialProcessConfig' that could be used by any
library that needs to combine process options.
Finally it has types and functions for creating 'Plan's that
use temporary resources. This is used to create the default
behavior of 'Database.Postgres.Temp.startConfig' and related
functions.
|-}
module Database.Postgres.Temp.Internal.Partial where
import Database.Postgres.Temp.Internal.Core
import Control.Applicative.Lift
import Control.Exception
import Control.Monad (join)
import Control.Monad.Trans.Class
import Control.Monad.Trans.Cont
import qualified Data.Map.Strict as Map
import Data.Map.Strict (Map)
import Data.Maybe
import Data.Monoid
import Data.Monoid.Generic
import Data.Typeable
import qualified Database.PostgreSQL.Simple.Options as Client
import GHC.Generics (Generic)
import Network.Socket.Free (getFreePort)
import System.Directory
import System.Environment
import System.IO
import System.IO.Error
import System.IO.Temp (createTempDirectory)
import Text.PrettyPrint.ANSI.Leijen hiding ((<$>))
prettyMap :: (Pretty a, Pretty b) => Map a b -> Doc
prettyMap theMap =
let xs = Map.toList theMap
in vsep $ map (uncurry prettyKeyPair) xs
-- | The environment variables can be declared to
-- inherit from the running process or they
-- can be specifically added.
data PartialEnvVars = PartialEnvVars
{ partialEnvVarsInherit :: Last Bool
, partialEnvVarsSpecific :: Map String String
}
deriving stock (Generic, Show, Eq)
instance Semigroup PartialEnvVars where
x <> y = PartialEnvVars
{ partialEnvVarsInherit =
partialEnvVarsInherit x <> partialEnvVarsInherit y
, partialEnvVarsSpecific =
partialEnvVarsSpecific y <> partialEnvVarsSpecific x
}
instance Monoid PartialEnvVars where
mempty = PartialEnvVars mempty mempty
instance Pretty PartialEnvVars where
pretty PartialEnvVars {..}
= text "partialEnvVarsInherit:"
<+> pretty (getLast partialEnvVarsInherit)
<> hardline
<> text "partialEnvVarsSpecific:"
<> softline
<> indent 2 (prettyMap partialEnvVarsSpecific)
-- | Combine the current environment
-- (if indicated by 'partialEnvVarsInherit')
-- with 'partialEnvVarsSpecific'
completePartialEnvVars :: [(String, String)] -> PartialEnvVars -> Either [String] [(String, String)]
completePartialEnvVars envs PartialEnvVars {..} = case getLast partialEnvVarsInherit of
Nothing -> Left ["Inherit not specified"]
Just x -> Right $ (if x then envs else [])
<> Map.toList partialEnvVarsSpecific
-- | A type to help combine command line arguments.
data PartialCommandLineArgs = PartialCommandLineArgs
{ partialCommandLineArgsKeyBased :: Map String (Maybe String)
-- ^ Arguments of the form @-h foo@, @--host=foo@ and @--switch@.
-- The key is `mappend`ed with value so the key should include
-- the space or equals (as shown in the first two examples
-- respectively).
-- The 'Dual' monoid is used so the last key wins.
, partialCommandLineArgsIndexBased :: Map Int String
-- ^ Arguments that appear at the end of the key based
-- arguments.
-- The 'Dual' monoid is used so the last key wins.
}
deriving stock (Generic, Show, Eq)
deriving Monoid via GenericMonoid PartialCommandLineArgs
instance Semigroup PartialCommandLineArgs where
x <> y = PartialCommandLineArgs
{ partialCommandLineArgsKeyBased =
partialCommandLineArgsKeyBased y <> partialCommandLineArgsKeyBased x
, partialCommandLineArgsIndexBased =
partialCommandLineArgsIndexBased y <> partialCommandLineArgsIndexBased x
}
instance Pretty PartialCommandLineArgs where
pretty p@PartialCommandLineArgs {..}
= text "partialCommandLineArgsKeyBased:"
<> softline
<> indent 2 (prettyMap partialCommandLineArgsKeyBased)
<> hardline
<> text "partialCommandLineArgsIndexBased:"
<> softline
<> indent 2 (prettyMap partialCommandLineArgsIndexBased)
<> hardline
<> text "completed:" <+> text (unwords (completeCommandLineArgs p))
-- Take values as long as the index is the successor of the
-- last index.
takeWhileInSequence :: [(Int, a)] -> [a]
takeWhileInSequence ((0, x):xs) = x : go 0 xs where
go _ [] = []
go prev ((next, a):rest)
| prev + 1 == next = a : go next rest
| otherwise = []
takeWhileInSequence _ = []
-- | This convert the 'PartialCommandLineArgs' to '
completeCommandLineArgs :: PartialCommandLineArgs -> [String]
completeCommandLineArgs PartialCommandLineArgs {..}
= map (\(name, mvalue) -> maybe name (name <>) mvalue)
(Map.toList partialCommandLineArgsKeyBased)
<> takeWhileInSequence (Map.toList partialCommandLineArgsIndexBased)
-- | The monoidial version of 'ProcessConfig'. Used to combine overrides with
-- defaults when creating a 'ProcessConfig'.
data PartialProcessConfig = PartialProcessConfig
{ partialProcessConfigEnvVars :: PartialEnvVars
-- ^ A monoid for combine environment variables or replacing them.
-- for the maps the 'Dual' monoid is used. So the last key wins.
, partialProcessConfigCmdLine :: PartialCommandLineArgs
-- ^ A monoid for combine command line arguments or replacing them
, partialProcessConfigStdIn :: Last Handle
-- ^ A monoid for configuring the standard input 'Handle'
, partialProcessConfigStdOut :: Last Handle
-- ^ A monoid for configuring the standard output 'Handle'
, partialProcessConfigStdErr :: Last Handle
-- ^ A monoid for configuring the standard error 'Handle'
}
deriving stock (Generic, Eq, Show)
deriving Semigroup via GenericSemigroup PartialProcessConfig
deriving Monoid via GenericMonoid PartialProcessConfig
prettyHandle :: Handle -> Doc
prettyHandle _ = text "[HANDLE]"
instance Pretty PartialProcessConfig where
pretty PartialProcessConfig {..}
= text "partialProcessConfigEnvVars:"
<> softline
<> indent 2 (pretty partialProcessConfigEnvVars)
<> hardline
<> text "partialProcessConfigCmdLine:"
<> softline
<> indent 2 (pretty partialProcessConfigEnvVars)
<> hardline
<> text "partialProcessConfigStdIn:" <+>
pretty (prettyHandle <$> getLast partialProcessConfigStdIn)
<> hardline
<> text "partialProcessConfigStdOut:" <+>
pretty (prettyHandle <$> getLast partialProcessConfigStdOut)
<> hardline
<> text "partialProcessConfigStdErr:" <+>
pretty (prettyHandle <$> getLast partialProcessConfigStdErr)
-- | The 'standardProcessConfig' sets the handles to 'stdin', 'stdout' and
-- 'stderr' and inherits the environment variables from the calling
-- process.
standardProcessConfig :: PartialProcessConfig
standardProcessConfig = mempty
{ partialProcessConfigEnvVars = mempty
{ partialEnvVarsInherit = pure True
}
, partialProcessConfigStdIn = pure stdin
, partialProcessConfigStdOut = pure stdout
, partialProcessConfigStdErr = pure stderr
}
-- A helper to add more info to all the error messages.
addErrorContext :: String -> Either [String] a -> Either [String] a
addErrorContext cxt = either (Left . map (cxt <>)) Right
-- A helper for creating an error if a 'Last' is not defined.
getOption :: String -> Last a -> Errors [String] a
getOption optionName = \case
Last (Just x) -> pure x
Last Nothing -> failure ["Missing " ++ optionName ++ " option"]
-- | Turn a 'PartialProcessConfig' into a 'ProcessConfig'. Fails if
-- any values are missing.
completeProcessConfig
:: [(String, String)] -> PartialProcessConfig -> Either [String] ProcessConfig
completeProcessConfig envs PartialProcessConfig {..} = runErrors $ do
let processConfigCmdLine = completeCommandLineArgs partialProcessConfigCmdLine
processConfigEnvVars <- eitherToErrors $
completePartialEnvVars envs partialProcessConfigEnvVars
processConfigStdIn <-
getOption "partialProcessConfigStdIn" partialProcessConfigStdIn
processConfigStdOut <-
getOption "partialProcessConfigStdOut" partialProcessConfigStdOut
processConfigStdErr <-
getOption "partialProcessConfigStdErr" partialProcessConfigStdErr
pure ProcessConfig {..}
-- | A type to track whether a file is temporary and needs to be cleaned up.
data DirectoryType = Permanent FilePath | Temporary FilePath
deriving(Show, Eq, Ord)
-- | Get the file path of a 'DirectoryType', regardless if it is a
-- 'Permanent' or 'Temporary' type.
toFilePath :: DirectoryType -> FilePath
toFilePath = \case
Permanent x -> x
Temporary x -> x
instance Pretty DirectoryType where
pretty = \case
Permanent x -> text "Permanent" <+> pretty x
Temporary x -> text "Temporary" <+> pretty x
makePermanent :: DirectoryType -> DirectoryType
makePermanent = \case
Temporary x -> Permanent x
x -> x
-- | The monoidial version of 'DirectoryType'. Used to combine overrides with
-- defaults when creating a 'DirectoryType'. The monoid instance treats
-- 'PTemporary' as 'mempty' and takes the last 'PPermanent' value.
data PartialDirectoryType
= PPermanent FilePath
-- ^ A permanent file that should not be generated.
| PTemporary
-- ^ A temporary file that needs to generated.
deriving(Show, Eq, Ord)
instance Pretty PartialDirectoryType where
pretty = \case
PPermanent x -> text "Permanent" <+> pretty x
PTemporary -> text "Temporary"
instance Semigroup PartialDirectoryType where
x <> y = case (x, y) of
(a, PTemporary ) -> a
(_, a@PPermanent {}) -> a
instance Monoid PartialDirectoryType where
mempty = PTemporary
-- | Either create a'Temporary' directory or do nothing to a 'Permanent'
-- one.
setupDirectoryType :: String -> PartialDirectoryType -> IO DirectoryType
setupDirectoryType pattern = \case
PTemporary -> Temporary <$> createTempDirectory "/tmp" pattern
PPermanent x -> pure $ Permanent x
-- Either create a temporary directory or do nothing
rmDirIgnoreErrors :: FilePath -> IO ()
rmDirIgnoreErrors mainDir = do
let ignoreDirIsMissing e
| isDoesNotExistError e = return ()
| otherwise = throwIO e
removeDirectoryRecursive mainDir `catch` ignoreDirIsMissing
-- | Either remove a 'Temporary' directory or do nothing to a 'Permanent'
-- one.
cleanupDirectoryType :: DirectoryType -> IO ()
cleanupDirectoryType = \case
Permanent _ -> pure ()
Temporary filePath -> rmDirIgnoreErrors filePath
-- | A type for configuring the listening address of the @postgres@ process.
-- @postgres@ can listen on several types of sockets simulatanously but we
-- don't support that behavior. One can either listen on a IP based socket
-- or a UNIX domain socket.
data SocketClass
= IpSocket String
-- ^ IP socket type. The 'String' is either an IP address or
-- a host that will resolve to an IP address.
| UnixSocket DirectoryType
-- ^ UNIX domain socket
deriving (Show, Eq, Ord, Generic, Typeable)
instance Pretty SocketClass where
pretty = \case
IpSocket x -> text "IpSocket:" <+> pretty x
UnixSocket x -> text "UnixSocket:" <+> pretty x
-- | Create the extra config lines for listening based on the 'SocketClass'
socketClassToConfig :: SocketClass -> [String]
socketClassToConfig = \case
IpSocket ip -> ["listen_addresses = '" <> ip <> "'"]
UnixSocket dir ->
[ "listen_addresses = ''"
, "unix_socket_directories = '" <> toFilePath dir <> "'"
]
-- | Many processes require a \"host\" flag. We can generate one from the
-- 'SocketClass'.
socketClassToHostFlag :: SocketClass -> [(String, Maybe String)]
socketClassToHostFlag x = [("-h", Just (socketClassToHost x))]
-- | Get the IP address, host name or UNIX domain socket directory
-- as a 'String'
socketClassToHost :: SocketClass -> String
socketClassToHost = \case
IpSocket ip -> ip
UnixSocket dir -> toFilePath dir
-- | The monoidial version of 'SocketClass'. Used to combine overrides with
-- defaults when creating a 'SocketClass'. The monoid instance treats
-- 'PUnixSocket mempty' as 'mempty' and combines the
data PartialSocketClass
= PIpSocket (Last String)
-- ^ The monoid for combining IP address configuration
| PUnixSocket PartialDirectoryType
-- ^ The monoid for combining UNIX socket configuration
deriving stock (Show, Eq, Ord, Generic, Typeable)
instance Pretty PartialSocketClass where
pretty = \case
PIpSocket x -> "IpSocket:" <+> pretty (getLast x)
PUnixSocket x -> "UnixSocket" <+> pretty x
instance Semigroup PartialSocketClass where
x <> y = case (x, y) of
(PIpSocket a, PIpSocket b) -> PIpSocket $ a <> b
(a@(PIpSocket _), PUnixSocket _) -> a
(PUnixSocket _, a@(PIpSocket _)) -> a
(PUnixSocket a, PUnixSocket b) -> PUnixSocket $ a <> b
instance Monoid PartialSocketClass where
mempty = PUnixSocket mempty
-- | Turn a 'PartialSocketClass' to a 'SocketClass'. If the 'PIpSocket' is
-- 'Nothing' default to \"127.0.0.1\". If the is a 'PUnixSocket'
-- optionally create a temporary directory if configured to do so.
setupPartialSocketClass :: PartialSocketClass -> IO SocketClass
setupPartialSocketClass theClass = case theClass of
PIpSocket mIp -> pure $ IpSocket $ fromMaybe "127.0.0.1" $
getLast mIp
PUnixSocket mFilePath ->
UnixSocket <$> setupDirectoryType "tmp-postgres-socket" mFilePath
-- | Cleanup the UNIX socket temporary directory if one was created.
cleanupSocketConfig :: SocketClass -> IO ()
cleanupSocketConfig = \case
IpSocket {} -> pure ()
UnixSocket dir -> cleanupDirectoryType dir
-- | @postgres@ process config and corresponding client connection
-- 'Client.Options'.
data PartialPostgresPlan = PartialPostgresPlan
{ partialPostgresPlanProcessConfig :: PartialProcessConfig
-- ^ Monoid for the @postgres@ ProcessConfig.
, partialPostgresPlanClientConfig :: Client.Options
-- ^ Monoid for the @postgres@ client connection options.
}
deriving stock (Generic)
deriving Semigroup via GenericSemigroup PartialPostgresPlan
deriving Monoid via GenericMonoid PartialPostgresPlan
instance Pretty PartialPostgresPlan where
pretty PartialPostgresPlan {..}
= text "partialPostgresPlanProcessConfig:"
<> softline
<> indent 2 (pretty partialPostgresPlanProcessConfig)
<> hardline
<> text "partialPostgresPlanClientConfig:"
<> softline
<> indent 2 (prettyOptions partialPostgresPlanClientConfig)
-- | Turn a 'PartialPostgresPlan' into a 'PostgresPlan'. Fails if any
-- values are missing.
completePostgresPlan :: [(String, String)] -> PartialPostgresPlan -> Either [String] PostgresPlan
completePostgresPlan envs PartialPostgresPlan {..} = runErrors $ do
let postgresPlanClientOptions = partialPostgresPlanClientConfig
postgresPlanProcessConfig <-
eitherToErrors $ addErrorContext "partialPostgresPlanProcessConfig: " $
completeProcessConfig envs partialPostgresPlanProcessConfig
pure PostgresPlan {..}
-------------------------------------------------------------------------------
-- PartialPlan
-------------------------------------------------------------------------------
-- | The monoidial version of 'Plan'. Used to combine overrides with defaults
-- when creating a plan.
data PartialPlan = PartialPlan
{ partialPlanLogger :: Last Logger
, partialPlanInitDb :: Maybe PartialProcessConfig
, partialPlanCreateDb :: Maybe PartialProcessConfig
, partialPlanPostgres :: PartialPostgresPlan
, partialPlanConfig :: [String]
, partialPlanDataDirectory :: Last String
}
deriving stock (Generic)
deriving Semigroup via GenericSemigroup PartialPlan
deriving Monoid via GenericMonoid PartialPlan
instance Pretty PartialPlan where
pretty PartialPlan {..}
= text "partialPlanInitDb:"
<> softline
<> indent 2 (pretty partialPlanInitDb)
<> hardline
<> text "partialPlanInitDb:"
<> softline
<> indent 2 (pretty partialPlanCreateDb)
<> hardline
<> text "partialPlanPostgres:"
<> softline
<> indent 2 (pretty partialPlanPostgres)
<> hardline
<> text "partialPlanConfig:"
<> softline
<> indent 2 (vsep $ map text partialPlanConfig)
<> hardline
<> text "partialPlanDataDirectory:" <+> pretty (getLast partialPlanDataDirectory)
-- | Turn a 'PartialPlan' into a 'Plan'. Fails if any values are missing.
completePlan :: [(String, String)] -> PartialPlan -> Either [String] Plan
completePlan envs PartialPlan {..} = runErrors $ do
planLogger <- getOption "partialPlanLogger" partialPlanLogger
planInitDb <- eitherToErrors $ addErrorContext "partialPlanInitDb: " $
traverse (completeProcessConfig envs) partialPlanInitDb
planCreateDb <- eitherToErrors $ addErrorContext "partialPlanCreateDb: " $
traverse (completeProcessConfig envs) partialPlanCreateDb
planPostgres <- eitherToErrors $ addErrorContext "partialPlanPostgres: " $
completePostgresPlan envs partialPlanPostgres
let planConfig = unlines partialPlanConfig
planDataDirectory <- getOption "partialPlanDataDirectory"
partialPlanDataDirectory
pure Plan {..}
-- Returns 'True' if the 'PartialPlan' has a
-- 'Just' 'partialPlanInitDb'
hasInitDb :: PartialPlan -> Bool
hasInitDb PartialPlan {..} = isJust partialPlanInitDb
-- Returns 'True' if the 'PartialPlan' has a
-- 'Just' 'partialPlanCreateDb'
hasCreateDb :: PartialPlan -> Bool
hasCreateDb PartialPlan {..} = isJust partialPlanCreateDb
-- | 'Resources' holds a description of the temporary folders (if there are any)
-- and includes the final 'Plan' that can be used with 'startPlan'.
-- See 'setupConfig' for an example of how to create a 'Resources'.
data Resources = Resources
{ resourcesPlan :: Plan
-- ^ Final 'Plan'. See 'startPlan' for information on 'Plan's
, resourcesSocket :: SocketClass
-- ^ The 'SocketClass'. Used to track if a temporary directory was made
-- as the socket location.
, resourcesDataDir :: DirectoryType
-- ^ The data directory. Used to track if a temporary directory was used.
}
instance Pretty Resources where
pretty Resources {..}
= text "resourcePlan:"
<> softline
<> indent 2 (pretty resourcesPlan)
<> hardline
<> text "resourcesSocket:"
<+> pretty resourcesSocket
<> hardline
<> text "resourcesDataDir:"
<+> pretty resourcesDataDir
-- | Make the 'resourcesDataDir' 'Permanent' so it will not
-- get cleaned up.
makeResourcesDataDirPermanent :: Resources -> Resources
makeResourcesDataDirPermanent r = r
{ resourcesDataDir = makePermanent $ resourcesDataDir r
}
-- | The high level options for overriding default behavior.
data Config = Config
{ configPlan :: PartialPlan
-- ^ Extend or replace any of the configuration used to create a final
-- 'Plan'
, configSocket :: PartialSocketClass
-- ^ Override the default 'SocketClass' by setting this.
, configDataDir :: PartialDirectoryType
-- ^ Override the default temporary data directory by passing in
-- 'Permanent DIRECTORY'
, configPort :: Last (Maybe Int)
-- ^ A monoid for using an existing port (via 'Just PORT_NUMBER') or
-- requesting a free port (via a 'Nothing')
}
deriving stock (Generic)
deriving Semigroup via GenericSemigroup Config
deriving Monoid via GenericMonoid Config
instance Pretty Config where
pretty Config {..}
= text "configPlan:"
<> softline
<> pretty configPlan
<> hardline
<> text "configSocket:"
<> softline
<> pretty configSocket
<> hardline
<> text "configDataDir:"
<> softline
<> pretty configDataDir
<> hardline
<> text "configPort:" <+> pretty (getLast configPort)
-- | Create a 'PartialPlan' that sets the command line options of all processes
-- (@initdb@, @postgres@ and @createdb@) using a
toPlan
:: Bool
-- ^ Make @initdb@ options
-> Bool
-- ^ Make @createdb@ options
-> Int
-- ^ port
-> SocketClass
-- ^ Whether to listen on a IP address or UNIX domain socket
-> FilePath
-- ^ The @postgres@ data directory
-> PartialPlan
toPlan makeInitDb makeCreateDb port socketClass dataDirectory = mempty
{ partialPlanConfig = socketClassToConfig socketClass
, partialPlanDataDirectory = pure dataDirectory
, partialPlanPostgres = mempty
{ partialPostgresPlanProcessConfig = mempty
{ partialProcessConfigCmdLine = mempty
{ partialCommandLineArgsKeyBased = Map.fromList
[ ("-p", Just $ show port)
, ("-D", Just dataDirectory)
]
}
}
, partialPostgresPlanClientConfig = mempty
{ Client.host = pure $ socketClassToHost socketClass
, Client.port = pure port
, Client.dbname = pure "postgres"
}
}
, partialPlanCreateDb = if makeCreateDb
then pure $ mempty
{ partialProcessConfigCmdLine = mempty
{ partialCommandLineArgsKeyBased = Map.fromList $
socketClassToHostFlag socketClass <>
[("-p ", Just $ show port)]
}
}
else Nothing
, partialPlanInitDb = if makeInitDb
then pure $ mempty
{ partialProcessConfigCmdLine = mempty
{ partialCommandLineArgsKeyBased = Map.fromList $
[("--pgdata=", Just dataDirectory)]
}
}
else Nothing
}
-- | Create all the temporary resources from a 'Config'. This also combines the
-- 'PartialPlan' from 'toPlan' with the @extraConfig@ passed in.
setupConfig
:: Config
-- ^ @extraConfig@ to 'mappend' after the default config
-> IO Resources
setupConfig Config {..} = evalContT $ do
envs <- lift getEnvironment
port <- lift $ maybe getFreePort pure $ join $ getLast configPort
resourcesSocket <- ContT $ bracketOnError
(setupPartialSocketClass configSocket) cleanupSocketConfig
resourcesDataDir <- ContT $ bracketOnError
(setupDirectoryType "tmp-postgres-data" configDataDir) cleanupDirectoryType
let hostAndDirPartial = toPlan
(hasInitDb configPlan)
(hasCreateDb configPlan)
port
resourcesSocket
(toFilePath resourcesDataDir)
finalPlan = hostAndDirPartial <> configPlan
resourcesPlan <- lift $
either (throwIO . CompletePlanFailed (show $ pretty finalPlan)) pure $
completePlan envs finalPlan
pure Resources {..}
-- | Free the temporary resources created by 'setupConfig'
cleanupConfig :: Resources -> IO ()
cleanupConfig Resources {..} = do
cleanupSocketConfig resourcesSocket
cleanupDirectoryType resourcesDataDir
-------------------------------------------------------------------------------
-- Config Generation
-------------------------------------------------------------------------------
-- | Attempt to create a config from a 'Client.Options'. This is useful if
-- want to create a database owned by a specific user you will also log in as
-- among other use cases. It is possible some 'Client.Options' are not
-- supported so don't hesitate to open an issue on github if you find one.
optionsToConfig :: Client.Options -> Config
optionsToConfig opts@Client.Options {..}
= ( mempty
{ configPlan = optionsToPlan opts
, configPort = maybe (Last Nothing) (pure . pure) $ getLast port
, configSocket = maybe mempty hostToSocketClass $ getLast host
}
)
-- Convert the 'Client.Options' to a 'PartialPlan' that can
-- be connected to with the 'Client.Options'.
optionsToPlan :: Client.Options -> PartialPlan
optionsToPlan opts@Client.Options {..}
= maybe mempty dbnameToPlan (getLast dbname)
<> maybe mempty userToPlan (getLast user)
<> clientOptionsToPlan opts
-- Wrap the 'Client.Options' in an appropiate
-- 'PartialPostgresPlan'
clientOptionsToPlan :: Client.Options -> PartialPlan
clientOptionsToPlan opts = mempty
{ partialPlanPostgres = mempty
{ partialPostgresPlanClientConfig = opts
}
}
-- Create a 'PartialPlan' given a user
userToPlan :: String -> PartialPlan
userToPlan user = mempty
{ partialPlanCreateDb = pure $ mempty
{ partialProcessConfigCmdLine = mempty
{ partialCommandLineArgsKeyBased = Map.singleton "--username=" $ Just user
}
}
, partialPlanInitDb = pure $ mempty
{ partialProcessConfigCmdLine = mempty
{ partialCommandLineArgsKeyBased = Map.singleton "--username=" $ Just user
}
}
}
-- Adds a @createdb@ PartialProcessPlan with the argument
-- as the database name.
dbnameToPlan :: String -> PartialPlan
dbnameToPlan dbName = mempty
{ partialPlanCreateDb = pure $ mempty
{ partialProcessConfigCmdLine = mempty
{ partialCommandLineArgsIndexBased = Map.singleton 0 dbName
}
}
}
-- Parse a host string as either an UNIX domain socket directory
-- or a domain or IP.
hostToSocketClass :: String -> PartialSocketClass
hostToSocketClass hostOrSocketPath = case hostOrSocketPath of
'/' : _ -> PUnixSocket $ PPermanent hostOrSocketPath
_ -> PIpSocket $ pure hostOrSocketPath
-------------------------------------------------------------------------------
-- Lenses
-- Most this code was generated with microlens-th
-------------------------------------------------------------------------------
-- | Local Lens alias
type Lens s t a b = forall f. Functor f => (a -> f b) -> s -> f t
-- | Local Lens' alias
type Lens' s a = Lens s s a a
-- | Lens for 'partialEnvVarsInherit'
partialEnvVarsInheritL :: Lens' PartialEnvVars (Last Bool)
partialEnvVarsInheritL f_aj5e (PartialEnvVars x_aj5f x_aj5g)
= (fmap (\ y_aj5h -> (PartialEnvVars y_aj5h) x_aj5g))
(f_aj5e x_aj5f)
{-# INLINE partialEnvVarsInheritL #-}
-- | Lens for 'partialEnvVarsSpecific'
partialEnvVarsSpecificL :: Lens' PartialEnvVars (Map String String)
partialEnvVarsSpecificL f_aj5i (PartialEnvVars x_aj5j x_aj5k)
= (fmap (\ y_aj5l -> (PartialEnvVars x_aj5j) y_aj5l))
(f_aj5i x_aj5k)
{-# INLINE partialEnvVarsSpecificL #-}
-- | Lens for 'partialProcessConfigCmdLine'
partialProcessConfigCmdLineL ::
Lens' PartialProcessConfig PartialCommandLineArgs
partialProcessConfigCmdLineL
f_allv
(PartialProcessConfig x_allw x_allx x_ally x_allz x_allA)
= (fmap
(\ y_allB
-> ((((PartialProcessConfig x_allw) y_allB) x_ally) x_allz)
x_allA))
(f_allv x_allx)
{-# INLINE partialProcessConfigCmdLineL #-}
-- | Lens for 'partialProcessConfigEnvVars'
partialProcessConfigEnvVarsL ::
Lens' PartialProcessConfig PartialEnvVars
partialProcessConfigEnvVarsL
f_allC
(PartialProcessConfig x_allD x_allE x_allF x_allG x_allH)
= (fmap
(\ y_allI
-> ((((PartialProcessConfig y_allI) x_allE) x_allF) x_allG)
x_allH))
(f_allC x_allD)
{-# INLINE partialProcessConfigEnvVarsL #-}
-- | Lens for 'partialProcessConfigStdErr'
partialProcessConfigStdErrL ::
Lens' PartialProcessConfig (Last Handle)
partialProcessConfigStdErrL
f_allJ
(PartialProcessConfig x_allK x_allL x_allM x_allN x_allO)
= (fmap
(\ y_allP
-> ((((PartialProcessConfig x_allK) x_allL) x_allM) x_allN)
y_allP))
(f_allJ x_allO)
-- | Lens for 'partialProcessConfigStdIn'
{-# INLINE partialProcessConfigStdErrL #-}
partialProcessConfigStdInL ::
Lens' PartialProcessConfig (Last Handle)
partialProcessConfigStdInL
f_allQ
(PartialProcessConfig x_allR x_allS x_allT x_allU x_allV)
= (fmap
(\ y_allW
-> ((((PartialProcessConfig x_allR) x_allS) y_allW) x_allU)
x_allV))
(f_allQ x_allT)
{-# INLINE partialProcessConfigStdInL #-}
-- | Lens for 'partialProcessConfigStdOut'
partialProcessConfigStdOutL ::
Lens' PartialProcessConfig (Last Handle)
partialProcessConfigStdOutL
f_allX
(PartialProcessConfig x_allY x_allZ x_alm0 x_alm1 x_alm2)
= (fmap
(\ y_alm3
-> ((((PartialProcessConfig x_allY) x_allZ) x_alm0) y_alm3)
x_alm2))
(f_allX x_alm1)
{-# INLINE partialProcessConfigStdOutL #-}
-- | Lens for 'partialPostgresPlanClientConfig'
partialPostgresPlanClientConfigL ::
Lens' PartialPostgresPlan Client.Options
partialPostgresPlanClientConfigL
f_am1y
(PartialPostgresPlan x_am1z x_am1A)
= (fmap (\ y_am1B -> (PartialPostgresPlan x_am1z) y_am1B))
(f_am1y x_am1A)
{-# INLINE partialPostgresPlanClientConfigL #-}
-- | Lens for 'partialPostgresPlanProcessConfig'
partialPostgresPlanProcessConfigL ::
Lens' PartialPostgresPlan PartialProcessConfig
partialPostgresPlanProcessConfigL
f_am1C
(PartialPostgresPlan x_am1D x_am1E)
= (fmap (\ y_am1F -> (PartialPostgresPlan y_am1F) x_am1E))
(f_am1C x_am1D)
{-# INLINE partialPostgresPlanProcessConfigL #-}
-- | Lens for 'partialPlanConfig'
partialPlanConfigL :: Lens' PartialPlan [String]
partialPlanConfigL
f_amcw
(PartialPlan x_amcx x_amcy x_amcz x_amcA x_amcB x_amcC)
= (fmap
(\ y_amcD
-> (((((PartialPlan x_amcx) x_amcy) x_amcz) x_amcA) y_amcD)
x_amcC))
(f_amcw x_amcB)
{-# INLINE partialPlanConfigL #-}
-- | Lens for 'partialPlanCreateDb'
partialPlanCreateDbL ::
Lens' PartialPlan (Maybe PartialProcessConfig)
partialPlanCreateDbL
f_amcE
(PartialPlan x_amcF x_amcG x_amcH x_amcI x_amcJ x_amcK)
= (fmap
(\ y_amcL
-> (((((PartialPlan x_amcF) x_amcG) y_amcL) x_amcI) x_amcJ)
x_amcK))
(f_amcE x_amcH)
{-# INLINE partialPlanCreateDbL #-}
-- | Lens for 'partialPlanDataDirectory'
partialPlanDataDirectoryL :: Lens' PartialPlan (Last String)
partialPlanDataDirectoryL
f_amcM
(PartialPlan x_amcN x_amcO x_amcP x_amcQ x_amcR x_amcS)
= (fmap
(\ y_amcT
-> (((((PartialPlan x_amcN) x_amcO) x_amcP) x_amcQ) x_amcR)
y_amcT))
(f_amcM x_amcS)
{-# INLINE partialPlanDataDirectoryL #-}
-- | Lens for 'partialPlanInitDb'
partialPlanInitDbL ::
Lens' PartialPlan (Maybe PartialProcessConfig)
partialPlanInitDbL
f_amcU
(PartialPlan x_amcV x_amcW x_amcX x_amcY x_amcZ x_amd0)
= (fmap
(\ y_amd1
-> (((((PartialPlan x_amcV) y_amd1) x_amcX) x_amcY) x_amcZ)
x_amd0))
(f_amcU x_amcW)
{-# INLINE partialPlanInitDbL #-}
-- | Lens for 'partialPlanLogger'
partialPlanLoggerL :: Lens' PartialPlan (Last Logger)
partialPlanLoggerL
f_amd2
(PartialPlan x_amd3 x_amd4 x_amd5 x_amd6 x_amd7 x_amd8)
= (fmap
(\ y_amd9
-> (((((PartialPlan y_amd9) x_amd4) x_amd5) x_amd6) x_amd7)
x_amd8))
(f_amd2 x_amd3)
{-# INLINE partialPlanLoggerL #-}
-- | Lens for 'partialPlanPostgres'
partialPlanPostgresL :: Lens' PartialPlan PartialPostgresPlan
partialPlanPostgresL
f_amda
(PartialPlan x_amdb x_amdc x_amdd x_amde x_amdf x_amdg)
= (fmap
(\ y_amdh
-> (((((PartialPlan x_amdb) x_amdc) x_amdd) y_amdh) x_amdf)
x_amdg))
(f_amda x_amde)
{-# INLINE partialPlanPostgresL #-}
-- | Lens for 'resourcesDataDir'
resourcesDataDirL :: Lens' Resources DirectoryType
resourcesDataDirL f_ampd (Resources x_ampe x_ampf x_ampg)
= (fmap (\ y_amph -> ((Resources x_ampe) x_ampf) y_amph))
(f_ampd x_ampg)
{-# INLINE resourcesDataDirL #-}
-- | Lens for 'resourcesPlan'
resourcesPlanL :: Lens' Resources Plan
resourcesPlanL f_ampi (Resources x_ampj x_ampk x_ampl)
= (fmap (\ y_ampm -> ((Resources y_ampm) x_ampk) x_ampl))
(f_ampi x_ampj)
{-# INLINE resourcesPlanL #-}
-- | Lens for 'resourcesSocket'
resourcesSocketL :: Lens' Resources SocketClass
resourcesSocketL f_ampn (Resources x_ampo x_ampp x_ampq)
= (fmap (\ y_ampr -> ((Resources x_ampo) y_ampr) x_ampq))
(f_ampn x_ampp)
{-# INLINE resourcesSocketL #-}
-- | Lens for 'configDataDir'
configDataDirL :: Lens' Config PartialDirectoryType
configDataDirL f_amyD (Config x_amyE x_amyF x_amyG x_amyH)
= (fmap (\ y_amyI -> (((Config x_amyE) x_amyF) y_amyI) x_amyH))
(f_amyD x_amyG)
{-# INLINE configDataDirL #-}
-- | Lens for 'configPlan'
configPlanL :: Lens' Config PartialPlan
configPlanL f_amyJ (Config x_amyK x_amyL x_amyM x_amyN)
= (fmap (\ y_amyO -> (((Config y_amyO) x_amyL) x_amyM) x_amyN))
(f_amyJ x_amyK)
{-# INLINE configPlanL #-}
-- | Lens for 'configPort'
configPortL :: Lens' Config (Last (Maybe Int))
configPortL f_amyP (Config x_amyQ x_amyR x_amyS x_amyT)
= (fmap (\ y_amyU -> (((Config x_amyQ) x_amyR) x_amyS) y_amyU))
(f_amyP x_amyT)
{-# INLINE configPortL #-}
-- | Lens for 'configSocket'
configSocketL :: Lens' Config PartialSocketClass
configSocketL f_amyV (Config x_amyW x_amyX x_amyY x_amyZ)
= (fmap (\ y_amz0 -> (((Config x_amyW) y_amz0) x_amyY) x_amyZ))
(f_amyV x_amyX)
{-# INLINE configSocketL #-}
-- | Lens for 'partialCommandLineArgsIndexBased'
partialCommandLineArgsIndexBasedL ::
Lens' PartialCommandLineArgs (Map Int String)
partialCommandLineArgsIndexBasedL
f_amNr
(PartialCommandLineArgs x_amNs x_amNt)
= (fmap (\ y_amNu -> (PartialCommandLineArgs x_amNs) y_amNu))
(f_amNr x_amNt)
{-# INLINE partialCommandLineArgsIndexBasedL #-}
-- | Lens for 'partialCommandLineArgsKeyBased'
partialCommandLineArgsKeyBasedL ::
Lens' PartialCommandLineArgs (Map String (Maybe String))
partialCommandLineArgsKeyBasedL
f_amNv
(PartialCommandLineArgs x_amNw x_amNx)
= (fmap (\ y_amNy -> (PartialCommandLineArgs y_amNy) x_amNx))
(f_amNv x_amNw)
{-# INLINE partialCommandLineArgsKeyBasedL #-}