Elastic example class

gql-elastic.Elastic-0.scala

class Elastic(props: ElasticProperties) extends ElasticHelpers {

  implicit val ec: ExecutionContext = ExecutionContext.global
  override val elasticProps: ElasticProperties = props
  override val elasticClient = ElasticClient(JavaClient(elasticProps))

  def searchUsers(filter: Filter) =
    elasticClient.execute {
      search(USER_INDEX).bool(buildQuery(filter))
    }.map(resp => UsersResponse(resp.result.to[User], resp.result.totalHits))

  def searchCoffeeShops(filter: Filter) =
    elasticClient.execute {
      search(COFFEE_SHOPS_INDEX).bool(buildQuery(filter))
    }.map(resp => CoffeeShopsResponse(resp.result.to[CoffeeShop], resp.result.totalHits))

  def buildQuery(queryFilter: Filter): BoolQuery = {
    var qMusts = mutable.ListBuffer[Query]()
    var qFilters = mutable.ListBuffer[Query]()

    qMusts += matchAllQuery()

    if (queryFilter.bbox.isDefined) {
      val geom = queryFilter.bbox.get
      qFilters += geoQuery(geom)
    }

    return must(qMusts.toSeq).filter(qFilters)
  }
}