--- /dev/null
+/*-
+ * ============LICENSE_START=======================================================
+ * ECOMP Policy Engine
+ * ================================================================================
+ * Copyright (C) 2017 AT&T Intellectual Property. 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=========================================================
+ */
+
+
+package org.openecomp.portalapp.service;
+
+import java.util.ArrayList;
+import java.util.Iterator;
+import java.util.List;
+import java.util.Set;
+import java.util.SortedSet;
+import java.util.TreeSet;
+
+import javax.servlet.http.HttpServletRequest;
+
+import org.openecomp.portalsdk.core.domain.Role;
+import org.openecomp.portalsdk.core.domain.User;
+import org.openecomp.portalsdk.core.domain.UserApp;
+import org.openecomp.portalsdk.core.logging.logic.EELFLoggerDelegate;
+import org.openecomp.portalsdk.core.onboarding.client.AppContextManager;
+import org.openecomp.portalsdk.core.onboarding.crossapi.IPortalRestAPIService;
+import org.openecomp.portalsdk.core.onboarding.crossapi.PortalAPIException;
+import org.openecomp.portalsdk.core.onboarding.crossapi.PortalTimeoutHandler;
+import org.openecomp.portalsdk.core.restful.domain.EcompRole;
+import org.openecomp.portalsdk.core.restful.domain.EcompUser;
+import org.openecomp.portalsdk.core.service.RoleService;
+import org.openecomp.portalsdk.core.service.UserProfileService;
+import org.openecomp.portalsdk.core.service.WebServiceCallService;
+import org.openecomp.portalsdk.core.util.JSONUtil;
+import org.openecomp.portalsdk.core.util.SystemProperties;
+import org.openecomp.portalsdk.core.web.support.UserUtils;
+import org.slf4j.MDC;
+
+
+public class OnBoardingApiServiceImplPolicy implements IPortalRestAPIService {
+ RoleService roleService;
+ UserProfileService userProfileService;
+ AdminAuthExtension adminAuthExtension;
+
+ EELFLoggerDelegate logger = EELFLoggerDelegate.getLogger(OnBoardingApiServiceImplPolicy.class);
+
+ public OnBoardingApiServiceImplPolicy(){
+ roleService = AppContextManager.getAppContext().getBean(RoleService.class);
+ userProfileService = AppContextManager.getAppContext().getBean(UserProfileService.class);
+ adminAuthExtension = AppContextManager.getAppContext().getBean(AdminAuthExtension.class);
+ }
+
+ private void setCurrentAttributes(User user, EcompUser userJson){
+ user.setEmail(userJson.getEmail());
+ user.setFirstName(userJson.getFirstName());
+ user.setHrid(userJson.getHrid());
+ user.setJobTitle(userJson.getJobTitle());
+ user.setLastName(userJson.getLastName());
+ user.setLoginId(userJson.getLoginId());
+ user.setOrgManagerUserId(userJson.getOrgManagerUserId());
+ user.setMiddleInitial(userJson.getMiddleInitial());
+ user.setOrgCode(userJson.getOrgCode());
+ user.setOrgId(userJson.getOrgId());
+ user.setPhone(userJson.getPhone());
+ user.setOrgUserId(userJson.getOrgUserId());
+ user.setActive(userJson.isActive());
+ }
+
+
+ @Override
+ public void pushUser(EcompUser userJson) throws PortalAPIException {
+
+ logger.debug(EELFLoggerDelegate.debugLogger, "pushUser was invoked" + userJson);
+
+ User user = new User();
+ String response = "";
+
+ logger.debug(EELFLoggerDelegate.debugLogger, "## REST API ## userJson: " + userJson);
+
+ try {
+
+ //Set input attributes to the object about to be saved
+ setCurrentAttributes(user, userJson);
+
+ user.setRoles(new TreeSet());
+ user.setUserApps(new TreeSet());
+ user.setPseudoRoles(new TreeSet());
+
+ userProfileService.saveUser(user);
+ adminAuthExtension.saveUserExtension(user);
+ logger.debug(EELFLoggerDelegate.debugLogger, "push user success.");
+ response = "push user success.";
+ response = JSONUtil.convertResponseToJSON(response);
+ } catch (Exception e) {
+ e.printStackTrace();
+ response = "push user failed with error: " + e.getMessage();
+ logger.error(EELFLoggerDelegate.debugLogger, response);
+ logger.error(EELFLoggerDelegate.errorLogger, "Error happened during OnboardingApiService.pushUser operation: " + response);
+ logger.error(EELFLoggerDelegate.debugLogger, "Error happened during OnboardingApiService.pushUser operation: " + response);
+ logger.info(EELFLoggerDelegate.metricsLogger, "OnboardingApiService.pushUser operation has failed.");
+ throw new PortalAPIException(response, e);
+ }finally {
+ MDC.remove(SystemProperties.MDC_TIMER);
+ }
+ }
+
+ @Override
+ public void editUser(String loginId, EcompUser userJson) throws PortalAPIException {
+
+ logger.debug(EELFLoggerDelegate.debugLogger, "OnboardingApi editUser was invoked" + userJson);
+
+ User editUser = new User();
+ String response = "";
+ logger.debug(EELFLoggerDelegate.debugLogger, "## REST API ## loginId: " + loginId);
+ logger.debug(EELFLoggerDelegate.debugLogger, "## REST API ## userJson: " + userJson);
+
+ try {
+
+ setCurrentAttributes(editUser, userJson);
+
+ if (editUser.getOrgUserId() != null) {
+ editUser.setLoginId(editUser.getOrgUserId());
+ }
+
+ User domainUser = userProfileService.getUserByLoginId(loginId);
+ if (domainUser != null)
+ domainUser = JSONUtil.mapToDomainUser(domainUser, editUser);
+ else
+ domainUser = editUser;
+ userProfileService.saveUser(domainUser);
+ adminAuthExtension.saveUserExtension(domainUser);
+
+ logger.debug(EELFLoggerDelegate.debugLogger, "edit user success.");
+ response = "edit user success.";
+ response = JSONUtil.convertResponseToJSON(response);
+ } catch (Exception e) {
+ e.printStackTrace();
+ response = "edit user failed with error: " + e.getMessage();
+ logger.error(EELFLoggerDelegate.errorLogger, response);
+ logger.error(EELFLoggerDelegate.debugLogger, "Error happened during OnboardingApiService.editUser operation: " + response);
+ logger.error(EELFLoggerDelegate.errorLogger, "Error happened during OnboardingApiService.editUser operation: " + response);
+ throw new PortalAPIException(response, e);
+ }finally {
+ MDC.remove(SystemProperties.MDC_TIMER);
+ }
+
+ //return response;
+ }
+
+ @Override
+ public EcompUser getUser(String loginId) throws PortalAPIException {
+ try{
+ logger.debug(EELFLoggerDelegate.debugLogger, "## REST API ## loginId: " + loginId);
+
+ User user = userProfileService.getUserByLoginId(loginId);
+
+ if(user == null){
+ logger.info(EELFLoggerDelegate.debugLogger, "User + " + loginId + " doesn't exist");
+ return null;
+ }
+ else
+ return UserUtils.convertToEcompUser(user);
+ }
+ catch(Exception e){
+ logger.error(EELFLoggerDelegate.errorLogger, e.getMessage());
+ return null;
+ }
+
+ }
+
+ @Override
+ public List<EcompUser> getUsers() throws PortalAPIException {
+
+
+ String response = "";
+
+ try {
+
+ List<User> users = userProfileService.findAllActive();
+ List<EcompUser> ecompUsers = new ArrayList<EcompUser>();
+ for(User user : users)
+ ecompUsers.add(UserUtils.convertToEcompUser(user));
+
+ return ecompUsers;
+
+ }
+ catch (Exception pe){
+
+ response = "getUsers failed with error: " + pe.getMessage();
+ pe.printStackTrace();
+ logger.error(EELFLoggerDelegate.debugLogger, response);
+ logger.error(EELFLoggerDelegate.errorLogger, response);
+ throw new PortalAPIException(response, pe);
+ }
+
+
+ }
+
+ @Override
+ public List<EcompRole> getAvailableRoles() throws PortalAPIException{
+
+ String response = "";
+
+ try{
+ List<Role> roles = roleService.getActiveRoles();
+ List<EcompRole> ecompRoles = new ArrayList<EcompRole>();
+
+ for(Role role : roles)
+ ecompRoles.add(UserUtils.convertToEcompRole(role));
+
+ return ecompRoles;
+
+ }
+ catch (Exception pe){
+ response = "getUsers failed with error: " + pe.getMessage();
+ pe.printStackTrace();
+ logger.error(EELFLoggerDelegate.debugLogger, response);
+ logger.error(EELFLoggerDelegate.errorLogger, response);
+ throw new PortalAPIException(response, pe);
+ }
+ }
+
+ @Override
+ public void pushUserRole(String loginId, List<EcompRole> rolesJson) throws PortalAPIException {
+
+
+ String response = "";
+ try {
+ logger.debug(EELFLoggerDelegate.debugLogger, "## REST API ## loginId: " + loginId);
+ logger.debug(EELFLoggerDelegate.debugLogger, "## REST API ## rolesJson: " + rolesJson);
+ User user = userProfileService.getUserByLoginId(loginId);
+
+ SortedSet<Role> roles = new TreeSet();
+ for (EcompRole role : rolesJson) {
+ roles.add(roleService.getRole(role.getId()));
+ }
+ // Replace existing roles with new ones
+ replaceExistingRoles(roles, user);
+
+ logger.debug(EELFLoggerDelegate.debugLogger, "push user role success.");
+ response = "push user role success.";
+ response = JSONUtil.convertResponseToJSON(response);
+
+ } catch (Exception e) {
+ response = "pushUserRole failed with error: " + e.getMessage();
+ e.printStackTrace();
+ logger.error(EELFLoggerDelegate.debugLogger, response);
+ logger.error(EELFLoggerDelegate.errorLogger, response);
+ throw new PortalAPIException(response, e);
+ }finally {
+ MDC.remove(SystemProperties.MDC_TIMER);
+ }
+
+ }
+
+ @Override
+ public List<EcompRole> getUserRoles(String loginId) throws PortalAPIException {
+
+ logger.debug(EELFLoggerDelegate.debugLogger, "## REST API ## loginId: " + loginId);
+
+ List<EcompRole> ecompRoles = new ArrayList<EcompRole>();
+ try {
+
+
+ User user = userProfileService.getUserByLoginId(loginId);
+
+ SortedSet<Role> currentRoles = null;
+ if(user != null){
+
+ currentRoles = user.getRoles();
+
+ if(currentRoles != null)
+ for(Role role : currentRoles)
+ ecompRoles.add(UserUtils.convertToEcompRole(role));
+ }
+ return ecompRoles;
+ }
+ catch (Exception e){
+ String response = "getUserRoles failed with error: " + e.getMessage();
+ e.printStackTrace();
+ logger.error(EELFLoggerDelegate.debugLogger, response);
+ logger.debug(EELFLoggerDelegate.errorLogger, response);
+ throw new PortalAPIException(response, e);
+ }
+ }
+
+ private void replaceExistingRoles(SortedSet<Role> roles, User user) {
+ // 1. remove existing roles
+ Set<UserApp> userApps = user.getUserApps();
+ Iterator appsItr = (Iterator) userApps.iterator();
+ while (appsItr.hasNext()) {
+ UserApp tempUserApp = (UserApp)appsItr.next();
+ boolean roleFound = false;
+ for (Role role : roles) {
+ if (tempUserApp.getRole().getId().equals(role.getId())) {
+ roleFound = true;
+ break;
+ }
+ }
+ if (!roleFound)
+ appsItr.remove();
+ }
+ user.setUserApps(userApps);
+ userProfileService.saveUser(user);
+
+ // 2. add new roles
+ user.setRoles(roles);
+ userProfileService.saveUser(user);
+ adminAuthExtension.saveUserExtension(user);
+ }
+
+
+ @Override
+ public boolean isAppAuthenticated(HttpServletRequest request) throws PortalAPIException {
+ WebServiceCallService securityService = AppContextManager.getAppContext().getBean(WebServiceCallService.class);
+ try {
+ String appUser = request.getHeader("username");
+ String password = request.getHeader("password");
+ boolean flag = securityService.verifyRESTCredential(null, appUser, password);
+ return flag;
+
+ } catch (Exception e) {
+ logger.error(EELFLoggerDelegate.errorLogger, "Failed to authenticate" + e.getMessage());
+ throw new PortalAPIException("Failed to authenticate: " + e.getMessage());
+ }
+
+ }
+
+ public String getSessionTimeOuts() throws Exception{
+ return PortalTimeoutHandler.gatherSessionExtensions();
+ }
+
+ public void updateSessionTimeOuts(String sessionMap) throws Exception{
+ PortalTimeoutHandler.updateSessionExtensions(sessionMap);
+ }
+}
Code Review / policy / engine.git / blobdiff