µServerless-01.scala

import com.amazonaws.services.lambda.runtime.Context
import com.amazonaws.services.lambda.runtime.events.S3Event
import com.amazonaws.services.s3.{AmazonS3, AmazonS3ClientBuilder}
import com.amazonaws.services.s3.event.S3EventNotification.S3EventNotificationRecord
import io.onema.userverless.configuration.lambda.EnvLambdaConfiguration
import io.onema.userverless.function.LambdaHandler
import scala.collection.JavaConverters._


class CopyFunction extends LambdaHandler[S3Event, Unit] with EnvLambdaConfiguration {

  //--- Fields ---
  private val destinationBucket: String = getValue("destination/bucket").getOrElse("")
  private val s3Client: AmazonS3 = AmazonS3ClientBuilder.defaultClient()

  //--- Methods ---
  def execute(event: S3Event, context: Context): Unit = {
    event.getRecords.asScala.foreach(copy)
  }

  def copy(record: S3EventNotificationRecord): Unit = {
    val sourceBucket = record.getS3.getBucket.getName
    val sourceKey = record.getS3.getObject.getKey
    s3Client.copyObject(sourceBucket, sourceKey, destinationBucket, sourceKey)
  }
}