Commit a3d3a68e authored by joffinjoy's avatar joffinjoy
Browse files

Merge branch 'knowlg-friday-local-v1' into knowlg-friday

No related merge requests found
Showing with 14 additions and 9 deletions
+14 -9
......@@ -15,7 +15,7 @@ class MovieActor @Inject() (implicit oec: OntologyEngineContext) extends BaseAct
override def onReceive(request: Request): Future[Response] = {
request.getOperation match {
case "addMovie" => add(request)
case "createMovie" => create(request)
/*
case "updateMovie" => update(request)
case "readMovie" => read(request)
......@@ -26,7 +26,7 @@ class MovieActor @Inject() (implicit oec: OntologyEngineContext) extends BaseAct
}
}
def add(request: Request): Future[Response]={
def create(request: Request): Future[Response]={
RequestUtil.restrictProperties(request)
DataNode.create(request).map(node =>{
val response = ResponseHandler.OK
......
......@@ -14,12 +14,12 @@ class MovieController @Inject()(@Named(ActorNames.MOVIE_ACTOR) movieActor: Actor
val schemaName: String = "movie"
val version = "1.0"
def add() = Action.async { implicit request =>
def create() = Action.async { implicit request =>
val headers = commonHeaders()
val body = requestBody()
val movie = body.getOrDefault("movie", new java.util.HashMap()).asInstanceOf[java.util.Map[String, AnyRef]]
movie.putAll(headers)
val movieRequest = getRequest(movie,headers,MovieOperations.addMovie.toString)
val movieRequest = getRequest(movie,headers,MovieOperations.createMovie.toString)
setRequestContext(movieRequest, version, objectType,schemaName)
getResult(ApiId.ADD_MOVIE, movieActor, movieRequest)
}
......
......@@ -4,6 +4,7 @@ import com.google.inject.AbstractModule
import org.sunbird.channel.actors.ChannelActor
import org.sunbird.collectioncsv.actors.CollectionCSVActor
import org.sunbird.content.actors.{AppActor, AssetActor, CategoryActor, CollectionActor, ContentActor, EventActor, EventSetActor, HealthActor, LicenseActor, ObjectActor}
import org.sunbird.movie.actors.MovieActor
import play.libs.akka.AkkaGuiceSupport
import utils.ActorNames
......@@ -24,6 +25,7 @@ class ContentModule extends AbstractModule with AkkaGuiceSupport {
bindActor(classOf[AppActor], ActorNames.APP_ACTOR)
bindActor(classOf[ObjectActor], ActorNames.OBJECT_ACTOR)
bindActor(classOf[CollectionCSVActor], ActorNames.COLLECTION_CSV_ACTOR)
bindActor(classOf[MovieActor], ActorNames.MOVIE_ACTOR)
println("Initialized application actors...")
// $COVERAGE-ON
}
......
package utils
object MovieOperations extends Enumeration {
val addMovie = Value
val createMovie = Value
}
......@@ -107,6 +107,12 @@ akka {
nr-of-instances = 10
dispatcher = actors-dispatcher
}
/movieActor
{
router = smallest-mailbox-pool
nr-of-instances = 10
dispatcher = actors-dispatcher
}
}
}
}
......
......@@ -132,7 +132,4 @@ GET /collection/v4/export/:collectionId controllers.v4.CollectionCon
POST /collection/v4/review/:identifier controllers.v4.CollectionController.review(identifier:String)
# Movie V4 APIs
//add
//Update
//Delete
//Read
\ No newline at end of file
POST /movie/v4/create controllers.v4.MovieController.create
\ No newline at end of file
Supports Markdown
0% or .
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment