packages feed

keiro-dsl-0.6.0.0: test/conformance-aggregate-scalars/Generated/AggregateScalars/ScalarLedger/Codec.hs

{-# LANGUAGE OverloadedRecordDot #-}

-- @generated by keiro-dsl; do not edit. Regenerated from the .keiro spec.
module Generated.AggregateScalars.ScalarLedger.Codec (
    scalarLedgerCodec,
    parseScalarLedgerEvent,
    encodeScalarLedgerEvent,
) where

import Data.Aeson (Value, object, withObject, (.:), (.=))
import Data.Aeson.Types (Parser, parseEither)
import Data.List.NonEmpty (NonEmpty (..))
import Data.Text (Text)
import qualified Data.Text as T
import Generated.AggregateScalars.ScalarLedger.Domain
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"

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