module Network.Xmpp.Concurrent.Presence where
import Control.Concurrent.STM
import Network.Xmpp.Types
import Network.Xmpp.Concurrent.Types
import Network.Xmpp.Concurrent.Basic
pullPresence :: Session -> IO (Either PresenceError Presence)
pullPresence session = do
stanza <- atomically . readTChan $ stanzaCh session
case stanza of
PresenceS p -> return $ Right p
PresenceErrorS e -> return $ Left e
_ -> pullPresence session
waitForPresence :: (Presence -> Bool) -> Session -> IO Presence
waitForPresence f session = do
s <- pullPresence session
case s of
Left _ -> waitForPresence f session
Right m | f m -> return m
| otherwise -> waitForPresence f session
sendPresence :: Presence -> Session -> IO Bool
sendPresence p session = sendStanza (PresenceS p) session