MongoDAO.scala

package models.dao

import scala.concurrent.ExecutionContext
import scala.concurrent.Future

import play.api.Play.current
import play.modules.reactivemongo.ReactiveMongoPlugin
import reactivemongo.api.collections.default.BSONCollection
import reactivemongo.bson.BSONDocument
import reactivemongo.bson.BSONDocumentIdentity
import reactivemongo.bson.BSONDocumentReader
import reactivemongo.bson.BSONDocumentWriter
import reactivemongo.core.commands.LastError

trait MongoDAO[T] {

	implicit val ec: ExecutionContext

	implicit val reader: BSONDocumentReader[T]

	val collectionName: String

	def db = ReactiveMongoPlugin.db

	def collection = db[BSONCollection](collectionName)

	def insert[T](document: T)(implicit writer: BSONDocumentWriter[T]): Future[LastError] = {
		collection.insert(document)
	}

	def findAll(implicit reader: BSONDocumentReader[T]): Future[List[T]] = {
		collection.find(BSONDocument()).cursor[T].collect[List]()
	}

}