simple fedmsg haskell thingy

fedmsg.hs

module Main where
import System.ZMQ
import Control.Monad (replicateM, forever)
import qualified Data.ByteString
import Text.Printf

type Topics = [String]
type MessageHandler = (Data.ByteString.ByteString -> IO ())

subscribeTopics :: SubsType a => Topics -> Socket a -> IO ()
subscribeTopics topics sock = mapM_ (subscribe sock) topics

ingestMessages :: SubsType a => Socket a -> MessageHandler -> IO ()
ingestMessages socket handler = forever $ receive socket [] >>= handler

connectSocket :: String -> Topics -> Context -> IO ()
connectSocket endpoint topics context= withSocket context Sub $ \subscriber -> do
    putStrLn $ "Connecting to " ++ endpoint
    connect subscriber endpoint
    subscribeTopics topics subscriber
    ingestMessages subscriber Data.ByteString.putStrLn

startContext :: String -> 
startContext = withContext 1 $ connectSocket 
main :: IO ()
main = do
    withContext 1 $ theThings "tcp://hub.fedoraproject.org:9940" [""]