keiro-dsl-0.10.0.0: test/conformance-aggregate-scalars/Generated/AggregateScalars/ScalarLedger/Codec.hs
{-# LANGUAGE OverloadedRecordDot #-}
-- @generated by keiro-dsl 0.9.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.List.NonEmpty qualified as NonEmpty
import Data.Text (Text)
import qualified Data.Text as T
import Keiro.Codec (Codec (..), EventType (..))
scalarLedgerEventTypes :: NonEmpty EventType
scalarLedgerEventTypes = EventType "ScalarsRecorded" :| []
scalarLedgerCodec :: Codec ScalarLedgerEvent
scalarLedgerCodec =
Codec
{ eventTypes = scalarLedgerEventTypes
, 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: " <> _renderEventTypes scalarLedgerEventTypes)
mapLeftText :: Either String b -> Either Text b
mapLeftText = either (Left . T.pack) Right
_renderEventTypes :: NonEmpty EventType -> String
_renderEventTypes =
T.unpack
. T.intercalate ", "
. map (\(EventType eventTypeName) -> eventTypeName)
. NonEmpty.toList