tapir.scala

trait TapirHandler extends RequestStreamHandler {
  def endpoints: List[ServerEndpoint[_, _, _, Any, Identity]]

  override def handleRequest(input: InputStream, output: OutputStream, 
                             context: Context): Unit = {
    val json = new String(input.readAllBytes(), UTF_8)
    val writer = new BufferedWriter(new OutputStreamWriter(output, UTF_8))
    writer.write(handleRequest(json))
    writer.flush()
  }

  def handleRequest(input: String): String = {
    val resp = decode[AwsRequest](input) match {
      case Left(error) => AwsResponse(Nil, isBase64Encoded = false, 
                                      StatusCode.BadRequest.code, Map.empty, 
                                      error.getMessage)
      case Right(req)  => AwsServerInterpreter(req, endpoints)
    }

    Printer.noSpaces.print(resp.asJson)
  }
}