Codec.hs

{-# LANGUAGE OverloadedRecordDot #-}
-- @generated by keiro-dsl 0.12.0.0 (language keiro-dsl 5) from aggregate Shipments; do not edit.
module Generated.CatalogDemo.Shipments.Codec (
    shipmentsCodec,
    parseShipmentsEvent,
    encodeShipmentsEvent,
) where

import Generated.CatalogDemo.Shipments.Domain
import Data.Aeson (Value, object, toJSON, withObject, (.:), (.=))
import Data.Aeson.Types (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 (..))

import CatalogDemo.MappedDomain ()





shipmentsEventTypes :: NonEmpty EventType
shipmentsEventTypes = EventType "ShipmentRecorded" :| []

shipmentsCodec :: Codec ShipmentsEvent
shipmentsCodec =
  Codec
    { eventTypes = shipmentsEventTypes
    , eventType = \case
        ShipmentRecorded{} -> EventType "ShipmentRecorded"
    , schemaVersion = 1
    , encode = encodeShipmentsEvent
    , decode = parseShipmentsEvent
    , upcasters = []
    }

encodeShipmentsEvent :: ShipmentsEvent -> Value
encodeShipmentsEvent = \case
  ShipmentRecorded payload ->
    object
      [ "kind" .= ("ShipmentRecorded" :: Text)
      , "sharedReference" .= toJSON payload.sharedReference
      , "accepted" .= payload.accepted
      ]

parseShipmentsEvent :: EventType -> Value -> Either Text ShipmentsEvent
parseShipmentsEvent (EventType tag) = mapLeftText . parseEither (withObject "ShipmentsEvent" go)
  where
    go o = do
      case tag of
        "ShipmentRecorded" ->
          ShipmentRecorded
            <$> ( ShipmentRecordedData
                    <$> o .: "sharedReference"
                    <*> o .: "accepted"
                )
        _ -> fail ("unknown event type " <> show tag <> "; expected one of: " <> renderExpectedEventTypes shipmentsEventTypes)

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

renderExpectedEventTypes :: NonEmpty EventType -> String
renderExpectedEventTypes =
  T.unpack
    . T.intercalate ", "
    . map (\(EventType eventTypeName) -> eventTypeName)
    . NonEmpty.toList