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

   1 /*-
   2  * ============LICENSE_START==========================================
   3  * ONAP Portal
   4  * ===================================================================
   5  * Copyright © 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.openecomp.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.openecomp.portalapp.portal.domain.EPApp;
  53 import org.openecomp.portalapp.portal.domain.EPUser;
  54 import org.openecomp.portalapp.portal.logging.aop.EPMetricsLog;
  55 import org.openecomp.portalapp.portal.logging.format.EPAppMessagesEnum;
  56 import org.openecomp.portalapp.portal.logging.logic.EPLogUtil;
  57 import org.openecomp.portalapp.portal.transport.FieldsValidator;
  58 import org.openecomp.portalapp.portal.transport.OnboardingApp;
  59 import org.openecomp.portalapp.portal.utils.EcompPortalUtils;
  60 import org.openecomp.portalsdk.core.logging.logic.EELFLoggerDelegate;
  61 import org.openecomp.portalsdk.core.service.DataAccessService;
  62 import org.springframework.beans.factory.annotation.Autowired;
  63 import org.springframework.context.annotation.EnableAspectJAutoProxy;
  64 import org.springframework.stereotype.Service;
  65 import org.springframework.transaction.annotation.Transactional;
  66
  67 import com.att.nsa.cambria.client.CambriaClientFactory;
  68 import com.att.nsa.cambria.client.CambriaTopicManager;
  69
  70 @Service("epAppService")
  71 @Transactional
  72 @org.springframework.context.annotation.Configuration
  73 @EnableAspectJAutoProxy
  74 @EPMetricsLog
  75 public class EPAppServiceImpl extends EPAppCommonServiceImpl implements EPAppService {
  76
  77         private EELFLoggerDelegate logger = EELFLoggerDelegate.getLogger(EPAppServiceImpl.class);
  78
  79         private static Object syncRests = new Object();
  80
  81         @Autowired
  82         private DataAccessService dataAccessService;
  83
  84         @Override
  85         public List<EPApp> getUserRemoteApps(String id) {
  86                 StringBuilder query = new StringBuilder();
  87                 query.append("SELECT * FROM FN_APP join FN_USER_ROLE ON FN_USER_ROLE.APP_ID = FN_APP.APP_ID where ");
  88                 query.append("FN_USER_ROLE.USER_ID = " + id + " AND FN_USER_ROLE.ROLE_ID != " + SUPER_ADMIN_ROLE_ID);
  89                 query.append(" AND FN_APP.ENABLED = 'Y'");
  90                 TreeSet<EPApp> distinctApps = new TreeSet<EPApp>();
  91                 @SuppressWarnings("unchecked")
  92                 List<EPApp> adminApps = dataAccessService.executeSQLQuery(query.toString(), EPApp.class, null);
  93                 for (EPApp app : adminApps) {
  94                         distinctApps.add(app);
  95                 }
  96                 List<EPApp> userApps = new ArrayList<EPApp>();
  97                 userApps.addAll(distinctApps);
  98                 return userApps;
  99         }
 100
 101         @Override
 102         protected void updateRestrictedApp(Long appId, OnboardingApp onboardingApp, FieldsValidator fieldsValidator,
 103                         EPUser user) {
 104                 synchronized (syncRests) {
 105                         boolean result = false;
 106                         Session localSession = null;
 107                         Transaction transaction = null;
 108                         try {
 109                                 localSession = sessionFactory.openSession();
 110                                 transaction = localSession.beginTransaction();
 111                                 EPApp app;
 112                                 if (appId == null) {
 113                                         app = new EPApp();
 114                                         /*
 115                                          * In the parent class, the UEB code is responsible for generating the
 116                                          * keys/secret/mailbox but UEB Messaging is not actually being used currently;
 117                                          * may be used in future at which point we can just remove this method and
 118                                          * depend on parent class's method So, using UUID generator to generate the
 119                                          * unique key instead.
 120                                          */
 121                                         String uuidStr = UUID.randomUUID().toString();
 122                                         String appKey = uuidStr;
 123                                         String appSecret = uuidStr;
 124                                         String appMailboxName = "ECOMP-PORTAL-OUTBOX";
 125                                         onboardingApp.setUebTopicName(appMailboxName);
 126                                         onboardingApp.setUebKey(appKey);
 127                                         onboardingApp.setUebSecret(appSecret);
 128                                 } else {
 129                                         app = (EPApp) localSession.get(EPApp.class, appId);
 130                                         if (app == null || app.getId() == null) {
 131                                                 // App is already deleted!
 132                                                 transaction.commit();
 133                                                 localSession.close();
 134                                                 fieldsValidator.httpStatusCode = new Long(HttpServletResponse.SC_NOT_FOUND);
 135                                                 return;
 136                                         }
 137                                 }
 138                                 logger.debug(EELFLoggerDelegate.debugLogger,
 139                                                 "updateRestrictedApp: about to call createAppFromOnboarding");
 140                                 createAppFromOnboarding(app, onboardingApp, localSession);
 141                                 logger.debug(EELFLoggerDelegate.debugLogger,
 142                                                 "updateRestrictedApp: finished calling createAppFromOnboarding");
 143                                 localSession.saveOrUpdate(app);
 144                                 logger.debug(EELFLoggerDelegate.debugLogger,
 145                                                 "updateRestrictedApp: finished calling localSession.saveOrUpdate");
 146                                 // Enable or disable all menu items associated with this app
 147                                 setFunctionalMenuItemsEnabled(localSession, onboardingApp.isEnabled, appId);
 148                                 logger.debug(EELFLoggerDelegate.debugLogger,
 149                                                 "updateRestrictedApp: finished calling setFunctionalMenuItemsEnabled");
 150                                 transaction.commit();
 151                                 logger.debug(EELFLoggerDelegate.debugLogger,
 152                                                 "updateRestrictedApp: finished calling transaction.commit");
 153                                 result = true;
 154                         } catch (Exception e) {
 155                                 logger.error(EELFLoggerDelegate.errorLogger, "updateRestrictedApp failed", e);
 156                                 EPLogUtil.logEcompError(logger, EPAppMessagesEnum.BeUebRegisterOnboardingAppError, e);
 157                                 EPLogUtil.logEcompError(logger, EPAppMessagesEnum.BeDaoSystemError, e);
 158                                 EcompPortalUtils.rollbackTransaction(transaction,
 159                                                 "updateRestrictedApp rollback, exception = " + e.toString());
 160                         } finally {
 161                                 EcompPortalUtils.closeLocalSession(localSession, "updateRestrictedApp");
 162                         }
 163                         if (!result) {
 164                                 fieldsValidator.httpStatusCode = new Long(HttpServletResponse.SC_INTERNAL_SERVER_ERROR);
 165                         }
 166                 }
 167
 168         }
 169
 170         @Override
 171         public CambriaTopicManager getTopicManager(List<String> urlList, String key, String secret)
 172                         throws MalformedURLException, GeneralSecurityException {
 173                 return CambriaClientFactory.createTopicManager(null, urlList, key, secret);
 174         }
 175
 176 }