acs/requestprocessor/src/main/java/org/commscope/tr069adapter/acs/requestprocessor/impl/SessionManager.java

   1 /*\r
   2  * ============LICENSE_START========================================================================\r
   3  * ONAP : tr-069-adapter\r
   4  * =================================================================================================\r
   5  * Copyright (C) 2020 CommScope Inc Intellectual Property.\r
   6  * =================================================================================================\r
   7  * This tr-069-adapter software file is distributed by CommScope Inc under the Apache License,\r
   8  * Version 2.0 (the "License"); you may not use this file except in compliance with the License. You\r
   9  * may obtain a copy of the License at\r
  10  *\r
  11  * http://www.apache.org/licenses/LICENSE-2.0\r
  12  *\r
  13  * This file is distributed on an "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND,\r
  14  * either express or implied. See the License for the specific language governing permissions and\r
  15  * limitations under the License.\r
  16  * ===============LICENSE_END=======================================================================\r
  17  */\r
  18 \r
  19 package org.commscope.tr069adapter.acs.requestprocessor.impl;\r
  20 \r
  21 import com.fasterxml.uuid.EthernetAddress;\r
  22 import com.fasterxml.uuid.Generators;\r
  23 import com.fasterxml.uuid.impl.TimeBasedGenerator;\r
  24 \r
  25 import java.util.Optional;\r
  26 import java.util.UUID;\r
  27 \r
  28 import org.commscope.tr069adapter.acs.common.exception.SessionConcurrentAccessException;\r
  29 import org.commscope.tr069adapter.acs.common.exception.SessionManagerException;\r
  30 import org.commscope.tr069adapter.acs.common.utils.ErrorCode;\r
  31 import org.commscope.tr069adapter.acs.requestprocessor.dao.SessionRepository;\r
  32 import org.commscope.tr069adapter.acs.requestprocessor.dto.SessionDTO;\r
  33 import org.commscope.tr069adapter.acs.requestprocessor.dto.SessionState;\r
  34 import org.commscope.tr069adapter.acs.requestprocessor.entity.SessionManagerEntity;\r
  35 import org.commscope.tr069adapter.acs.requestprocessor.util.SessionManagerUtility;\r
  36 import org.slf4j.Logger;\r
  37 import org.slf4j.LoggerFactory;\r
  38 import org.springframework.beans.factory.annotation.Autowired;\r
  39 import org.springframework.stereotype.Component;\r
  40 \r
  41 @Component\r
  42 public class SessionManager {\r
  43 \r
  44   private static final Logger logger = LoggerFactory.getLogger(SessionManager.class);\r
  45 \r
  46   @Autowired\r
  47   SessionRepository sessionRepository;\r
  48 \r
  49   /**\r
  50    * @param deviceId\r
  51    * @return\r
  52    * @throws SessionManagerException\r
  53    */\r
  54   public SessionDTO getSession(String deviceId) {\r
  55     SessionManagerEntity session = null;\r
  56     Optional<SessionManagerEntity> optionalSessionData = sessionRepository.findById(deviceId);\r
  57     if (optionalSessionData.isPresent()) {\r
  58       session = optionalSessionData.get();\r
  59     }\r
  60     return SessionManagerUtility.convertToDTO(session);\r
  61   }\r
  62 \r
  63   /**\r
  64    * @param sessionId\r
  65    * @return\r
  66    * @throws SessionManagerException\r
  67    */\r
  68   public SessionDTO getSessionBySessionId(String sessionId) throws SessionManagerException {\r
  69 \r
  70     SessionManagerEntity sessionManagerEntity = sessionRepository.findBySessionId(sessionId);\r
  71     if (sessionManagerEntity == null || SessionState.TERMINATED\r
  72         .equals(SessionState.getByValue(sessionManagerEntity.getState()))) {\r
  73       throw new SessionManagerException(ErrorCode.SESSION_EXPIRED, sessionId);\r
  74     }\r
  75     return SessionManagerUtility.convertToDTO(sessionManagerEntity);\r
  76   }\r
  77 \r
  78   /**\r
  79    * @param session\r
  80    * @return\r
  81    * @throws SessionManagerException\r
  82    */\r
  83   public SessionDTO createSession(SessionDTO session) throws SessionManagerException {\r
  84     if (session == null) {\r
  85       SessionManagerException sme = new SessionManagerException(ErrorCode.SESSION_CREATION_ERROR,\r
  86           "Session object cannot be null");\r
  87       logger.error(sme.getMessage());\r
  88       throw sme;\r
  89     }\r
  90     logger.debug("Creating a new session for the device");\r
  91     return SessionManagerUtility\r
  92         .convertToDTO(sessionRepository.save(SessionManagerUtility.convertToEntity(session)));\r
  93   }\r
  94 \r
  95   /**\r
  96    * @param dto\r
  97    * @return\r
  98    * @throws SessionManagerException\r
  99    */\r
 100   public SessionDTO updateSession(SessionDTO dto) {\r
 101     return SessionManagerUtility\r
 102         .convertToDTO(sessionRepository.save(SessionManagerUtility.convertToEntity(dto)));\r
 103   }\r
 104 \r
 105   /**\r
 106    * @param deviceId\r
 107    * @throws SessionConcurrentAccessException\r
 108    */\r
 109   public void deleteSession(String deviceId) {\r
 110     sessionRepository.deleteById(deviceId);\r
 111   }\r
 112 \r
 113   /**\r
 114    * @param deviceId\r
 115    * @return\r
 116    * @throws SessionManagerException\r
 117    */\r
 118   public SessionDTO getLockedSession(String deviceId) {\r
 119     logger.debug("Acquiring the session lock for the device");\r
 120     return SessionManagerUtility.convertToDTO(sessionRepository.findByDeviceId(deviceId));\r
 121   }\r
 122 \r
 123   /**\r
 124    * @return\r
 125    */\r
 126   public String generateUniqueSessionID() {\r
 127     EthernetAddress addr = EthernetAddress.fromInterface();\r
 128     TimeBasedGenerator uuidGenerator = Generators.timeBasedGenerator(addr);\r
 129     UUID uuid = uuidGenerator.generate();\r
 130     return uuid.toString();\r
 131   }\r
 132 \r
 133 }\r