Skip to content

Commit

Permalink
SB-1211 feat:DBOperationActor test case
Browse files Browse the repository at this point in the history
  • Loading branch information
AMIT KUMAR committed Dec 28, 2017
1 parent e4b4e78 commit 7005392
Showing 1 changed file with 251 additions and 0 deletions.
251 changes: 251 additions & 0 deletions actors/src/test/java/org/sunbird/learner/actors/DbOperationActorTest.java
View file
Original file line number Diff line number Diff line change
@@ -0,0 +1,251 @@
package org.sunbird.learner.actors;

import static akka.testkit.JavaTestKit.duration;

import akka.actor.ActorRef;
import akka.actor.ActorSystem;
import akka.actor.Props;
import akka.testkit.javadsl.TestKit;
import java.util.ArrayList;
import java.util.HashMap;
import java.util.List;
import java.util.Map;
import org.junit.BeforeClass;
import org.junit.FixMethodOrder;
import org.junit.Test;
import org.junit.runners.MethodSorters;
import org.sunbird.cassandra.CassandraOperation;
import org.sunbird.common.exception.ProjectCommonException;
import org.sunbird.common.models.response.Response;
import org.sunbird.common.models.util.ActorOperations;
import org.sunbird.common.models.util.JsonKey;
import org.sunbird.common.models.util.PropertiesCache;
import org.sunbird.common.request.Request;
import org.sunbird.helper.CassandraConnectionManager;
import org.sunbird.helper.CassandraConnectionMngrFactory;
import org.sunbird.helper.ServiceFactory;
import org.sunbird.learner.Application;
import org.sunbird.learner.datapersistence.DbOperationActor;
import org.sunbird.learner.util.Util;

@FixMethodOrder(MethodSorters.NAME_ASCENDING)
public class DbOperationActorTest {
static ActorSystem system;
static CassandraOperation operation= ServiceFactory.getInstance();
private static CassandraConnectionManager manager = CassandraConnectionMngrFactory
.getObject(PropertiesCache.getInstance().getProperty(JsonKey.SUNBIRD_CASSANDRA_MODE));
static PropertiesCache cach = PropertiesCache.getInstance();
final static Props props = Props.create(DbOperationActor.class);


@BeforeClass
public static void setUp() {
Application.startLocalActorSystem();
system = ActorSystem.create("system");
Util.checkCassandraDbConnections(JsonKey.SUNBIRD_PLUGIN);
}

@Test
public void testInvalidOperation(){
TestKit probe = new TestKit(system);
ActorRef subject = system.actorOf(props);

Request reqObj = new Request();
reqObj.setOperation("INVALID_OPERATION");

subject.tell(reqObj, probe.getRef());
probe.expectMsgClass(ProjectCommonException.class);
}

@Test
public void testInvalidMessageType(){
TestKit probe = new TestKit(system);
ActorRef subject = system.actorOf(props);

subject.tell(new String("Invelid Type"), probe.getRef());
probe.expectMsgClass(ProjectCommonException.class);
}

@Test
public void testA1Create(){
TestKit probe = new TestKit(system);
ActorRef subject = system.actorOf(props);
Request reqObj = new Request();
reqObj.setOperation(ActorOperations.CREATE_DATA.getValue());
Map<String,Object> map = new HashMap<>();
map.put("entityName", "announcement");
map.put("indexed", true);
Map<String,Object> innerMap = new HashMap<>();
innerMap.put("id", "454ee9-17-a2-47-id");
innerMap.put("sourceid", "45_sourceId");
innerMap.put("userid", "230cb747-userId");
innerMap.put("status", "active");
map.put("payload", innerMap);
reqObj.setRequest(map);
subject.tell(reqObj, probe.getRef());
probe.expectMsgClass(duration("20 second"),Response.class);
}

@Test
public void testA1CreateFrExc(){
TestKit probe = new TestKit(system);
ActorRef subject = system.actorOf(props);
Request reqObj = new Request();
reqObj.setOperation(ActorOperations.CREATE_DATA.getValue());
Map<String,Object> map = new HashMap<>();
map.put("entityName", "announcement");
map.put("indexed", true);
Map<String,Object> innerMap = new HashMap<>();
innerMap.put("id", "454ee9-17-a2-47-id");
innerMap.put("sourceid", "45_sourceId");
innerMap.put("userid", "230cb747-userId");
innerMap.put("status1", "active");
map.put("payload", innerMap);
reqObj.setRequest(map);
subject.tell(reqObj, probe.getRef());
probe.expectMsgClass(duration("20 second"),ProjectCommonException.class);
}

@Test
public void testA2Update(){
TestKit probe = new TestKit(system);
ActorRef subject = system.actorOf(props);
Request reqObj = new Request();
reqObj.setOperation(ActorOperations.UPDATE_DATA.getValue());
Map<String,Object> map = new HashMap<>();
map.put("entityName", "announcement");
map.put("indexed", true);
Map<String,Object> innerMap = new HashMap<>();
innerMap.put("id", "454ee9-17-a2-47-id");
innerMap.put("sourceid", "45_sourceId");
innerMap.put("userid", "230cb747-userId");
innerMap.put("status", "inactive");
map.put("payload", innerMap);
reqObj.setRequest(map);
subject.tell(reqObj, probe.getRef());
probe.expectMsgClass(duration("20 second"),Response.class);
}

@Test
public void testA2UpdateFrExc(){
TestKit probe = new TestKit(system);
ActorRef subject = system.actorOf(props);
Request reqObj = new Request();
reqObj.setOperation(ActorOperations.UPDATE_DATA.getValue());
Map<String,Object> map = new HashMap<>();
map.put("entityName", "announcement");
map.put("indexed", true);
Map<String,Object> innerMap = new HashMap<>();
innerMap.put("id", "454ee9-17-a2-47-id");
innerMap.put("sourceid", "45_sourceId");
innerMap.put("userid", "230cb747-userId");
innerMap.put("status1", "inactive");
map.put("payload", innerMap);
reqObj.setRequest(map);
subject.tell(reqObj, probe.getRef());
probe.expectMsgClass(duration("20 second"),ProjectCommonException.class);
}

@Test
public void testA3Read(){
TestKit probe = new TestKit(system);
ActorRef subject = system.actorOf(props);
Request reqObj = new Request();
reqObj.setOperation(ActorOperations.READ_DATA.getValue());
Map<String,Object> map = new HashMap<>();
map.put("entityName", "announcement");
map.put("id", "454ee9-17-a2-47-id");
reqObj.setRequest(map);
subject.tell(reqObj, probe.getRef());
probe.expectMsgClass(duration("20 second"),Response.class);
}

@Test
public void testA3ReadFrExec(){
TestKit probe = new TestKit(system);
ActorRef subject = system.actorOf(props);
Request reqObj = new Request();
reqObj.setOperation(ActorOperations.READ_DATA.getValue());
Map<String,Object> map = new HashMap<>();
map.put("entityName", "announcement1");
map.put("id", "454ee9-17-a2-47-id");
reqObj.setRequest(map);
subject.tell(reqObj, probe.getRef());
probe.expectMsgClass(duration("20 second"),ProjectCommonException.class);
}

@Test
public void testA4ReadAll(){
TestKit probe = new TestKit(system);
ActorRef subject = system.actorOf(props);
Request reqObj = new Request();
reqObj.setOperation(ActorOperations.READ_ALL_DATA.getValue());
Map<String,Object> map = new HashMap<>();
map.put("entityName", "announcement");
reqObj.setRequest(map);
subject.tell(reqObj, probe.getRef());
probe.expectMsgClass(duration("20 second"),Response.class);
}

@Test
public void testA4ReadAllFrExc(){
TestKit probe = new TestKit(system);
ActorRef subject = system.actorOf(props);
Request reqObj = new Request();
reqObj.setOperation(ActorOperations.READ_ALL_DATA.getValue());
Map<String,Object> map = new HashMap<>();
map.put("entityName", "announcement1");
reqObj.setRequest(map);
subject.tell(reqObj, probe.getRef());
probe.expectMsgClass(duration("20 second"),ProjectCommonException.class);
}

@Test
public void testA5Search(){
TestKit probe = new TestKit(system);
ActorRef subject = system.actorOf(props);
Request reqObj = new Request();
reqObj.setOperation(ActorOperations.SEARCH_DATA.getValue());
Map<String,Object> map = new HashMap<>();
map.put("entityName", "announcement");
List<String> list = new ArrayList<>();
list.add("id");
map.put("requiredFields", list);
Map<String,Object> filter = new HashMap<>();
map.put(JsonKey.FILTERS, filter);
reqObj.setRequest(map);
subject.tell(reqObj, probe.getRef());
probe.expectMsgClass(duration("20 second"),Response.class);
}

@Test
public void testA6delete(){
TestKit probe = new TestKit(system);
ActorRef subject = system.actorOf(props);
Request reqObj = new Request();
reqObj.setOperation(ActorOperations.DELETE_DATA.getValue());
Map<String,Object> map = new HashMap<>();
map.put("entityName", "announcement");
map.put("indexed", true);
map.put("id", "454ee9-17-a2-47-id");
reqObj.setRequest(map);
subject.tell(reqObj, probe.getRef());
probe.expectMsgClass(duration("20 second"),Response.class);
}

@Test
public void testA7getMetrics(){
TestKit probe = new TestKit(system);
ActorRef subject = system.actorOf(props);
Request reqObj = new Request();
reqObj.setOperation(ActorOperations.GET_METRICS.getValue());
Map<String,Object> map = new HashMap<>();
map.put("entityName", "announcement");
Map<String,Object> query = new HashMap<>();
map.put("rawQuery", query);
reqObj.setRequest(map);
subject.tell(reqObj, probe.getRef());
probe.expectMsgClass(duration("20 second"),Response.class);
}

}

0 comments on commit 7005392

Please sign in to comment.