Introducing Capped buckets

Application.scala

object Application extends Controller {

  def bucket = Couchbase.cappedBucket("default", 100)

  def data = Action.async {
    import org.ancelin.play2.couchbase.CouchbaseRWImplicits.documentAsJsObjectReader
    val enumerator = bucket.tail[JsObject]()
    enumerator.map( Ok.chunked( _ ) )
  }

  def insert = Action.async(parse.json) { request =>
    import org.ancelin.play2.couchbase.CouchbaseRWImplicits.jsObjectToDocumentWriter
    bucket.insert[JsObject](UUID.randomUUID().toString, request.body.as[JsObject]).map(s => Ok(Json.obj("status" -> s.getMessage)))
  }
}