def persistBakeEvent()

in app/event/Behaviours.scala [79:92]


  def persistBakeEvent(
      notificationConfig: Option[NotificationConfig]
  )(implicit dynamo: Dynamo, exec: ExecutionContext): Behavior[BakeEvent] =
    Behaviors.receiveMessage[BakeEvent] { message =>
      message match {
        case Log(_, bakeLog)           => BakeLogs.save(bakeLog)
        case AmiCreated(bakeId, amiId) => Bakes.updateAmiId(bakeId, amiId)
        case PackerProcessExited(bakeId, exitCode) =>
          val status =
            if (exitCode == 0) BakeStatus.Complete else BakeStatus.Failed
          Bake.updateStatusAndNotifyFailure(bakeId, status, notificationConfig)
      }
      Behaviors.same
    }