ecomp-portal-BE-common/src/main/java/org/openecomp/portalapp/service/sessionmgt/ManageService.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.service.sessionmgt;
  39
  40 import java.util.Calendar;
  41 import java.util.Date;
  42 import java.util.List;
  43
  44 import org.openecomp.portalapp.portal.logging.aop.EPMetricsLog;
  45 import org.openecomp.portalapp.portal.service.EPAppService;
  46 import org.openecomp.portalapp.portal.transport.OnboardingApp;
  47 import org.openecomp.portalsdk.core.logging.logic.EELFLoggerDelegate;
  48 import org.openecomp.portalsdk.core.onboarding.listener.PortalTimeoutHandler;
  49 import org.openecomp.portalsdk.core.util.SystemProperties;
  50 import org.quartz.CronExpression;
  51 import org.springframework.beans.factory.annotation.Autowired;
  52 import org.springframework.context.annotation.EnableAspectJAutoProxy;
  53 import org.springframework.stereotype.Service;
  54 import org.springframework.util.StringUtils;
  55
  56 @Service("manageService")
  57 @org.springframework.context.annotation.Configuration
  58 @EnableAspectJAutoProxy
  59 @EPMetricsLog
  60 public class ManageService implements PortalTimeoutHandler.SessionCommInf {
  61         private EELFLoggerDelegate logger = EELFLoggerDelegate.getLogger(ManageService.class);
  62
  63         @Autowired
  64         private EPAppService appService;
  65
  66         @Autowired
  67         private SessionCommunication sessionCommunication;
  68
  69         public Integer fetchSessionSlotCheckInterval(String... params) throws Exception {
  70
  71                 String defaultCronExpressionStr = "0 0/5 * * * ? *";
  72                 String cronExpressionStr = SystemProperties.getProperty(SystemProperties.SESSIONTIMEOUT_FEED_CRON);
  73
  74                 if (cronExpressionStr == null) {
  75                         cronExpressionStr = defaultCronExpressionStr;
  76                 }
  77
  78                 CronExpression cal = new CronExpression(cronExpressionStr);
  79                 final Date nowTime = Calendar.getInstance().getTime();
  80                 Date nextTime = cal.getNextValidTimeAfter(nowTime);
  81                 Date nextNextTime = cal.getNextValidTimeAfter(nextTime);
  82
  83                 final int timeDiff = (int)(nextNextTime.getTime()-nextTime.getTime());
  84                 logger.debug(EELFLoggerDelegate.debugLogger, "Time interval between subsequent session checks " + timeDiff);
  85
  86                 return timeDiff;
  87         }
  88
  89         public void extendSessionTimeOuts(String... params) throws Exception {
  90                 try {
  91                         String sessionMap = params[3];
  92
  93                         logger.debug(EELFLoggerDelegate.debugLogger, "Extending the App sessions for last minute request: " + sessionMap);
  94
  95                         if (StringUtils.isEmpty(sessionMap)) {
  96                                 logger.error(EELFLoggerDelegate.errorLogger, "extendSessionTimeOuts: Skipping session updates since the portal session value is empty.");
  97                         } else {
  98                                 List<OnboardingApp> appList = appService.getEnabledNonOpenOnboardingApps();
  99                                 for (OnboardingApp onApp : appList) {
 100                                         sessionCommunication.pingSession(onApp, sessionMap);
 101                                 }
 102                                 updateSessionExtensions(sessionMap);
 103                                 sessionCommunication.clear(false);
 104                         }
 105                 } catch (Exception e) {
 106                         logger.error(EELFLoggerDelegate.errorLogger, "extendSessionTimeOuts failed", e);
 107                 }
 108         }
 109
 110         public String gatherSessionExtenstions() {
 111                 return PortalTimeoutHandler.gatherSessionExtensions();
 112         }
 113
 114         public void updateSessionExtensions(String sessionTimeoutMapStr) throws Exception {
 115                 PortalTimeoutHandler.updateSessionExtensions(sessionTimeoutMapStr);
 116         }
 117
 118 }