summaryrefslogtreecommitdiffstats
path: root/src/test/java/org/openecomp/sparky/security/portal/TestUserManager.java
diff options
context:
space:
mode:
authorArul.Nambi <arul.nambi@amdocs.com>2017-09-26 14:00:57 -0400
committerArul.Nambi <arul.nambi@amdocs.com>2017-09-26 14:01:41 -0400
commitc593dfe4c59d37d5d4ea14e3ac31da3318029562 (patch)
tree76cc5a494f02e14b809caad9c050fbfd6cd61a51 /src/test/java/org/openecomp/sparky/security/portal/TestUserManager.java
parent6777c6092050a0271c5d7de9c239cf1580d41fa8 (diff)
Renaming openecomp to onap
Issue-ID: AAI-208 Change-Id: I2bd02287bed376111156aca0100e2b7b74e368e3 Signed-off-by: Arul.Nambi <arul.nambi@amdocs.com>
Diffstat (limited to 'src/test/java/org/openecomp/sparky/security/portal/TestUserManager.java')
-rw-r--r--src/test/java/org/openecomp/sparky/security/portal/TestUserManager.java205
1 files changed, 0 insertions, 205 deletions
diff --git a/src/test/java/org/openecomp/sparky/security/portal/TestUserManager.java b/src/test/java/org/openecomp/sparky/security/portal/TestUserManager.java
deleted file mode 100644
index 1a8a9e9..0000000
--- a/src/test/java/org/openecomp/sparky/security/portal/TestUserManager.java
+++ /dev/null
@@ -1,205 +0,0 @@
-/*
-* ============LICENSE_START=======================================================
-* SPARKY (AAI UI service)
-* ================================================================================
-* Copyright © 2017 AT&T Intellectual Property.
-* Copyright © 2017 Amdocs
-* All rights reserved.
-* ================================================================================
-* 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=========================================================
-*
-* ECOMP and OpenECOMP are trademarks
-* and service marks of AT&T Intellectual Property.
-*/
-
-package org.openecomp.sparky.security.portal;
-
-import static org.hamcrest.Matchers.empty;
-import static org.hamcrest.Matchers.is;
-import static org.junit.Assert.assertThat;
-
-import java.io.File;
-import java.io.IOException;
-import java.nio.file.Files;
-import java.nio.file.Paths;
-import java.util.Arrays;
-import java.util.List;
-import java.util.concurrent.Callable;
-import java.util.concurrent.ExecutorService;
-import java.util.concurrent.Executors;
-import java.util.stream.Collectors;
-
-import org.junit.After;
-import org.junit.AfterClass;
-import org.junit.Before;
-import org.junit.BeforeClass;
-import org.junit.Test;
-import org.junit.runner.RunWith;
-import org.openecomp.portalsdk.core.restful.domain.EcompUser;
-import org.openecomp.sparky.util.NodeUtils;
-import org.powermock.modules.junit4.PowerMockRunner;
-
-import com.google.gson.Gson;
-
-@RunWith(PowerMockRunner.class)
-//@PrepareForTest(RolesConfig.class)
-public class TestUserManager {
-
- private static final String LOGINID_3 = "3";
- private static File noFile;
- private static File concurrentUsers;
- private static File concurrentEditUsers;
-
- private static final Gson GSON = new Gson();
- private static final String LOGINID_1 = "1";
- private static final String LOGINID_2 = "2";
-
- enum TestData {
- // @formatter:off
- NO_FILE ("src/test/resources/portal/no-users.config"),
- CONCURRENT_USERS ("src/test/resources/portal/concurrent-users.config"),
- CONCURRENT_EDIT_USERS ("src/test/resources/portal/concurrent-edit-users.config");
-// ROLES_CONFIG_FILE ("src/test/resources/portal/roles.config");
-
- private String filename;
- TestData(String filename) {this.filename = filename;}
- public String getFilename() {return this.filename;}
- // @formatter:on
- }
-
- @BeforeClass
- public static void setUpBeforeClass() throws Exception {
- noFile = Paths.get(TestData.NO_FILE.getFilename()).toFile();
- concurrentUsers = Paths.get(TestData.CONCURRENT_USERS.getFilename()).toFile();
- concurrentEditUsers = Paths.get(TestData.CONCURRENT_EDIT_USERS.getFilename()).toFile();
- }
-
- @AfterClass
- public static void tearDownAfterClass() throws Exception {
- Files.deleteIfExists(concurrentUsers.toPath());
- Files.deleteIfExists(concurrentEditUsers.toPath());
- }
-
- @Before
- public void setUp() throws Exception {
- EcompUser user1 = new EcompUser();
- user1.setLoginId(LOGINID_1);
-
- EcompUser user2 = new EcompUser();
- user2.setLoginId(LOGINID_2);
-
- List<EcompUser> users = Arrays.asList(user1, user2);
- Files.write(concurrentEditUsers.toPath(), GSON.toJson(users).getBytes());
-
-// Whitebox.setInternalState(RolesConfig.class, "ROLES_CONFIG_FILE",
-// TestData.ROLES_CONFIG_FILE.getFilename());
- }
-
- @After
- public void tearDown() throws Exception {
- Files.deleteIfExists(concurrentUsers.toPath());
- Files.deleteIfExists(concurrentEditUsers.toPath());
- }
-
- @Test
- public void testGetUsersNoFile() throws Exception {
- UserManager userManager = new UserManager(noFile);
- List<EcompUser> users = userManager.getUsers();
-
- assertThat(users, empty());
- }
-
- @Test
- public void testConcurrentPush() throws Exception {
- Callable<EcompUser> pushTask = () -> {
- return pushTask(concurrentUsers, String.valueOf(NodeUtils.getRandomTxnId()));
- };
-
- List<Callable<EcompUser>> callables = Arrays.asList(pushTask, pushTask, pushTask, pushTask,
- pushTask);
-
- ExecutorService executor = Executors.newWorkStealingPool();
- executor.invokeAll(callables).stream().map(future -> {
- try {
- return future.get();
- } catch (Exception e) {
- throw new IllegalStateException(e);
- }
- });
-
- UserManager userManager = new UserManager(concurrentUsers);
- assertThat(userManager.getUsers().size(), is(5));
- }
-
- @Test
- public void testConcurrentPushAndEdit() throws Exception {
- Callable<EcompUser> pushTaskRandomId = () -> {
- return pushTask(concurrentEditUsers, String.valueOf(NodeUtils.getRandomTxnId()));
- };
-
- Callable<EcompUser> pushTaskId3 = () -> {
- return pushTask(concurrentEditUsers, LOGINID_3);
- };
-
- Callable<EcompUser> editTaskId1 = () -> {
- return editTask(LOGINID_1, "Bob");
- };
-
- Callable<EcompUser> editTaskId2 = () -> {
- return editTask(LOGINID_2, "Jen");
- };
-
- Callable<EcompUser> editTaskId3 = () -> {
- return editTask(LOGINID_3, "Amy");
- };
-
- List<Callable<EcompUser>> callables = Arrays.asList(pushTaskRandomId, pushTaskRandomId,
- pushTaskId3, editTaskId1, pushTaskRandomId, pushTaskRandomId, editTaskId3, editTaskId2,
- pushTaskRandomId);
-
- ExecutorService executor = Executors.newWorkStealingPool();
- List<EcompUser> userTasks = executor.invokeAll(callables).stream().map(future -> {
- try {
- return future.get();
- } catch (Exception e) {
- throw new IllegalStateException(e);
- }
- }).collect(Collectors.toList());
-
- assertThat(userTasks.size(), is(9));
-
- UserManager userManager = new UserManager(concurrentEditUsers);
- assertThat(userManager.getUsers().size(), is(8));
- assertThat(userManager.getUser(LOGINID_1).get().getFirstName(), is("Bob"));
- assertThat(userManager.getUser(LOGINID_2).get().getFirstName(), is("Jen"));
- assertThat(userManager.getUser(LOGINID_3).get().getFirstName(), is("Amy"));
- }
-
- private EcompUser pushTask(File fileStore, String loginId) throws IOException {
- UserManager userManager = new UserManager(fileStore);
- EcompUser user = new EcompUser();
- user.setLoginId(loginId);
- userManager.pushUser(user);
- return user;
- }
-
- private EcompUser editTask(String loginId, String firstName) throws IOException {
- UserManager userManager = new UserManager(concurrentEditUsers);
- EcompUser user = new EcompUser();
- user.setLoginId(loginId);
- user.setFirstName(firstName);
- userManager.editUser(loginId, user);
- return user;
- }
-} \ No newline at end of file