Refine Agent to create CADI Configs

Issue-ID: AAF-378
Change-Id: I4bb70ff582a3990d0344d23aaac2b750e931a6b1
Signed-off-by: Instrumental <jonathan.gathman@att.com>

9 files changed, 164 insertions, 197 deletions

diff --git a/auth/auth-locate/pom.xml b/auth/auth-locate/pom.xml
index a8e7de2c..13640b53 100644
--- a/auth/auth-locate/pom.xml
+++ b/auth/auth-locate/pom.xml
@@ -48,6 +48,11 @@
 	<dependencies>
 		<dependency>
 			<groupId>org.onap.aaf.authz</groupId>
+			<artifactId>aaf-auth-client</artifactId>
+		</dependency>
+	
+		<dependency>
+			<groupId>org.onap.aaf.authz</groupId>
 			<artifactId>aaf-auth-core</artifactId>
 		</dependency>
 
@@ -60,6 +65,11 @@
 			<groupId>org.onap.aaf.authz</groupId>
 			<artifactId>aaf-cadi-aaf</artifactId>
 		</dependency>
+
+		<dependency>
+			<groupId>org.onap.aaf.authz</groupId>
+			<artifactId>aaf-misc-rosetta</artifactId>
+		</dependency>
 	</dependencies>
 
 	<build>
@@ -80,7 +90,6 @@
 				</configuration>
 			</plugin>
 
-
 			<plugin>
 				<groupId>org.apache.maven.plugins</groupId>
 				<artifactId>maven-deploy-plugin</artifactId>
diff --git a/auth/auth-locate/src/main/java/org/onap/aaf/auth/locate/AAF_Locate.java b/auth/auth-locate/src/main/java/org/onap/aaf/auth/locate/AAF_Locate.java
index 9986c60a..8371ff14 100644
--- a/auth/auth-locate/src/main/java/org/onap/aaf/auth/locate/AAF_Locate.java
+++ b/auth/auth-locate/src/main/java/org/onap/aaf/auth/locate/AAF_Locate.java
@@ -62,6 +62,7 @@ import org.onap.aaf.cadi.register.Registrant;
 import org.onap.aaf.misc.env.APIException;
 import org.onap.aaf.misc.env.Data;
 import org.onap.aaf.misc.env.Env;
+import org.onap.aaf.misc.rosetta.env.RosettaEnv;
 
 import com.datastax.driver.core.Cluster;
 
diff --git a/auth/auth-locate/src/main/java/org/onap/aaf/auth/locate/facade/LocateFacadeFactory.java b/auth/auth-locate/src/main/java/org/onap/aaf/auth/locate/facade/LocateFacadeFactory.java
index cff70f03..84fc20a5 100644
--- a/auth/auth-locate/src/main/java/org/onap/aaf/auth/locate/facade/LocateFacadeFactory.java
+++ b/auth/auth-locate/src/main/java/org/onap/aaf/auth/locate/facade/LocateFacadeFactory.java
@@ -29,9 +29,10 @@ import org.onap.aaf.auth.locate.service.LocateServiceImpl;
 import org.onap.aaf.misc.env.APIException;
 import org.onap.aaf.misc.env.Data;
 
-import locate_local.v1_0.Error;
 import locate_local.v1_0.InRequest;
 import locate_local.v1_0.Out;
+import locate_local.v1_0.Error;;
+
 
 
 public class LocateFacadeFactory {
diff --git a/auth/auth-locate/src/main/java/org/onap/aaf/auth/locate/facade/LocateFacadeImpl.java b/auth/auth-locate/src/main/java/org/onap/aaf/auth/locate/facade/LocateFacadeImpl.java
index af6ad1c1..f7b9c363 100644
--- a/auth/auth-locate/src/main/java/org/onap/aaf/auth/locate/facade/LocateFacadeImpl.java
+++ b/auth/auth-locate/src/main/java/org/onap/aaf/auth/locate/facade/LocateFacadeImpl.java
@@ -62,6 +62,7 @@ import org.onap.aaf.misc.rosetta.env.RosettaData;
 
 import locate_local.v1_0.Api;
 
+
 /**
  * AuthzFacade
  * 
diff --git a/auth/auth-locate/src/main/java/org/onap/aaf/auth/locate/facade/LocateFacade_1_1.java b/auth/auth-locate/src/main/java/org/onap/aaf/auth/locate/facade/LocateFacade_1_1.java
index d044b731..87d98361 100644
--- a/auth/auth-locate/src/main/java/org/onap/aaf/auth/locate/facade/LocateFacade_1_1.java
+++ b/auth/auth-locate/src/main/java/org/onap/aaf/auth/locate/facade/LocateFacade_1_1.java
@@ -28,10 +28,11 @@ import org.onap.aaf.misc.env.Data;
 
 import locate.v1_0.Endpoints;
 import locate.v1_0.MgmtEndpoints;
-import locate_local.v1_0.Error;
+import locate.v1_1.Configuration;
 import locate_local.v1_0.InRequest;
 import locate_local.v1_0.Out;
-import locate_local.v1_1.Configuration;
+import locate_local.v1_0.Error;
+
 
 public class LocateFacade_1_1 extends LocateFacadeImpl<InRequest,Out,Endpoints,MgmtEndpoints,Configuration,Error>
 {
diff --git a/auth/auth-locate/src/main/java/org/onap/aaf/auth/locate/mapper/Mapper_1_1.java b/auth/auth-locate/src/main/java/org/onap/aaf/auth/locate/mapper/Mapper_1_1.java
index 61178951..2edb54f9 100644
--- a/auth/auth-locate/src/main/java/org/onap/aaf/auth/locate/mapper/Mapper_1_1.java
+++ b/auth/auth-locate/src/main/java/org/onap/aaf/auth/locate/mapper/Mapper_1_1.java
@@ -32,10 +32,10 @@ import locate.v1_0.Endpoint;
 import locate.v1_0.Endpoints;
 import locate.v1_0.MgmtEndpoint;
 import locate.v1_0.MgmtEndpoints;
+import locate.v1_1.Configuration;
 import locate_local.v1_0.Error;
 import locate_local.v1_0.InRequest;
 import locate_local.v1_0.Out;
-import locate_local.v1_1.Configuration;
 
 public class Mapper_1_1 implements Mapper<InRequest,Out,Endpoints,MgmtEndpoints,Configuration,Error> {
 	
diff --git a/auth/auth-locate/src/main/java/org/onap/aaf/auth/locate/service/LocateServiceImpl.java b/auth/auth-locate/src/main/java/org/onap/aaf/auth/locate/service/LocateServiceImpl.java
index 9789ad0e..595a6857 100644
--- a/auth/auth-locate/src/main/java/org/onap/aaf/auth/locate/service/LocateServiceImpl.java
+++ b/auth/auth-locate/src/main/java/org/onap/aaf/auth/locate/service/LocateServiceImpl.java
@@ -38,8 +38,8 @@ import org.onap.aaf.misc.env.APIException;
 import locate.v1_0.Endpoints;
 import locate.v1_0.MgmtEndpoint;
 import locate.v1_0.MgmtEndpoints;
-import locate_local.v1_1.Configuration;
-import locate_local.v1_1.Configuration.Props;
+import locate.v1_1.Configuration;
+import locate.v1_1.Configuration.Props;
 
 public class LocateServiceImpl<IN,OUT,ERROR> 
 	  implements LocateService<IN,OUT,Endpoints,MgmtEndpoints,Configuration,ERROR> {
diff --git a/auth/auth-locate/src/main/xsd/locate_1_1.xsd b/auth/auth-locate/src/main/xsd/locate_1_1.xsd
deleted file mode 100644
index 59409d45..00000000
--- a/auth/auth-locate/src/main/xsd/locate_1_1.xsd
+++ /dev/null
@@ -1,46 +0,0 @@
-<!-- 
- * ============LICENSE_START====================================================
- * org.onap.aaf
- * ===========================================================================
- * Copyright (c) 2018 AT&T 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====================================================
- *
--->
-<xs:schema 
-	xmlns:xs="http://www.w3.org/2001/XMLSchema" 
-	xmlns:locate_local="urn:locate_local:v1_1" 
-	targetNamespace="urn:locate_local:v1_1" 
-	elementFormDefault="qualified">
-	
-
-<!-- 
-	Configurations
- -->
-	<xs:element name="Configuration">
-		<xs:complexType>
-			<xs:sequence>
-				<xs:element name="name" type="xs:string"/>
-				<xs:element name="props" minOccurs="0" maxOccurs="unbounded">
-					<xs:complexType>
-						<xs:sequence>
-							<xs:element name="tag" type="xs:string"/>
-							<xs:element name="value" type="xs:string"/>
-						</xs:sequence>
-					</xs:complexType>
-				</xs:element>
-			</xs:sequence>
-		</xs:complexType>
-	</xs:element>
-</xs:schema>
\ No newline at end of file
diff --git a/auth/auth-locate/src/test/java/org/onap/aaf/auth/locate/validation/JU_LocateValidatorTest.java b/auth/auth-locate/src/test/java/org/onap/aaf/auth/locate/validation/JU_LocateValidatorTest.java
index ef076da8..80248d2f 100644
--- a/auth/auth-locate/src/test/java/org/onap/aaf/auth/locate/validation/JU_LocateValidatorTest.java
+++ b/auth/auth-locate/src/test/java/org/onap/aaf/auth/locate/validation/JU_LocateValidatorTest.java
@@ -40,148 +40,148 @@ import locate.v1_0.MgmtEndpoints;
 

 public class JU_LocateValidatorTest {

 

-	@Mock

-	private Endpoint endpoint;

-

-	@Mock(answer = Answers.RETURNS_DEEP_STUBS)

-	private Endpoints endpoints;

-	@Mock(answer = Answers.RETURNS_DEEP_STUBS)

-	private MgmtEndpoints me;

-	@Mock(answer = Answers.RETURNS_DEEP_STUBS)

-	private MgmtEndpoint mgmtEndpoint;

-	@Mock(answer = Answers.RETURNS_DEEP_STUBS)

-	private SpecialPorts specialPort;

-

-	@Before

-	public void setup() {

-		MockitoAnnotations.initMocks(this);

-	}

-

-	@Test

-	public void testNullEndPoint() {

-		LocateValidator validator = new LocateValidator();

-

-		validator.endpoint(null);

-		assertEquals("Endpoint Data is null.\n", validator.errs());

-	}

-

-	@Test

-	public void testEndPoint() {

-		LocateValidator validator = new LocateValidator();

-

-		when(endpoint.getName()).thenReturn("Endpoint1");

-		when(endpoint.getHostname()).thenReturn("HOST1");

-		when(endpoint.getPort()).thenReturn(9090);

-		when(endpoint.getProtocol()).thenReturn("HTTP");

-

-		validator.endpoint(endpoint);

-

-		assertEquals("Endpoint Name must prefixed by Namespace\n", validator.errs());

-	}

-

-	@Test

-	public void testSubProtoCol() {

-		LocateValidator validator = new LocateValidator();

-

-		List<String> subProtocol = new ArrayList<String>();

-		subProtocol.add(null);

-

-		when(endpoint.getName()).thenReturn("EndPoint.Endpoint1");

-		when(endpoint.getHostname()).thenReturn("HOST1");

-		when(endpoint.getPort()).thenReturn(9090);

-		when(endpoint.getProtocol()).thenReturn("HTTP");

-		when(endpoint.getSubprotocol()).thenReturn(subProtocol);

-

-		validator.endpoint(endpoint);

-

-		assertEquals("Endpoint Subprotocol is null.\n", validator.errs());

-	}

-

-	@Test

-	public void testNullEndpoints() {

-		LocateValidator validator = new LocateValidator();

-

-		validator.endpoints(null, false);

-		validator.mgmt_endpoint_key(null);

-		validator.mgmt_endpoints(null, false);

-		assertEquals("Endpoints Data is null.\n" + "MgmtEndpoints Data is null.\n" + "MgmtEndpoints Data is null.\n",

-				validator.errs());

-	}

-

-	@Test

-	public void testEndpointsWithListContaingNull() {

-		LocateValidator validator = new LocateValidator();

-		when(endpoints.getEndpoint().size()).thenReturn(0);

-		when(me.getMgmtEndpoint().size()).thenReturn(0);

-

-		validator.endpoints(endpoints, true);

-		validator.mgmt_endpoints(me, false);

-		assertEquals("Endpoints contains no endpoints\n" + "MgmtEndpoints contains no data\n", validator.errs());

-	}

-

-	@Test

-	public void testEndpointsWithSpecialPortsNull() {

-		LocateValidator validator = new LocateValidator();

-

-		when(endpoint.getName()).thenReturn("EndPoint.Endpoint1");

-		when(endpoint.getHostname()).thenReturn("HOST1");

-		when(endpoint.getPort()).thenReturn(9090);

-		when(endpoint.getProtocol()).thenReturn("HTTP");

-		List<String> subprotocol = new ArrayList<String>();

-		when(endpoint.getSubprotocol()).thenReturn(subprotocol);

-

-		List<Endpoint> endpointList = new ArrayList<Endpoint>();

-		endpointList.add(endpoint);

-

-		when(mgmtEndpoint.getName()).thenReturn("EndPoint.Endpoint1");

-		when(mgmtEndpoint.getHostname()).thenReturn("HOST1");

-		when(mgmtEndpoint.getPort()).thenReturn(9090);

-		when(mgmtEndpoint.getProtocol()).thenReturn("HTTP");

-		List<SpecialPorts> specialPorts = new ArrayList<SpecialPorts>();

-		specialPorts.add(null);

-		when(mgmtEndpoint.getSpecialPorts()).thenReturn(specialPorts);

-		List<MgmtEndpoint> mgmtEndpoints = new ArrayList<MgmtEndpoint>();

-		mgmtEndpoints.add(mgmtEndpoint);

-

-		when(endpoints.getEndpoint()).thenReturn(endpointList);

-		when(me.getMgmtEndpoint()).thenReturn(mgmtEndpoints);

-

-		validator.endpoints(endpoints, false);

-		validator.mgmt_endpoints(me, true);

-		assertEquals("Special Ports is null.\n", validator.errs());

-	}

-

-	@Test

-	public void testEndpointsWithSpecialPorts() {

-		LocateValidator validator = new LocateValidator();

-

-		when(mgmtEndpoint.getName()).thenReturn("EndPoint.Endpoint1");

-		when(mgmtEndpoint.getHostname()).thenReturn("HOST1");

-		when(mgmtEndpoint.getPort()).thenReturn(9090);

-		when(mgmtEndpoint.getProtocol()).thenReturn("HTTP");

-

-		List<SpecialPorts> specialPorts = new ArrayList<SpecialPorts>();

-		specialPorts.add(specialPort);

-

-		when(specialPort.getName()).thenReturn("Port1");

-		when(specialPort.getProtocol()).thenReturn("HTTP");

-		when(specialPort.getPort()).thenReturn(9090);

-

-		List<String> versions = new ArrayList<String>();

-		versions.add("1");

-

-		when(specialPort.getProtocolVersions()).thenReturn(versions);

-

-		when(mgmtEndpoint.getSpecialPorts()).thenReturn(specialPorts);

-		List<MgmtEndpoint> mgmtEndpoints = new ArrayList<MgmtEndpoint>();

-		mgmtEndpoints.add(mgmtEndpoint);

-

-		when(me.getMgmtEndpoint()).thenReturn(mgmtEndpoints);

-

-		validator.endpoints(endpoints, false);

-		validator.mgmt_endpoints(me, true);

-		validator.mgmt_endpoint_key(me);

-		assertEquals(false, validator.err());

-

-	}

+    @Mock

+    private Endpoint endpoint;

+

+    @Mock(answer = Answers.RETURNS_DEEP_STUBS)

+    private Endpoints endpoints;

+    @Mock(answer = Answers.RETURNS_DEEP_STUBS)

+    private MgmtEndpoints me;

+    @Mock(answer = Answers.RETURNS_DEEP_STUBS)

+    private MgmtEndpoint mgmtEndpoint;

+    @Mock(answer = Answers.RETURNS_DEEP_STUBS)

+    private SpecialPorts specialPort;

+

+    @Before

+    public void setup() {

+        MockitoAnnotations.initMocks(this);

+    }

+

+    @Test

+    public void testNullEndPoint() {

+        LocateValidator validator = new LocateValidator();

+

+        validator.endpoint(null);

+        assertEquals("Endpoint Data is null.\n", validator.errs());

+    }

+

+    @Test

+    public void testEndPoint() {

+        LocateValidator validator = new LocateValidator();

+

+        when(endpoint.getName()).thenReturn("Endpoint1");

+        when(endpoint.getHostname()).thenReturn("HOST1");

+        when(endpoint.getPort()).thenReturn(9090);

+        when(endpoint.getProtocol()).thenReturn("HTTP");

+

+        validator.endpoint(endpoint);

+

+        assertEquals("Endpoint Name must prefixed by Namespace\n", validator.errs());

+    }

+

+    @Test

+    public void testSubProtoCol() {

+        LocateValidator validator = new LocateValidator();

+

+        List<String> subProtocol = new ArrayList<String>();

+        subProtocol.add(null);

+

+        when(endpoint.getName()).thenReturn("EndPoint.Endpoint1");

+        when(endpoint.getHostname()).thenReturn("HOST1");

+        when(endpoint.getPort()).thenReturn(9090);

+        when(endpoint.getProtocol()).thenReturn("HTTP");

+        when(endpoint.getSubprotocol()).thenReturn(subProtocol);

+

+        validator.endpoint(endpoint);

+

+        assertEquals("Endpoint Subprotocol is null.\n", validator.errs());

+    }

+

+    @Test

+    public void testNullEndpoints() {

+        LocateValidator validator = new LocateValidator();

+

+        validator.endpoints(null, false);

+        validator.mgmt_endpoint_key(null);

+        validator.mgmt_endpoints(null, false);

+        assertEquals("Endpoints Data is null.\n" + "MgmtEndpoints Data is null.\n" + "MgmtEndpoints Data is null.\n",

+                validator.errs());

+    }

+

+    @Test

+    public void testEndpointsWithListContaingNull() {

+        LocateValidator validator = new LocateValidator();

+        when(endpoints.getEndpoint().size()).thenReturn(0);

+        when(me.getMgmtEndpoint().size()).thenReturn(0);

+

+        validator.endpoints(endpoints, true);

+        validator.mgmt_endpoints(me, false);

+        assertEquals("Endpoints contains no endpoints\n" + "MgmtEndpoints contains no data\n", validator.errs());

+    }

+

+    @Test

+    public void testEndpointsWithSpecialPortsNull() {

+        LocateValidator validator = new LocateValidator();

+

+        when(endpoint.getName()).thenReturn("EndPoint.Endpoint1");

+        when(endpoint.getHostname()).thenReturn("HOST1");

+        when(endpoint.getPort()).thenReturn(9090);

+        when(endpoint.getProtocol()).thenReturn("HTTP");

+        List<String> subprotocol = new ArrayList<String>();

+        when(endpoint.getSubprotocol()).thenReturn(subprotocol);

+

+        List<Endpoint> endpointList = new ArrayList<Endpoint>();

+        endpointList.add(endpoint);

+

+        when(mgmtEndpoint.getName()).thenReturn("EndPoint.Endpoint1");

+        when(mgmtEndpoint.getHostname()).thenReturn("HOST1");

+        when(mgmtEndpoint.getPort()).thenReturn(9090);

+        when(mgmtEndpoint.getProtocol()).thenReturn("HTTP");

+        List<SpecialPorts> specialPorts = new ArrayList<SpecialPorts>();

+        specialPorts.add(null);

+        when(mgmtEndpoint.getSpecialPorts()).thenReturn(specialPorts);

+        List<MgmtEndpoint> mgmtEndpoints = new ArrayList<MgmtEndpoint>();

+        mgmtEndpoints.add(mgmtEndpoint);

+

+        when(endpoints.getEndpoint()).thenReturn(endpointList);

+        when(me.getMgmtEndpoint()).thenReturn(mgmtEndpoints);

+

+        validator.endpoints(endpoints, false);

+        validator.mgmt_endpoints(me, true);

+        assertEquals("Special Ports is null.\n", validator.errs());

+    }

+

+    @Test

+    public void testEndpointsWithSpecialPorts() {

+        LocateValidator validator = new LocateValidator();

+

+        when(mgmtEndpoint.getName()).thenReturn("EndPoint.Endpoint1");

+        when(mgmtEndpoint.getHostname()).thenReturn("HOST1");

+        when(mgmtEndpoint.getPort()).thenReturn(9090);

+        when(mgmtEndpoint.getProtocol()).thenReturn("HTTP");

+

+        List<SpecialPorts> specialPorts = new ArrayList<SpecialPorts>();

+        specialPorts.add(specialPort);

+

+        when(specialPort.getName()).thenReturn("Port1");

+        when(specialPort.getProtocol()).thenReturn("HTTP");

+        when(specialPort.getPort()).thenReturn(9090);

+

+        List<String> versions = new ArrayList<String>();

+        versions.add("1");

+

+        when(specialPort.getProtocolVersions()).thenReturn(versions);

+

+        when(mgmtEndpoint.getSpecialPorts()).thenReturn(specialPorts);

+        List<MgmtEndpoint> mgmtEndpoints = new ArrayList<MgmtEndpoint>();

+        mgmtEndpoints.add(mgmtEndpoint);

+

+        when(me.getMgmtEndpoint()).thenReturn(mgmtEndpoints);

+

+        validator.endpoints(endpoints, false);

+        validator.mgmt_endpoints(me, true);

+        validator.mgmt_endpoint_key(me);

+        assertEquals(false, validator.err());

+

+    }

 }