Renaming openecomp to onap

Issue-ID: AAI-208
Change-Id: Ib5dc63c9b2f4c580caec21414c2fafae904adca9
Signed-off-by: Arul.Nambi <arul.nambi@amdocs.com>

6 files changed, 1 insertions, 365 deletions

diff --git a/src/test/java/org/openecomp/datarouter/entity/SuggestionSearchEntityTest.java b/src/test/java/org/openecomp/datarouter/entity/SuggestionSearchEntityTest.java
index 4461bdc..6ae4a8e 100644
--- a/src/test/java/org/openecomp/datarouter/entity/SuggestionSearchEntityTest.java
+++ b/src/test/java/org/openecomp/datarouter/entity/SuggestionSearchEntityTest.java
@@ -40,7 +40,7 @@ import org.junit.Before;
 import org.junit.Test;
 import org.mockito.Mockito;
 import org.onap.aai.datarouter.entity.SuggestionSearchEntity;
-import org.openecomp.datarouter.search.filters.config.UiFiltersSchemaUtility;
+import org.onap.aai.datarouter.search.filters.config.UiFiltersSchemaUtility;
 
 public class SuggestionSearchEntityTest {
   private static SuggestionSearchEntity suggestionSearchEntity;
diff --git a/src/test/java/org/openecomp/datarouter/policy/EntityEventPolicyStubbed.java b/src/test/java/org/openecomp/datarouter/policy/EntityEventPolicyStubbed.java
deleted file mode 100644
index b36108f..0000000
--- a/src/test/java/org/openecomp/datarouter/policy/EntityEventPolicyStubbed.java
+++ /dev/null
@@ -1,34 +0,0 @@
-package org.openecomp.datarouter.policy;
-
-import java.io.FileNotFoundException;
-
-import org.onap.aai.datarouter.entity.DocumentStoreDataEntity;
-
-public class EntityEventPolicyStubbed extends EntityEventPolicy {
-	
-
-	public EntityEventPolicyStubbed(EntityEventPolicyConfig config) throws FileNotFoundException {
-		super(config);
-		
-	}
-
-	protected void handleSearchServiceOperation(DocumentStoreDataEntity eventEntity, String action, String index) {
-		//Stub out the actual call to Search Data service and instead store/update documents in memory
-		try {
-			switch (action.toLowerCase()) {
-			case "create":
-				InMemorySearchDatastore.put(eventEntity.getId(), eventEntity.getAsJson()); // they are executed if variable == c1
-				break;
-			case "update":
-				InMemorySearchDatastore.put(eventEntity.getId(), eventEntity.getAsJson()); // they are executed if variable == c1
-				break;
-			case "delete":
-				InMemorySearchDatastore.remove(eventEntity.getId()); // they are executed if variable == c1
-				break;
-			default:
-				break;
-			}
-		} catch (Exception ex) {
-		}
-	}
-}
diff --git a/src/test/java/org/openecomp/datarouter/policy/EntityEventPolicyTest.java b/src/test/java/org/openecomp/datarouter/policy/EntityEventPolicyTest.java
deleted file mode 100644
index 0d97e1d..0000000
--- a/src/test/java/org/openecomp/datarouter/policy/EntityEventPolicyTest.java
+++ /dev/null
@@ -1,79 +0,0 @@
-package org.openecomp.datarouter.policy;
-
-import static org.junit.Assert.*;
-import static org.mockito.Matchers.anyObject;
-import static org.mockito.Matchers.anyString;
-
-import java.io.File;
-import java.io.FileInputStream;
-
-import org.apache.camel.Exchange;
-import org.apache.camel.Message;
-import org.apache.commons.io.IOUtils;
-import org.junit.Before;
-import org.junit.Test;
-import org.openecomp.datarouter.util.NodeUtils;
-import org.openecomp.datarouter.util.SearchServiceAgent;
-import org.powermock.api.mockito.PowerMockito;
-
-
-
-public class EntityEventPolicyTest {
-	EntityEventPolicy policy;
-	String eventJson;
-	
-	@SuppressWarnings("unchecked")
-    @Before
-    public void init() throws Exception {
-		EntityEventPolicyConfig config = PowerMockito.mock(EntityEventPolicyConfig.class); 
-		PowerMockito.when(config.getSearchKeystorePwd()).thenReturn("password");
-		PowerMockito.when(config.getSourceDomain()).thenReturn("JUNIT");
-		
-		
-		SearchServiceAgent searchServiceAgent = PowerMockito.mock(SearchServiceAgent.class); 
-		
-		PowerMockito.whenNew(SearchServiceAgent.class).withAnyArguments().thenReturn(searchServiceAgent);
-		
-		
-		policy = new EntityEventPolicyStubbed(config);
-		FileInputStream event = new FileInputStream( new File("src/test/resources/aai_event.json"));
-		eventJson = IOUtils.toString(event, "UTF-8");
-
-	}
-
-	@Test
-	 public void testProcess() throws Exception {
-		policy.process(getExchangeEvent("event1","create"));
-		policy.process(getExchangeEvent("event2","create"));
-		
-		assertNotNull(InMemorySearchDatastore.get(NodeUtils.generateUniqueShaDigest("event1")));
-		assertNotNull(InMemorySearchDatastore.get(NodeUtils.generateUniqueShaDigest("event2")));
-		
-		policy.process(getExchangeEvent("event1","update"));
-		policy.process(getExchangeEvent("event2","update"));
-		assertNotNull(InMemorySearchDatastore.get(NodeUtils.generateUniqueShaDigest("event1")));
-		assertNotNull(InMemorySearchDatastore.get(NodeUtils.generateUniqueShaDigest("event2")));
-		
-		policy.process(getExchangeEvent("event2","delete"));
-		assertNull(InMemorySearchDatastore.get(NodeUtils.generateUniqueShaDigest("event2")));
-	}
-	
-	private Exchange getExchangeEvent(String link,String action){
-		Object obj = eventJson.replace("$LINK",link ).replace("$ACTION",action) ;
-		Exchange exchange = PowerMockito.mock(Exchange.class); 
-		Message inMessage = PowerMockito.mock(Message.class);
-		Message outMessage = PowerMockito.mock(Message.class);
-		PowerMockito.when(exchange.getIn()).thenReturn(inMessage);		
-		PowerMockito.when(inMessage.getBody()).thenReturn(obj);
-		
-		PowerMockito.when(exchange.getOut()).thenReturn(outMessage);
-		PowerMockito.doNothing().when(outMessage).setBody(anyObject());
-		PowerMockito.doNothing().when(outMessage).setHeader(anyString(), anyObject());
-		
-		return exchange;
-		
-	}
-
-	
-
-}
diff --git a/src/test/java/org/openecomp/datarouter/policy/InMemorySearchDatastore.java b/src/test/java/org/openecomp/datarouter/policy/InMemorySearchDatastore.java
deleted file mode 100644
index 4b25f6e..0000000
--- a/src/test/java/org/openecomp/datarouter/policy/InMemorySearchDatastore.java
+++ /dev/null
@@ -1,24 +0,0 @@
-package org.openecomp.datarouter.policy;
-
-import java.util.concurrent.ConcurrentHashMap;
-
-public final class InMemorySearchDatastore {
-
-	private final static ConcurrentHashMap<String, String> documents = new ConcurrentHashMap<String, String>();
-
-	public static ConcurrentHashMap<String, String> getAll() {
-		return documents;
-	}
-
-	public static void put(String key, String value) {
-		documents.put(key, value);
-	}
-
-	public static String get(String key) {
-		return documents.get(key);
-	}
-
-	public static void remove(String key) {
-		documents.remove(key);
-	}
-}
diff --git a/src/test/java/org/openecomp/datarouter/util/AaiUiSvcPolicyUtilTest.java b/src/test/java/org/openecomp/datarouter/util/AaiUiSvcPolicyUtilTest.java
deleted file mode 100644
index 5e6841f..0000000
--- a/src/test/java/org/openecomp/datarouter/util/AaiUiSvcPolicyUtilTest.java
+++ /dev/null
@@ -1,112 +0,0 @@
-/**
- * ============LICENSE_START=======================================================
- * DataRouter
- * ================================================================================
- * Copyright © 2017 AT&T Intellectual Property.
- * Copyright © 2017 Amdocs
- * 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=========================================================
- *
- * ECOMP and OpenECOMP are trademarks
- * and service marks of AT&T Intellectual Property.
- */
-
-package org.openecomp.datarouter.util;
-
-import static org.junit.Assert.assertNull;
-import static org.junit.Assert.assertTrue;
-import static org.junit.Assert.fail;
-
-import org.junit.BeforeClass;
-import org.junit.Test;
-
-import com.fasterxml.jackson.databind.JsonNode;
-import com.fasterxml.jackson.databind.ObjectMapper;
-
-public class AaiUiSvcPolicyUtilTest {
-  
-  private final static String ORIGIN_URI = "testUri/somePath";
-  private final static String ORIGIN_PAYLOAD = "test payload";
-
-  private final static String validPayload = "{" +
-        "\"origin-uri\": \"" + ORIGIN_URI + "\"," + 
-        "\"origin-payload\": \"" + ORIGIN_PAYLOAD + "\"}";
-  
-  private final static String payloadWithoutOriginUri = "{" +
-      "\"origin-payload\": \"" + ORIGIN_PAYLOAD + "\"}";
-  
-  private final static String payloadWithoutOriginPayload = "{" +
-      "\"origin-uri\": \"" + ORIGIN_URI + "\"}";
-  
-  private static JsonNode node = null;
-  private static JsonNode nodeWithoutOrginUri = null;
-  private static JsonNode nodeWithoutOrginPayload = null;
-  static ObjectMapper mapper = new ObjectMapper();
-  
-  @BeforeClass
-  public static void init(){
-    try {
-      node = mapper.readTree(validPayload);
-      nodeWithoutOrginUri = mapper.readTree(payloadWithoutOriginUri);
-      nodeWithoutOrginPayload = mapper.readTree(payloadWithoutOriginPayload);
-    } catch (Exception e) {
-      fail("Initialization error");
-    }
-  }
-  
-  @Test
-  public void testGetOriginPayload_missingPayload() {
-    JsonNode value = null;
-    try {
-      value = AaiUiSvcPolicyUtil.getOriginPayload(nodeWithoutOrginPayload);
-      assertNull("Failure to extract origin payload", value);
-    } catch (Exception e) {
-      fail("Failure to extract origin payload");
-    }
-  }
-
-  @Test
-  public void testGetOriginPayload_validPayload() {
-    JsonNode value = null;
-    try {
-      value = AaiUiSvcPolicyUtil.getOriginPayload(node);
-      assertTrue("Failure to extract origin payload", ORIGIN_PAYLOAD.equals(value.asText()));
-    } catch (Exception e) {
-      fail("Failure to extract origin payload");
-    }
-  }
-  
-  @Test
-  public void testGetOriginUri_missingUri() {
-    String value = null;
-    try {
-      value = AaiUiSvcPolicyUtil.getOriginUri(nodeWithoutOrginUri);
-      assertTrue("Failure to extract origin uri", value.isEmpty());
-    } catch (Exception e) {
-      fail("Failure to extract origin uri");
-    }
-  }
-
-  @Test
-  public void testGetOriginUri_validPayload() {
-    String value = null;
-    try {
-      value = AaiUiSvcPolicyUtil.getOriginUri(node);
-      assertTrue("Failure to extract origin uri", ORIGIN_URI.equals(value));
-    } catch (Exception e) {
-      fail("Failure to extract origin uri");
-    }
-  }
-}
diff --git a/src/test/java/org/openecomp/datarouter/util/client/NoAuthRestClientTest.java b/src/test/java/org/openecomp/datarouter/util/client/NoAuthRestClientTest.java
deleted file mode 100644
index 160981d..0000000
--- a/src/test/java/org/openecomp/datarouter/util/client/NoAuthRestClientTest.java
+++ /dev/null
@@ -1,115 +0,0 @@
-/**
- * ============LICENSE_START=======================================================
- * DataRouter
- * ================================================================================
- * Copyright © 2017 AT&T Intellectual Property.
- * Copyright © 2017 Amdocs
- * 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=========================================================
- *
- * ECOMP and OpenECOMP are trademarks
- * and service marks of AT&T Intellectual Property.
- */
-
-package org.openecomp.datarouter.util.client;
-
-import static org.junit.Assert.assertEquals;
-import static org.junit.Assert.fail;
-
-import javax.ws.rs.core.MediaType;
-
-import org.apache.camel.CamelContext;
-import org.apache.camel.Exchange;
-import org.apache.camel.impl.DefaultCamelContext;
-import org.apache.camel.impl.DefaultExchange;
-import org.junit.Before;
-import org.junit.Test;
-import org.mockito.Mockito;
-import org.onap.aai.restclient.client.OperationResult;
-import org.onap.aai.restclient.client.RestClient;
-
-public class NoAuthRestClientTest {
-
-  RestClient client = null;
-  OperationResult successResult = null;
-  OperationResult failureResult = null;
-  Exchange exchange = null;
-  NoAuthRestClient narc = new NoAuthRestClient(60,60);
-  String goodDomain = "AGoodUrlThatNeverFails.com";
-  String badDomain = "ABadUrlThatAlwaysFails.com";
-  String goodTargetUrl = "http://" + goodDomain + ":1234/servicegraph";
-  String badTargetUrl = "http://" + badDomain + ":1234/servicegraph";
-  String payload = "{\"origin-uri\":\"/routerService/servicegraph\","
-      + "\"origin-payload\":{\"hashId\":\"claymore-sdwan-service.full.(View and Inspect)\"}}";
-  
-  String successResponsePayload = "very-good-result";
-  String failureResponsePayload = "Server Error";
-  
-  @SuppressWarnings("unchecked")
-  @Before
-  public void init(){
-    client = Mockito.mock(RestClient.class);
-    successResult = new OperationResult(200, successResponsePayload);
-    failureResult = new OperationResult(500, failureResponsePayload);
-    failureResult.setFailureCause(failureResponsePayload);
-    Mockito.when(client.post(Mockito.eq(goodTargetUrl), Mockito.anyString(), Mockito.anyMap(), 
-        Mockito.eq(MediaType.APPLICATION_JSON_TYPE), Mockito.eq(MediaType.APPLICATION_JSON_TYPE)))
-    .thenReturn(successResult);
-    Mockito.when(client.post(Mockito.eq(badTargetUrl), Mockito.anyString(), Mockito.anyMap(), 
-        Mockito.eq(MediaType.APPLICATION_JSON_TYPE), Mockito.eq(MediaType.APPLICATION_JSON_TYPE)))
-    .thenReturn(failureResult);
-    narc.setRestClient(client);
-
-  }
-  
-  public Exchange getExchange(){
-    CamelContext ctx = new DefaultCamelContext(); 
-    Exchange ex = new DefaultExchange(ctx);
-    ex.getIn().setHeader(Exchange.HTTP_URL, "http://ARandomOrigin.com");
-    ex.getIn().setBody(payload);
-    return ex;
-  }
-  
-  @Test
-  public void testHandleRequest_successScenario() {
-    Exchange ex = getExchange();
-    try {
-      narc.handleRequest(goodDomain, "1234", ex);
-      String outBody = ex.getOut().getBody(String.class);
-      assertEquals("Routing success scenario: Failure to get correct http status.", 
-          ex.getOut().getHeader(Exchange.HTTP_RESPONSE_CODE), 200 );
-      assertEquals("Routing success scenario: Failure to get response body.", 
-          outBody, successResponsePayload);
-    } catch (Exception e) {
-      fail("Routing success scenario: Failure to process.");
-    }
-  }
-  
-  @Test
-  public void testHandleRequest_failureScenario() {
-    Exchange ex = getExchange();
-    try {
-      narc.handleRequest(badDomain, "1234", ex);
-      String outBody = ex.getOut().getBody(String.class);
-      assertEquals("Routing failure scenario: Failure to get correct http status.", 
-          ex.getOut().getHeader(Exchange.HTTP_RESPONSE_CODE), 500 );
-      assertEquals("Routing failure scenario: Failure to get response body.", 
-          outBody, failureResult.getFailureCause());
-    } catch (Exception e) {
-      fail("Routing failure scenario: Failure to process.");
-    }
-  }
-
-}