add simple CBOR importer

Author: mgmeier

timeseries-io/src/Cardano/Timeseries/Import/PlainCBOR.hs

@@ -0,0 +1,47 @@
+{-# LANGUAGE DeriveAnyClass #-}
+{-# LANGUAGE DeriveGeneric #-}
+{-# LANGUAGE LambdaCase #-}
+{-# LANGUAGE TypeSynonymInstances #-}
+
+{-# OPTIONS_GHC -Wno-type-defaults -Wno-orphans #-}
+
+module Cardano.Timeseries.Import.PlainCBOR where
+
+import           Codec.Serialise
+import           Control.Applicative
+import           Data.Map.Strict as Map (Map, size)
+import           Data.Text (Text, unpack)
+import           Data.Time.Clock.POSIX (POSIXTime)
+import           GHC.Generics (Generic)
+
+
+data NumericValue =
+    NVInt       Int
+  | NVDouble    Double
+  deriving (Generic, Show, Serialise)
+
+
+data Snapshot = Snapshot
+  { singletonLabel  :: Text
+  , timeStamp       :: POSIXTime
+  , scrape          :: Map Text NumericValue
+  }
+  deriving (Generic, Serialise)
+
+instance Show Snapshot where
+  show (Snapshot l t s) = "Snapshot{" ++ unpack l ++ "} @ " ++ show t ++ ", entries: " ++ show (Map.size s)
+
+
+instance Serialise POSIXTime where
+  encode = encode . toInteger . floor
+  decode = fromInteger <$> decode
+
+
+readFileSnapshots :: FilePath -> IO [Snapshot]
+readFileSnapshots = readFileDeserialise
+
+-- can be used with Data.List.sortBy
+snapshotOrd :: Snapshot -> Snapshot -> Ordering
+snapshotOrd a b =
+     singletonLabel a `compare` singletonLabel b
+  <> timeStamp a `compare` timeStamp b

timeseries-io/timeseries-io.cabal

@@ -69,6 +69,7 @@ executable timeseries-io
                    Cardano.Timeseries.Domain.Interval,
                    Cardano.Timeseries.Domain.Timeseries,
                    Cardano.Timeseries.Domain.Types,
+                   Cardano.Timeseries.Import.PlainCBOR,
                    Cardano.Timeseries.Query,
                    Cardano.Timeseries.Query.Expr,
                    Cardano.Timeseries.Query.Parser,
@@ -92,7 +93,9 @@ executable timeseries-io
                       attoparsec,
                       vector,
                       text,
+                      serialise,
                       statistics,
+                      time,
                       containers
 
     -- Directories containing source files.