Parse lines to Envelope type

Signed-off-by: Sasha Bogicevic <[email protected]>

Author: v0d1ch

hydra-node/exe/visualize-logs/Main.hs

@@ -1,12 +1,41 @@
+{-# LANGUAGE OverloadedRecordDot #-}
+
 module Main where
 
 import Hydra.Cardano.Api
-import Hydra.Prelude
+import Hydra.Prelude hiding (encodeUtf8)
 
+import Control.Lens ((^?))
+import Data.Aeson (eitherDecode')
+import Data.Aeson.Lens (key, _String)
+import Data.ByteString.Lazy.Char8 qualified as C8
+import Data.Text.Encoding (encodeUtf8)
+import Hydra.Logging (Envelope (..))
 import Hydra.Logging.Messages (HydraLog)
-import Hydra.Utils (readJsonFileThrow)
+import Hydra.Node (HydraNodeLog)
+
+data Decoded tx
+  = DecodedHydraLog (HydraLog tx)
+  | DecodedHydraNodeLog (HydraNodeLog tx)
+  deriving (Show)
 
 main :: IO ()
 main = do
-  results <- readJsonFileThrow parseJSON "devnet/alice-logs.txt" :: IO (Either String (HydraLog Tx))
+  logLines <- readFileLBS "../devnet/alice-logs.txt"
+  let allLogLines = zip [1 :: Int ..] (C8.lines logLines)
+  decodedLines <- forM allLogLines $ \(ix, l) ->
+    case l ^? key "message" . _String of
+      Nothing -> error "Failed to find key 'message' which was expected"
+      Just line ->
+        let envelope = fromStrict $ encodeUtf8 line
+         in case decodeAs envelope (undefined :: Envelope (HydraLog Tx)) of
+              Left e -> error $ "Line " <> show ix <> ": error - " <> show e <> " line: " <> show line
+              Right decoded -> pure $ DecodedHydraLog $ decoded.message
+  print decodedLines
   pure ()
+
+decodeAs :: forall a. FromJSON a => C8.ByteString -> a -> Either String a
+decodeAs l _ =
+  case eitherDecode' l :: Either String a of
+    Left e -> Left e
+    Right decoded -> pure decoded

hydra-node/hydra-node.cabal

@@ -252,14 +252,20 @@ executable visualize-logs
   hs-source-dirs: exe/visualize-logs
   main-is:        Main.hs
   build-depends:
+    , aeson
     , base
     , bytestring
+    , containers
     , hydra-cardano-api
     , hydra-node
     , hydra-prelude
+    , lens
+    , lens-aeson
+    , text
     , unix
 
   ghc-options:    -threaded -rtsopts -with-rtsopts=-N4
+
 benchmark tx-cost
   import:         project-config
   hs-source-dirs: bench/tx-cost

hydra-node/src/Hydra/Logging.hs

@@ -76,6 +76,14 @@ instance ToJSON a => ToJSON (Envelope a) where
         , "message" .= message
         ]
 
+instance FromJSON a => FromJSON (Envelope a) where
+  parseJSON = Aeson.withObject "Envelope" $ \o -> do
+    timestamp <- o Aeson..: "timestamp"
+    threadId <- o Aeson..: "threadId"
+    namespace <- o Aeson..: "namespace"
+    message <- o Aeson..: "message"
+    pure Envelope{timestamp, threadId, namespace, message}
+
 defaultQueueSize :: Natural
 defaultQueueSize = 500