GraphQL Server 0

gql-elastic.GraphQLServer-0.scala

object GraphQLServer {

  val elastic = new Elastic(
    ElasticProperties("http://localhost:9200")
  )

  def endpoint(requestJSON: JsValue)(implicit ec: ExecutionContext): Route = {
    val JsObject(fields) = requestJSON
    val JsString(query) = fields("query")

    QueryParser.parse(query) match {
      case Success(queryAst) =>
        val variables = fields.get("variables") match {
          case Some(obj: JsObject) => obj
          case _                   => JsObject.empty
        }

        complete(executeGraphQLQuery(queryAst, None, variables))
      case Failure(error) =>
        complete(BadRequest, JsObject("error" -> JsString(error.getMessage)))
    }
  }
}