angel-0.4.2: Angel/Data.hs

module Angel.Data where

import qualified Data.Map as M
import System.Process (createProcess, proc, waitForProcess, ProcessHandle)
import System.Process (terminateProcess, CreateProcess(..), StdStream(..))
import Control.Concurrent.STM.TChan (TChan)
import System.IO (Handle)

-- |the whole shared state of the program; spec is what _should_
-- |be running, while running is what actually _is_ running_ currently
data GroupConfig = GroupConfig {
    spec :: SpecKey,
    running :: RunKey,
    fileRequest :: TChan FileRequest
}

-- |map program ids to relevant structure
type SpecKey = M.Map ProgramId Program
type RunKey = M.Map ProgramId (Program, Maybe ProcessHandle)
type ProgramId = String
type FileRequest = (String, TChan (Maybe Handle))

-- |the representation of a program is these 6 values, 
-- |read from the config file
data Program = Program {
    name :: String,
    exec :: Maybe String,
    delay :: Maybe Int,
    stdout :: Maybe String,
    stderr :: Maybe String,
    workingDir :: Maybe FilePath,
    logExec :: Maybe String,
    pidFile :: Maybe FilePath
} deriving (Show, Eq, Ord)

-- |Lower-level atoms in the configuration process
type Spec = [Program]

-- |a template for an empty program; the variable set to ""
-- |are required, and must be overridden in the config file
defaultProgram = Program "" Nothing Nothing Nothing Nothing Nothing Nothing Nothing
defaultDelay = 5 :: Int
defaultStdout = "/dev/null"
defaultStderr = "/dev/null"