|
|
|
|
@ -59,13 +59,15 @@ startBot conf = do
@@ -59,13 +59,15 @@ startBot conf = do
|
|
|
|
|
mTrade <- eitherDecode' . BL.fromStrict <$> receive sock |
|
|
|
|
send sock [] $ encodeUtf8 "{ \"response\" : \"ok\" }" |
|
|
|
|
case mTrade of |
|
|
|
|
Right trade -> do |
|
|
|
|
Right (trade@(TradeSinkTrade{..})) -> do |
|
|
|
|
|
|
|
|
|
debugM "ATradeBot.TradeSink" $ "Incoming trade: " ++ show trade |
|
|
|
|
forM_ (cTargetUsers conf) $ \username -> do |
|
|
|
|
r <- sendMessage (message { messageTo = jidFromText username, messagePayload = toXml . messageForTrade $ trade }) sess |
|
|
|
|
case r of |
|
|
|
|
Left err -> warningM "ATradeBot" (show err) |
|
|
|
|
_ -> return () |
|
|
|
|
Right _ -> return () |
|
|
|
|
Left err -> warningM "ATradeBot.TradeSink" $ "Error: " ++ show err |
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|