in lambda/src/main/scala/pricemigrationengine/handlers/NotificationHandler.scala [397:418]
private def paymentFrequency(billingPeriod: String) =
ZIO
.fromOption(BillingPeriod.notificationPaymentFrequencyMapping.get(billingPeriod))
.orElseFail(EmailSenderFailure(s"No payment frequency mapping found for billing period: $billingPeriod"))
private def updateCohortItemStatus(subscriptionNumber: String, processingStage: CohortTableFilter) = {
for {
now <- Clock.instant
_ <-
CohortTable
.update(
CohortItem(
subscriptionName = subscriptionNumber,
processingStage = processingStage,
whenNotificationSent = Some(now)
)
)
.mapError { error =>
NotificationHandlerFailure(s"Failed set status CohortItem $subscriptionNumber to $processingStage: $error")
}
} yield ()
}