add unit tests for oauth-provider

add unit tests and some fixes for oauth provider

Issue-ID: CCSDK-3169
Signed-off-by: Michael DÜrre <michael.duerre@highstreet-technologies.com>
Change-Id: I88c5b2123df7e0c6e49b087c3cc7d24130be5bff

9 files changed, 1096 insertions, 2 deletions

diff --git a/sdnr/wt/oauth-provider/provider-jar/src/test/java/org/onap/ccsdk/features/sdnr/wt/oauthprovider/test/TestAuthHttpServlet.java b/sdnr/wt/oauth-provider/provider-jar/src/test/java/org/onap/ccsdk/features/sdnr/wt/oauthprovider/test/TestAuthHttpServlet.java
new file mode 100644
index 000000000..bf2a39b55
--- /dev/null
+++ b/sdnr/wt/oauth-provider/provider-jar/src/test/java/org/onap/ccsdk/features/sdnr/wt/oauthprovider/test/TestAuthHttpServlet.java
@@ -0,0 +1,368 @@
+/*
+ * ============LICENSE_START=======================================================
+ * ONAP : ccsdk features
+ * ================================================================================
+ * Copyright (C) 2021 highstreet technologies GmbH Intellectual Property.
+ * All rights reserved.
+ * ================================================================================
+ * Licensed under the Apache License, Version 2.0 (the "License");
+ * you may not use this file 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.
+ * ============LICENSE_END=========================================================
+ *
+ */
+package org.onap.ccsdk.features.sdnr.wt.oauthprovider.test;
+
+import static org.junit.Assert.assertEquals;
+import static org.junit.Assert.assertNotNull;
+import static org.junit.Assert.fail;
+import static org.mockito.ArgumentMatchers.any;
+import static org.mockito.Mockito.mock;
+import static org.mockito.Mockito.verify;
+import static org.mockito.Mockito.when;
+import com.fasterxml.jackson.core.JsonParseException;
+import com.fasterxml.jackson.core.JsonProcessingException;
+import com.fasterxml.jackson.databind.JsonMappingException;
+import com.google.common.util.concurrent.FluentFuture;
+import java.io.File;
+import java.io.IOException;
+import java.nio.charset.StandardCharsets;
+import java.util.Arrays;
+import java.util.List;
+import java.util.Optional;
+import javax.servlet.ServletException;
+import javax.servlet.http.HttpServletRequest;
+import javax.servlet.http.HttpServletResponse;
+import org.jolokia.osgi.security.Authenticator;
+import org.json.JSONArray;
+import org.junit.BeforeClass;
+import org.junit.Test;
+import org.onap.ccsdk.features.sdnr.wt.common.http.BaseHTTPClient;
+import org.onap.ccsdk.features.sdnr.wt.common.test.ServletOutputStreamToByteArrayOutputStream;
+import org.onap.ccsdk.features.sdnr.wt.oauthprovider.data.Config;
+import org.onap.ccsdk.features.sdnr.wt.oauthprovider.data.CustomObjectMapper;
+import org.onap.ccsdk.features.sdnr.wt.oauthprovider.data.OdlPolicy;
+import org.onap.ccsdk.features.sdnr.wt.oauthprovider.data.UserTokenPayload;
+import org.onap.ccsdk.features.sdnr.wt.oauthprovider.http.AuthHttpServlet;
+import org.onap.ccsdk.features.sdnr.wt.oauthprovider.http.HeadersOnlyHttpServletRequest;
+import org.onap.ccsdk.features.sdnr.wt.oauthprovider.providers.TokenCreator;
+import org.onap.ccsdk.features.sdnr.wt.oauthprovider.test.helper.OdlJsonMapper;
+import org.onap.ccsdk.features.sdnr.wt.oauthprovider.test.helper.OdlXmlMapper;
+import org.opendaylight.aaa.api.IdMService;
+import org.opendaylight.aaa.shiro.filters.backport.BearerToken;
+import org.opendaylight.mdsal.binding.api.DataBroker;
+import org.opendaylight.mdsal.binding.api.ReadTransaction;
+import org.opendaylight.mdsal.common.api.LogicalDatastoreType;
+import org.opendaylight.yang.gen.v1.urn.opendaylight.aaa.app.config.rev170619.ShiroConfiguration;
+import org.opendaylight.yang.gen.v1.urn.opendaylight.aaa.app.config.rev170619.ShiroConfigurationBuilder;
+import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.aaa.rev161214.HttpAuthorization;
+import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.aaa.rev161214.http.authorization.Policies;
+import org.opendaylight.yangtools.util.concurrent.FluentFutures;
+import org.opendaylight.yangtools.yang.binding.InstanceIdentifier;
+
+
+public class TestAuthHttpServlet {
+
+    private static final String TESTCONFIGFILE = TestConfig.TEST_CONFIG_FILENAME;
+    private static final String TESTSHIROCONFIGFILE = "src/test/resources/aaa-app-config.test.xml";
+    private static final String MDSALDYNAUTHFILENAME = "src/test/resources/mdsalDynAuthData.json";
+    private static TestServlet servlet;
+    private static DataBroker dataBroker = loadDynamicMdsalAuthDataBroker();
+    private static Authenticator odlAuthenticator = mock(Authenticator.class);
+    private static IdMService odlIdentityService = mock(IdMService.class);
+    private static ShiroConfiguration shiroConfiguration = null;
+    private static TokenCreator tokenCreator;
+//    private static final HttpServletRequest authreq = new HeadersOnlyHttpServletRequest(
+//            Map.of("Authorization", BaseHTTPClient.getAuthorizationHeaderValue("admin@sdn", "admin")));
+
+    @BeforeClass
+    public static void init() {
+
+        try {
+            Config config = createConfigFile();
+            tokenCreator = TokenCreator.getInstance(config);
+            servlet = new TestServlet();
+            shiroConfiguration = loadShiroConfig(TESTSHIROCONFIGFILE);
+        } catch (IOException e) {
+            fail(e.getMessage());
+        }
+        servlet.setDataBroker(dataBroker);
+        servlet.setOdlAuthenticator(odlAuthenticator);
+        servlet.setOdlIdentityService(odlIdentityService);
+        servlet.setShiroConfiguration(shiroConfiguration);
+    }
+
+    private static DataBroker loadDynamicMdsalAuthDataBroker() {
+        DataBroker dataBroker = mock(DataBroker.class);
+        ReadTransaction rotx = mock(ReadTransaction.class);
+        InstanceIdentifier<Policies> iif = InstanceIdentifier.create(HttpAuthorization.class).child(Policies.class);
+        try {
+            when(rotx.read(LogicalDatastoreType.CONFIGURATION, iif))
+                    .thenReturn(loadDataBrokerFile(MDSALDYNAUTHFILENAME, Policies.class));
+        } catch (IOException e) {
+            fail("problem init databroker read" + e.getMessage());
+        }
+        when(dataBroker.newReadOnlyTransaction()).thenReturn(rotx);
+        return dataBroker;
+    }
+
+    private static <T> FluentFuture<Optional<T>> loadDataBrokerFile(String fn, Class<T> clazz) throws IOException {
+        return FluentFutures.immediateFluentFuture(Optional.ofNullable(readJson(new File(fn), clazz)));
+    }
+
+    private static ShiroConfiguration loadShiroConfig(String filename)
+            throws JsonParseException, JsonMappingException, IOException {
+        OdlXmlMapper mapper = new OdlXmlMapper();
+        return mapper.readValue(new File(filename), ShiroConfigurationBuilder.class).build();
+    }
+
+    private static Config createConfigFile() throws IOException {
+        return Config.getInstance(TESTCONFIGFILE);
+
+    }
+
+    @Test
+    public void testValidLoginRedirect() {
+
+        HttpServletRequest req = mock(HttpServletRequest.class);
+        when(req.getRequestURI()).thenReturn("/oauth/login/keycloak");
+        HttpServletResponse resp = mock(HttpServletResponse.class);
+        try {
+            servlet.doGet(req, resp);
+        } catch (ServletException | IOException e) {
+            fail(e.getMessage());
+        }
+        verify(resp).setStatus(302);
+        verify(resp).setHeader("Location",
+                "http://10.20.11.160:8080/auth/realms/onap/protocol/openid-connect/auth?client_id=odlux.app&response"
+                        + "_type=code&scope=openid&redirect_uri=http%3A%2F%2Fnasp.diasf.de%2Foauth%2Fredirect%2Fkeycloak");
+    }
+
+    @Test
+    public void testInValidLoginRedirect() {
+
+        HttpServletRequest req = mock(HttpServletRequest.class);
+        when(req.getRequestURI()).thenReturn("/oauth/login/unknownproviderid");
+        HttpServletResponse resp = mock(HttpServletResponse.class);
+        ServletOutputStreamToByteArrayOutputStream printOut = new ServletOutputStreamToByteArrayOutputStream();
+        try {
+            when(resp.getOutputStream()).thenReturn(printOut);
+            servlet.doGet(req, resp);
+        } catch (ServletException | IOException e) {
+            fail(e.getMessage());
+        }
+        verify(resp).setStatus(404);
+    }
+
+    @Test
+    public void testValidLogin() {
+
+        HttpServletRequest req = mock(HttpServletRequest.class);
+        when(req.getRequestURI()).thenReturn("/oauth/login");
+        when(req.getParameter("username")).thenReturn("admin");
+        when(req.getParameter("password")).thenReturn("admin");
+        when(odlAuthenticator.authenticate(any(HeadersOnlyHttpServletRequest.class))).thenReturn(true);
+        HttpServletResponse resp = mock(HttpServletResponse.class);
+        ServletOutputStreamToByteArrayOutputStream printOut = new ServletOutputStreamToByteArrayOutputStream();
+        try {
+            when(resp.getOutputStream()).thenReturn(printOut);
+            servlet.doPost(req, resp);
+        } catch (ServletException | IOException e) {
+            fail(e.getMessage());
+        }
+        verify(resp).setStatus(200);
+    }
+
+    @Test
+    public void testGetProviders() {
+
+        HttpServletRequest req = mock(HttpServletRequest.class);
+        when(req.getRequestURI()).thenReturn("/oauth/providers");
+        HttpServletResponse resp = mock(HttpServletResponse.class);
+        ServletOutputStreamToByteArrayOutputStream printOut = new ServletOutputStreamToByteArrayOutputStream();
+        try {
+            when(resp.getOutputStream()).thenReturn(printOut);
+            servlet.doGet(req, resp);
+        } catch (ServletException | IOException e) {
+            fail(e.getMessage());
+        }
+        verify(resp).setStatus(200);
+        String responseBody = printOut.getByteArrayOutputStream().toString(StandardCharsets.UTF_8);
+        System.out.println(responseBody);
+        JSONArray a = new JSONArray(responseBody);
+        assertEquals(1, a.length());
+        assertEquals("keycloak", a.getJSONObject(0).getString("id"));
+        assertEquals("OSNL Keycloak Provider", a.getJSONObject(0).getString("title"));
+        assertEquals("/oauth/login/keycloak", a.getJSONObject(0).getString("loginUrl"));
+
+    }
+
+    @Test
+    public void testPoliciesAnon() {
+
+        HttpServletRequest req = mock(HttpServletRequest.class);
+        when(req.getRequestURI()).thenReturn("/oauth/policies");
+        HttpServletResponse resp = mock(HttpServletResponse.class);
+        ServletOutputStreamToByteArrayOutputStream printOut = new ServletOutputStreamToByteArrayOutputStream();
+        try {
+            when(resp.getOutputStream()).thenReturn(printOut);
+            servlet.doGet(req, resp);
+        } catch (ServletException | IOException e) {
+            fail(e.getMessage());
+        }
+        verify(resp).setStatus(200);
+        String responseBody = printOut.getByteArrayOutputStream().toString(StandardCharsets.UTF_8);
+        System.out.println(responseBody);
+        OdlPolicy[] anonPolicies = null;
+        try {
+            anonPolicies = readJson(responseBody, OdlPolicy[].class);
+        } catch (JsonProcessingException e) {
+            fail("unable to read anon policies response");
+        }
+        assertEquals(9, anonPolicies.length);
+        OdlPolicy pApidoc = find(anonPolicies, "/apidoc/**");
+        assertNotNull(pApidoc);
+        assertAllEquals(false, pApidoc);
+        OdlPolicy pOauth = find(anonPolicies, "/oauth/**");
+        assertNotNull(pOauth);
+        assertAllEquals(true, pOauth);
+        OdlPolicy pRestconf = find(anonPolicies, "/rests/**");
+        assertNotNull(pRestconf);
+        assertAllEquals(false, pRestconf);
+    }
+
+    @Test
+    public void testPoliciesBasicAuth() {
+
+        HttpServletRequest req = mock(HttpServletRequest.class);
+        when(req.getRequestURI()).thenReturn("/oauth/policies");
+        when(req.getHeader("Authorization")).thenReturn(BaseHTTPClient.getAuthorizationHeaderValue("admin", "admin"));
+        when(odlIdentityService.listRoles("admin@sdn", "sdn")).thenReturn(Arrays.asList("admin"));
+        HttpServletResponse resp = mock(HttpServletResponse.class);
+        ServletOutputStreamToByteArrayOutputStream printOut = new ServletOutputStreamToByteArrayOutputStream();
+        try {
+            when(resp.getOutputStream()).thenReturn(printOut);
+            servlet.doGet(req, resp);
+        } catch (ServletException | IOException e) {
+            fail(e.getMessage());
+        }
+        verify(resp).setStatus(200);
+        String responseBody = printOut.getByteArrayOutputStream().toString(StandardCharsets.UTF_8);
+        System.out.println(responseBody);
+        OdlPolicy[] anonPolicies = null;
+        try {
+            anonPolicies = readJson(responseBody, OdlPolicy[].class);
+        } catch (JsonProcessingException e) {
+            fail("unable to read anon policies response");
+        }
+        assertEquals(9, anonPolicies.length);
+        OdlPolicy pApidoc = find(anonPolicies, "/apidoc/**");
+        assertNotNull(pApidoc);
+        assertAllEquals(true, pApidoc);
+        OdlPolicy pOauth = find(anonPolicies, "/oauth/**");
+        assertNotNull(pOauth);
+        assertAllEquals(true, pOauth);
+        OdlPolicy pRestconf = find(anonPolicies, "/rests/**");
+        assertNotNull(pRestconf);
+        assertAllEquals(true, pRestconf);
+    }
+
+    @Test
+    public void testPoliciesBearer() {
+        HttpServletRequest req = mock(HttpServletRequest.class);
+        when(req.getRequestURI()).thenReturn("/oauth/policies");
+        String token = createToken("admin", Arrays.asList("admin", "provision")).getToken();
+        when(req.getHeader("Authorization")).thenReturn(String.format("Bearer %s", token));
+        HttpServletResponse resp = mock(HttpServletResponse.class);
+        ServletOutputStreamToByteArrayOutputStream printOut = new ServletOutputStreamToByteArrayOutputStream();
+        try {
+            when(resp.getOutputStream()).thenReturn(printOut);
+            servlet.doGet(req, resp);
+        } catch (ServletException | IOException e) {
+            fail(e.getMessage());
+        }
+        verify(resp).setStatus(200);
+        String responseBody = printOut.getByteArrayOutputStream().toString(StandardCharsets.UTF_8);
+        System.out.println(responseBody);
+        OdlPolicy[] anonPolicies = null;
+        try {
+            anonPolicies = readJson(responseBody, OdlPolicy[].class);
+        } catch (JsonProcessingException e) {
+            fail("unable to read anon policies response");
+        }
+        assertEquals(9, anonPolicies.length);
+        OdlPolicy pApidoc = find(anonPolicies, "/apidoc/**");
+        assertNotNull(pApidoc);
+        assertAllEquals(false, pApidoc);
+        OdlPolicy pOauth = find(anonPolicies, "/oauth/**");
+        assertNotNull(pOauth);
+        assertAllEquals(true, pOauth);
+        OdlPolicy pRestconf = find(anonPolicies, "/rests/**");
+        assertNotNull(pRestconf);
+        assertAllEquals(true, pRestconf);
+    }
+
+    private static BearerToken createToken(String username, List<String> roles) {
+        UserTokenPayload data = new UserTokenPayload();
+        data.setPreferredUsername(username);
+        data.setFamilyName("");
+        data.setGivenName(username);
+        data.setExp(tokenCreator.getDefaultExp());
+        data.setRoles(roles);
+        return tokenCreator.createNewJWT(data);
+    }
+
+    private static void assertAllEquals(boolean b, OdlPolicy p) {
+        assertEquals(b, p.getMethods().isGet());
+        assertEquals(b, p.getMethods().isPost());
+        assertEquals(b, p.getMethods().isPut());
+        assertEquals(b, p.getMethods().isDelete());
+        assertEquals(b, p.getMethods().isPatch());
+    }
+
+    private static OdlPolicy find(OdlPolicy[] policies, String path) {
+        for (OdlPolicy p : policies) {
+            if (path.equals(p.getPath())) {
+                return p;
+            }
+        }
+        return null;
+    }
+
+    private static <T> T readJson(String data, Class<T> clazz) throws JsonMappingException, JsonProcessingException {
+        CustomObjectMapper mapper = new CustomObjectMapper();
+        return mapper.readValue(data, clazz);
+    }
+
+    private static <T> T readJson(File file, Class<T> clazz) throws IOException {
+        OdlJsonMapper mapper = new OdlJsonMapper();
+        return mapper.readValue(file, clazz);
+    }
+
+    private static class TestServlet extends AuthHttpServlet {
+
+        private static final long serialVersionUID = 1L;
+
+        public TestServlet() throws IOException {
+            super();
+        }
+
+        @Override
+        public void doGet(HttpServletRequest req, HttpServletResponse resp) throws ServletException, IOException {
+            super.doGet(req, resp);
+        }
+
+        @Override
+        public void doPost(HttpServletRequest req, HttpServletResponse resp) throws ServletException, IOException {
+            super.doPost(req, resp);
+        }
+    }
+}
diff --git a/sdnr/wt/oauth-provider/provider-jar/src/test/java/org/onap/ccsdk/features/sdnr/wt/oauthprovider/test/TestConfig.java b/sdnr/wt/oauth-provider/provider-jar/src/test/java/org/onap/ccsdk/features/sdnr/wt/oauthprovider/test/TestConfig.java
index 2b88141ae..d07950de7 100644
--- a/sdnr/wt/oauth-provider/provider-jar/src/test/java/org/onap/ccsdk/features/sdnr/wt/oauthprovider/test/TestConfig.java
+++ b/sdnr/wt/oauth-provider/provider-jar/src/test/java/org/onap/ccsdk/features/sdnr/wt/oauthprovider/test/TestConfig.java
@@ -27,10 +27,19 @@ import org.onap.ccsdk.features.sdnr.wt.oauthprovider.data.Config;
 
 public class TestConfig {
 
+    public static String TEST_CONFIG_FILENAME = "src/test/resources/test.config.json";
+    public static String TEST_OOMCONFIG_FILENAME = "src/test/resources/oom.test.config.json";
     @Test
     public void test() throws IOException {
 
-        Config config = Config.load("src/test/resources/test.config.json");
+        Config config = Config.load(TEST_CONFIG_FILENAME);
         System.out.println("config="+config);
     }
+    @Test
+    public void testOom() throws IOException {
+
+        Config config = Config.load(TEST_OOMCONFIG_FILENAME);
+        System.out.println("config="+config);
+
+    }
 }
diff --git a/sdnr/wt/oauth-provider/provider-jar/src/test/java/org/onap/ccsdk/features/sdnr/wt/oauthprovider/test/TestDeserializer.java b/sdnr/wt/oauth-provider/provider-jar/src/test/java/org/onap/ccsdk/features/sdnr/wt/oauthprovider/test/TestDeserializer.java
index 236c0ffac..65ef2cbd6 100644
--- a/sdnr/wt/oauth-provider/provider-jar/src/test/java/org/onap/ccsdk/features/sdnr/wt/oauthprovider/test/TestDeserializer.java
+++ b/sdnr/wt/oauth-provider/provider-jar/src/test/java/org/onap/ccsdk/features/sdnr/wt/oauthprovider/test/TestDeserializer.java
@@ -28,6 +28,7 @@ import com.fasterxml.jackson.databind.JsonMappingException;
 import com.fasterxml.jackson.databind.ObjectMapper;
 import java.io.IOException;
 import org.junit.Test;
+import org.onap.ccsdk.features.sdnr.wt.common.http.BaseHTTPResponse;
 import org.onap.ccsdk.features.sdnr.wt.oauthprovider.data.KeycloakUserTokenPayload;
 import org.onap.ccsdk.features.sdnr.wt.oauthprovider.data.OAuthResponseData;
 import org.onap.ccsdk.features.sdnr.wt.oauthprovider.http.client.MappedBaseHttpResponse;
@@ -50,7 +51,8 @@ public class TestDeserializer {
                         + "U5IiwiaXNzIjoiaHR0cDovLzEwLjIwLjExLjE2MDo4MDgwL2F1dGgvcmVhbG1zL21hc3RlciIsImF1ZCI6Imh0dHA6Ly8xMC4yMC4xMS4xNjA6ODA4MC9hdXRoL3JlYWxtcy9tYXN0ZXIiLCJzdWIiOiIxODM4YzRmMi01ZmUzLTRmMGMtYjJkMi1kMzY0YjI3YTQ5OTciLCJ0eXAiOiJSZWZyZXNoIiwiYXpwIjoiYWRtaW4tY2xpIiwic2Vzc2lvbl9zdGF0ZSI6I"
                         + "mNjNzFmYzFmLWFkZDQtNGE4Ni1hZTVlLWMzNGRmNDAzYzc3MiIsInNjb3BlIjoiZW1haWwgcHJvZmlsZSJ9.qutqcFuQW-GzaCVNMfiYrbmHYD34GYwBqIbaQbJSY-g\",\"token_type\":\"bearer\",\"not-before-policy\":0,\"session_state\":\"cc71fc1f-add4-4a86-ae5e-c34df403c772\",\"scope\":\"email profile\"} ";
 
-        OAuthResponseData data = new MappedBaseHttpResponse<>(200,response,OAuthResponseData.class).body;
+        BaseHTTPResponse res = new BaseHTTPResponse(200, response);
+        OAuthResponseData data = new MappedBaseHttpResponse<>(res,OAuthResponseData.class).body;
         assertEquals(token,data.getAccess_token());
 
     }
diff --git a/sdnr/wt/oauth-provider/provider-jar/src/test/java/org/onap/ccsdk/features/sdnr/wt/oauthprovider/test/TestGitlabAuthService.java b/sdnr/wt/oauth-provider/provider-jar/src/test/java/org/onap/ccsdk/features/sdnr/wt/oauthprovider/test/TestGitlabAuthService.java
new file mode 100644
index 000000000..fb938000e
--- /dev/null
+++ b/sdnr/wt/oauth-provider/provider-jar/src/test/java/org/onap/ccsdk/features/sdnr/wt/oauthprovider/test/TestGitlabAuthService.java
@@ -0,0 +1,195 @@
+/*
+ * ============LICENSE_START=======================================================
+ * ONAP : ccsdk features
+ * ================================================================================
+ * Copyright (C) 2021 highstreet technologies GmbH Intellectual Property.
+ * All rights reserved.
+ * ================================================================================
+ * Licensed under the Apache License, Version 2.0 (the "License");
+ * you may not use this file 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.
+ * ============LICENSE_END=========================================================
+ *
+ */
+package org.onap.ccsdk.features.sdnr.wt.oauthprovider.test;
+
+import static org.junit.Assert.fail;
+import static org.mockito.Mockito.mock;
+import static org.mockito.Mockito.verify;
+import static org.mockito.Mockito.when;
+import com.sun.net.httpserver.HttpExchange;
+import com.sun.net.httpserver.HttpHandler;
+import com.sun.net.httpserver.HttpServer;
+import java.io.File;
+import java.io.IOException;
+import java.io.OutputStream;
+import java.net.InetSocketAddress;
+import java.nio.file.Files;
+import java.util.Random;
+import java.util.concurrent.ExecutorService;
+import java.util.concurrent.Executors;
+import javax.servlet.http.HttpServletRequest;
+import javax.servlet.http.HttpServletResponse;
+import org.junit.AfterClass;
+import org.junit.BeforeClass;
+import org.junit.Test;
+import org.onap.ccsdk.features.sdnr.wt.oauthprovider.data.OAuthProviderConfig;
+import org.onap.ccsdk.features.sdnr.wt.oauthprovider.providers.GitlabProviderService;
+import org.onap.ccsdk.features.sdnr.wt.oauthprovider.providers.TokenCreator;
+
+public class TestGitlabAuthService {
+
+    private static HttpServer server;
+    private static ExecutorService httpThreadPool;
+    private static GitlabProviderServiceToTest oauthService;
+    private static final int PORT = randomPort(50000, 55000);
+    private static final String GITURL = String.format("http://127.0.0.1:%d", PORT);
+    private static final String OAUTH_SECRET = "oauthsecret";
+    private static final String TOKENCREATOR_SECRET = "secret";
+    private static final String REDIRECT_URI = "/odlux/token?";
+
+    @BeforeClass
+    public static void init() {
+
+        TokenCreator tokenCreator = TokenCreator.getInstance(TOKENCREATOR_SECRET, "issuer");
+        OAuthProviderConfig config =
+                new OAuthProviderConfig("git", GITURL, "odlux.app", OAUTH_SECRET, "openid", "gitlab test");
+        oauthService = new GitlabProviderServiceToTest(config, REDIRECT_URI, tokenCreator);
+        try {
+            initGitlabTestWebserver(PORT, "/");
+        } catch (IOException e) {
+            fail(e.getMessage());
+        }
+    }
+
+    @AfterClass
+    public static void close() {
+        stopTestWebserver();
+    }
+
+    @Test
+    public void test() {
+        HttpServletRequest req;
+        HttpServletResponse resp = null;
+        String host = "http://localhost:8412";
+        final String state = "stateabc";
+        try {
+            req = mock(HttpServletRequest.class);
+            resp = mock(HttpServletResponse.class);
+            when(req.getParameter("code")).thenReturn("abcdefg");
+            when(req.getParameter("state")).thenReturn(state);
+            oauthService.addState(state);
+            oauthService.handleRedirect(req, resp, host);
+        } catch (IOException e) {
+            fail(e.getMessage());
+        }
+        verify(resp).setStatus(302);
+        //verify(resp).setHeader("Location",any(String.class));
+    }
+
+    public void test2() {
+        oauthService.sendLoginRedirectResponse(null, null);
+    }
+
+    public static class GitlabProviderServiceToTest extends GitlabProviderService {
+
+        public GitlabProviderServiceToTest(OAuthProviderConfig config, String redirectUri, TokenCreator tokenCreator) {
+            super(config, redirectUri, tokenCreator);
+        }
+
+        public void addState(String state) {
+            this.randomIds.add(state);
+        }
+    }
+
+    private static int randomPort(int min, int max) {
+        Random random = new Random();
+        return random.nextInt(max + 1 - min) + min;
+    }
+
+    public static void initGitlabTestWebserver(int port, String baseUri) throws IOException {
+        server = HttpServer.create(new InetSocketAddress("127.0.0.1", port), 0);
+        httpThreadPool = Executors.newFixedThreadPool(5);
+        server.setExecutor(httpThreadPool);
+        server.createContext(baseUri, new MyHandler());
+        //server.createContext("/", new MyRootHandler());
+        server.setExecutor(null); // creates a default executor
+        server.start();
+        System.out.println("http server started");
+    }
+
+    public static void stopTestWebserver() {
+        if (server != null) {
+            server.stop(0);
+            httpThreadPool.shutdownNow();
+            System.out.println("http server stopped");
+        }
+    }
+
+    private static String loadResourceFileContent(String filename) {
+        try {
+            return Files.readString(new File(filename).toPath());
+        } catch (IOException e) {
+            fail(e.getMessage());
+        }
+        return null;
+    }
+    public static class MyHandler implements HttpHandler {
+        private static final String GITLAB_TOKEN_ENDPOINT = "/oauth/token";
+        private static final String GITLAB_USER_ENDPOINT = "/api/v4/user";
+        private static final String GITLAB_GROUP_ENDPOINT = "/api/v4/groups?min_access_level=10";
+        private static final String GITLAB_TOKEN_RESPONSE = loadResourceFileContent("src/test/resources/oauth/gitlab-token-response.json");
+        private static final String GITLAB_USER_RESPONSE =loadResourceFileContent("src/test/resources/oauth/gitlab-user-response.json");
+        private static final String GITLAB_GROUP_RESPONSE =loadResourceFileContent("src/test/resources/oauth/gitlab-groups-response.json");
+
+        @Override
+        public void handle(HttpExchange t) throws IOException {
+            final String method = t.getRequestMethod();
+            final String uri = t.getRequestURI().toString();
+            System.out.println(String.format("req received: %s %s", method, t.getRequestURI()));
+            OutputStream os = null;
+            String response = "";
+            try {
+                if (method.equals("GET")) {
+                    if(uri.equals(GITLAB_USER_ENDPOINT)) {
+                        t.sendResponseHeaders(200, GITLAB_USER_RESPONSE.length());
+                        os = t.getResponseBody();
+                        os.write(GITLAB_USER_RESPONSE.getBytes());
+                    }
+                    else if(uri.equals(GITLAB_GROUP_ENDPOINT)) {
+                        t.sendResponseHeaders(200, GITLAB_GROUP_RESPONSE.length());
+                        os = t.getResponseBody();
+                        os.write(GITLAB_GROUP_RESPONSE.getBytes());
+                    }
+                } else if (method.equals("POST")) {
+                    if(uri.equals(GITLAB_TOKEN_ENDPOINT)){
+                        t.sendResponseHeaders(200, GITLAB_TOKEN_RESPONSE.length());
+                        os = t.getResponseBody();
+                        os.write(GITLAB_TOKEN_RESPONSE.getBytes());
+                    }
+                    else {
+                        t.sendResponseHeaders(404, 0);
+                    }
+                } else {
+                    t.sendResponseHeaders(404, 0);
+                }
+                System.out.println("req handled successful");
+
+            } catch (Exception e) {
+                System.out.println(e.getMessage());
+            } finally {
+                if (os != null) {
+                    os.close();
+                }
+            }
+        }
+    }
+}
diff --git a/sdnr/wt/oauth-provider/provider-jar/src/test/java/org/onap/ccsdk/features/sdnr/wt/oauthprovider/test/TestKeycloakAuthService.java b/sdnr/wt/oauth-provider/provider-jar/src/test/java/org/onap/ccsdk/features/sdnr/wt/oauthprovider/test/TestKeycloakAuthService.java
new file mode 100644
index 000000000..945ad7ff5
--- /dev/null
+++ b/sdnr/wt/oauth-provider/provider-jar/src/test/java/org/onap/ccsdk/features/sdnr/wt/oauthprovider/test/TestKeycloakAuthService.java
@@ -0,0 +1,174 @@
+/*
+ * ============LICENSE_START=======================================================
+ * ONAP : ccsdk features
+ * ================================================================================
+ * Copyright (C) 2021 highstreet technologies GmbH Intellectual Property.
+ * All rights reserved.
+ * ================================================================================
+ * Licensed under the Apache License, Version 2.0 (the "License");
+ * you may not use this file 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.
+ * ============LICENSE_END=========================================================
+ *
+ */
+package org.onap.ccsdk.features.sdnr.wt.oauthprovider.test;
+
+import static org.junit.Assert.fail;
+import static org.mockito.Mockito.mock;
+import static org.mockito.Mockito.verify;
+import static org.mockito.Mockito.when;
+import com.sun.net.httpserver.HttpExchange;
+import com.sun.net.httpserver.HttpHandler;
+import com.sun.net.httpserver.HttpServer;
+import java.io.File;
+import java.io.IOException;
+import java.io.OutputStream;
+import java.net.InetSocketAddress;
+import java.nio.file.Files;
+import java.util.Random;
+import java.util.concurrent.ExecutorService;
+import java.util.concurrent.Executors;
+import javax.servlet.http.HttpServletRequest;
+import javax.servlet.http.HttpServletResponse;
+import org.junit.AfterClass;
+import org.junit.BeforeClass;
+import org.junit.Test;
+import org.onap.ccsdk.features.sdnr.wt.oauthprovider.data.OAuthProviderConfig;
+import org.onap.ccsdk.features.sdnr.wt.oauthprovider.providers.KeycloakProviderService;
+import org.onap.ccsdk.features.sdnr.wt.oauthprovider.providers.TokenCreator;
+
+public class TestKeycloakAuthService {
+
+    private static HttpServer server;
+    private static ExecutorService httpThreadPool;
+    private static KeycloakProviderServiceToTest oauthService;
+    private static final int PORT = randomPort(50000, 55000);
+    private static final String KEYCLOAKURL = String.format("http://127.0.0.1:%d", PORT);
+    private static final String OAUTH_SECRET = "oauthsecret";
+    private static final String TOKENCREATOR_SECRET = "secret";
+    private static final String REDIRECT_URI = "/odlux/token?";
+
+    @BeforeClass
+    public static void init() {
+
+        TokenCreator tokenCreator = TokenCreator.getInstance(TOKENCREATOR_SECRET, "issuer");
+        OAuthProviderConfig config =
+                new OAuthProviderConfig("kc", KEYCLOAKURL, "odlux.app", OAUTH_SECRET, "openid", "keycloak test");
+        oauthService = new KeycloakProviderServiceToTest(config, REDIRECT_URI, tokenCreator);
+        try {
+            initKeycloakTestWebserver(PORT, "/");
+        } catch (IOException e) {
+            fail(e.getMessage());
+        }
+    }
+
+    @AfterClass
+    public static void close() {
+        stopTestWebserver();
+    }
+
+    @Test
+    public void test() {
+        HttpServletRequest req;
+        HttpServletResponse resp = null;
+        String host = "http://localhost:8412";
+        final String state = "stateabc";
+        try {
+            req = mock(HttpServletRequest.class);
+            resp = mock(HttpServletResponse.class);
+            when(req.getParameter("code")).thenReturn("abcdefg");
+            when(req.getParameter("state")).thenReturn(state);
+            oauthService.handleRedirect(req, resp, host);
+        } catch (IOException e) {
+            fail(e.getMessage());
+        }
+        verify(resp).setStatus(302);
+        //verify(resp).setHeader("Location",any(String.class));
+    }
+
+    public void test2() {
+        oauthService.sendLoginRedirectResponse(null, null);
+    }
+
+    public static class KeycloakProviderServiceToTest extends KeycloakProviderService {
+
+        public KeycloakProviderServiceToTest(OAuthProviderConfig config, String redirectUri, TokenCreator tokenCreator) {
+            super(config, redirectUri, tokenCreator);
+        }
+    }
+
+    private static int randomPort(int min, int max) {
+        Random random = new Random();
+        return random.nextInt(max + 1 - min) + min;
+    }
+
+    public static void initKeycloakTestWebserver(int port, String baseUri) throws IOException {
+        server = HttpServer.create(new InetSocketAddress("127.0.0.1", port), 0);
+        httpThreadPool = Executors.newFixedThreadPool(5);
+        server.setExecutor(httpThreadPool);
+        server.createContext(baseUri, new MyHandler());
+        //server.createContext("/", new MyRootHandler());
+        server.setExecutor(null); // creates a default executor
+        server.start();
+        System.out.println("http server started");
+    }
+
+    public static void stopTestWebserver() {
+        if (server != null) {
+            server.stop(0);
+            httpThreadPool.shutdownNow();
+            System.out.println("http server stopped");
+        }
+    }
+
+    private static String loadResourceFileContent(String filename) {
+        try {
+            return Files.readString(new File(filename).toPath());
+        } catch (IOException e) {
+            fail(e.getMessage());
+        }
+        return null;
+    }
+    public static class MyHandler implements HttpHandler {
+        private static final String KEYCLOAK_TOKEN_ENDPOINT = "/auth/realms/onap/protocol/openid-connect/token";
+        private static final String KEYCLOAK_TOKEN_RESPONSE = loadResourceFileContent("src/test/resources/oauth/keycloak-token-response.json");
+
+        @Override
+        public void handle(HttpExchange t) throws IOException {
+            final String method = t.getRequestMethod();
+            final String uri = t.getRequestURI().toString();
+            System.out.println(String.format("req received: %s %s", method, t.getRequestURI()));
+            OutputStream os = null;
+            try {
+               if (method.equals("POST")) {
+                    if(uri.equals(KEYCLOAK_TOKEN_ENDPOINT)){
+                        t.sendResponseHeaders(200, KEYCLOAK_TOKEN_RESPONSE.length());
+                        os = t.getResponseBody();
+                        os.write(KEYCLOAK_TOKEN_RESPONSE.getBytes());
+                    }
+                    else {
+                        t.sendResponseHeaders(404, 0);
+                    }
+                } else {
+                    t.sendResponseHeaders(404, 0);
+                }
+                System.out.println("req handled successful");
+
+            } catch (Exception e) {
+                System.out.println(e.getMessage());
+            } finally {
+                if (os != null) {
+                    os.close();
+                }
+            }
+        }
+    }
+}
diff --git a/sdnr/wt/oauth-provider/provider-jar/src/test/java/org/onap/ccsdk/features/sdnr/wt/oauthprovider/test/TestPolicy.java b/sdnr/wt/oauth-provider/provider-jar/src/test/java/org/onap/ccsdk/features/sdnr/wt/oauthprovider/test/TestPolicy.java
new file mode 100644
index 000000000..31d72944c
--- /dev/null
+++ b/sdnr/wt/oauth-provider/provider-jar/src/test/java/org/onap/ccsdk/features/sdnr/wt/oauthprovider/test/TestPolicy.java
@@ -0,0 +1,56 @@
+/*
+ * ============LICENSE_START=======================================================
+ * ONAP : ccsdk features
+ * ================================================================================
+ * Copyright (C) 2021 highstreet technologies GmbH Intellectual Property.
+ * All rights reserved.
+ * ================================================================================
+ * Licensed under the Apache License, Version 2.0 (the "License");
+ * you may not use this file 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.
+ * ============LICENSE_END=========================================================
+ *
+ */
+package org.onap.ccsdk.features.sdnr.wt.oauthprovider.test;
+
+import static org.junit.Assert.assertEquals;
+import static org.junit.Assert.assertFalse;
+import static org.junit.Assert.assertTrue;
+import org.junit.Test;
+import org.onap.ccsdk.features.sdnr.wt.oauthprovider.data.OdlPolicy;
+
+public class TestPolicy {
+
+    private static final String PATH_1 = "/p1/**";
+
+    @Test
+    public void testPolicyAllowAll() {
+        OdlPolicy p = OdlPolicy.allowAll(PATH_1);
+        assertTrue(p.getMethods().isGet());
+        assertTrue(p.getMethods().isPost());
+        assertTrue(p.getMethods().isPut());
+        assertTrue(p.getMethods().isDelete());
+        assertTrue(p.getMethods().isPatch());
+        assertEquals(PATH_1,p.getPath());
+    }
+
+    @Test
+    public void testPolicyDenyAll() {
+        OdlPolicy p = OdlPolicy.denyAll(PATH_1);
+        assertFalse(p.getMethods().isGet());
+        assertFalse(p.getMethods().isPost());
+        assertFalse(p.getMethods().isPut());
+        assertFalse(p.getMethods().isDelete());
+        assertFalse(p.getMethods().isPatch());
+        assertEquals(PATH_1,p.getPath());
+    }
+
+}
diff --git a/sdnr/wt/oauth-provider/provider-jar/src/test/java/org/onap/ccsdk/features/sdnr/wt/oauthprovider/test/TestRealm.java b/sdnr/wt/oauth-provider/provider-jar/src/test/java/org/onap/ccsdk/features/sdnr/wt/oauthprovider/test/TestRealm.java
new file mode 100644
index 000000000..fe9dae31d
--- /dev/null
+++ b/sdnr/wt/oauth-provider/provider-jar/src/test/java/org/onap/ccsdk/features/sdnr/wt/oauthprovider/test/TestRealm.java
@@ -0,0 +1,178 @@
+/*
+ * ============LICENSE_START=======================================================
+ * ONAP : ccsdk features
+ * ================================================================================
+ * Copyright (C) 2021 highstreet technologies GmbH Intellectual Property.
+ * All rights reserved.
+ * ================================================================================
+ * Licensed under the Apache License, Version 2.0 (the "License");
+ * you may not use this file 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.
+ * ============LICENSE_END=========================================================
+ *
+ */
+package org.onap.ccsdk.features.sdnr.wt.oauthprovider.test;
+
+import static org.junit.Assert.assertEquals;
+import static org.junit.Assert.assertTrue;
+import static org.junit.Assert.fail;
+import static org.mockito.Mockito.mock;
+import static org.mockito.Mockito.when;
+import com.auth0.jwt.interfaces.DecodedJWT;
+import java.io.IOException;
+import java.util.Arrays;
+import java.util.HashSet;
+import java.util.List;
+import org.apache.shiro.authc.AuthenticationException;
+import org.apache.shiro.authc.AuthenticationInfo;
+import org.apache.shiro.authc.AuthenticationToken;
+import org.apache.shiro.authc.UsernamePasswordToken;
+import org.apache.shiro.authz.AuthorizationInfo;
+import org.apache.shiro.subject.PrincipalCollection;
+import org.junit.BeforeClass;
+import org.junit.Test;
+import org.onap.ccsdk.features.sdnr.wt.oauthprovider.OAuth2Realm;
+import org.onap.ccsdk.features.sdnr.wt.oauthprovider.data.Config;
+import org.onap.ccsdk.features.sdnr.wt.oauthprovider.data.UserTokenPayload;
+import org.onap.ccsdk.features.sdnr.wt.oauthprovider.providers.TokenCreator;
+import org.opendaylight.aaa.api.shiro.principal.ODLPrincipal;
+import org.opendaylight.aaa.shiro.filters.backport.BearerToken;
+import org.opendaylight.aaa.shiro.tokenauthrealm.auth.AuthenticationManager;
+import org.opendaylight.aaa.shiro.tokenauthrealm.auth.TokenAuthenticators;
+import org.opendaylight.aaa.shiro.web.env.ThreadLocals;
+
+public class TestRealm {
+
+    private static OAuth2RealmToTest realm;
+    private static TokenCreator tokenCreator;
+
+    @BeforeClass
+    public static void init() {
+        ThreadLocals.AUTH_SETVICE_TL.set(new AuthenticationManager());
+        ThreadLocals.TOKEN_AUTHENICATORS_TL.set(new TokenAuthenticators());
+        try {
+            Config config = Config.getInstance(TestConfig.TEST_CONFIG_FILENAME);
+            tokenCreator = TokenCreator.getInstance(config);
+            realm = new OAuth2RealmToTest();
+        } catch (IOException e) {
+            fail(e.getMessage());
+        }
+    }
+
+
+    @Test
+    public void testTokenSupport() {
+        assertTrue(realm.supports(new UsernamePasswordToken()));
+        assertTrue(realm.supports(new BearerToken("")));
+    }
+
+
+    @Test
+    public void testAuthorizationInfo() {
+        //bearer token use case
+        PrincipalCollection c = mock(PrincipalCollection.class);
+        final List<String> roles = Arrays.asList("admin", "provision");
+        UserTokenPayload userData = createUserData("", roles);
+
+        DecodedJWT decodedJwt = tokenCreator.verify(tokenCreator.createNewJWT(userData).getToken());
+        when(c.getPrimaryPrincipal()).thenReturn(decodedJwt);
+
+        AuthorizationInfo ai = realm.doGetAuthorizationInfo(c);
+        for (String role : roles) {
+            assertTrue(ai.getRoles().contains(role));
+        }
+        assertEquals(roles.size(), ai.getRoles().size());
+        //odl token use case
+        ODLPrincipal principal = mock(ODLPrincipal.class);
+        when(principal.getRoles()).thenReturn(new HashSet<String>(roles));
+        PrincipalCollection c2 = mock(PrincipalCollection.class);
+        when(c2.getPrimaryPrincipal()).thenReturn(principal);
+        ai = realm.doGetAuthorizationInfo(c2);
+        for (String role : roles) {
+            assertTrue(ai.getRoles().contains(role));
+        }
+        assertEquals(roles.size(), ai.getRoles().size());
+
+    }
+
+    @Test
+    public void testAssertCredentialsMatch() {
+        //bearer token use case
+        UserTokenPayload userData = createUserData("", Arrays.asList("admin", "provision"));
+        AuthenticationToken atoken = new BearerToken(tokenCreator.createNewJWT(userData).getToken());
+        AuthenticationInfo ai = null;
+        try {
+            realm.assertCredentialsMatch(atoken, ai);
+        } catch (AuthenticationException e) {
+            fail(e.getMessage());
+        }
+        //odl token use case
+        atoken = new UsernamePasswordToken("admin", "admin");
+        try {
+            realm.assertCredentialsMatch(atoken, ai);
+        } catch (AuthenticationException e) {
+            fail(e.getMessage());
+        }
+    }
+
+    @Test
+    public void testAuthenticationInfo() {
+        //bearer token use case
+        UserTokenPayload userData = createUserData("", Arrays.asList("admin", "provision"));
+        AuthenticationToken atoken = new BearerToken(tokenCreator.createNewJWT(userData).getToken());
+        AuthenticationInfo ai = null;
+        try {
+            ai = realm.doGetAuthenticationInfo(atoken);
+        } catch (AuthenticationException e) {
+            fail(e.getMessage());
+        }
+        //odl token use case
+        atoken = new UsernamePasswordToken("admin", "admin");
+        try {
+            ai = realm.doGetAuthenticationInfo(atoken);
+        } catch (AuthenticationException e) {
+            fail(e.getMessage());
+        }
+    }
+
+    private static UserTokenPayload createUserData(String username, List<String> roles) {
+        UserTokenPayload userData = new UserTokenPayload();
+        userData.setExp(tokenCreator.getDefaultExp());
+        userData.setFamilyName("");
+        userData.setGivenName("");
+        userData.setPreferredUsername(username);
+        userData.setRoles(roles);
+        return userData;
+    }
+
+    public static class OAuth2RealmToTest extends OAuth2Realm {
+
+        public OAuth2RealmToTest() throws IOException {
+            super();
+        }
+
+        @Override
+        public AuthorizationInfo doGetAuthorizationInfo(PrincipalCollection arg) {
+            return super.doGetAuthorizationInfo(arg);
+        }
+
+        @Override
+        public void assertCredentialsMatch(AuthenticationToken atoken, AuthenticationInfo ai)
+                throws AuthenticationException {
+            super.assertCredentialsMatch(atoken, ai);
+        }
+
+        @Override
+        public AuthenticationInfo doGetAuthenticationInfo(AuthenticationToken token) throws AuthenticationException {
+            return super.doGetAuthenticationInfo(token);
+        }
+    }
+}
diff --git a/sdnr/wt/oauth-provider/provider-jar/src/test/java/org/onap/ccsdk/features/sdnr/wt/oauthprovider/test/helper/OdlJsonMapper.java b/sdnr/wt/oauth-provider/provider-jar/src/test/java/org/onap/ccsdk/features/sdnr/wt/oauthprovider/test/helper/OdlJsonMapper.java
new file mode 100644
index 000000000..0399655ed
--- /dev/null
+++ b/sdnr/wt/oauth-provider/provider-jar/src/test/java/org/onap/ccsdk/features/sdnr/wt/oauthprovider/test/helper/OdlJsonMapper.java
@@ -0,0 +1,66 @@
+/*
+ * ============LICENSE_START=======================================================
+ * ONAP : ccsdk features
+ * ================================================================================
+ * Copyright (C) 2021 highstreet technologies GmbH Intellectual Property.
+ * All rights reserved.
+ * ================================================================================
+ * Licensed under the Apache License, Version 2.0 (the "License");
+ * you may not use this file 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.
+ * ============LICENSE_END=========================================================
+ *
+ */
+package org.onap.ccsdk.features.sdnr.wt.oauthprovider.test.helper;
+
+import com.fasterxml.jackson.annotation.JsonInclude.Include;
+import com.fasterxml.jackson.databind.DeserializationFeature;
+import com.fasterxml.jackson.databind.MapperFeature;
+import com.fasterxml.jackson.databind.ObjectMapper;
+import com.fasterxml.jackson.databind.PropertyNamingStrategy;
+import org.onap.ccsdk.features.sdnr.wt.dataprovider.yangtools.mapperextensions.YangToolsBuilderAnnotationIntrospector;
+import org.onap.ccsdk.features.sdnr.wt.dataprovider.yangtools.mapperextensions.YangToolsModule;
+import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.aaa.rev161214.http.permission.Permissions;
+import org.opendaylight.yangtools.concepts.Builder;
+
+public class OdlJsonMapper extends ObjectMapper {
+
+    private static final long serialVersionUID = 1L;
+
+
+    public OdlJsonMapper() {
+        this.configure(DeserializationFeature.FAIL_ON_UNKNOWN_PROPERTIES, false);
+        this.setSerializationInclusion(Include.NON_NULL);
+        this.setPropertyNamingStrategy(PropertyNamingStrategy.KEBAB_CASE);
+        this.enable(MapperFeature.USE_GETTERS_AS_SETTERS);
+        YangToolsBuilderAnnotationIntrospector introspector = new YangToolsBuilderAnnotationIntrospector();
+        //introspector.addDeserializer(Main.class, ShiroMainBuilder.class.getName());
+        introspector.addDeserializer(Permissions.class,PermissionsBuilder.class.getName());
+        this.setAnnotationIntrospector(introspector);
+        this.registerModule(new YangToolsModule());
+    }
+
+    public static class PermissionsBuilder implements Builder<Permissions> {
+        private Permissions _value;
+
+        public PermissionsBuilder() {
+
+        }
+        public PermissionsBuilder(Permissions value) {
+            this._value = value;
+        }
+
+        @Override
+        public Permissions build() {
+            return this._value;
+        }
+    }
+}
diff --git a/sdnr/wt/oauth-provider/provider-jar/src/test/java/org/onap/ccsdk/features/sdnr/wt/oauthprovider/test/helper/OdlXmlMapper.java b/sdnr/wt/oauth-provider/provider-jar/src/test/java/org/onap/ccsdk/features/sdnr/wt/oauthprovider/test/helper/OdlXmlMapper.java
new file mode 100644
index 000000000..cc029bd05
--- /dev/null
+++ b/sdnr/wt/oauth-provider/provider-jar/src/test/java/org/onap/ccsdk/features/sdnr/wt/oauthprovider/test/helper/OdlXmlMapper.java
@@ -0,0 +1,46 @@
+/*
+ * ============LICENSE_START=======================================================
+ * ONAP : ccsdk features
+ * ================================================================================
+ * Copyright (C) 2021 highstreet technologies GmbH Intellectual Property.
+ * All rights reserved.
+ * ================================================================================
+ * Licensed under the Apache License, Version 2.0 (the "License");
+ * you may not use this file 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.
+ * ============LICENSE_END=========================================================
+ *
+ */
+package org.onap.ccsdk.features.sdnr.wt.oauthprovider.test.helper;
+
+import com.fasterxml.jackson.annotation.JsonInclude.Include;
+import com.fasterxml.jackson.databind.DeserializationFeature;
+import com.fasterxml.jackson.databind.MapperFeature;
+import com.fasterxml.jackson.databind.PropertyNamingStrategy;
+import com.fasterxml.jackson.dataformat.xml.XmlMapper;
+import org.onap.ccsdk.features.sdnr.wt.dataprovider.yangtools.mapperextensions.YangToolsBuilderAnnotationIntrospector;
+
+public class OdlXmlMapper extends XmlMapper{
+
+    private static final long serialVersionUID = 1L;
+
+
+    public OdlXmlMapper() {
+        this.configure(DeserializationFeature.FAIL_ON_UNKNOWN_PROPERTIES, false);
+        this.setSerializationInclusion(Include.NON_NULL);
+        this.setPropertyNamingStrategy(PropertyNamingStrategy.KEBAB_CASE);
+        this.enable(MapperFeature.USE_GETTERS_AS_SETTERS);
+        YangToolsBuilderAnnotationIntrospector introspector = new YangToolsBuilderAnnotationIntrospector();
+        //introspector.addDeserializer(Main.class, ShiroMainBuilder.class.getName());
+
+        this.setAnnotationIntrospector(introspector);
+    }
+}