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
}