Properly parse command replies

src/EuphApi/Connection.hs

@@ -63,6 +63,7 @@ import           Control.Concurrent.Async
 import           Control.Concurrent.STM
 import           Control.Monad.Trans.State
 import           Data.Aeson
+import           Data.Aeson.Types
 import qualified Data.ByteString.Lazy      as BS
 import qualified Data.HashMap.Strict       as HM
 import qualified Data.Map                  as M
@@ -189,13 +190,16 @@ sendThread euphCon qRecv con = do
 
 data PacketInfo = PacketInfo
   { infoPacketID :: Maybe PacketID
-  , infoServerError :: Maybe T.Text
+  , infoData     :: Either T.Text Value
   } deriving (Show)
 
 instance FromJSON PacketInfo where
   parseJSON = withObject "packet" $ \o -> do
     infoPacketID    <- o .:? "id"
-    infoServerError <- o .:? "error"
+    packetData <- o .:? "data"
+    infoData <- case packetData of
+      Nothing -> Left <$> o .: "error"
+      Just d  -> return $ Right d
     return PacketInfo{..}
 
 -- TODO: Swap for HashMap?
@@ -217,16 +221,16 @@ processPacket qEvent bs = do
         PacketInfo{..} <- decode bs
         replyID <- infoPacketID
         replyMVar <- M.lookup replyID replies
-        return (replyID, replyMVar, infoServerError)
+        return (replyID, replyMVar, infoData)
   -- ... and then write the appropriate result into the MVar.
-  whenJust result $ \(replyID, ReplyMVar var, serverError) -> do
+  whenJust result $ \(replyID, ReplyMVar var, infoData) -> do
     modify (M.delete replyID)
-    case serverError of
+    case infoData of
-      Just e -> liftIO $ putMVar var (Left (EuphServerError e))
+      Left e  -> liftIO $ putMVar var (Left (EuphServerError e))
-      Nothing ->
+      Right d ->
-        case decode bs of
+        case parseEither parseJSON d of
-          Nothing -> liftIO $ putMVar var (Left EuphParse)
+          Left e  -> liftIO $ putMVar var (Left $ EuphParse e bs)
-          Just r  -> liftIO $ putMVar var (Right r)
+          Right r -> liftIO $ putMVar var (Right r)
 
 processRecv :: RecvQueue -> EventQueue -> StateT Awaiting IO ()
 processRecv qRecv qEvent = do
@@ -436,14 +440,14 @@ data EuphException = EuphClosed
                      -- ^ Disconnected from server while waiting for the reply.
                    | EuphServerError T.Text
                      -- ^ The server replied with an error.
-                   | EuphParse
+                   | EuphParse String BS.ByteString
                      -- ^ Could not parse the server's reply correctly.
 
 instance Show EuphException where
   show EuphClosed           = "Connection already closed"
   show EuphDisconnected     = "Disconnected from server"
   show (EuphServerError t)  = "Server error: " ++ T.unpack t
-  show EuphParse           = "Parsing failed"
+  show (EuphParse e bs)     = "Parsing failed: " ++ e ++ " - packet was " ++ show bs
 
 instance Exception EuphException
 

src/EuphApi/Types.hs

@@ -84,7 +84,7 @@ data Message = Message
     -- ^ The unix timestamp of when the message was posted
   , msgSender    :: SessionView
     -- ^ The view of the sender's session
-  , msgContent   :: String
+  , msgContent   :: T.Text
     -- ^ The content of the message (client-defined)
   , msgEdited    :: Maybe UTCTime
     -- ^ The unix timestamp of when the message was last edited