02-serverless-api/API.java

// camel-k: language=java open-api=openapi.yaml dependency=camel-openapi-java

import org.apache.camel.builder.AggregationStrategies;
import org.apache.camel.builder.RouteBuilder;

public class API extends RouteBuilder {
  @Override
  public void configure() throws Exception {

    // All endpoints starting from "direct:..." reference an operationId defined
    // in the "openapi.yaml" file.

    // List the object names available in the S3 bucket
    from("direct:list")
      .to("aws-s3://{{api.bucket}}?operation=listObjects")
      .transform().simple("${body.objectSummaries}")
      .split(simple("${body}"), AggregationStrategies.groupedBody())
        .transform().simple("${body.key}")
      .end()
      .marshal().json();


    // Get an object from the S3 bucket
    from("direct:get")
      .setHeader("CamelAwsS3Key", simple("${header.name}"))
      .to("aws-s3://{{api.bucket}}?operation=getObject")
      .setHeader("Content-Type", simple("${body.objectMetadata.contentType}"))
      .transform().simple("${body.objectContent}");


    // Upload a new object into the S3 bucket
    from("direct:create")
      .setHeader("CamelAwsS3Key", simple("${header.name}"))
      .to("aws-s3://{{api.bucket}}");


    // Delete an object from the S3 bucket
    from("direct:delete")
    .setHeader("CamelAwsS3Key", simple("${header.name}"))
    .to("aws-s3://{{api.bucket}}?operation=deleteObject")
    .setBody().constant("");

  }
}