+/*-
+ * ============LICENSE_START==========================================
+ * ONAP Portal
+ * ===================================================================
+ * Copyright (C) 2017 AT&T Intellectual Property. All rights reserved.
+ * ===================================================================
+ *
+ * Unless otherwise specified, all software contained herein is licensed
+ * under the Apache License, Version 2.0 (the "License");
+ * you may not use this software except in compliance with the License.
+ * You may obtain a copy of the License at
+ *
+ * http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ *
+ * Unless otherwise specified, all documentation contained herein is licensed
+ * under the Creative Commons License, Attribution 4.0 Intl. (the "License");
+ * you may not use this documentation except in compliance with the License.
+ * You may obtain a copy of the License at
+ *
+ * https://creativecommons.org/licenses/by/4.0/
+ *
+ * Unless required by applicable law or agreed to in writing, documentation
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ *
+ * ============LICENSE_END============================================
+ *
+ *
+ */
package org.onap.portal.service.sharedContext;
+import java.text.SimpleDateFormat;
+import java.time.Instant;
+import java.time.LocalDateTime;
+import java.time.ZoneId;
+import java.util.ArrayList;
+import java.util.Date;
+import java.util.List;
+import java.util.Optional;
import org.onap.portal.domain.db.fn.FnSharedContext;
+import org.onap.portal.logging.aop.EPMetricsLog;
+import org.onap.portalsdk.core.logging.logic.EELFLoggerDelegate;
import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.context.annotation.EnableAspectJAutoProxy;
import org.springframework.stereotype.Service;
+import org.springframework.transaction.annotation.Transactional;
-import java.util.List;
@Service
+@Transactional
+@EnableAspectJAutoProxy
+@EPMetricsLog
public class FnSharedContextService {
- private final FnSharedContextDao fnSharedContextDao;
+ private EELFLoggerDelegate logger = EELFLoggerDelegate.getLogger(FnSharedContextService.class);
+
+ private final FnSharedContextDao fnSharedContextDao;
+
+ @Autowired
+ public FnSharedContextService(final FnSharedContextDao fnSharedContextDao) {
+ this.fnSharedContextDao = fnSharedContextDao;
+ }
+
+ public List<FnSharedContext> getSharedContexts(String contextId) {
+ return fnSharedContextDao.getByContextId(contextId).orElse(new ArrayList<>());
+ }
+
+ public FnSharedContext getFnSharedContext(String contextId, String ckey) {
+ FnSharedContext context = null;
+ Optional<List<FnSharedContext>> contexts = fnSharedContextDao.getByContextIdAndCkey(contextId, ckey);
+ if (contexts.isPresent() && contexts.get().size() == 1) {
+ context = contexts.get().get(0);
+ }
+ return context;
+ }
+
+ public FnSharedContext addFnSharedContext(String contextId, String key, String value) {
+ return this.save(new FnSharedContext(contextId, key, value));
+ }
+
+
+ public FnSharedContext save(FnSharedContext context) {
+ return this.fnSharedContextDao.saveAndFlush(context);
+ }
+
+ public List<FnSharedContext> saveAll(List<FnSharedContext> fnSharedContexts){
+ return fnSharedContextDao.saveAll(fnSharedContexts);
+ }
+
+ public void delete(FnSharedContext context) {
+ this.fnSharedContextDao.delete(context);
+ }
+
+ public int deleteSharedContexts(String contextId) {
+ // Uses an inefficient method to avoid a where clause
+ // that could be used to mount a SQL injection attack.
+ List<FnSharedContext> contexts = getSharedContexts(contextId);
+ if (contexts == null)
+ return 0;
+
+ logger.debug(EELFLoggerDelegate.debugLogger, "deleteFnSharedContexts: count is " + contexts.size());
+ for (FnSharedContext sc : contexts)
+ this.delete(sc);
+
+ return contexts.size();
+ }
- @Autowired
- public FnSharedContextService(FnSharedContextDao fnSharedContextDao) {
- this.fnSharedContextDao = fnSharedContextDao;
- }
+ public void expireFnSharedContexts(int ageInSeconds) {
+ Date expiredDateTime = new Date(System.currentTimeMillis() - ageInSeconds * 1000);
+ logger.debug(EELFLoggerDelegate.debugLogger,
+ "expireFnSharedContexts: expire time is " + expiredDateTime.toString());
+ this.fnSharedContextDao.deleteByCreated(convertToLocalDateTimeViaInstant(expiredDateTime));
+ }
- public List<FnSharedContext> saveAll(List<FnSharedContext> sharedContexts) {
- return fnSharedContextDao.saveAll(sharedContexts);
- }
+ private LocalDateTime convertToLocalDateTimeViaInstant(Date dateToConvert) {
+ return dateToConvert.toInstant()
+ .atZone(ZoneId.systemDefault())
+ .toLocalDateTime();
+ }
}
Code Review / portal.git / blobdiff