X-Git-Url: https://gerrit.onap.org/r/gitweb?a=blobdiff_plain;f=portal-BE%2Fsrc%2Fmain%2Fjava%2Forg%2Fonap%2Fportal%2Fservice%2FsharedContext%2FFnSharedContextService.java;fp=portal-BE%2Fsrc%2Fmain%2Fjava%2Forg%2Fonap%2Fportal%2Fservice%2FsharedContext%2FFnSharedContextService.java;h=ee0be613faea901c790d5eb09994e18a03b2a139;hb=f7e300301a4a5f01585677657b96a80338cdf03d;hp=7a427ae98e3c17ba2b2aea23ea559d521c07502a;hpb=cbc896f277fcf24dc52fcd591667e4ede1e9a9ab;p=portal.git

diff --git a/portal-BE/src/main/java/org/onap/portal/service/sharedContext/FnSharedContextService.java b/portal-BE/src/main/java/org/onap/portal/service/sharedContext/FnSharedContextService.java
index 7a427ae9..ee0be613 100644
--- a/portal-BE/src/main/java/org/onap/portal/service/sharedContext/FnSharedContextService.java
+++ b/portal-BE/src/main/java/org/onap/portal/service/sharedContext/FnSharedContextService.java
@@ -1,22 +1,128 @@
+/*-
+ * ============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();
+	}
 }