Added akka-http example

Author: howardjohn

build.sbt

@@ -8,7 +8,7 @@ lazy val root = project
  .in(file("."))
  .settings(commonSettings)
  .settings(noPublishSettings)
- .aggregate(common, tests, http4s, akka, exampleHttp4s)
+ .aggregate(common, tests, http4s, akka, exampleHttp4s, exampleAkka)
 
 lazy val CirceVersion = "0.9.0"
 lazy val ScalaTestVersion = "3.0.4"
@@ -60,7 +60,6 @@ lazy val http4s = project
  .dependsOn(common)
  .dependsOn(tests % "test")
 
-
 lazy val akka = project
  .in(file("akka-http-lambda"))
  .settings(publishSettings)
@@ -88,14 +87,25 @@ lazy val exampleHttp4s = project
  moduleName := "example-http4s",
  assemblyJarName in assembly := "example-http4s.jar",
  libraryDependencies ++= Seq(
- "org.http4s" %% "http4s-circe" % Http4sVersion,
- "io.circe" %% "circe-parser" % CirceVersion,
- "io.circe" %% "circe-generic" % CirceVersion,
  "org.http4s" %% "http4s-dsl" % Http4sVersion
  )
  )
  .dependsOn(http4s)
 
+lazy val exampleAkka = project
+ .in(file("example-akka-http"))
+ .settings(noPublishSettings)
+ .settings(commonSettings)
+ .settings(
+ moduleName := "example-akka-http",
+ assemblyJarName in assembly := "example-akka-http.jar",
+ libraryDependencies ++= Seq(
+ "com.typesafe.akka" %% "akka-http" % "10.1.1",
+ "com.typesafe.akka" %% "akka-stream" % "2.5.11"
+ )
+ )
+ .dependsOn(akka)
+
 lazy val noPublishSettings = Seq(
  publish := {},
  publishLocal := {},

example-akka-http/serverless.yml

@@ -0,0 +1,25 @@
+service: example-akka-http
+
+provider:
+ name: aws
+ runtime: java8
+ region: us-west-2
+ stage: dev
+
+package:
+ artifact: target/scala-2.12/example-akka-http.jar
+
+functions:
+ api:
+ handler: io.github.howardjohn.lambda.akka.example.Route$EntryPoint::handle
+ events:
+ - http:
+ path: "{proxy+}"
+ method: any
+ cors: true
+# Uncomment below to keep the application warm
+# - schedule:
+# rate: rate(4 minutes)
+# input:
+# httpMethod: GET
+# path: /hello/keepWarm

example-akka-http/src/main/scala/io/github/howardjohn/lambda/akka/example/Route.scala

@@ -0,0 +1,25 @@
+package io.github.howardjohn.lambda.akka.example
+
+import akka.actor.ActorSystem
+import akka.http.scaladsl.server.Route
+import akka.http.scaladsl.server.Directives._
+import akka.stream.ActorMaterializer
+import io.github.howardjohn.lambda.akka.AkkaHttpLambdaHandler
+
+object Route {
+ // Set up the route
+ val route: Route =
+ path("hello" / Segment) { name: String =>
+ get {
+ complete(s"Hello, $name!")
+ }
+ }
+
+ // Set up dependencies
+ implicit val system: ActorSystem = ActorSystem("example")
+ implicit val materializer: ActorMaterializer = ActorMaterializer()
+ implicit val ec = scala.concurrent.ExecutionContext.Implicits.global
+
+ // Define the entry point for Lambda
+ class EntryPoint extends AkkaHttpLambdaHandler(route)
+}

example-http4s/src/main/scala/io/github/howardjohn/lambda/http4s/example/Route.scala

@@ -3,32 +3,14 @@ package io.github.howardjohn.lambda.http4s.example
 import cats.effect.IO
 import io.github.howardjohn.lambda.http4s.Http4sLambdaHandler
 import org.http4s.HttpService
-import org.http4s.circe.jsonOf
-import io.circe.generic.auto._
 import org.http4s.dsl.io._
 
 object Route {
- implicit val inputDecoder = jsonOf[IO, Input]
-
  // Set up the route
  val service: HttpService[IO] = HttpService[IO] {
- case GET -> Root / "hello" / name :? TimesQueryMatcher(times) =>
- Ok(s"Hello, $name." * times.getOrElse(1))
- case req @ POST -> Root / "message" =>
- for {
- inp <- req.as[Input]
- resp <- Ok(inp.messages.map(msg => s"$msg, ${inp.name}!").mkString(" "))
- } yield resp
+ case GET -> Root / "hello" / name => Ok(s"Hello, $name!")
  }
 
  // Define the entry point for Lambda
- // Referenced as ` io.github.howardjohn.http4s.lambda.example$Route::handler` in Lambda
  class EntryPoint extends Http4sLambdaHandler(service)
-
- case class Input(
- name: String,
- messages: Seq[String]
- )
-
- object TimesQueryMatcher extends OptionalQueryParamDecoderMatcher[Int]("times")
 }