Packet request Thread, ready for testing

1 files changed, 7 insertions, 1 deletions

diff --git a/src/Network/Tox/Crypto/Handlers.hs b/src/Network/Tox/Crypto/Handlers.hs
index 356ddf24..1cb9c48e 100644
--- a/src/Network/Tox/Crypto/Handlers.hs
+++ b/src/Network/Tox/Crypto/Handlers.hs
@@ -755,7 +755,13 @@ runUponHandshake netCryptoSession0 addr pktoq = do
             atomically (readTVar (ncRequestInterval netCryptoSession0)) >>= threadDelay
             nums <- atomically $ PQ.getMissing pktq
             dput XNetCrypto $ "(Request Thread) Missing Packets detected:" ++ show nums
-            dput XNetCrypto $ "TODO: compose PacketRequest message and send it."
+            getOutGoingParam <- PQ.readyOutGoing pktoq
+            atomically $ do 
+                seqno <- PQ.getLastDequeuedPlus1 pktq
+                ogresult <- PQ.tryAppendQueueOutgoing getOutGoingParam pktoq (createRequestPacket seqno nums)
+                case ogresult of
+                    PQ.OGSuccess -> return ()
+                    _ -> retry
             loop
     dput XNetCrypto $ "runUponHandshake: " ++ show threadid ++ " = NetCryptoRequest." ++ show (key2id remotePublicKey) ++ sidStr
     -- launch dequeueOutgoing thread