1 files changed, 63 insertions, 0 deletions
diff --git a/workflow-designer-be/src/main/java/org/onap/sdc/workflow/server/filters/SessionContextFilter.java b/workflow-designer-be/src/main/java/org/onap/sdc/workflow/server/filters/SessionContextFilter.java
new file mode 100644
index 00000000..d4dc8a80
--- /dev/null
+++ b/workflow-designer-be/src/main/java/org/onap/sdc/workflow/server/filters/SessionContextFilter.java
@@ -0,0 +1,63 @@
+package org.onap.sdc.workflow.server.filters;
+
+import static org.onap.sdc.workflow.api.RestConstants.USER_ID_HEADER_PARAM;
+
+import java.io.IOException;
+import javax.servlet.Filter;
+import javax.servlet.FilterChain;
+import javax.servlet.FilterConfig;
+import javax.servlet.ServletException;
+import javax.servlet.ServletRequest;
+import javax.servlet.ServletResponse;
+import javax.servlet.http.HttpServletRequest;
+import org.onap.sdc.workflow.server.config.ZusammenConfig;
+import org.openecomp.sdc.common.session.SessionContextProvider;
+import org.openecomp.sdc.common.session.SessionContextProviderFactory;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.stereotype.Component;
+
+@Component
+public class SessionContextFilter implements Filter {
+
+    private ZusammenConfig zusammenConfig;
+
+    @Autowired
+    public SessionContextFilter(ZusammenConfig zusammenConfig) {
+        this.zusammenConfig = zusammenConfig;
+    }
+
+    @Override
+    public void init(FilterConfig filterConfig) {
+        // not implemented
+    }
+
+    @Override
+    public void doFilter(ServletRequest servletRequest, ServletResponse servletResponse, FilterChain filterChain)
+            throws IOException, ServletException {
+        SessionContextProvider contextProvider = SessionContextProviderFactory.getInstance().createInterface();
+
+        try {
+            if (servletRequest instanceof HttpServletRequest) {
+
+                contextProvider.create(getUser(servletRequest), getTenant());
+            }
+
+            filterChain.doFilter(servletRequest, servletResponse);
+        } finally {
+            contextProvider.close();
+        }
+    }
+
+    @Override
+    public void destroy() {
+        // not implemented
+    }
+
+    private String getUser(ServletRequest servletRequest) {
+        return ((HttpServletRequest) servletRequest).getHeader(USER_ID_HEADER_PARAM);
+    }
+
+    private String getTenant() {
+        return zusammenConfig.getTenant();
+    }
+}