R/sns-events.R

In mdneuzerling/lambdr: Create a Runtime for Serving Containerised R Functions on 'AWS Lambda'

#' Determine if a Lambda event is coming from SNS
#'
#' See \url{https://docs.aws.amazon.com/lambda/latest/dg/with-sns.html}
#' for more information.
#'
#' @param event_content
#'
#' @return logical
#' @keywords internal
is_sns_event_content <- function(event_content) {
  grepl('"EventSource": "aws:sns"', event_content)
}

#' @export
parse_event_content.sns_event <- function(event, ...) {
  message <- jsonlite::fromJSON(event$event_content)[["Records"]][["Sns"]][["Message"]]
  if (jsonlite::validate(message)) {
    jsonlite::fromJSON(message)
  } else {
    message
  }
}