1 files changed, 15 insertions, 2 deletions

diff --git a/examples/dhtd.hs b/examples/dhtd.hs
index 6e2647d1..1aa36b77 100644
--- a/examples/dhtd.hs
+++ b/examples/dhtd.hs
@@ -94,6 +94,7 @@ import Data.Typeable
 import Network.Tox.ContactInfo as Tox
 import OnionRouter
 import PingMachine
+import Data.PacketQueue
 
 -- Presence imports.
 import ConsoleWriter
@@ -998,8 +999,20 @@ newXmmpSource session = do
                                  newXmmpSource session
 
 newXmmpSink :: Tox.NetCryptoSession -> C.Sink (Flush Tox.CryptoMessage) IO ()
-newXmmpSink sessions = C.awaitForever $ \flush_cyptomessage -> do
-    liftIO $ (_todo sessions {- send the fucking message -}) flush_cyptomessage
+newXmmpSink session@(Tox.NCrypto { ncOutgoingQueue, ncPacketQueue }) = C.awaitForever $ \flush_cyptomessage -> do
+    let sendit :: Tox.NetCryptoSession -> Flush Tox.CryptoMessage -> IO ()
+        sendit session (Chunk msg) = do
+            extra <- readyOutGoing ncOutgoingQueue
+            r <- atomically $ do
+                rTry <- tryAppendQueueOutgoing extra ncOutgoingQueue msg
+                case rTry of
+                    OGFull -> retry
+                    OGSuccess -> return OGSuccess
+                    OGEncodeFail -> return OGEncodeFail
+            when (r == OGEncodeFail) $
+                hPutStrLn stderr ("FAILURE to Encode Outgoing: " ++ show msg)
+        sendit session Flush = return ()
+    liftIO $ sendit session flush_cyptomessage
 
 -- | TODO
 --