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