Codec.hs

{-# LANGUAGE OverloadedRecordDot #-}
-- @generated by keiro-dsl 0.9.0.0 (language keiro-dsl 4) from aggregate Subscription; do not edit.
module Generated.Billing.Subscription.Codec (
    subscriptionCodec,
    parseSubscriptionEvent,
    encodeSubscriptionEvent,
) where

import Generated.Billing.Subscription.Domain
import Generated.Billing.Nominals (CustomerId, customerIdText, Plan (..), planText, SubscriptionId, subscriptionIdText)
import Generated.Billing.Nominals.Internal (unsafeCustomerIdFromLegacyText, unsafeSubscriptionIdFromLegacyText)
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 (..))


parsePlan :: Text -> Parser Plan
parsePlan = \case
  "paid" -> pure Paid
  "free" -> pure Free
  tag -> fail ("unknown Plan " <> show tag <> "; expected one of: paid, free")


subscriptionEventTypes :: NonEmpty EventType
subscriptionEventTypes = EventType "SubscriptionActivated" :| [EventType "SubscriptionCancelled"]

subscriptionCodec :: Codec SubscriptionEvent
subscriptionCodec =
  Codec
    { eventTypes = subscriptionEventTypes
    , eventType = \case
        SubscriptionActivated{} -> EventType "SubscriptionActivated"
        SubscriptionCancelled{} -> EventType "SubscriptionCancelled"
    , schemaVersion = 1
    , encode = encodeSubscriptionEvent
    , decode = parseSubscriptionEvent
    , upcasters = []
    }

encodeSubscriptionEvent :: SubscriptionEvent -> Value
encodeSubscriptionEvent = \case
  SubscriptionActivated payload ->
    object
      [ "kind" .= ("SubscriptionActivated" :: Text)
      , "subscriptionId" .= subscriptionIdText payload.subscriptionId
      , "customerId" .= customerIdText payload.customerId
      , "plan" .= planText payload.plan
      ]
  SubscriptionCancelled payload ->
    object
      [ "kind" .= ("SubscriptionCancelled" :: Text)
      , "subscriptionId" .= subscriptionIdText payload.subscriptionId
      , "customerId" .= customerIdText payload.customerId
      ]

parseSubscriptionEvent :: EventType -> Value -> Either Text SubscriptionEvent
parseSubscriptionEvent (EventType tag) = mapLeftText . parseEither (withObject "SubscriptionEvent" go)
  where
    go o = do
      case tag of
        "SubscriptionActivated" ->
          SubscriptionActivated
            <$> ( SubscriptionActivatedData
                    <$> (unsafeSubscriptionIdFromLegacyText <$> o .: "subscriptionId")
                    <*> (unsafeCustomerIdFromLegacyText <$> o .: "customerId")
                    <*> explicitParseField (withText "Plan" parsePlan) o "plan"
                )
        "SubscriptionCancelled" ->
          SubscriptionCancelled
            <$> ( SubscriptionCancelledData
                    <$> (unsafeSubscriptionIdFromLegacyText <$> o .: "subscriptionId")
                    <*> (unsafeCustomerIdFromLegacyText <$> o .: "customerId")
                )
        _ -> fail ("unknown event type " <> show tag <> "; expected one of: " <> _renderEventTypes subscriptionEventTypes)

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