ecomp-portal-BE-os/src/main/java/org/onap/portalapp/portal/service/EPAppServiceImpl.java

   1 /*-
   2  * ============LICENSE_START==========================================
   3  * ONAP Portal
   4  * ===================================================================
   5  * Copyright (C) 2017 AT&T Intellectual Property. All rights reserved.
   6  * ===================================================================
   7  *
   8  * Unless otherwise specified, all software contained herein is licensed
   9  * under the Apache License, Version 2.0 (the "License");
  10  * you may not use this software except in compliance with the License.
  11  * You may obtain a copy of the License at
  12  *
  13  *             http://www.apache.org/licenses/LICENSE-2.0
  14  *
  15  * Unless required by applicable law or agreed to in writing, software
  16  * distributed under the License is distributed on an "AS IS" BASIS,
  17  * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
  18  * See the License for the specific language governing permissions and
  19  * limitations under the License.
  20  *
  21  * Unless otherwise specified, all documentation contained herein is licensed
  22  * under the Creative Commons License, Attribution 4.0 Intl. (the "License");
  23  * you may not use this documentation except in compliance with the License.
  24  * You may obtain a copy of the License at
  25  *
  26  *             https://creativecommons.org/licenses/by/4.0/
  27  *
  28  * Unless required by applicable law or agreed to in writing, documentation
  29  * distributed under the License is distributed on an "AS IS" BASIS,
  30  * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
  31  * See the License for the specific language governing permissions and
  32  * limitations under the License.
  33  *
  34  * ============LICENSE_END============================================
  35  *
  36  * ECOMP is a trademark and service mark of AT&T Intellectual Property.
  37  */
  38 package org.onap.portalapp.portal.service;
  39
  40 import java.net.MalformedURLException;
  41 import java.security.GeneralSecurityException;
  42 import java.util.ArrayList;
  43 import java.util.LinkedList;
  44 import java.util.List;
  45 import java.util.TreeSet;
  46 import java.util.UUID;
  47
  48 import javax.servlet.http.HttpServletResponse;
  49
  50 import org.hibernate.Session;
  51 import org.hibernate.Transaction;
  52 import org.onap.portalapp.portal.domain.EPApp;
  53 import org.onap.portalapp.portal.domain.EPUser;
  54 import org.onap.portalapp.portal.logging.aop.EPMetricsLog;
  55 import org.onap.portalapp.portal.logging.format.EPAppMessagesEnum;
  56 import org.onap.portalapp.portal.logging.logic.EPLogUtil;
  57 import org.onap.portalapp.portal.service.EPAppCommonServiceImpl;
  58 import org.onap.portalapp.portal.service.EPAppService;
  59 import org.onap.portalapp.portal.transport.FieldsValidator;
  60 import org.onap.portalapp.portal.transport.OnboardingApp;
  61 import org.onap.portalapp.portal.utils.EcompPortalUtils;
  62 import org.onap.portalsdk.core.logging.logic.EELFLoggerDelegate;
  63 import org.onap.portalsdk.core.service.DataAccessService;
  64 import org.springframework.beans.factory.annotation.Autowired;
  65 import org.springframework.context.annotation.EnableAspectJAutoProxy;
  66 import org.springframework.stereotype.Service;
  67 import org.springframework.transaction.annotation.Transactional;
  68
  69 import com.att.nsa.cambria.client.CambriaClientFactory;
  70 import com.att.nsa.cambria.client.CambriaTopicManager;
  71
  72 @Service("epAppService")
  73 @Transactional
  74 @org.springframework.context.annotation.Configuration
  75 @EnableAspectJAutoProxy
  76 @EPMetricsLog
  77 public class EPAppServiceImpl extends EPAppCommonServiceImpl implements EPAppService {
  78
  79         private EELFLoggerDelegate logger = EELFLoggerDelegate.getLogger(EPAppServiceImpl.class);
  80
  81         private static Object syncRests = new Object();
  82
  83         @Autowired
  84         private DataAccessService dataAccessService;
  85
  86         @Override
  87         public List<EPApp> getUserRemoteApps(String id) {
  88                 StringBuilder query = new StringBuilder();
  89                 query.append("SELECT * FROM FN_APP join FN_USER_ROLE ON FN_USER_ROLE.APP_ID = FN_APP.APP_ID where ");
  90                 query.append("FN_USER_ROLE.USER_ID = " + id + " AND FN_USER_ROLE.ROLE_ID != " + SUPER_ADMIN_ROLE_ID);
  91                 query.append(" AND FN_APP.ENABLED = 'Y'");
  92                 TreeSet<EPApp> distinctApps = new TreeSet<EPApp>();
  93                 @SuppressWarnings("unchecked")
  94                 List<EPApp> adminApps = dataAccessService.executeSQLQuery(query.toString(), EPApp.class, null);
  95                 for (EPApp app : adminApps) {
  96                         distinctApps.add(app);
  97                 }
  98                 List<EPApp> userApps = new ArrayList<EPApp>();
  99                 userApps.addAll(distinctApps);
 100                 return userApps;
 101         }
 102
 103         @Override
 104         protected void updateRestrictedApp(Long appId, OnboardingApp onboardingApp, FieldsValidator fieldsValidator,
 105                         EPUser user) {
 106                 synchronized (syncRests) {
 107                         boolean result = false;
 108                         Session localSession = null;
 109                         Transaction transaction = null;
 110                         try {
 111                                 localSession = sessionFactory.openSession();
 112                                 transaction = localSession.beginTransaction();
 113                                 EPApp app;
 114                                 if (appId == null) {
 115                                         app = new EPApp();
 116                                         /*
 117                                          * In the parent class, the UEB code is responsible for generating the
 118                                          * keys/secret/mailbox but UEB Messaging is not actually being used currently;
 119                                          * may be used in future at which point we can just remove this method and
 120                                          * depend on parent class's method So, using UUID generator to generate the
 121                                          * unique key instead.
 122                                          */
 123                                         String uuidStr = UUID.randomUUID().toString();
 124                                         String appKey = uuidStr;
 125                                         String appSecret = uuidStr;
 126                                         String appMailboxName = "ECOMP-PORTAL-OUTBOX";
 127                                         onboardingApp.setUebTopicName(appMailboxName);
 128                                         onboardingApp.setUebKey(appKey);
 129                                         onboardingApp.setUebSecret(appSecret);
 130                                 } else {
 131                                         app = (EPApp) localSession.get(EPApp.class, appId);
 132                                         if (app == null || app.getId() == null) {
 133                                                 // App is already deleted!
 134                                                 transaction.commit();
 135                                                 localSession.close();
 136                                                 fieldsValidator.httpStatusCode = new Long(HttpServletResponse.SC_NOT_FOUND);
 137                                                 return;
 138                                         }
 139                                 }
 140                                 logger.debug(EELFLoggerDelegate.debugLogger,
 141                                                 "updateRestrictedApp: about to call createAppFromOnboarding");
 142                                 createAppFromOnboarding(app, onboardingApp, localSession);
 143                                 logger.debug(EELFLoggerDelegate.debugLogger,
 144                                                 "updateRestrictedApp: finished calling createAppFromOnboarding");
 145                                 localSession.saveOrUpdate(app);
 146                                 logger.debug(EELFLoggerDelegate.debugLogger,
 147                                                 "updateRestrictedApp: finished calling localSession.saveOrUpdate");
 148                                 // Enable or disable all menu items associated with this app
 149                                 setFunctionalMenuItemsEnabled(localSession, onboardingApp.isEnabled, appId);
 150                                 logger.debug(EELFLoggerDelegate.debugLogger,
 151                                                 "updateRestrictedApp: finished calling setFunctionalMenuItemsEnabled");
 152                                 transaction.commit();
 153                                 logger.debug(EELFLoggerDelegate.debugLogger,
 154                                                 "updateRestrictedApp: finished calling transaction.commit");
 155                                 result = true;
 156                         } catch (Exception e) {
 157                                 logger.error(EELFLoggerDelegate.errorLogger, "updateRestrictedApp failed", e);
 158                                 EPLogUtil.logEcompError(logger, EPAppMessagesEnum.BeUebRegisterOnboardingAppError, e);
 159                                 EPLogUtil.logEcompError(logger, EPAppMessagesEnum.BeDaoSystemError, e);
 160                                 EcompPortalUtils.rollbackTransaction(transaction,
 161                                                 "updateRestrictedApp rollback, exception = " + e.toString());
 162                         } finally {
 163                                 EcompPortalUtils.closeLocalSession(localSession, "updateRestrictedApp");
 164                         }
 165                         if (!result) {
 166                                 fieldsValidator.httpStatusCode = new Long(HttpServletResponse.SC_INTERNAL_SERVER_ERROR);
 167                         }
 168                 }
 169
 170         }
 171
 172         @Override
 173         public CambriaTopicManager getTopicManager(List<String> urlList, String key, String secret)
 174                         throws MalformedURLException, GeneralSecurityException {
 175                 return CambriaClientFactory.createTopicManager(null, urlList, key, secret);
 176         }
 177
 178 }