Codec.hs

{-# LANGUAGE OverloadedRecordDot #-}

-- @generated by keiro-dsl 0.8.0.0 (language keiro-dsl 3) from aggregate OrderBook; do not edit.
module Generated.IdDomainMigration.OrderBook.Codec
  ( orderBookCodec,
    parseOrderBookEvent,
    encodeOrderBookEvent,
  )
where

import Data.Aeson (Value, object, withObject, withText, (.:), (.=))
import Data.Aeson.Types (Parser, explicitParseField, parseEither)
import Data.List.NonEmpty (NonEmpty (..))
import Data.Text (Text)
import Data.Text qualified as T
import Generated.IdDomainMigration.Nominals (OrderId, orderIdText)
import Generated.IdDomainMigration.Nominals.Internal (unsafeOrderIdFromLegacyText)
import Generated.IdDomainMigration.OrderBook.Domain
import Keiro.Codec (Codec (..), EventType (..))

orderBookCodec :: Codec OrderBookEvent
orderBookCodec =
  Codec
    { eventTypes = EventType "OrderRecorded" :| [],
      eventType = \case
        OrderRecorded {} -> EventType "OrderRecorded",
      schemaVersion = 1,
      encode = encodeOrderBookEvent,
      decode = parseOrderBookEvent,
      upcasters = []
    }

encodeOrderBookEvent :: OrderBookEvent -> Value
encodeOrderBookEvent = \case
  OrderRecorded payload ->
    object
      [ "kind" .= ("OrderRecorded" :: Text),
        "orderId" .= orderIdText payload.orderId
      ]

parseOrderBookEvent :: EventType -> Value -> Either Text OrderBookEvent
parseOrderBookEvent (EventType tag) = mapLeftText . parseEither (withObject "OrderBookEvent" go)
  where
    go o = do
      case tag of
        "OrderRecorded" ->
          OrderRecorded
            <$> ( OrderRecordedData
                    <$> (unsafeOrderIdFromLegacyText <$> o .: "orderId")
                )
        _ -> fail ("unknown event type " <> show tag <> "; expected one of: OrderRecorded")

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