From 9f4e2644188f985d7cd806c13e2c0dee1688b9f0 Mon Sep 17 00:00:00 2001
From: tv <tv@krebsco.de>
Date: Tue, 29 Jan 2019 20:49:47 +0100
Subject: Reaktor: add send delay support

---
 src/Reaktor.hs | 11 +++++++----
 1 file changed, 7 insertions(+), 4 deletions(-)

(limited to 'src/Reaktor.hs')

diff --git a/src/Reaktor.hs b/src/Reaktor.hs
index 042fcfe..0910e0b 100644
--- a/src/Reaktor.hs
+++ b/src/Reaktor.hs
@@ -86,7 +86,7 @@ run Config{..} getPlugins =
           receiver actions putInMsg sockRecv,
           logger cLogHandle takeLog,
           pinger aSend,
-          sender takeOutMsg sockSend,
+          sender cSendDelay takeOutMsg sockSend,
           splitter plugins takeInMsg
         ]
 
@@ -147,9 +147,12 @@ receiver Actions{..} putInMsg sockRecv =
           aLog $ SGR [38,5,235] "< " <> SGR [38,5,244] (Plain bs)
 
 
-sender :: IO Message -> (ByteString -> IO ()) -> IO ()
-sender takeOutMsg sockSend =
-    forever $ takeOutMsg >>= sockSend . T.encodeUtf8 . formatMessage
+sender :: Maybe Int -> IO Message -> (ByteString -> IO ()) -> IO ()
+sender cSendDelay takeOutMsg sockSend =
+    forever send
+  where
+    send = maybe send0 ((send0 >>) . threadDelay) cSendDelay
+    send0 = takeOutMsg >>= sockSend . T.encodeUtf8 . formatMessage
 
 splitter :: [Message -> IO ()] -> IO Message -> IO ()
 splitter plugins takeInMsg =
-- 
cgit v1.2.3