added rest client section

package controllers

import models.ClusterMapping

import scala.concurrent.ExecutionContext.Implicits.global

class GetClusterMappingController extends BaseController {

  def processRequest = (request, client) => client.getClusterMapping(request.host).map { response =>

    Ok(ClusterMapping(response.body))

  }

}

package controllers

class RestController extends ElasticActionController {

  def processElasticRequest = (request, client) => {

    client.executeRequest(

      request.get("method"),

      request.get("path"),

      request.getOpt("data"),

      request.host

    )

  }

}

  def getIndexRecovery(index: String, host: String) =

    ElasticResponse(WS.url(s"$host/$index/_recovery?active_only=true&human=true").get())

  def getClusterMapping(host: String) =

    ElasticResponse(WS.url(s"$host/_mapping").get())

  def executeRequest(method: String, path: String, data: Option[String], host: String) =

    ElasticResponse(data.foldLeft(WS.url(s"$host/$path"))(_ withBody _).execute(method))

}

  def getArray(name: String) = (body \ name).asOpt[Array[String]].getOrElse(throw MissingRequiredParamException(name))

  def getOpt(name: String) =

    (body \ name).asOpt[String]

}

object CerebroRequest {

package models

import play.api.libs.json.{Json, JsString, JsObject, JsValue}

object ClusterMapping {

  def apply(mappings: JsValue) = JsObject(mappings.as[JsObject].value.map {

    case (index, indexMappings) =>

      (index -> Json.obj("types" -> (indexMappings \ "mappings").as[JsObject].keys.map(JsString(_))))

  })

}