Message.hs

-- | Define a continuous integration system.
module Development.Bake.Message(
    Message(..), Reply(..), sendMessage, fromPayload
    ) where

import Development.Bake.Type
import Development.Bake.Web

data Message
    -- Send by the user
    = AddPatch Author Patch
    | DelPatch Author Patch
    | DelAllPatches Author
    | Pause Author
    | Unpause Author
    -- Sent by the client
    | Ping Author String String [String] Int -- name, cookie, provides, threads
    | Finished (Candidate State Patch) String (Maybe Test) String Double (Either Int [Test])
                                       -- stdout time   result

data Reply = Reply (Candidate State Patch) (Maybe Test)

toPayload :: Message -> Payload
toPayload = undefined


fromPayload :: Payload -> Message
fromPayload = undefined


sendMessage :: (Host,Port) -> Message -> IO [Reply]
sendMessage hp msg = do
    send hp $ toPayload msg
    return []