Added some methods

Author: ankeshdave

app/controllers/BlogController.scala

@@ -20,37 +20,66 @@ class BlogController @Inject()(val mongoRepository: MongoRepository)(implicit ex
  for {
  blogs: List[Blog] <- mongoRepository.getBlogs()
  } yield
- Ok(Json.toJson(blogs))
+ Ok( Json.toJson( blogs ) )
  }
 
- def addBlog(): Action[JsValue] = Action.async(parse.json) {
+ def addBlog(): Action[JsValue] = Action.async( parse.json ) {
  request => {
- Json.fromJson[Blog](request.body) match {
+ Json.fromJson[Blog]( request.body ) match {
 
- case JsSuccess(blog, _) => {
+ case JsSuccess( blog, _ ) => {
  for {
- result <- mongoRepository.addBlog(blog)
+ result <- mongoRepository.addBlog( blog )
  } yield {
- Ok(s"Blog Add result $result")
+ Ok( s"Blog Add result $result" )
  }
  }
- case JsError(errors) => {
- Future.successful(BadRequest(s"Error adding data ${Errors.show(errors)}"))
+ case JsError( errors ) => {
+ Future.successful( BadRequest( s"Error adding data ${Errors.show( errors )}" ) )
  }
  }
 
  }
  }
 
+ def editBlog(id: String): Action[JsValue] = Action.async( parse.json ) {
+ request => {
+ Json.fromJson[Blog]( request.body ) match {
+ case JsSuccess( blog, _ ) => {
+ for {
+ result <- mongoRepository.updateBlog( id, blog )
+ } yield {
+ Ok( Json.toJson( result.get ) )
+ }
+ }
+ case JsError( errors ) => {
+ Future.successful( Ok( "" ) )
+ }
+ }
+ }
+ }
+
+ def deleteBlog(id: String) = Action.async {
+ for {
+ result <- mongoRepository.deleteBlog( id )
+ } yield {
+ if (result) {
+ Ok( s"Blog with $id deleted successfully" )
+ }
+ else
+ NotFound( "Blog was not found" )
+ }
+ }
+
  def getBlog(id: String) = Action.async {
  _ => {
  for {
- result: Option[Blog] <- mongoRepository.getBlog(id)
- } yield{
+ result: Option[Blog] <- mongoRepository.getBlog( id )
+ } yield {
  if (result.isEmpty)
- NotFound(s"Blog with Id : $id was not found")
+  NotFound( s"Blog with Id : $id was not found" )
  else
- Ok(Json.toJson(result.get))
+ Ok( Json.toJson( result.get ) )
  }
  }
  }

app/services/MongoRepository.scala

@@ -8,6 +8,7 @@ import reactivemongo.api.commands.WriteResult
 import reactivemongo.api.{Cursor, ReadPreference}
 import reactivemongo.bson.{BSONDocument, BSONObjectID}
 import reactivemongo.play.json._
+import reactivemongo.play.json.collection.JSONBatchCommands.FindAndModifyCommand
 import reactivemongo.play.json.collection.JSONCollection
 
 import scala.concurrent.{ExecutionContext, Future}
@@ -16,8 +17,29 @@ import scala.concurrent.{ExecutionContext, Future}
  * Created by Ankesh Dave on 3/21/2017.
  */
 class MongoRepository @Inject()(val reactiveMongoApi: ReactiveMongoApi)(implicit executionContext: ExecutionContext) {
+ def deleteBlog(id: String): Future[Boolean] = {
+ for {
+ blogCollection <- blogsFuture
+ query = BSONDocument("_id" -> BSONObjectID.parse(id).get)
+ result: WriteResult <- blogCollection.remove(query)
+ } yield {
+ result.ok
+ }
+ }
+
+
+ def updateBlog(id: String, blog: Blog): Future[Option[Blog]] = {
+ for {
+ blogCollection: JSONCollection <- blogsFuture
+ query: BSONDocument = BSONDocument("_id" -> BSONObjectID.parse(id).get)
+ returnValue: FindAndModifyCommand.FindAndModifyResult <- blogCollection.findAndUpdate(query,blog , true)
+ result: Option[Blog] = returnValue.result[Blog]
+ } yield {
+ result
+ }
+ }
+
  def getBlog(id: String): Future[Option[Blog]] = {
- import play.modules.reactivemongo._
  for{
  blogCollection: JSONCollection <- blogsFuture
  query = BSONDocument("_id" -> BSONObjectID.parse(id).get)

conf/routes

@@ -1,7 +1,11 @@
 
-GET / controllers.BlogController.getBlogs()
+GET / controllers.BlogController.getBlogs()
+# Blog
+
 GET /blog/:id controllers.BlogController.getBlog(id: String)
-POST /blog/add controllers.BlogController.addBlog
+PUT /blog/:id controllers.BlogController.editBlog(id : String)
+POST /blog controllers.BlogController.addBlog
+DELETE /blog/:id controllers.BlogController.deleteBlog(id : String)
 
 
 POST /cities/add controllers.CityController.create(name: String, population: Int)

test/controllers/CityControllerTest.scala

@@ -0,0 +1,8 @@
+package controllers
+
+/**
+ * Created by Ankesh on 28-03-2017.
+ */
+class CityControllerTest {
+
+}