Codec.hs

{-# LANGUAGE OverloadedRecordDot #-}
-- @generated by keiro-dsl 0.8.0.0 (language keiro-dsl 4) from aggregate ScalarLedger; do not edit.
module Generated.AggregateScalars.ScalarLedger.Codec (
    scalarLedgerCodec,
    parseScalarLedgerEvent,
    encodeScalarLedgerEvent,
) where

import Generated.AggregateScalars.ScalarLedger.Domain
import Data.Aeson (Value, object, withObject, withText, (.:), (.=))
import Data.Aeson.Types (Parser, explicitParseField, parseEither)
import Data.List.NonEmpty (NonEmpty (..))
import Data.Text (Text)
import qualified Data.Text as T
import Keiro.Codec (Codec (..), EventType (..))





scalarLedgerCodec :: Codec ScalarLedgerEvent
scalarLedgerCodec =
  Codec
    { eventTypes = EventType "ScalarsRecorded" :| []
    , eventType = \case
        ScalarsRecorded{} -> EventType "ScalarsRecorded"
    , schemaVersion = 1
    , encode = encodeScalarLedgerEvent
    , decode = parseScalarLedgerEvent
    , upcasters = []
    }

encodeScalarLedgerEvent :: ScalarLedgerEvent -> Value
encodeScalarLedgerEvent = \case
  ScalarsRecorded payload ->
    object
      [ "kind" .= ("ScalarsRecorded" :: Text)
      , "observedAt" .= payload.observedAt
      , "revision" .= payload.revision
      ]

parseScalarLedgerEvent :: EventType -> Value -> Either Text ScalarLedgerEvent
parseScalarLedgerEvent (EventType tag) = mapLeftText . parseEither (withObject "ScalarLedgerEvent" go)
  where
    go o = do
      case tag of
        "ScalarsRecorded" ->
          ScalarsRecorded
            <$> ( ScalarsRecordedData
                    <$> o .: "observedAt"
                    <*> o .: "revision"
                )
        _ -> fail ("unknown event type " <> show tag <> "; expected one of: ScalarsRecorded")

mapLeftText :: Either String b -> Either Text b
mapLeftText = either (Left . T.pack) Right