diff options
Diffstat (limited to 'dht/src/Network/Tox/DHT/Handlers.hs')
-rw-r--r-- | dht/src/Network/Tox/DHT/Handlers.hs | 8 |
1 files changed, 4 insertions, 4 deletions
diff --git a/dht/src/Network/Tox/DHT/Handlers.hs b/dht/src/Network/Tox/DHT/Handlers.hs index 7806da78..dc4ca5fa 100644 --- a/dht/src/Network/Tox/DHT/Handlers.hs +++ b/dht/src/Network/Tox/DHT/Handlers.hs | |||
@@ -353,7 +353,7 @@ ping client addr = do | |||
353 | dput XPing $ show addr ++ " <-- ping" | 353 | dput XPing $ show addr ++ " <-- ping" |
354 | reply <- QR.sendQuery client (serializer PingType DHTPing unpong) Ping addr | 354 | reply <- QR.sendQuery client (serializer PingType DHTPing unpong) Ping addr |
355 | dput XPing $ show addr ++ " -pong-> " ++ show reply | 355 | dput XPing $ show addr ++ " -pong-> " ++ show reply |
356 | maybe (return False) (\Pong -> return True) $ join reply | 356 | maybe (return False) (\Pong -> return True) $ join $ resultToMaybe reply |
357 | 357 | ||
358 | 358 | ||
359 | saveCookieKey :: TVar [(SockAddr, (Int, PublicKey))] -> SockAddr -> PublicKey -> STM () | 359 | saveCookieKey :: TVar [(SockAddr, (Int, PublicKey))] -> SockAddr -> PublicKey -> STM () |
@@ -396,7 +396,7 @@ cookieRequest crypto client localUserKey addr = do | |||
396 | reply <- QR.sendQuery client cookieSerializer cookieRequest addr | 396 | reply <- QR.sendQuery client cookieSerializer cookieRequest addr |
397 | runlast | 397 | runlast |
398 | dput XNetCrypto $ show addr ++ " -cookieResponse-> " ++ show reply | 398 | dput XNetCrypto $ show addr ++ " -cookieResponse-> " ++ show reply |
399 | return $ join reply | 399 | return $ join $ resultToMaybe reply |
400 | 400 | ||
401 | unCookie :: DHTMessage t -> Maybe (t (Cookie Encrypted)) | 401 | unCookie :: DHTMessage t -> Maybe (t (Cookie Encrypted)) |
402 | unCookie (DHTCookie n24 fcookie) = Just fcookie | 402 | unCookie (DHTCookie n24 fcookie) = Just fcookie |
@@ -415,7 +415,7 @@ getNodes client cbvar nid addr = do | |||
415 | -- dput XMisc $ show addr ++ " <-- getnodes " ++ show nid | 415 | -- dput XMisc $ show addr ++ " <-- getnodes " ++ show nid |
416 | reply <- QR.sendQuery client (serializer GetNodesType DHTGetNodes unsendNodes) (GetNodes nid) addr | 416 | reply <- QR.sendQuery client (serializer GetNodesType DHTGetNodes unsendNodes) (GetNodes nid) addr |
417 | -- dput XMisc $ show addr ++ " -sendnodes-> " ++ show reply | 417 | -- dput XMisc $ show addr ++ " -sendnodes-> " ++ show reply |
418 | forM_ (join reply) $ \(SendNodes ns) -> | 418 | forM_ (join $ resultToMaybe reply) $ \(SendNodes ns) -> |
419 | forM_ ns $ \n -> do | 419 | forM_ ns $ \n -> do |
420 | now <- getPOSIXTime | 420 | now <- getPOSIXTime |
421 | atomically $ do | 421 | atomically $ do |
@@ -423,7 +423,7 @@ getNodes client cbvar nid addr = do | |||
423 | forM_ mcbs $ \cbs -> do | 423 | forM_ mcbs $ \cbs -> do |
424 | forM_ cbs $ \cb -> do | 424 | forM_ cbs $ \cb -> do |
425 | rumoredAddress cb now addr (udpNodeInfo n) | 425 | rumoredAddress cb now addr (udpNodeInfo n) |
426 | return $ fmap unwrapNodes $ join reply | 426 | return $ fmap unwrapNodes $ join $ resultToMaybe reply |
427 | 427 | ||
428 | getNodesUDP :: Client -> TVar (HashMap NodeId [NodeInfoCallback]) -> NodeId -> NodeInfo -> IO (Maybe ([NodeInfo],[NodeInfo],Maybe ())) | 428 | getNodesUDP :: Client -> TVar (HashMap NodeId [NodeInfoCallback]) -> NodeId -> NodeInfo -> IO (Maybe ([NodeInfo],[NodeInfo],Maybe ())) |
429 | getNodesUDP client cbvar nid addr = getNodes client cbvar nid (Multi.UDP ==> addr) | 429 | getNodesUDP client cbvar nid addr = getNodes client cbvar nid (Multi.UDP ==> addr) |