|
|
|
@ -414,17 +414,15 @@ connectTcp host port hostname config = do |
|
|
|
((sourceHandle h $= logConduit) $= XP.parseBytes def) |
|
|
|
((sourceHandle h $= logConduit) $= XP.parseBytes def) |
|
|
|
(return ()) |
|
|
|
(return ()) |
|
|
|
let hand = StreamHandle { streamSend = \d -> do |
|
|
|
let hand = StreamHandle { streamSend = \d -> do |
|
|
|
let d64 = encode d |
|
|
|
|
|
|
|
debugM "Pontarius.Xmpp" $ |
|
|
|
debugM "Pontarius.Xmpp" $ |
|
|
|
"Sending TCP data: " ++ (BSC8.unpack d64) |
|
|
|
"Sending TCP data: " ++ (BSC8.unpack d) |
|
|
|
++ "." |
|
|
|
++ "." |
|
|
|
catchPush $ BS.hPut h d |
|
|
|
catchPush $ BS.hPut h d |
|
|
|
, streamReceive = \n -> do |
|
|
|
, streamReceive = \n -> do |
|
|
|
d <- BS.hGetSome h n |
|
|
|
d <- BS.hGetSome h n |
|
|
|
let d64 = encode d |
|
|
|
|
|
|
|
debugM "Pontarius.Xmpp" $ |
|
|
|
debugM "Pontarius.Xmpp" $ |
|
|
|
"Received TCP data: " ++ |
|
|
|
"Received TCP data: " ++ |
|
|
|
(BSC8.unpack d64) ++ "." |
|
|
|
(BSC8.unpack d) ++ "." |
|
|
|
return d |
|
|
|
return d |
|
|
|
, streamFlush = hFlush h |
|
|
|
, streamFlush = hFlush h |
|
|
|
, streamClose = hClose h |
|
|
|
, streamClose = hClose h |
|
|
|
|