Skip to content

Commit

Permalink
Add logging statements
Browse files Browse the repository at this point in the history
  • Loading branch information
lindseydew committed Feb 29, 2024
1 parent 7fde09a commit 55549e0
Showing 1 changed file with 12 additions and 9 deletions.
Original file line number Diff line number Diff line change
Expand Up @@ -10,21 +10,24 @@ import coml.gu.sfl.userdeletion.db.SflDynamoDb
import scala.collection.JavaConverters._

object UserDeletionLambda extends Logging {
val saveForLaterApp = Option(System.getenv("SaveForLaterApp")).getOrElse(sys.error("No main app name configured"))
val stage = Option(System.getenv("Stage")).getOrElse(sys.error("No main stage configured"))
val saveForLaterApp = Option(System.getenv("SaveForLaterApp"))
.getOrElse(sys.error("No main app name configured"))
val stage = Option(System.getenv("Stage"))
.getOrElse(sys.error("No main stage configured"))

val sflDyanamo = new SflDynamoDb(PersistenceConfig(saveForLaterApp, stage))

def handler(sQSEvent: SQSEvent) {
val messages = sQSEvent.getRecords.asScala.map(mes => mes).toList
logger.info(s"Recieved: ${messages.size} mesages")
messages.map{
m =>
val body = m.getBody
logger.debug(s"Message body: ${body}")
val node = mapper.readTree(body)
val user = mapper.readValue[UserDeleteMessage](node.get("Message").asText())
sflDyanamo.deleteSavedArticleasForUser(user)
logger.info(messages)
messages.map { m =>
val body = m.getBody
logger.info(s"Message body: ${body}")
val node = mapper.readTree(body)
val user =
mapper.readValue[UserDeleteMessage](node.get("Message").asText())
sflDyanamo.deleteSavedArticleasForUser(user)
}
}
}

0 comments on commit 55549e0

Please sign in to comment.