app/services/notification/NotificationJob.scala

package services.notification

import org.joda.time.DateTime
import org.quartz.{Job, JobExecutionContext}
import play.api.Logging

import scala.concurrent.{Await, ExecutionContext}
import scala.concurrent.duration._

/** Quartz job wrapper for [[ScheduledNotificationRunner]] */
class NotificationJob extends Job with Logging {

  override def execute(context: JobExecutionContext): Unit = {
    val schedulerContext = context.getScheduler.getContext
    val scheduledNotificationRunner = schedulerContext
      .get("ScheduledNotificationRunner")
      .asInstanceOf[ScheduledNotificationRunner]
    implicit val ec =
      schedulerContext.get("ExecutionContext").asInstanceOf[ExecutionContext]
    val result = scheduledNotificationRunner.run(new DateTime())
    Await
      .result(result.asFuture, 10.minutes)
      .fold(
        err =>
          logger
            .error(s"Failed to send scheduled notifications: ${err.logString}"),
        { msgs =>
          logger.info(s"Email notifications: ${msgs.size} sent")
        }
      )
  }
}