ExampleSqsEventHandler.scala

package org.encalmo.lambda.example

import org.encalmo.aws.AwsClient
import org.encalmo.aws.AwsSqsApi
import org.encalmo.lambda.*
import upickle.default.*

object ExampleSqsEventHandler extends SqsEventHandler[AwsClient] {

  override def functionName: Option[String] = Some("SendTargetEvent")

  case class Event(name: String) derives ReadWriter

  override def handleRecord(record: SqsEvent.Record)(using LambdaContext, AwsClient): Option[String] = {
    println(record.body)
    record
      .maybeParseBodyAs[Event]
      .map(sendTargetEvent)
  }

  def sendTargetEvent(event: Event)(using context: LambdaContext, aws: AwsClient): String =
    val greeting = s"Hello ${event.name}!"
    context
      .maybeGetProperty("TARGET_SQS_QUEUE_URL")
      .map { queueUrl =>
        val messageId = AwsSqsApi.sendMessage(queueUrl, greeting).messageId()
        println(s"Message $messageId sent to $queueUrl")
      }
      .getOrElse {
        println("TARGET_SQS_QUEUE_URL not defined")
      }
    ""

}