[notifications] fix for send

sendNonblocking threw an error initially. I just do a compromise and
timeout the normal send (which blocks infinitely sometimes)

src/Gargantext/Core/AsyncUpdates/CentralExchange.hs

@@ -29,7 +29,8 @@ import Gargantext.Core.AsyncUpdates.CentralExchange.Types
 import Gargantext.Core.Config.Types (NotificationsConfig(..))
 import Gargantext.Prelude
 import Gargantext.System.Logging (LogLevel(..), withLogger, logMsg)
-import Nanomsg (Pull(..), Push(..), bind, connect, recv, sendNonblocking, withSocket)
+import Nanomsg (Pull(..), Push(..), bind, connect, recv, send, withSocket)
+import System.Timeout (timeout)
     
 {-
 
@@ -74,7 +75,8 @@ gServer (NotificationsConfig { .. }) = do
             Just _ujp@(UpdateJobProgress _s) -> do
               -- logMsg ioLogger DEBUG $ "[central_exchange] " <> show ujp
               -- send the same message that we received
-              void $ sendNonblocking s_dispatcher r
+              -- void $ sendNonblocking s_dispatcher r
+              void $ timeout 100_000 $ send s_dispatcher r
             Just (UpdateTreeFirstLevel node_id) -> do
               logMsg ioLogger INFO $ "[central_exchange] update tree: " <> show node_id
               -- putText $ "[central_exchange] sending that to the dispatcher: " <> show node_id
@@ -92,7 +94,8 @@ gServer (NotificationsConfig { .. }) = do
               -- gargantext-server but maybe it can be a separate
               -- process, independent of the server.
               -- send the same message that we received
-              void $ sendNonblocking s_dispatcher r
+              -- void $ sendNonblocking s_dispatcher r
+              void $ timeout 100_000 $ send s_dispatcher r
             _ -> logMsg ioLogger DEBUG $ "[central_exchange] unknown message"
       
 
@@ -104,4 +107,6 @@ notify (NotificationsConfig { _nc_central_exchange_connect }) ceMessage = do
       let str = Aeson.encode ceMessage
       withLogger () $ \ioLogger ->
         logMsg ioLogger DEBUG $ "[central_exchange] sending: " <> (T.unpack $ TE.decodeUtf8 $ BSL.toStrict str)
-      void $ sendNonblocking s $ BSL.toStrict str
+      -- err <- sendNonblocking s $ BSL.toStrict str
+      -- putText $ "[notify] err: " <> show err
+      void $ timeout 100_000 $ send s $ BSL.toStrict str