aboutsummaryrefslogtreecommitdiffstats
path: root/src/test
diff options
context:
space:
mode:
Diffstat (limited to 'src/test')
-rw-r--r--src/test/java/org/onap/music/unittests/TestRestMusicAdminAPI.java106
-rw-r--r--src/test/java/org/onap/music/unittests/TestRestMusicData.java766
2 files changed, 492 insertions, 380 deletions
diff --git a/src/test/java/org/onap/music/unittests/TestRestMusicAdminAPI.java b/src/test/java/org/onap/music/unittests/TestRestMusicAdminAPI.java
new file mode 100644
index 00000000..7fdad7d0
--- /dev/null
+++ b/src/test/java/org/onap/music/unittests/TestRestMusicAdminAPI.java
@@ -0,0 +1,106 @@
+/*
+ * ============LICENSE_START==========================================
+ * org.onap.music
+ * ===================================================================
+ * Copyright (c) 2019 IBM.
+ * ===================================================================
+ * Licensed under the Apache License, Version 2.0 (the "License");
+ * you may not use this file except in compliance with the License.
+ * You may obtain a copy of the License at
+ *
+ * http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ *
+ * ============LICENSE_END=============================================
+ * ====================================================================
+ */
+
+package org.onap.music.unittests;
+
+import static org.junit.Assert.assertEquals;
+
+import javax.ws.rs.core.Response;
+
+import org.junit.Assert;
+import org.junit.Test;
+import org.junit.runner.RunWith;
+import org.mockito.InjectMocks;
+import org.mockito.Mock;
+import org.mockito.Mockito;
+import org.mockito.junit.MockitoJUnitRunner;
+import org.onap.music.datastore.jsonobjects.JSONObject;
+import org.onap.music.datastore.jsonobjects.JsonOnboard;
+import org.onap.music.rest.RestMusicAdminAPI;
+import org.onap.music.rest.service.RestMusicAdminService;
+
+import com.fasterxml.jackson.core.JsonProcessingException;
+import com.fasterxml.jackson.databind.ObjectMapper;
+
+@RunWith(MockitoJUnitRunner.class)
+public class TestRestMusicAdminAPI {
+
+ @InjectMocks
+ RestMusicAdminAPI restMusicAdminAPI;
+
+ @Mock
+ RestMusicAdminService restMusicAdminService;
+
+ @Mock
+ Response response;
+
+ private JsonOnboard json;
+
+ public String mapToJson(Object obj) throws JsonProcessingException {
+ ObjectMapper objectMapper = new ObjectMapper();
+ return objectMapper.writeValueAsString(obj);
+ }
+
+ @Test
+ public void testOnboardAppWithMusic() throws Exception {
+ json = new JsonOnboard("testApp", "testUser", "testPassword", "false", "a0eebc99-9c0b-4ef8-bb6d-6bb9bd380a11");
+ Mockito.when(restMusicAdminService.onboardAppWithMusic(json)).thenReturn(response);
+ Assert.assertNotNull(restMusicAdminAPI.onboardAppWithMusic(json));
+
+ }
+
+ @Test
+ public void testGetOnboardedInfoSearch() throws Exception {
+
+ JsonOnboard json = new JsonOnboard("testApp", "", "", "false", "a0eebc99-9c0b-4ef8-bb6d-6bb9bd380a11");
+ Mockito.when(restMusicAdminService.getOnboardedInfoSearch(json)).thenReturn(response);
+ Assert.assertNotNull(restMusicAdminAPI.getOnboardedInfoSearch(json));
+
+ }
+
+ @Test
+ public void testDeleteOnboardApp() throws Exception {
+
+ JsonOnboard json = new JsonOnboard("testApp", "", "", "", "a0eebc99-9c0b-4ef8-bb6d-6bb9bd380a11");
+ Mockito.when(restMusicAdminService.deleteOnboardApp(json)).thenReturn(response);
+ Assert.assertNotNull(restMusicAdminAPI.deleteOnboardApp(json));
+
+ }
+
+ @Test
+ public void testUpdateOnboardApp() throws Exception {
+
+ JsonOnboard json = new JsonOnboard("testApp", "testUser", "testPassword", "false",
+ "a0eebc99-9c0b-4ef8-bb6d-6bb9bd380a11");
+ Mockito.when(restMusicAdminService.updateOnboardApp(json)).thenReturn(response);
+ Assert.assertNotNull(restMusicAdminAPI.updateOnboardApp(json));
+
+ }
+
+ @Test
+ public void testCallbackOps() throws Exception {
+ JSONObject json = new JSONObject();
+ assertEquals("Success", restMusicAdminAPI.callbackOps(json));
+
+ }
+
+}
diff --git a/src/test/java/org/onap/music/unittests/TestRestMusicData.java b/src/test/java/org/onap/music/unittests/TestRestMusicData.java
index c8dd0830..8b6248de 100644
--- a/src/test/java/org/onap/music/unittests/TestRestMusicData.java
+++ b/src/test/java/org/onap/music/unittests/TestRestMusicData.java
@@ -2,6 +2,8 @@
* ============LICENSE_START========================================== org.onap.music
* =================================================================== Copyright (c) 2017 AT&T
* Intellectual Property ===================================================================
+ * Modifications Copyright (c) 2018-2019 IBM ===============================
+ * ===========================================================================================
* Licensed under the Apache License, Version 2.0 (the "License"); you may not use this file except
* in compliance with the License. You may obtain a copy of the License at
*
@@ -71,7 +73,7 @@ public class TestRestMusicData {
RestMusicDataAPI data = new RestMusicDataAPI();
RestMusicAdminAPI admin = new RestMusicAdminAPI();
- RestMusicLocksAPI lock = new RestMusicLocksAPI();
+ RestMusicLocksAPI lock = new RestMusicLocksAPI();
static PreparedQueryObject testObject;
static TestingServer zkServer;
@@ -80,12 +82,12 @@ public class TestRestMusicData {
@Mock
UriInfo info;
-
+
static String appName = "TestApp";
static String userId = "TestUser";
static String password = "TestPassword";
- static String authData = userId+":"+password;
- static String wrongAuthData = userId+":"+"pass";
+ static String authData = userId + ":" + password;
+ static String wrongAuthData = userId + ":" + "pass";
static String authorization = new String(Base64.encode(authData.getBytes()));
static String wrongAuthorization = new String(Base64.encode(wrongAuthData.getBytes()));
static boolean isAAF = false;
@@ -99,7 +101,7 @@ public class TestRestMusicData {
@BeforeClass
public static void init() throws Exception {
- try {
+ try {
MusicDataStoreHandle.mDstoreHandle = CassandraCQL.connectToEmbeddedCassandra();
MusicCore.mLockHandle = new CassaLockStore(MusicDataStoreHandle.mDstoreHandle);
} catch (Exception e) {
@@ -115,59 +117,56 @@ public class TestRestMusicData {
testObject = new PreparedQueryObject();
testObject.appendQueryString("DROP KEYSPACE IF EXISTS admin");
MusicCore.eventualPut(testObject);
- if(MusicDataStoreHandle.mDstoreHandle!=null)
- MusicDataStoreHandle.mDstoreHandle.close();
- if(zkServer!=null)
- zkServer.stop();
+ if (MusicDataStoreHandle.mDstoreHandle != null)
+ MusicDataStoreHandle.mDstoreHandle.close();
+ if (zkServer != null)
+ zkServer.stop();
}
@Test
public void Test1_createKeyspace() throws Exception {
testObject = new PreparedQueryObject();
- testObject.appendQueryString("CREATE KEYSPACE admin WITH REPLICATION = "
- + "{'class' : 'SimpleStrategy' , "
- + "'replication_factor': 1} AND DURABLE_WRITES = true");
+ testObject.appendQueryString("CREATE KEYSPACE admin WITH REPLICATION = " + "{'class' : 'SimpleStrategy' , "
+ + "'replication_factor': 1} AND DURABLE_WRITES = true");
MusicCore.eventualPut(testObject);
testObject = new PreparedQueryObject();
- testObject.appendQueryString(
- "CREATE TABLE admin.keyspace_master (" + " uuid uuid, keyspace_name text,"
- + " application_name text, is_api boolean,"
- + " password text, username text,"
- + " is_aaf boolean, PRIMARY KEY (uuid)\n" + ");");
+ testObject.appendQueryString("CREATE TABLE admin.keyspace_master (" + " uuid uuid, keyspace_name text,"
+ + " application_name text, is_api boolean," + " password text, username text,"
+ + " is_aaf boolean, PRIMARY KEY (uuid)\n" + ");");
MusicCore.eventualPut(testObject);
testObject = new PreparedQueryObject();
- testObject.appendQueryString(
- "INSERT INTO admin.keyspace_master (uuid, keyspace_name, application_name, is_api, "
- + "password, username, is_aaf) VALUES (?,?,?,?,?,?,?)");
+ testObject
+ .appendQueryString("INSERT INTO admin.keyspace_master (uuid, keyspace_name, application_name, is_api, "
+ + "password, username, is_aaf) VALUES (?,?,?,?,?,?,?)");
testObject.addValue(MusicUtil.convertToActualDataType(DataType.uuid(), uuid));
- testObject.addValue(MusicUtil.convertToActualDataType(DataType.text(),
- MusicUtil.DEFAULTKEYSPACENAME));
+ testObject.addValue(MusicUtil.convertToActualDataType(DataType.text(), MusicUtil.DEFAULTKEYSPACENAME));
testObject.addValue(MusicUtil.convertToActualDataType(DataType.text(), appName));
testObject.addValue(MusicUtil.convertToActualDataType(DataType.cboolean(), "True"));
- testObject.addValue(MusicUtil.convertToActualDataType(DataType.text(), BCrypt.hashpw(password, BCrypt.gensalt())));
+ testObject.addValue(
+ MusicUtil.convertToActualDataType(DataType.text(), BCrypt.hashpw(password, BCrypt.gensalt())));
testObject.addValue(MusicUtil.convertToActualDataType(DataType.text(), userId));
testObject.addValue(MusicUtil.convertToActualDataType(DataType.cboolean(), isAAF));
MusicCore.eventualPut(testObject);
testObject = new PreparedQueryObject();
- testObject.appendQueryString(
- "INSERT INTO admin.keyspace_master (uuid, keyspace_name, application_name, is_api, "
- + "password, username, is_aaf) VALUES (?,?,?,?,?,?,?)");
+ testObject
+ .appendQueryString("INSERT INTO admin.keyspace_master (uuid, keyspace_name, application_name, is_api, "
+ + "password, username, is_aaf) VALUES (?,?,?,?,?,?,?)");
testObject.addValue(MusicUtil.convertToActualDataType(DataType.uuid(),
- UUID.fromString("bbc66ccc-d857-4e90-b1e5-df98a3d40de6")));
- testObject.addValue(MusicUtil.convertToActualDataType(DataType.text(),
- MusicUtil.DEFAULTKEYSPACENAME));
+ UUID.fromString("bbc66ccc-d857-4e90-b1e5-df98a3d40de6")));
+ testObject.addValue(MusicUtil.convertToActualDataType(DataType.text(), MusicUtil.DEFAULTKEYSPACENAME));
testObject.addValue(MusicUtil.convertToActualDataType(DataType.text(), "TestApp1"));
testObject.addValue(MusicUtil.convertToActualDataType(DataType.cboolean(), "True"));
- testObject.addValue(MusicUtil.convertToActualDataType(DataType.text(), BCrypt.hashpw(password, BCrypt.gensalt())));
+ testObject.addValue(
+ MusicUtil.convertToActualDataType(DataType.text(), BCrypt.hashpw(password, BCrypt.gensalt())));
testObject.addValue(MusicUtil.convertToActualDataType(DataType.text(), "TestUser1"));
testObject.addValue(MusicUtil.convertToActualDataType(DataType.cboolean(), isAAF));
MusicCore.eventualPut(testObject);
testObject = new PreparedQueryObject();
- testObject.appendQueryString(
- "select uuid from admin.keyspace_master where application_name = ? allow filtering");
+ testObject
+ .appendQueryString("select uuid from admin.keyspace_master where application_name = ? allow filtering");
testObject.addValue(MusicUtil.convertToActualDataType(DataType.text(), appName));
ResultSet rs = MusicCore.get(testObject);
List<Row> rows = rs.all();
@@ -188,11 +187,13 @@ public class TestRestMusicData {
jsonKeyspace.setDurabilityOfWrites("true");
jsonKeyspace.setKeyspaceName(keyspaceName);
jsonKeyspace.setReplicationInfo(replicationInfo);
- //Mockito.doNothing().when(http).addHeader(xLatestVersion, MusicUtil.getVersion());
- Response response = data.createKeySpace("1", "1", "1", null,authorization, appName, jsonKeyspace, keyspaceName);
+ // Mockito.doNothing().when(http).addHeader(xLatestVersion,
+ // MusicUtil.getVersion());
+ Response response = data.createKeySpace("1", "1", "1", null, authorization, appName, jsonKeyspace,
+ keyspaceName);
System.out.println("#######status is " + response.getStatus());
System.out.println("Entity" + response.getEntity());
- assertEquals(200,response.getStatus());
+ assertEquals(200, response.getStatus());
}
@Test
@@ -200,24 +201,29 @@ public class TestRestMusicData {
JsonKeySpace jsonKeyspace = new JsonKeySpace();
Map<String, String> consistencyInfo = new HashMap<>();
Map<String, Object> replicationInfo = new HashMap<>();
- //Mockito.doNothing().when(http).addHeader(xLatestVersion, MusicUtil.getVersion());
- Response response = data.createKeySpace("1", "1", "1", null, authorization,appName, jsonKeyspace, keyspaceName);
+ // Mockito.doNothing().when(http).addHeader(xLatestVersion,
+ // MusicUtil.getVersion());
+ Response response = data.createKeySpace("1", "1", "1", null, authorization, appName, jsonKeyspace,
+ keyspaceName);
System.out.println("#######status is " + response.getStatus());
System.out.println("Entity" + response.getEntity());
- assertEquals(400,response.getStatus());
+ assertEquals(400, response.getStatus());
}
-//MusicCore.autheticateUser
+
+ // MusicCore.autheticateUser
@Test
public void Test2_createKeyspace01() throws Exception {
JsonKeySpace jsonKeyspace = new JsonKeySpace();
Map<String, String> consistencyInfo = new HashMap<>();
Map<String, Object> replicationInfo = new HashMap<>();
String appName1 = "test";
- //Mockito.doNothing().when(http).addHeader(xLatestVersion, MusicUtil.getVersion());
- Response response = data.createKeySpace("1", "1", "1", null,authorization, appName1, jsonKeyspace, keyspaceName);
+ // Mockito.doNothing().when(http).addHeader(xLatestVersion,
+ // MusicUtil.getVersion());
+ Response response = data.createKeySpace("1", "1", "1", null, authorization, appName1, jsonKeyspace,
+ keyspaceName);
System.out.println("#######status is " + response.getStatus());
System.out.println("Entity" + response.getEntity());
- assertEquals(401,response.getStatus());
+ assertEquals(401, response.getStatus());
}
@Test
@@ -232,12 +238,13 @@ public class TestRestMusicData {
jsonKeyspace.setDurabilityOfWrites("true");
jsonKeyspace.setKeyspaceName("TestApp1");
jsonKeyspace.setReplicationInfo(replicationInfo);
- //Mockito.doNothing().when(http).addHeader(xLatestVersion, MusicUtil.getVersion());
- Response response = data.createKeySpace("1", "1", "1", null,authorization, "TestApp1",
- jsonKeyspace, keyspaceName);
+ // Mockito.doNothing().when(http).addHeader(xLatestVersion,
+ // MusicUtil.getVersion());
+ Response response = data.createKeySpace("1", "1", "1", null, authorization, "TestApp1", jsonKeyspace,
+ keyspaceName);
System.out.println("#######status is " + response.getStatus());
System.out.println("Entity" + response.getEntity());
- assertEquals(401,response.getStatus());
+ assertEquals(401, response.getStatus());
}
@Test
@@ -252,22 +259,24 @@ public class TestRestMusicData {
jsonKeyspace.setDurabilityOfWrites("true");
jsonKeyspace.setKeyspaceName(keyspaceName);
jsonKeyspace.setReplicationInfo(replicationInfo);
- //Map<String, Object> m1= new HashMap<>() ;
- //Mockito.when(CachingUtil.verifyOnboarding("x","y","x")).thenReturn(m1);
- //Mockito.when(CachingUtil.verifyOnboarding(appNamex,userId,password).thenReturn(m1));
- //Mockito.doNothing().when(http).addHeader(xLatestVersion, MusicUtil.getVersion());
- String authDatax = ":"+password;
+ // Map<String, Object> m1= new HashMap<>() ;
+ // Mockito.when(CachingUtil.verifyOnboarding("x","y","x")).thenReturn(m1);
+ // Mockito.when(CachingUtil.verifyOnboarding(appNamex,userId,password).thenReturn(m1));
+ // Mockito.doNothing().when(http).addHeader(xLatestVersion,
+ // MusicUtil.getVersion());
+ String authDatax = ":" + password;
String authorizationx = new String(Base64.encode(authDatax.getBytes()));
try {
- Response response = data.createKeySpace("1", "1", "1", null,authorizationx, appName, jsonKeyspace, keyspaceName);
- System.out.println("#######status is " + response.getStatus());
- System.out.println("Entity" + response.getEntity());
- assertNotEquals(200,response.getStatus());
- } catch (RuntimeException e ) {
- System.out.println("#######status is runtime exception= " + e);
+ Response response = data.createKeySpace("1", "1", "1", null, authorizationx, appName, jsonKeyspace,
+ keyspaceName);
+ System.out.println("#######status is " + response.getStatus());
+ System.out.println("Entity" + response.getEntity());
+ assertNotEquals(200, response.getStatus());
+ } catch (RuntimeException e) {
+ System.out.println("#######status is runtime exception= " + e);
}
}
-
+
@Test
public void Test3_createTable() throws Exception {
JsonTable jsonTable = new JsonTable();
@@ -283,16 +292,15 @@ public class TestRestMusicData {
jsonTable.setPrimaryKey("emp_name");
jsonTable.setTableName(tableName);
jsonTable.setFields(fields);
- //Mockito.doNothing().when(http).addHeader(xLatestVersion, MusicUtil.getVersion());
- Response response = data.createTable("1", "1", "1",
- "abc66ccc-d857-4e90-b1e5-df98a3d40ce6",appName, authorization,
- jsonTable, keyspaceName, tableName);
+ // Mockito.doNothing().when(http).addHeader(xLatestVersion,
+ // MusicUtil.getVersion());
+ Response response = data.createTable("1", "1", "1", "abc66ccc-d857-4e90-b1e5-df98a3d40ce6", appName,
+ authorization, jsonTable, keyspaceName, tableName);
System.out.println("#######status is " + response.getStatus());
System.out.println("Entity" + response.getEntity());
assertEquals(200, response.getStatus());
}
-
-
+
@Test
public void Test3_createTableClusterOrderBad() throws Exception {
JsonTable jsonTable = new JsonTable();
@@ -309,15 +317,15 @@ public class TestRestMusicData {
jsonTable.setClusteringOrder("ASC");
jsonTable.setTableName(tableName);
jsonTable.setFields(fields);
- //Mockito.doNothing().when(http).addHeader(xLatestVersion, MusicUtil.getVersion());
- Response response = data.createTable("1", "1", "1",
- "abc66ccc-d857-4e90-b1e5-df98a3d40ce6",appName, authorization,
- jsonTable, keyspaceName, tableName);
+ // Mockito.doNothing().when(http).addHeader(xLatestVersion,
+ // MusicUtil.getVersion());
+ Response response = data.createTable("1", "1", "1", "abc66ccc-d857-4e90-b1e5-df98a3d40ce6", appName,
+ authorization, jsonTable, keyspaceName, tableName);
System.out.println("#######status is " + response.getStatus());
System.out.println("Entity" + response.getEntity());
assertNotEquals(200, response.getStatus());
}
-
+
@Test
public void Test3_createTable_withPropertiesNotNull() throws Exception {
JsonTable jsonTable = new JsonTable();
@@ -329,24 +337,24 @@ public class TestRestMusicData {
fields.put("PRIMARY KEY", "(emp_name)");
consistencyInfo.put("type", "eventual");
Map<String, Object> properties = new HashMap<>();
- properties.put("comment","Testing prperties not null");
+ properties.put("comment", "Testing prperties not null");
jsonTable.setConsistencyInfo(consistencyInfo);
jsonTable.setKeyspaceName(keyspaceName);
jsonTable.setPrimaryKey("emp_name");
- String tableName_prop=tableName+"_Prop";
+ String tableName_prop = tableName + "_Prop";
jsonTable.setTableName(tableName_prop);
jsonTable.setFields(fields);
jsonTable.setProperties(properties);
-
- //Mockito.doNothing().when(http).addHeader(xLatestVersion, MusicUtil.getVersion());
- Response response = data.createTable("1", "1", "1",
- "abc66ccc-d857-4e90-b1e5-df98a3d40ce6",appName, authorization,
- jsonTable, keyspaceName, tableName_prop);
+
+ // Mockito.doNothing().when(http).addHeader(xLatestVersion,
+ // MusicUtil.getVersion());
+ Response response = data.createTable("1", "1", "1", "abc66ccc-d857-4e90-b1e5-df98a3d40ce6", appName,
+ authorization, jsonTable, keyspaceName, tableName_prop);
System.out.println("#######status is " + response.getStatus());
System.out.println("Entity" + response.getEntity());
assertEquals(200, response.getStatus());
}
-
+
@Test
public void Test3_createTable_duplicateTable() throws Exception {
JsonTable jsonTable = new JsonTable();
@@ -360,26 +368,25 @@ public class TestRestMusicData {
jsonTable.setConsistencyInfo(consistencyInfo);
jsonTable.setKeyspaceName(keyspaceName);
jsonTable.setPrimaryKey("emp_name");
- String tableNameDup=tableName+"X";
+ String tableNameDup = tableName + "X";
jsonTable.setTableName(tableNameDup);
jsonTable.setFields(fields);
- //Mockito.doNothing().when(http).addHeader(xLatestVersion, MusicUtil.getVersion());
- Response response = data.createTable("1", "1", "1",
- "abc66ccc-d857-4e90-b1e5-df98a3d40ce6", appName, authorization,
- jsonTable, keyspaceName, tableNameDup);
+ // Mockito.doNothing().when(http).addHeader(xLatestVersion,
+ // MusicUtil.getVersion());
+ Response response = data.createTable("1", "1", "1", "abc66ccc-d857-4e90-b1e5-df98a3d40ce6", appName,
+ authorization, jsonTable, keyspaceName, tableNameDup);
System.out.println("#######status for 1st time " + response.getStatus());
System.out.println("Entity" + response.getEntity());
-
- Response response0 = data.createTable("1", "1", "1",
- "abc66ccc-d857-4e90-b1e5-df98a3d40ce6", appName, authorization,
- jsonTable, keyspaceName, tableNameDup);
+
+ Response response0 = data.createTable("1", "1", "1", "abc66ccc-d857-4e90-b1e5-df98a3d40ce6", appName,
+ authorization, jsonTable, keyspaceName, tableNameDup);
// 400 is the duplicate status found in response
- // Music 113 duplicate testing
- //import static org.junit.Assert.assertNotEquals;
+ // Music 113 duplicate testing
+ // import static org.junit.Assert.assertNotEquals;
System.out.println("#######status for 2nd time " + response0.getStatus());
System.out.println("Entity" + response0.getEntity());
-
- assertFalse("Duplicate table not created for "+tableNameDup, 200==response0.getStatus());
+
+ assertFalse("Duplicate table not created for " + tableNameDup, 200 == response0.getStatus());
}
@@ -399,10 +406,10 @@ public class TestRestMusicData {
jsonTable.setPrimaryKey("emp_name");
jsonTable.setTableName(tableName);
jsonTable.setFields(fields);
- //Mockito.doNothing().when(http).addHeader(xLatestVersion, MusicUtil.getVersion());
- Response response = data.createTable("1", "1", "1",
- "abc66ccc-d857-4e90-b1e5-df98a3d40ce6", appName, wrongAuthorization,
- jsonTable, keyspaceName, tableName);
+ // Mockito.doNothing().when(http).addHeader(xLatestVersion,
+ // MusicUtil.getVersion());
+ Response response = data.createTable("1", "1", "1", "abc66ccc-d857-4e90-b1e5-df98a3d40ce6", appName,
+ wrongAuthorization, jsonTable, keyspaceName, tableName);
System.out.println("#######status is " + response.getStatus());
System.out.println("Entity" + response.getEntity());
assertEquals(401, response.getStatus());
@@ -424,19 +431,19 @@ public class TestRestMusicData {
jsonTable.setPrimaryKey("emp_name");
jsonTable.setTableName(tableName);
jsonTable.setFields(fields);
- //Mockito.doNothing().when(http).addHeader(xLatestVersion, MusicUtil.getVersion());
- Response response = data.createTable("1", "1", "1",
- "abc66ccc-d857-4e90-b1e5-df98a3d40ce6", appName, authorization,
- jsonTable, "wrong", tableName);
+ // Mockito.doNothing().when(http).addHeader(xLatestVersion,
+ // MusicUtil.getVersion());
+ Response response = data.createTable("1", "1", "1", "abc66ccc-d857-4e90-b1e5-df98a3d40ce6", appName,
+ authorization, jsonTable, "wrong", tableName);
System.out.println("#######status is " + response.getStatus());
System.out.println("Entity" + response.getEntity());
assertEquals(401, response.getStatus());
}
-
+
// Improper parenthesis in key field
@Test
public void Test3_createTable_badParantesis() throws Exception {
- String tableNameC ="testTable0";
+ String tableNameC = "testTable0";
JsonTable jsonTable = new JsonTable();
Map<String, String> consistencyInfo = new HashMap<>();
Map<String, String> fields = new HashMap<>();
@@ -452,21 +459,20 @@ public class TestRestMusicData {
jsonTable.setTableName(tableNameC);
jsonTable.setClusteringOrder("emp_id Desc");
jsonTable.setFields(fields);
- //Mockito.doNothing().when(http).addHeader(xLatestVersion, MusicUtil.getVersion());
- Response response = data.createTable("1", "1", "1",
- "abc66ccc-d857-4e90-b1e5-df98a3d40ce6", appName, authorization,
- jsonTable, keyspaceName, tableNameC);
+ // Mockito.doNothing().when(http).addHeader(xLatestVersion,
+ // MusicUtil.getVersion());
+ Response response = data.createTable("1", "1", "1", "abc66ccc-d857-4e90-b1e5-df98a3d40ce6", appName,
+ authorization, jsonTable, keyspaceName, tableNameC);
System.out.println("#######status is " + response.getStatus());
System.out.println("Entity" + response.getEntity());
- //assertEquals(400, response.getStatus());
+ // assertEquals(400, response.getStatus());
assertTrue(200 != response.getStatus());
}
-
// good clustering key
@Test
public void Test3_createTable_1_clusterKey_good() throws Exception {
- String tableNameC ="testTableC1";
+ String tableNameC = "testTableC1";
JsonTable jsonTable = new JsonTable();
Map<String, String> consistencyInfo = new HashMap<>();
Map<String, String> fields = new HashMap<>();
@@ -477,14 +483,14 @@ public class TestRestMusicData {
consistencyInfo.put("type", "eventual");
jsonTable.setConsistencyInfo(consistencyInfo);
jsonTable.setKeyspaceName(keyspaceName);
- // jsonTable.setPrimaryKey("emp_name");
+ // jsonTable.setPrimaryKey("emp_name");
jsonTable.setTableName(tableNameC);
jsonTable.setClusteringOrder("emp_salary ASC");
jsonTable.setFields(fields);
- //Mockito.doNothing().when(http).addHeader(xLatestVersion, MusicUtil.getVersion());
- Response response = data.createTable("1", "1", "1",
- "abc66ccc-d857-4e90-b1e5-df98a3d40ce6", appName, authorization,
- jsonTable, keyspaceName, tableNameC);
+ // Mockito.doNothing().when(http).addHeader(xLatestVersion,
+ // MusicUtil.getVersion());
+ Response response = data.createTable("1", "1", "1", "abc66ccc-d857-4e90-b1e5-df98a3d40ce6", appName,
+ authorization, jsonTable, keyspaceName, tableNameC);
System.out.println("#######status is " + response.getStatus());
System.out.println("Entity" + response.getEntity());
assertEquals(200, response.getStatus());
@@ -493,7 +499,7 @@ public class TestRestMusicData {
// bad partition key=clustering key
@Test
public void Test3_createTable_2_clusterKey_bad() throws Exception {
- String tableNameC ="testTableC2";
+ String tableNameC = "testTableC2";
JsonTable jsonTable = new JsonTable();
Map<String, String> consistencyInfo = new HashMap<>();
Map<String, String> fields = new HashMap<>();
@@ -504,23 +510,24 @@ public class TestRestMusicData {
consistencyInfo.put("type", "eventual");
jsonTable.setConsistencyInfo(consistencyInfo);
jsonTable.setKeyspaceName(keyspaceName);
- jsonTable.setPrimaryKey("emp_name"); // "PRIMARY KEY" overrides if primaryKey present
+ jsonTable.setPrimaryKey("emp_name"); // "PRIMARY KEY" overrides if
+ // primaryKey present
jsonTable.setTableName(tableNameC);
jsonTable.setClusteringOrder("emp_salary ASC");
jsonTable.setFields(fields);
- //Mockito.doNothing().when(http).addHeader(xLatestVersion, MusicUtil.getVersion());
- Response response = data.createTable("1", "1", "1",
- "abc66ccc-d857-4e90-b1e5-df98a3d40ce6", appName, authorization,
- jsonTable, keyspaceName, tableNameC);
+ // Mockito.doNothing().when(http).addHeader(xLatestVersion,
+ // MusicUtil.getVersion());
+ Response response = data.createTable("1", "1", "1", "abc66ccc-d857-4e90-b1e5-df98a3d40ce6", appName,
+ authorization, jsonTable, keyspaceName, tableNameC);
System.out.println("#######status is " + response.getStatus());
System.out.println("Entity" + response.getEntity());
- assertTrue(200 !=response.getStatus());
+ assertTrue(200 != response.getStatus());
}
// good composite partition key,clustering key
@Test
public void Test3_createTable_3_partition_clusterKey_good() throws Exception {
- String tableNameC ="testTableC3";
+ String tableNameC = "testTableC3";
JsonTable jsonTable = new JsonTable();
Map<String, String> consistencyInfo = new HashMap<>();
Map<String, String> fields = new HashMap<>();
@@ -536,10 +543,10 @@ public class TestRestMusicData {
jsonTable.setTableName(tableNameC);
jsonTable.setClusteringOrder("emp_salary ASC");
jsonTable.setFields(fields);
- //Mockito.doNothing().when(http).addHeader(xLatestVersion, MusicUtil.getVersion());
- Response response = data.createTable("1", "1", "1",
- "abc66ccc-d857-4e90-b1e5-df98a3d40ce6", appName, authorization,
- jsonTable, keyspaceName, tableNameC);
+ // Mockito.doNothing().when(http).addHeader(xLatestVersion,
+ // MusicUtil.getVersion());
+ Response response = data.createTable("1", "1", "1", "abc66ccc-d857-4e90-b1e5-df98a3d40ce6", appName,
+ authorization, jsonTable, keyspaceName, tableNameC);
System.out.println("#######status is " + response.getStatus());
System.out.println("Entity" + response.getEntity());
assertEquals(200, response.getStatus());
@@ -548,7 +555,7 @@ public class TestRestMusicData {
// bad - not all cols in order by of composite partition key,clustering key
@Test
public void Test3_createTable_4_clusteringOrder_bad() throws Exception {
- String tableNameC ="testTableC4";
+ String tableNameC = "testTableC4";
JsonTable jsonTable = new JsonTable();
Map<String, String> consistencyInfo = new HashMap<>();
Map<String, String> fields = new HashMap<>();
@@ -564,10 +571,10 @@ public class TestRestMusicData {
jsonTable.setTableName(tableNameC);
jsonTable.setClusteringOrder("emp_salary ASC");
jsonTable.setFields(fields);
- //Mockito.doNothing().when(http).addHeader(xLatestVersion, MusicUtil.getVersion());
- Response response = data.createTable("1", "1", "1",
- "abc66ccc-d857-4e90-b1e5-df98a3d40ce6", appName, authorization,
- jsonTable, keyspaceName, tableNameC);
+ // Mockito.doNothing().when(http).addHeader(xLatestVersion,
+ // MusicUtil.getVersion());
+ Response response = data.createTable("1", "1", "1", "abc66ccc-d857-4e90-b1e5-df98a3d40ce6", appName,
+ authorization, jsonTable, keyspaceName, tableNameC);
System.out.println("#######status is " + response.getStatus());
System.out.println("Entity" + response.getEntity());
assertTrue(200 != response.getStatus());
@@ -576,7 +583,7 @@ public class TestRestMusicData {
// bad - wrong cols in order by of composite partition key,clustering key
@Test
public void Test3_createTable_5_clusteringOrder_bad() throws Exception {
- String tableNameC ="testTableC5";
+ String tableNameC = "testTableC5";
JsonTable jsonTable = new JsonTable();
Map<String, String> consistencyInfo = new HashMap<>();
Map<String, String> fields = new HashMap<>();
@@ -592,19 +599,19 @@ public class TestRestMusicData {
jsonTable.setTableName(tableNameC);
jsonTable.setClusteringOrder("emp_idx desc, emp_salary ASC");
jsonTable.setFields(fields);
- //Mockito.doNothing().when(http).addHeader(xLatestVersion, MusicUtil.getVersion());
- Response response = data.createTable("1", "1", "1",
- "abc66ccc-d857-4e90-b1e5-df98a3d40ce6", appName, authorization,
- jsonTable, keyspaceName, tableNameC);
+ // Mockito.doNothing().when(http).addHeader(xLatestVersion,
+ // MusicUtil.getVersion());
+ Response response = data.createTable("1", "1", "1", "abc66ccc-d857-4e90-b1e5-df98a3d40ce6", appName,
+ authorization, jsonTable, keyspaceName, tableNameC);
System.out.println("#######status is " + response.getStatus());
System.out.println("Entity" + response.getEntity());
assertTrue(200 != response.getStatus());
}
-
+
// bad - wrong cols in order by of composite partition key,clustering key
@Test
public void Test3_createTable_6_clusteringOrder_bad() throws Exception {
- String tableNameC ="testTableC6";
+ String tableNameC = "testTableC6";
JsonTable jsonTable = new JsonTable();
Map<String, String> consistencyInfo = new HashMap<>();
Map<String, String> fields = new HashMap<>();
@@ -616,24 +623,24 @@ public class TestRestMusicData {
consistencyInfo.put("type", "eventual");
jsonTable.setConsistencyInfo(consistencyInfo);
jsonTable.setKeyspaceName(keyspaceName);
- jsonTable.setPrimaryKey("((uuid,emp_name),emp_id,emp_salary)"); // overridden by
+ jsonTable.setPrimaryKey("((uuid,emp_name),emp_id,emp_salary)"); // overridden
+ // by
jsonTable.setTableName(tableNameC);
jsonTable.setClusteringOrder("emp_id desc, emp_salary ASC,uuid desc");
jsonTable.setFields(fields);
- //Mockito.doNothing().when(http).addHeader(xLatestVersion, MusicUtil.getVersion());
- Response response = data.createTable("1", "1", "1",
- "abc66ccc-d857-4e90-b1e5-df98a3d40ce6", appName, authorization,
- jsonTable, keyspaceName, tableNameC);
+ // Mockito.doNothing().when(http).addHeader(xLatestVersion,
+ // MusicUtil.getVersion());
+ Response response = data.createTable("1", "1", "1", "abc66ccc-d857-4e90-b1e5-df98a3d40ce6", appName,
+ authorization, jsonTable, keyspaceName, tableNameC);
System.out.println("#######status is " + response.getStatus());
System.out.println("Entity" + response.getEntity());
assertTrue(200 != response.getStatus());
}
-
// good clustering key, need to pass queryparameter
@Test
public void Test3_createTableIndex_1() throws Exception {
- String tableNameC ="testTableCinx";
+ String tableNameC = "testTableCinx";
JsonTable jsonTable = new JsonTable();
Map<String, String> consistencyInfo = new HashMap<>();
Map<String, String> fields = new HashMap<>();
@@ -644,29 +651,30 @@ public class TestRestMusicData {
consistencyInfo.put("type", "eventual");
jsonTable.setConsistencyInfo(consistencyInfo);
jsonTable.setKeyspaceName(keyspaceName);
- // jsonTable.setPrimaryKey("emp_name");
+ // jsonTable.setPrimaryKey("emp_name");
jsonTable.setTableName(tableNameC);
jsonTable.setClusteringOrder("emp_salary ASC");
jsonTable.setFields(fields);
- //Mockito.doNothing().when(http).addHeader(xLatestVersion, MusicUtil.getVersion());
- Response response = data.createTable("1", "1", "1",
- "abc66ccc-d857-4e90-b1e5-df98a3d40ce6", appName, authorization,
- jsonTable, keyspaceName, tableNameC);
+ // Mockito.doNothing().when(http).addHeader(xLatestVersion,
+ // MusicUtil.getVersion());
+ Response response = data.createTable("1", "1", "1", "abc66ccc-d857-4e90-b1e5-df98a3d40ce6", appName,
+ authorization, jsonTable, keyspaceName, tableNameC);
System.out.println("#######status is " + response.getStatus());
System.out.println("Entity" + response.getEntity());
- // if 200 print to log otherwise fail assertEquals(200, response.getStatus());
- // info.setQueryParameters("index_name=inx_uuid");
- Map<String,String> queryParametersMap =new HashMap<String, String>();
+ // if 200 print to log otherwise fail assertEquals(200,
+ // response.getStatus());
+ // info.setQueryParameters("index_name=inx_uuid");
+ Map<String, String> queryParametersMap = new HashMap<String, String>();
- queryParametersMap.put("index_name","inxuuid");
- // Mockito.when(info.getQueryParameters()).thenReturn(new MultivaluedMap<String, String>(queryParametersMap));
+ queryParametersMap.put("index_name", "inxuuid");
+ // Mockito.when(info.getQueryParameters()).thenReturn(new
+ // MultivaluedMap<String, String>(queryParametersMap));
try {
- response = data.createIndex("1", "1", "1",
- "abc66ccc-d857-4e90-b1e5-df98a3d40ce6", appName, authorization,
- keyspaceName, tableNameC,"uuid",info);
- assertEquals(200, response.getStatus());
+ response = data.createIndex("1", "1", "1", "abc66ccc-d857-4e90-b1e5-df98a3d40ce6", appName, authorization,
+ keyspaceName, tableNameC, "uuid", info);
+ assertEquals(200, response.getStatus());
} catch (NullPointerException e) {
-
+
}
}
@@ -683,9 +691,10 @@ public class TestRestMusicData {
jsonInsert.setKeyspaceName(keyspaceName);
jsonInsert.setTableName(tableName);
jsonInsert.setValues(values);
- //Mockito.doNothing().when(http).addHeader(xLatestVersion, MusicUtil.getVersion());
- Response response = data.insertIntoTable("1", "1", "1", "abc66ccc-d857-4e90-b1e5-df98a3d40ce6",
- appName, authorization, jsonInsert, keyspaceName, tableName);
+ // Mockito.doNothing().when(http).addHeader(xLatestVersion,
+ // MusicUtil.getVersion());
+ Response response = data.insertIntoTable("1", "1", "1", "abc66ccc-d857-4e90-b1e5-df98a3d40ce6", appName,
+ authorization, jsonInsert, keyspaceName, tableName);
assertEquals(200, response.getStatus());
}
@@ -702,10 +711,10 @@ public class TestRestMusicData {
jsonInsert.setKeyspaceName(keyspaceName);
jsonInsert.setTableName(tableName);
jsonInsert.setValues(values);
- //Mockito.doNothing().when(http).addHeader(xLatestVersion, MusicUtil.getVersion());
- Response response = data.insertIntoTable("1", "1", "1",
- "abc66ccc-d857-4e90-b1e5-df98a3d40ce6", appName, authorization,
- jsonInsert, keyspaceName, tableName);
+ // Mockito.doNothing().when(http).addHeader(xLatestVersion,
+ // MusicUtil.getVersion());
+ Response response = data.insertIntoTable("1", "1", "1", "abc66ccc-d857-4e90-b1e5-df98a3d40ce6", appName,
+ authorization, jsonInsert, keyspaceName, tableName);
assertEquals(200, response.getStatus());
}
@@ -723,10 +732,10 @@ public class TestRestMusicData {
jsonInsert.setKeyspaceName(keyspaceName);
jsonInsert.setTableName(tableName);
jsonInsert.setValues(values);
- //Mockito.doNothing().when(http).addHeader(xLatestVersion, MusicUtil.getVersion());
- Response response = data.insertIntoTable("1", "1", "1",
- "abc66ccc-d857-4e90-b1e5-df98a3d40ce6", appName, wrongAuthorization,
- jsonInsert, keyspaceName, tableName);
+ // Mockito.doNothing().when(http).addHeader(xLatestVersion,
+ // MusicUtil.getVersion());
+ Response response = data.insertIntoTable("1", "1", "1", "abc66ccc-d857-4e90-b1e5-df98a3d40ce6", appName,
+ wrongAuthorization, jsonInsert, keyspaceName, tableName);
assertEquals(401, response.getStatus());
}
@@ -744,14 +753,13 @@ public class TestRestMusicData {
jsonInsert.setKeyspaceName(keyspaceName);
jsonInsert.setTableName(tableName);
jsonInsert.setValues(values);
- //Mockito.doNothing().when(http).addHeader(xLatestVersion, MusicUtil.getVersion());
- Response response = data.insertIntoTable("1", "1", "1",
- "abc66ccc-d857-4e90-b1e5-df98a3d40ce6", appName, authorization,
- jsonInsert, keyspaceName, "wrong");
+ // Mockito.doNothing().when(http).addHeader(xLatestVersion,
+ // MusicUtil.getVersion());
+ Response response = data.insertIntoTable("1", "1", "1", "abc66ccc-d857-4e90-b1e5-df98a3d40ce6", appName,
+ authorization, jsonInsert, keyspaceName, "wrong");
assertEquals(400, response.getStatus());
}
-
-
+
@Test
public void Test5_updateTable() throws Exception {
JsonUpdate jsonUpdate = new JsonUpdate();
@@ -765,17 +773,18 @@ public class TestRestMusicData {
jsonUpdate.setKeyspaceName(keyspaceName);
jsonUpdate.setTableName(tableName);
jsonUpdate.setValues(values);
- //Mockito.doNothing().when(http).addHeader(xLatestVersion, MusicUtil.getVersion());
+ // Mockito.doNothing().when(http).addHeader(xLatestVersion,
+ // MusicUtil.getVersion());
Mockito.when(info.getQueryParameters()).thenReturn(row);
Response response = data.updateTable("1", "1", "1", "abc66ccc-d857-4e90-b1e5-df98a3d40ce6", appName,
authorization, jsonUpdate, keyspaceName, tableName, info);
assertEquals(200, response.getStatus());
- }
-
+ }
+
// need mock code to create error for MusicCore methods
@Test
public void Test5_updateTableAuthE() throws Exception {
- //MockitoAnnotations.initMocks(this);
+ // MockitoAnnotations.initMocks(this);
JsonUpdate jsonUpdate = new JsonUpdate();
Map<String, String> consistencyInfo = new HashMap<>();
MultivaluedMap<String, String> row = new MultivaluedMapImpl();
@@ -787,20 +796,21 @@ public class TestRestMusicData {
jsonUpdate.setKeyspaceName(keyspaceName);
jsonUpdate.setTableName(tableName);
jsonUpdate.setValues(values);
- //add ttl & timestamp
- //Mockito.doNothing().when(http).addHeader(xLatestVersion, MusicUtil.getVersion());
+ // add ttl & timestamp
+ // Mockito.doNothing().when(http).addHeader(xLatestVersion,
+ // MusicUtil.getVersion());
Mockito.when(info.getQueryParameters()).thenReturn(row);
- //Map<String, Object> m1= new HashMap<>() ;
- //Mockito.when(MusicCore.autheticateUser(appName,userId,password,keyspaceName,"abc66ccc-d857-4e90-b1e5-df98a3d40ce6","updateTable")).thenReturn(m1);
+ // Map<String, Object> m1= new HashMap<>() ;
+ // Mockito.when(MusicCore.autheticateUser(appName,userId,password,keyspaceName,"abc66ccc-d857-4e90-b1e5-df98a3d40ce6","updateTable")).thenReturn(m1);
try {
- Response response = data.updateTable("1", "1", "1", "abc66ccc-d857-4e90-b1e5-df98a3d40ce6", appName,
- authorization, jsonUpdate, keyspaceName, tableName, info);
- assertEquals(200, response.getStatus());
- } catch(NullPointerException e) {
-
+ Response response = data.updateTable("1", "1", "1", "abc66ccc-d857-4e90-b1e5-df98a3d40ce6", appName,
+ authorization, jsonUpdate, keyspaceName, tableName, info);
+ assertEquals(200, response.getStatus());
+ } catch (NullPointerException e) {
+
}
- }
-
+ }
+
@Test
public void Test5_updateTableAuthException1() throws Exception {
JsonUpdate jsonUpdate = new JsonUpdate();
@@ -814,18 +824,19 @@ public class TestRestMusicData {
jsonUpdate.setKeyspaceName(keyspaceName);
jsonUpdate.setTableName(tableName);
jsonUpdate.setValues(values);
-
- //Mockito.doNothing().when(http).addHeader(xLatestVersion, MusicUtil.getVersion());
- //Mockito.when(info.getQueryParameters()).thenReturn(row);
- String authDatax = ":";//+password;
+
+ // Mockito.doNothing().when(http).addHeader(xLatestVersion,
+ // MusicUtil.getVersion());
+ // Mockito.when(info.getQueryParameters()).thenReturn(row);
+ String authDatax = ":";// +password;
String authorizationx = new String(Base64.encode(authDatax.getBytes()));
try {
- Response response = data.updateTable("1", "1", "1", "abc66ccc-d857-4e90-b1e5-df98a3d40ce6", appName,
- authorizationx, jsonUpdate, keyspaceName, tableName, info);
- assertEquals(200, response.getStatus());
- } catch(RuntimeException e) {
- System.out.println("Update table Runtime exception="+e);
-
+ Response response = data.updateTable("1", "1", "1", "abc66ccc-d857-4e90-b1e5-df98a3d40ce6", appName,
+ authorizationx, jsonUpdate, keyspaceName, tableName, info);
+ assertEquals(200, response.getStatus());
+ } catch (RuntimeException e) {
+ System.out.println("Update table Runtime exception=" + e);
+
}
}
@@ -842,24 +853,25 @@ public class TestRestMusicData {
jsonUpdate.setKeyspaceName(keyspaceName);
jsonUpdate.setTableName(tableName);
jsonUpdate.setValues(values);
-
- //Mockito.doNothing().when(http).addHeader(xLatestVersion, MusicUtil.getVersion());
- //Mockito.when(info.getQueryParameters()).thenReturn(row);
- String authDatax =":"+password;
+
+ // Mockito.doNothing().when(http).addHeader(xLatestVersion,
+ // MusicUtil.getVersion());
+ // Mockito.when(info.getQueryParameters()).thenReturn(row);
+ String authDatax = ":" + password;
String authorizationx = new String(Base64.encode(authDatax.getBytes()));
- String appNamex="xx";
+ String appNamex = "xx";
try {
- // Response response = data.updateTable("1", "1", "1", "abc66ccc-d857-4e90-b1e5-df98a3d40ce6", appName,
- Response response = data.updateTable("1", "1", "1", "", appNamex,
- authorizationx, jsonUpdate, keyspaceName, tableName, info);
- assertEquals(200, response.getStatus());
- } catch(RuntimeException e) {
- System.out.println("Update table Runtime exception="+e);
-
+ // Response response = data.updateTable("1", "1", "1",
+ // "abc66ccc-d857-4e90-b1e5-df98a3d40ce6", appName,
+ Response response = data.updateTable("1", "1", "1", "", appNamex, authorizationx, jsonUpdate, keyspaceName,
+ tableName, info);
+ assertEquals(200, response.getStatus());
+ } catch (RuntimeException e) {
+ System.out.println("Update table Runtime exception=" + e);
+
}
}
-
@Test
public void Test6_select() throws Exception {
JsonSelect jsonSelect = new JsonSelect();
@@ -868,13 +880,14 @@ public class TestRestMusicData {
row.add("emp_name", "testName");
consistencyInfo.put("type", "atomic");
jsonSelect.setConsistencyInfo(consistencyInfo);
- //Mockito.doNothing().when(http).addHeader(xLatestVersion, MusicUtil.getVersion());
+ // Mockito.doNothing().when(http).addHeader(xLatestVersion,
+ // MusicUtil.getVersion());
Mockito.when(info.getQueryParameters()).thenReturn(row);
- Response response = data.select("1", "1", "1","abc66ccc-d857-4e90-b1e5-df98a3d40ce6",
- appName, authorization, keyspaceName, tableName, info);
- HashMap<String,HashMap<String,Object>> map = (HashMap<String, HashMap<String, Object>>) response.getEntity();
+ Response response = data.select("1", "1", "1", "abc66ccc-d857-4e90-b1e5-df98a3d40ce6", appName, authorization,
+ keyspaceName, tableName, info);
+ HashMap<String, HashMap<String, Object>> map = (HashMap<String, HashMap<String, Object>>) response.getEntity();
HashMap<String, Object> result = map.get("result");
- assertEquals("2500", ((HashMap<String,Object>) result.get("row 0")).get("emp_salary").toString());
+ assertEquals("2500", ((HashMap<String, Object>) result.get("row 0")).get("emp_salary").toString());
}
@Test
@@ -885,13 +898,14 @@ public class TestRestMusicData {
row.add("emp_name", "testName");
consistencyInfo.put("type", "atomic");
jsonInsert.setConsistencyInfo(consistencyInfo);
- //Mockito.doNothing().when(http).addHeader(xLatestVersion, MusicUtil.getVersion());
+ // Mockito.doNothing().when(http).addHeader(xLatestVersion,
+ // MusicUtil.getVersion());
Mockito.when(info.getQueryParameters()).thenReturn(row);
- Response response = data.selectCritical("1", "1", "1","abc66ccc-d857-4e90-b1e5-df98a3d40ce6",
- appName, authorization, jsonInsert, keyspaceName, tableName,info);
- HashMap<String,HashMap<String,Object>> map = (HashMap<String, HashMap<String, Object>>) response.getEntity();
+ Response response = data.selectCritical("1", "1", "1", "abc66ccc-d857-4e90-b1e5-df98a3d40ce6", appName,
+ authorization, jsonInsert, keyspaceName, tableName, info);
+ HashMap<String, HashMap<String, Object>> map = (HashMap<String, HashMap<String, Object>>) response.getEntity();
HashMap<String, Object> result = map.get("result");
- assertEquals("2500", ((HashMap<String,Object>) result.get("row 0")).get("emp_salary").toString());
+ assertEquals("2500", ((HashMap<String, Object>) result.get("row 0")).get("emp_salary").toString());
}
@Test
@@ -902,11 +916,11 @@ public class TestRestMusicData {
row.add("emp_name", "test1");
consistencyInfo.put("type", "atomic");
jsonDelete.setConsistencyInfo(consistencyInfo);
- //Mockito.doNothing().when(http).addHeader(xLatestVersion, MusicUtil.getVersion());
+ // Mockito.doNothing().when(http).addHeader(xLatestVersion,
+ // MusicUtil.getVersion());
Mockito.when(info.getQueryParameters()).thenReturn(row);
- Response response = data.deleteFromTable("1", "1", "1",
- "abc66ccc-d857-4e90-b1e5-df98a3d40ce6", appName, authorization,
- jsonDelete, keyspaceName, tableName, info);
+ Response response = data.deleteFromTable("1", "1", "1", "abc66ccc-d857-4e90-b1e5-df98a3d40ce6", appName,
+ authorization, jsonDelete, keyspaceName, tableName, info);
assertEquals(200, response.getStatus());
}
@@ -919,11 +933,11 @@ public class TestRestMusicData {
MultivaluedMap<String, String> row = new MultivaluedMapImpl();
consistencyInfo.put("type", "atomic");
jsonDelete.setConsistencyInfo(consistencyInfo);
- //Mockito.doNothing().when(http).addHeader(xLatestVersion, MusicUtil.getVersion());
+ // Mockito.doNothing().when(http).addHeader(xLatestVersion,
+ // MusicUtil.getVersion());
Mockito.when(info.getQueryParameters()).thenReturn(row);
- Response response = data.deleteFromTable("1", "1", "1",
- "abc66ccc-d857-4e90-b1e5-df98a3d40ce6", appName, authorization,
- jsonDelete, keyspaceName, tableName, info);
+ Response response = data.deleteFromTable("1", "1", "1", "abc66ccc-d857-4e90-b1e5-df98a3d40ce6", appName,
+ authorization, jsonDelete, keyspaceName, tableName, info);
assertEquals(400, response.getStatus());
}
@@ -936,11 +950,11 @@ public class TestRestMusicData {
row.add("emp_name", "test1");
consistencyInfo.put("type", "atomic");
jsonDelete.setConsistencyInfo(consistencyInfo);
- //Mockito.doNothing().when(http).addHeader(xLatestVersion, MusicUtil.getVersion());
- //Mockito.when(info.getQueryParameters()).thenReturn(row);
- Response response = data.deleteFromTable("1", "1", "1",
- "abc66ccc-d857-4e90-b1e5-df98a3d40ce6", appName, authorization,
- null, keyspaceName, tableName, info);
+ // Mockito.doNothing().when(http).addHeader(xLatestVersion,
+ // MusicUtil.getVersion());
+ // Mockito.when(info.getQueryParameters()).thenReturn(row);
+ Response response = data.deleteFromTable("1", "1", "1", "abc66ccc-d857-4e90-b1e5-df98a3d40ce6", appName,
+ authorization, null, keyspaceName, tableName, info);
assertEquals(400, response.getStatus());
}
@@ -950,14 +964,13 @@ public class TestRestMusicData {
Map<String, String> consistencyInfo = new HashMap<>();
consistencyInfo.put("type", "atomic");
jsonTable.setConsistencyInfo(consistencyInfo);
- //Mockito.doNothing().when(http).addHeader(xLatestVersion, MusicUtil.getVersion());
- Response response = data.dropTable("1", "1", "1",
- "abc66ccc-d857-4e90-b1e5-df98a3d40ce6", appName, authorization,
- keyspaceName, tableName);
+ // Mockito.doNothing().when(http).addHeader(xLatestVersion,
+ // MusicUtil.getVersion());
+ Response response = data.dropTable("1", "1", "1", "abc66ccc-d857-4e90-b1e5-df98a3d40ce6", appName,
+ authorization, keyspaceName, tableName);
assertEquals(200, response.getStatus());
}
-
@Test
public void Test8_deleteKeyspace() throws Exception {
JsonKeySpace jsonKeyspace = new JsonKeySpace();
@@ -970,12 +983,13 @@ public class TestRestMusicData {
jsonKeyspace.setDurabilityOfWrites("true");
jsonKeyspace.setKeyspaceName("TestApp1");
jsonKeyspace.setReplicationInfo(replicationInfo);
- //Mockito.doNothing().when(http).addHeader(xLatestVersion, MusicUtil.getVersion());
- Response response = data.dropKeySpace("1", "1", "1", "abc66ccc-d857-4e90-b1e5-df98a3d40ce6",
- authorization,appName, keyspaceName);
+ // Mockito.doNothing().when(http).addHeader(xLatestVersion,
+ // MusicUtil.getVersion());
+ Response response = data.dropKeySpace("1", "1", "1", "abc66ccc-d857-4e90-b1e5-df98a3d40ce6", authorization,
+ appName, keyspaceName);
assertEquals(200, response.getStatus());
}
-
+
@Test
public void Test8_deleteKeyspace2() throws Exception {
JsonKeySpace jsonKeyspace = new JsonKeySpace();
@@ -988,9 +1002,10 @@ public class TestRestMusicData {
jsonKeyspace.setDurabilityOfWrites("true");
jsonKeyspace.setKeyspaceName("TestApp1");
jsonKeyspace.setReplicationInfo(replicationInfo);
- //Mockito.doNothing().when(http).addHeader(xLatestVersion, MusicUtil.getVersion());
- Response response = data.dropKeySpace("1", "1", "1", "abc66ccc-d857-4e90-b1e5-df98a3d40ce6",
- wrongAuthorization, appName, keyspaceName);
+ // Mockito.doNothing().when(http).addHeader(xLatestVersion,
+ // MusicUtil.getVersion());
+ Response response = data.dropKeySpace("1", "1", "1", "abc66ccc-d857-4e90-b1e5-df98a3d40ce6", wrongAuthorization,
+ appName, keyspaceName);
assertEquals(401, response.getStatus());
}
@@ -999,137 +1014,123 @@ public class TestRestMusicData {
JsonKeySpace jsonKeyspace = new JsonKeySpace();
Map<String, String> consistencyInfo = new HashMap<>();
Map<String, Object> replicationInfo = new HashMap<>();
- //Mockito.doNothing().when(http).addHeader(xLatestVersion, MusicUtil.getVersion());
- Response response = data.dropKeySpace("1", "1", "1", "abc66ccc-d857-4e90-b1e5-df98a3d40ce6",
- authorization, appName, keyspaceName);
+ // Mockito.doNothing().when(http).addHeader(xLatestVersion,
+ // MusicUtil.getVersion());
+ Response response = data.dropKeySpace("1", "1", "1", "abc66ccc-d857-4e90-b1e5-df98a3d40ce6", authorization,
+ appName, keyspaceName);
assertEquals(400, response.getStatus());
}
-
-
- @Test
- public void Test6_onboard() throws Exception {
- JsonOnboard jsonOnboard = new JsonOnboard();
- jsonOnboard.setAppname("TestApp2");
- jsonOnboard.setIsAAF("false");
- jsonOnboard.setUserId("TestUser2");
- jsonOnboard.setPassword("TestPassword2");
- Map<String, Object> resultMap = (Map<String, Object>) admin.onboardAppWithMusic(jsonOnboard).getEntity();
- resultMap.containsKey("success");
- onboardUUID = resultMap.get("Generated AID").toString();
- assertEquals("Your application TestApp2 has been onboarded with MUSIC.", resultMap.get("Success"));
- }
- // Missing appname
- @Test
- public void Test6_onboard1() throws Exception {
- JsonOnboard jsonOnboard = new JsonOnboard();
- jsonOnboard.setIsAAF("false");
- jsonOnboard.setUserId("TestUser2");
- jsonOnboard.setPassword("TestPassword2");
- Map<String, Object> resultMap = (Map<String, Object>) admin.onboardAppWithMusic(jsonOnboard).getEntity();
- resultMap.containsKey("success");
- System.out.println("--->" + resultMap.toString());
- assertEquals("Unauthorized: Please check the request parameters. Some of the required values appName(ns), userId, password, isAAF are missing.", resultMap.get("Exception"));
- }
-
-
- @Test
- public void Test7_onboardSearch() throws Exception {
- JsonOnboard jsonOnboard = new JsonOnboard();
- jsonOnboard.setAppname("TestApp2");
- jsonOnboard.setIsAAF("false");
- jsonOnboard.setAid(onboardUUID);
- Map<String, Object> resultMap = (Map<String, Object>) admin.getOnboardedInfoSearch(jsonOnboard).getEntity();
- resultMap.containsKey("success");
- assertEquals(MusicUtil.DEFAULTKEYSPACENAME, resultMap.get(onboardUUID));
-
- }
-
- // Missing appname
- @Test
- public void Test7_onboardSearch1() throws Exception {
- JsonOnboard jsonOnboard = new JsonOnboard();
- jsonOnboard.setIsAAF("false");
- jsonOnboard.setAid(onboardUUID);
- Map<String, Object> resultMap = (Map<String, Object>) admin.getOnboardedInfoSearch(jsonOnboard).getEntity();
- System.out.println("--->" + resultMap.toString());
- resultMap.containsKey("success");
- assertEquals(MusicUtil.DEFAULTKEYSPACENAME, resultMap.get(onboardUUID));
-
- }
-
- @Test
- public void Test8_onboardUpdate() throws Exception {
- JsonOnboard jsonOnboard = new JsonOnboard();
- jsonOnboard.setIsAAF("false");
- jsonOnboard.setUserId("TestUser3");
- jsonOnboard.setPassword("TestPassword3");
- jsonOnboard.setAid(onboardUUID);
- Map<String, Object> resultMap = (Map<String, Object>) admin.updateOnboardApp(jsonOnboard).getEntity();
- System.out.println("--->" + resultMap.toString());
- resultMap.containsKey("success");
- assertEquals("Your application has been updated successfully", resultMap.get("Success"));
- }
-
- // Aid null
- @Test
- public void Test8_onboardUpdate1() throws Exception {
- JsonOnboard jsonOnboard = new JsonOnboard();
- jsonOnboard.setIsAAF("false");
- jsonOnboard.setUserId("TestUser3");
- jsonOnboard.setPassword("TestPassword3");
- Map<String, Object> resultMap = (Map<String, Object>) admin.updateOnboardApp(jsonOnboard).getEntity();
- System.out.println("--->" + resultMap.toString());
- resultMap.containsKey("success");
- assertEquals("Please make sure Aid is present", resultMap.get("Exception"));
- }
-
- // Appname not null
- @Test
- public void Test8_onboardUpdate2() throws Exception {
- JsonOnboard jsonOnboard = new JsonOnboard();
- jsonOnboard.setAppname("TestApp2");
- jsonOnboard.setIsAAF("false");
- jsonOnboard.setUserId("TestUser3");
- jsonOnboard.setPassword("TestPassword3");
- jsonOnboard.setAid(onboardUUID);
- Map<String, Object> resultMap = (Map<String, Object>) admin.updateOnboardApp(jsonOnboard).getEntity();
- resultMap.containsKey("success");
- System.out.println("--->" + resultMap.toString());
- assertEquals("Application TestApp2 has already been onboarded. Please contact admin.", resultMap.get("Exception"));
- }
-
- // All null
- @Test
- public void Test8_onboardUpdate3() throws Exception {
- JsonOnboard jsonOnboard = new JsonOnboard();
- jsonOnboard.setAid(onboardUUID);
- Map<String, Object> resultMap = (Map<String, Object>) admin.updateOnboardApp(jsonOnboard).getEntity();
- assertTrue(resultMap.containsKey("Exception") );
- }
-
- @Test
- public void Test9_onboardDelete() throws Exception {
- JsonOnboard jsonOnboard = new JsonOnboard();
- jsonOnboard.setAppname("TestApp2");
- jsonOnboard.setAid(onboardUUID);
- Map<String, Object> resultMap = (Map<String, Object>) admin.deleteOnboardApp(jsonOnboard).getEntity();
- resultMap.containsKey("success");
- assertEquals("Your application has been deleted successfully", resultMap.get("Success"));
- }
-
- @Test
- public void Test9_onboardDelete1() throws Exception {
- JsonOnboard jsonOnboard = new JsonOnboard();
- Map<String, Object> resultMap = (Map<String, Object>) admin.deleteOnboardApp(jsonOnboard).getEntity();
- assertTrue(resultMap.containsKey("Exception"));
- }
+ /*
+ * @Test public void Test6_onboard() throws Exception { JsonOnboard
+ * jsonOnboard = new JsonOnboard(); jsonOnboard.setAppname("TestApp2");
+ * jsonOnboard.setIsAAF("false"); jsonOnboard.setUserId("TestUser2");
+ * jsonOnboard.setPassword("TestPassword2"); Map<String, Object> resultMap =
+ * (Map<String, Object>) admin.onboardAppWithMusic(jsonOnboard).getEntity();
+ * resultMap.containsKey("success"); onboardUUID =
+ * resultMap.get("Generated AID").toString();
+ * assertEquals("Your application TestApp2 has been onboarded with MUSIC.",
+ * resultMap.get("Success")); } // Missing appname
+ *
+ * @Test public void Test6_onboard1() throws Exception { JsonOnboard
+ * jsonOnboard = new JsonOnboard(); jsonOnboard.setIsAAF("false");
+ * jsonOnboard.setUserId("TestUser2");
+ * jsonOnboard.setPassword("TestPassword2"); Map<String, Object> resultMap =
+ * (Map<String, Object>) admin.onboardAppWithMusic(jsonOnboard).getEntity();
+ * resultMap.containsKey("success"); System.out.println("--->" +
+ * resultMap.toString());
+ * assertEquals("Unauthorized: Please check the request parameters. Some of the required values appName(ns), userId, password, isAAF are missing."
+ * , resultMap.get("Exception")); }
+ *
+ *
+ * @Test public void Test7_onboardSearch() throws Exception { JsonOnboard
+ * jsonOnboard = new JsonOnboard(); jsonOnboard.setAppname("TestApp2");
+ * jsonOnboard.setIsAAF("false"); jsonOnboard.setAid(onboardUUID);
+ * Map<String, Object> resultMap = (Map<String, Object>)
+ * admin.getOnboardedInfoSearch(jsonOnboard).getEntity();
+ * resultMap.containsKey("success");
+ * assertEquals(MusicUtil.DEFAULTKEYSPACENAME, resultMap.get(onboardUUID));
+ *
+ * }
+ *
+ * // Missing appname
+ *
+ * @Test public void Test7_onboardSearch1() throws Exception { JsonOnboard
+ * jsonOnboard = new JsonOnboard(); jsonOnboard.setIsAAF("false");
+ * jsonOnboard.setAid(onboardUUID); Map<String, Object> resultMap =
+ * (Map<String, Object>)
+ * admin.getOnboardedInfoSearch(jsonOnboard).getEntity();
+ * System.out.println("--->" + resultMap.toString());
+ * resultMap.containsKey("success");
+ * assertEquals(MusicUtil.DEFAULTKEYSPACENAME, resultMap.get(onboardUUID));
+ *
+ * }
+ *
+ * @Test public void Test8_onboardUpdate() throws Exception { JsonOnboard
+ * jsonOnboard = new JsonOnboard(); jsonOnboard.setIsAAF("false");
+ * jsonOnboard.setUserId("TestUser3");
+ * jsonOnboard.setPassword("TestPassword3");
+ * jsonOnboard.setAid(onboardUUID); Map<String, Object> resultMap =
+ * (Map<String, Object>) admin.updateOnboardApp(jsonOnboard).getEntity();
+ * System.out.println("--->" + resultMap.toString());
+ * resultMap.containsKey("success");
+ * assertEquals("Your application has been updated successfully",
+ * resultMap.get("Success")); }
+ *
+ * // Aid null
+ *
+ * @Test public void Test8_onboardUpdate1() throws Exception { JsonOnboard
+ * jsonOnboard = new JsonOnboard(); jsonOnboard.setIsAAF("false");
+ * jsonOnboard.setUserId("TestUser3");
+ * jsonOnboard.setPassword("TestPassword3"); Map<String, Object> resultMap =
+ * (Map<String, Object>) admin.updateOnboardApp(jsonOnboard).getEntity();
+ * System.out.println("--->" + resultMap.toString());
+ * resultMap.containsKey("success");
+ * assertEquals("Please make sure Aid is present",
+ * resultMap.get("Exception")); }
+ *
+ * // Appname not null
+ *
+ * @Test public void Test8_onboardUpdate2() throws Exception { JsonOnboard
+ * jsonOnboard = new JsonOnboard(); jsonOnboard.setAppname("TestApp2");
+ * jsonOnboard.setIsAAF("false"); jsonOnboard.setUserId("TestUser3");
+ * jsonOnboard.setPassword("TestPassword3");
+ * jsonOnboard.setAid(onboardUUID); Map<String, Object> resultMap =
+ * (Map<String, Object>) admin.updateOnboardApp(jsonOnboard).getEntity();
+ * resultMap.containsKey("success"); System.out.println("--->" +
+ * resultMap.toString());
+ * assertEquals("Application TestApp2 has already been onboarded. Please contact admin."
+ * , resultMap.get("Exception")); }
+ *
+ * // All null
+ *
+ * @Test public void Test8_onboardUpdate3() throws Exception { JsonOnboard
+ * jsonOnboard = new JsonOnboard(); jsonOnboard.setAid(onboardUUID);
+ * Map<String, Object> resultMap = (Map<String, Object>)
+ * admin.updateOnboardApp(jsonOnboard).getEntity();
+ * assertTrue(resultMap.containsKey("Exception") ); }
+ *
+ * @Test public void Test9_onboardDelete() throws Exception { JsonOnboard
+ * jsonOnboard = new JsonOnboard(); jsonOnboard.setAppname("TestApp2");
+ * jsonOnboard.setAid(onboardUUID); Map<String, Object> resultMap =
+ * (Map<String, Object>) admin.deleteOnboardApp(jsonOnboard).getEntity();
+ * resultMap.containsKey("success");
+ * assertEquals("Your application has been deleted successfully",
+ * resultMap.get("Success")); }
+ *
+ * @Test public void Test9_onboardDelete1() throws Exception { JsonOnboard
+ * jsonOnboard = new JsonOnboard(); Map<String, Object> resultMap =
+ * (Map<String, Object>) admin.deleteOnboardApp(jsonOnboard).getEntity();
+ * assertTrue(resultMap.containsKey("Exception")); }
+ */
@Ignore
@Test
public void Test3_createLockReference() throws Exception {
- //Mockito.doNothing().when(http).addHeader(xLatestVersion, MusicUtil.getVersion());
- Map<String, Object> resultMap = (Map<String, Object>) lock.createLockReference(lockName,"1","1",authorization, null, appName).getEntity();
+ // Mockito.doNothing().when(http).addHeader(xLatestVersion,
+ // MusicUtil.getVersion());
+ Map<String, Object> resultMap = (Map<String, Object>) lock
+ .createLockReference(lockName, "1", "1", authorization, null, appName).getEntity();
@SuppressWarnings("unchecked")
Map<String, Object> resultMap1 = (Map<String, Object>) resultMap.get("lock");
lockId = (String) resultMap1.get("lock");
@@ -1139,26 +1140,31 @@ public class TestRestMusicData {
@Ignore
@Test
public void Test4_accquireLock() throws Exception {
- //Mockito.doNothing().when(http).addHeader(xLatestVersion, MusicUtil.getVersion());
- Map<String, Object> resultMap = (Map<String, Object>) lock.accquireLock(lockId,"1","1",authorization, null, appName).getEntity();
+ // Mockito.doNothing().when(http).addHeader(xLatestVersion,
+ // MusicUtil.getVersion());
+ Map<String, Object> resultMap = (Map<String, Object>) lock
+ .accquireLock(lockId, "1", "1", authorization, null, appName).getEntity();
assertEquals(ResultType.SUCCESS, resultMap.get("status"));
}
@Ignore
@Test
public void Test5_currentLockHolder() throws Exception {
- //Mockito.doNothing().when(http).addHeader(xLatestVersion, MusicUtil.getVersion());
- Map<String, Object> resultMap = (Map<String, Object>) lock.currentLockHolder(lockName,"1","1",authorization, null, appName).getEntity();
+ // Mockito.doNothing().when(http).addHeader(xLatestVersion,
+ // MusicUtil.getVersion());
+ Map<String, Object> resultMap = (Map<String, Object>) lock
+ .currentLockHolder(lockName, "1", "1", authorization, null, appName).getEntity();
assertEquals(ResultType.SUCCESS, resultMap.get("status"));
}
-
+
@Ignore
@Test
public void Test7_unLock() throws Exception {
- //Mockito.doNothing().when(http).addHeader(xLatestVersion, MusicUtil.getVersion());
- Map<String, Object> resultMap = (Map<String, Object>) lock.unLock(lockId,"1","1",authorization, null, appName).getEntity();
+ // Mockito.doNothing().when(http).addHeader(xLatestVersion,
+ // MusicUtil.getVersion());
+ Map<String, Object> resultMap = (Map<String, Object>) lock
+ .unLock(lockId, "1", "1", authorization, null, appName).getEntity();
assertEquals(ResultType.SUCCESS, resultMap.get("status"));
}
-
} \ No newline at end of file