{-# LANGUAGE NoMonomorphismRestriction #-} import Conduit as C import qualified Data.Conduit.List as CL import Data.Dependent.Sum import Data.Function import Data.Text (Text) import Data.XML.Types as XML import Crypto.Tox import Data.Tox.Msg as Tox import Network.Tox.NodeId import ToxToXMPP import Network.Address storeInvite :: Monad m => Int -> Maybe Text -> Invite -> m () storeInvite _ _ _ = return () me :: PublicKey me = id2key $ read "mb8x36b1oxgj1shbdy6dfj96pu6hdruy6cc49ykzdd3fb6wguwfe" them :: PublicKey them = id2key $ read "y4t5janwehaqb9ayc57cgxzc1c4hrmdzuybj6yatskhx8bdp1cys" pipe :: Monad m => ConduitM (Int,Tox.CryptoMessage) XML.Event m () pipe = toxToXmpp storeInvite localhost4 me (xmppHostname them) onlines = CL.replicate 50000 (1, Pkt USERSTATUS ==> Online) main = do runConduit $ onlines .| pipe .| CL.mapM_ print return ()