router-core 1.3.0 changes

Issue-ID: AAI-1670
Change-Id: Id42ece47c5c5972b471576f9c5f7fb2614196512
Signed-off-by: rv871f <richard.vondadelszen@amdocs.com>

8 files changed, 203 insertions, 150 deletions

diff --git a/src/main/java/org/onap/aai/datarouter/policy/AbstractSpikeEntityEventProcessor.java b/src/main/java/org/onap/aai/datarouter/policy/AbstractSpikeEntityEventProcessor.java
index 50d344b..9f96a22 100644
--- a/src/main/java/org/onap/aai/datarouter/policy/AbstractSpikeEntityEventProcessor.java
+++ b/src/main/java/org/onap/aai/datarouter/policy/AbstractSpikeEntityEventProcessor.java
@@ -26,7 +26,6 @@ import java.security.NoSuchAlgorithmException;
 import java.util.ArrayList;
 import java.util.Arrays;
 import java.util.Collection;
-import java.util.Collections;
 import java.util.HashMap;
 import java.util.Iterator;
 import java.util.List;
@@ -59,6 +58,7 @@ import org.onap.aai.util.VersionedOxmEntities;
 import org.onap.aai.restclient.client.Headers;
 import org.onap.aai.restclient.client.OperationResult;
 import org.onap.aai.restclient.rest.HttpUtil;
+import org.onap.aai.setup.SchemaVersions;
 import org.slf4j.MDC;
 
 import com.fasterxml.jackson.core.JsonProcessingException;
@@ -109,8 +109,7 @@ public abstract class AbstractSpikeEntityEventProcessor implements Processor {
   protected Logger logger;
   protected Logger metricsLogger;
   protected ObjectMapper mapper;
-
-
+  
   public AbstractSpikeEntityEventProcessor(SpikeEventPolicyConfig config)
       throws FileNotFoundException {
     mapper = new ObjectMapper();
@@ -128,7 +127,7 @@ public abstract class AbstractSpikeEntityEventProcessor implements Processor {
     this.externalOxmModelProcessors = new ArrayList<>();
     this.externalOxmModelProcessors.add(EntityOxmReferenceHelper.getInstance());
     OxmModelLoader.registerExternalOxmModelProcessors(externalOxmModelProcessors);
-    OxmModelLoader.loadModels();
+    OxmModelLoader.loadModels(config.getSchemaVersions(), config.getSchemaLocationsBean());
     oxmVersionContextMap = OxmModelLoader.getVersionContextMap();
     parseLatestOxmVersion();
   }
@@ -906,21 +905,4 @@ public abstract class AbstractSpikeEntityEventProcessor implements Processor {
 
   }
   
-  protected List<String> extractSuggestableAttr(VersionedOxmEntities oxmEntities, String entityType) {
-    // Extract suggestable attributeshandleTopographicalData
-    Map<String, OxmEntityDescriptor> rootDescriptor = oxmEntities.getSuggestableEntityDescriptors();
-
-    if (rootDescriptor == null) {
-      return Collections.emptyList();
-    }
-
-    OxmEntityDescriptor desc = rootDescriptor.get(entityType);
-
-    if (desc == null) {
-      return Collections.emptyList();
-    }
-
-    return desc.getSuggestableAttributes();
-  }
-  
 }
diff --git a/src/main/java/org/onap/aai/datarouter/policy/EntityEventPolicy.java b/src/main/java/org/onap/aai/datarouter/policy/EntityEventPolicy.java
index b6b7fd8..6660a79 100644
--- a/src/main/java/org/onap/aai/datarouter/policy/EntityEventPolicy.java
+++ b/src/main/java/org/onap/aai/datarouter/policy/EntityEventPolicy.java
@@ -56,6 +56,7 @@ import org.onap.aai.util.CrossEntityReference;
 import org.onap.aai.util.EntityOxmReferenceHelper;
 import org.onap.aai.util.ExternalOxmModelProcessor;
 import org.onap.aai.schema.OxmModelLoader;
+import org.onap.aai.setup.SchemaVersions;
 import org.onap.aai.util.Version;
 import org.onap.aai.util.VersionedOxmEntities;
 import org.onap.aai.cl.api.Logger;
@@ -96,16 +97,16 @@ public class EntityEventPolicy implements Processor {
 
   /** Agent for communicating with the Search Service. */
   private SearchServiceAgent searchAgent = null;
-
+  
   /** Search index name for storing AAI event entities. */
   private String entitySearchIndex;
 
   /** Search index name for storing topographical search data. */
   private String topographicalSearchIndex;
-
+  
   /** Search index name for suggestive search data. */
   private String aggregateGenericVnfIndex;
-
+  
   private String autosuggestIndex;
 
   private String srcDomain;
@@ -130,7 +131,7 @@ public class EntityEventPolicy implements Processor {
     topographicalSearchIndex = config.getSearchTopographySearchIndex();
     aggregateGenericVnfIndex = config.getSearchAggregationVnfIndex();
     autosuggestIndex		 = config.getSearchEntityAutoSuggestIndex();
-
+       
     // Instantiate the agent that we will use for interacting with the Search Service.
     searchAgent = new SearchServiceAgent(config.getSearchCertName(),
                                          config.getSearchKeystore(),
@@ -143,7 +144,7 @@ public class EntityEventPolicy implements Processor {
     this.externalOxmModelProcessors = new ArrayList<>();
     this.externalOxmModelProcessors.add(EntityOxmReferenceHelper.getInstance());
     OxmModelLoader.registerExternalOxmModelProcessors(externalOxmModelProcessors);
-    OxmModelLoader.loadModels();
+    OxmModelLoader.loadModels(config.getSchemaVersions(), config.getSchemaLocationsBean());
     oxmVersionContextMap = OxmModelLoader.getVersionContextMap();
     parseLatestOxmVersion();
   }
@@ -171,11 +172,11 @@ public class EntityEventPolicy implements Processor {
   }
 
   public void startup() {
-
+    
     // Create the indexes in the search service if they do not already exist.
     searchAgent.createSearchIndex(entitySearchIndex, ENTITY_SEARCH_SCHEMA);
     searchAgent.createSearchIndex(topographicalSearchIndex, TOPOGRAPHICAL_SEARCH_SCHEMA);
-
+    
     logger.info(EntityEventPolicyMsgs.ENTITY_EVENT_POLICY_REGISTERED);
   }
 
@@ -207,7 +208,7 @@ public class EntityEventPolicy implements Processor {
     logger.debug(EntityEventPolicyMsgs.DISCARD_EVENT_VERBOSE, errorMsg, payload);
     setResponse(exchange, ResponseType.FAILURE, additionalInfo);
   }
-
+  
   @Override
   public void process(Exchange exchange) throws Exception {
 
@@ -215,7 +216,7 @@ public class EntityEventPolicy implements Processor {
 
     String uebPayload = exchange.getIn().getBody().toString();
 
-    JsonNode uebAsJson =null;
+    JsonNode uebAsJson = null;
     ObjectMapper mapper = new ObjectMapper();
     try{
       uebAsJson = mapper.readTree(uebPayload);
@@ -230,7 +231,7 @@ public class EntityEventPolicy implements Processor {
       returnWithError(exchange, uebPayload, "Payload is missing " + EVENT_HEADER);
       return;
     }
-
+    
     JSONObject uebObjEntity = getUebContentAsJson(uebPayload, ENTITY_HEADER);
     if (uebObjEntity == null) {
       returnWithError(exchange, uebPayload, "Payload is missing " + ENTITY_HEADER);
@@ -392,14 +393,14 @@ public class EntityEventPolicy implements Processor {
      * NOTES:
      * 1. If the entity type is "customer", the below check will return true if any nested entityType
      * in that model could contain a CER based on the OXM model version that has been loaded.
-     * 2. For a DELETE operation on outer/parent entity (handled by the regular flow:
+     * 2. For a DELETE operation on outer/parent entity (handled by the regular flow: 
      * handleSearchServiceOperation()), ignore processing for cross-entity-reference under the
      * assumption that AAI will push down all required cascade-deletes for nested entities as well
      * 3. Handling the case where UEB events arrive out of order: CREATE customer is received before
      *  CREATE service-instance.
      */
 
-    if (!action.equalsIgnoreCase(ACTION_DELETE) && oxmEntities != null
+    if (!action.equalsIgnoreCase(ACTION_DELETE) && oxmEntities != null 
         && oxmEntities.entityModelContainsCrossEntityReference(topEntityType)) {
 
       // We know the model "can" contain a CER reference definition, let's process a bit more
@@ -409,116 +410,122 @@ public class EntityEventPolicy implements Processor {
 
       JSONObject entityJsonObject = getUebEntity(uebPayload);
 
-      if (entityJsonObject != null) {
-          JsonNode entityJsonNode = convertToJsonNode(entityJsonObject.toString());
-
-          String parentEntityType = entityType;
-
-          String targetEntityUrl = entityLink;
+      JsonNode entityJsonNode = convertToJsonNode(entityJsonObject.toString());
+      
+      String parentEntityType = entityType;
+      
+      String targetEntityUrl = entityLink;
 
-          for (Map.Entry<String, CrossEntityReference> entry : crossEntityRefMap.entrySet()) {
+      for (Map.Entry<String, CrossEntityReference> entry : crossEntityRefMap.entrySet()) {
 
-              /*
-               * if we know service-subscription is in the tree, then we can pull our all instances and process
-               * from there.
-               */
-
-              String key = entry.getKey();
-              CrossEntityReference cerDescriptor = entry.getValue();
-
-              ArrayList<JsonNode> foundNodes = new ArrayList<>();
+        /*
+         * if we know service-subscription is in the tree, then we can pull our all instances and
+         * process from there.
+         */
 
-              RouterServiceUtil.extractObjectsByKey(entityJsonNode, key, foundNodes);
+        String key = entry.getKey();
+        CrossEntityReference cerDescriptor = entry.getValue();
 
-              if (!foundNodes.isEmpty()) {
+        ArrayList<JsonNode> foundNodes = new ArrayList<>();
 
-                  for (JsonNode n : foundNodes) {
-                      if ("customer".equalsIgnoreCase(parentEntityType)) {
-                          /*
-                           * NOTES: 1. prepare to hand-create url for service-instance 2. this will break if the
-                           * URL structure for service-instance changes
-                           */
-                          if (n.has("service-type")) {
-                              targetEntityUrl += "/service-subscriptions/service-subscription/"
-                                      + RouterServiceUtil.getNodeFieldAsText(n, "service-type")
-                                      + "/service-instances/service-instance/";
-                          }
-                      }
+        RouterServiceUtil.extractObjectsByKey(entityJsonNode, key, foundNodes);
 
-                      List<String> extractedParentEntityAttributeValues = new ArrayList<>();
+        if (!foundNodes.isEmpty()) {
 
-                      RouterServiceUtil.extractFieldValuesFromObject(n, cerDescriptor.getAttributeNames(),
-                              extractedParentEntityAttributeValues);
+          for (JsonNode n : foundNodes) {
+            if ("customer".equalsIgnoreCase(parentEntityType)){  
+              /*
+               * NOTES:
+               * 1. prepare to hand-create url for service-instance
+               * 2. this will break if the URL structure for service-instance changes
+               */
+              if (n.has("service-type")){
+                targetEntityUrl += "/service-subscriptions/service-subscription/" 
+                    + RouterServiceUtil.getNodeFieldAsText(n, "service-type") 
+                    + "/service-instances/service-instance/";
+              }
+              
+            }
 
-                      List<JsonNode> nestedTargetEntityInstances = new ArrayList<>();
-                      RouterServiceUtil.extractObjectsByKey(n, cerDescriptor.getTargetEntityType(),
-                                    nestedTargetEntityInstances);
+            List<String> extractedParentEntityAttributeValues = new ArrayList<>();
 
-                      for (JsonNode targetEntityInstance : nestedTargetEntityInstances) {
-                          /*
-                           * Now: 1. build the AAIEntityType (IndexDocument) based on the extract entity 2. Get
-                           * data from ES 3. Extract ETAG 4. Merge ES Doc + AAIEntityType + Extracted Parent
-                           * Cross-Entity-Reference Values 5. Put data into ES with ETAG + updated doc
-                           */
+            RouterServiceUtil.extractFieldValuesFromObject(n, cerDescriptor.getAttributeNames(),
+                extractedParentEntityAttributeValues);
 
-                          // Get the complete URL for target entity
-                          if (targetEntityInstance.has("link")) { // nested SI has url mentioned
-                              targetEntityUrl = RouterServiceUtil.getNodeFieldAsText(targetEntityInstance, "link");
-                          } else if ("customer".equalsIgnoreCase(parentEntityType) && targetEntityInstance.has("service-instance-id")) {
-                                    targetEntityUrl += RouterServiceUtil.getNodeFieldAsText(targetEntityInstance, "service-instance-id");
-                          }
+            List<JsonNode> nestedTargetEntityInstances = new ArrayList<>();
+            RouterServiceUtil.extractObjectsByKey(n, cerDescriptor.getTargetEntityType(),
+                nestedTargetEntityInstances);
 
-                          OxmEntityDescriptor searchableDescriptor = oxmEntities.getSearchableEntityDescriptor(cerDescriptor.getTargetEntityType());
+            for (JsonNode targetEntityInstance : nestedTargetEntityInstances) {
+              /*
+               * Now: 
+               * 1. build the AAIEntityType (IndexDocument) based on the extract entity 
+               * 2. Get data from ES
+               * 3. Extract ETAG 
+               * 4. Merge ES Doc + AAIEntityType + Extracted Parent Cross-Entity-Reference Values
+               * 5. Put data into ES with ETAG + updated doc 
+               */
 
-                          if (searchableDescriptor != null) {
+              // Get the complete URL for target entity
+              if (targetEntityInstance.has("link")) {   // nested SI has url mentioned
+                targetEntityUrl = RouterServiceUtil.getNodeFieldAsText(targetEntityInstance, 
+                    "link");
+              } else if ("customer".equalsIgnoreCase(parentEntityType) && 
+                  targetEntityInstance.has("service-instance-id")){
+                targetEntityUrl += RouterServiceUtil.getNodeFieldAsText(targetEntityInstance, 
+                    "service-instance-id");
+              }
+                    
+              OxmEntityDescriptor searchableDescriptor =
+                  oxmEntities.getSearchableEntityDescriptor(cerDescriptor.getTargetEntityType());
 
-                              if (!searchableDescriptor.getSearchableAttributes().isEmpty()) {
+              if (searchableDescriptor != null) {
 
-                                  AaiEventEntity entityToSync = null;
+                if (!searchableDescriptor.getSearchableAttributes().isEmpty()) {
 
-                                  try {
+                  AaiEventEntity entityToSync = null;
 
-                                      entityToSync = getPopulatedEntity(targetEntityInstance, searchableDescriptor);
+                  try {
 
-                                      /*
-                                       * Ready to do some ElasticSearch ops
-                                       */
+                    entityToSync = getPopulatedEntity(targetEntityInstance, searchableDescriptor);
 
-                                      for (String parentCrossEntityReferenceAttributeValue : extractedParentEntityAttributeValues) {
-                                          entityToSync.addCrossEntityReferenceValue(parentCrossEntityReferenceAttributeValue);
-                                      }
+                    /*
+                     * Ready to do some ElasticSearch ops
+                     */
 
-                                      entityToSync.setLink(targetEntityUrl);
-                                      entityToSync.deriveFields();
+                    for (String parentCrossEntityReferenceAttributeValue : extractedParentEntityAttributeValues) {
+                      entityToSync
+                          .addCrossEntityReferenceValue(parentCrossEntityReferenceAttributeValue);
+                    }
 
-                                      updateCerInEntity(entityToSync);
+                    entityToSync.setLink(targetEntityUrl);
+                    entityToSync.deriveFields();
 
-                                  } catch (NoSuchAlgorithmException e) {
-                                      logger.debug(e.getMessage());
-                                  }
-                              }
-                          } else {
-                              logger.debug(EntityEventPolicyMsgs.CROSS_ENTITY_REFERENCE_SYNC,
-                                      "failure to find searchable descriptor for type "
-                                              + cerDescriptor.getTargetEntityType());
-                          }
-                      }
+                    updateCerInEntity(entityToSync);
 
+                  } catch (NoSuchAlgorithmException e) {
+                    logger.debug(e.getMessage());
                   }
-
+                }
               } else {
-                  logger.debug(EntityEventPolicyMsgs.CROSS_ENTITY_REFERENCE_SYNC,
-                          "failed to find 0 instances of cross-entity-reference with entity " + key);
+                logger.debug(EntityEventPolicyMsgs.CROSS_ENTITY_REFERENCE_SYNC,
+                    "failure to find searchable descriptor for type "
+                        + cerDescriptor.getTargetEntityType());
               }
+            }
 
           }
-      } else {
-          logger.info(EntityEventPolicyMsgs.FAILED_TO_PARSE_UEB_PAYLOAD, "Unable to get UEB object");
+
+        } else {
+          logger.debug(EntityEventPolicyMsgs.CROSS_ENTITY_REFERENCE_SYNC,
+              "failed to find 0 instances of cross-entity-reference with entity " + key);
+        }
+
       }
 
     } else {
-        logger.info(EntityEventPolicyMsgs.CROSS_ENTITY_REFERENCE_SYNC, "skipped due to OXM model for "
-                + topEntityType + " does not contain a cross-entity-reference entity");
+      logger.info(EntityEventPolicyMsgs.CROSS_ENTITY_REFERENCE_SYNC, "skipped due to OXM model for "
+          + topEntityType + " does not contain a cross-entity-reference entity");
     }
 
     /*
@@ -603,7 +610,7 @@ public class EntityEventPolicy implements Processor {
     }
 
     OxmEntityDescriptor desc = rootDescriptor.get(entityType);
-
+    
     if (desc == null) {
       return Collections.emptyList();
     }
@@ -878,11 +885,11 @@ public class EntityEventPolicy implements Processor {
 
       if (HttpUtil.isHttpResponseClassSuccess(storedEntity.getResultCode())) {
         /*
-         * NOTES: aaiEventEntity (ie the nested entity) may contain a subset of properties of
-         * the pre-existing object,
+         * NOTES: aaiEventEntity (ie the nested entity) may contain a subset of properties of 
+         * the pre-existing object, 
          * so all we want to do is update the CER on the pre-existing object (if needed).
          */
-
+        
         List<String> etag = storedEntity.getHeaders().get(Headers.ETAG);
 
         if (etag != null && !etag.isEmpty()) {
@@ -891,7 +898,7 @@ public class EntityEventPolicy implements Processor {
           logger.error(EntityEventPolicyMsgs.NO_ETAG_AVAILABLE_FAILURE,
                   entitySearchIndex, entityId);
         }
-
+        
         ArrayList<JsonNode> sourceObject = new ArrayList<>();
         NodeUtils.extractObjectsByKey(
             NodeUtils.convertJsonStrToJsonNode(storedEntity.getResult()),
@@ -899,7 +906,7 @@ public class EntityEventPolicy implements Processor {
 
         if (!sourceObject.isEmpty()) {
           JsonNode node = sourceObject.get(0);
-          final String sourceCer = NodeUtils.extractFieldValueFromObject(node,
+          final String sourceCer = NodeUtils.extractFieldValueFromObject(node, 
               "crossEntityReferenceValues");
           String newCer = aaiEventEntity.getCrossReferenceEntityValues();
           boolean hasNewCer = true;
@@ -910,7 +917,7 @@ public class EntityEventPolicy implements Processor {
               hasNewCer = false;
             }
           }
-
+          
           if (hasNewCer){
             // Do the PUT with new CER
             ((ObjectNode)node).put("crossEntityReferenceValues", newCer);
@@ -937,13 +944,13 @@ public class EntityEventPolicy implements Processor {
   /**
    * Perform create, read, update or delete (CRUD) operation on search engine's suggestive search
    * index
-   *
+   * 
    * @param eventEntity Entity/data to use in operation
    * @param action The operation to perform
    * @param target Resource to perform the operation on
    * @param allowDeleteEvent Allow delete operation to be performed on resource
    */
-  protected void handleSearchServiceOperation(DocumentStoreDataEntity eventEntity,
+  protected void handleSearchServiceOperation(DocumentStoreDataEntity eventEntity, 
                                             String                  action,
                                             String                  index) {
     try {
@@ -977,7 +984,7 @@ public class EntityEventPolicy implements Processor {
       } else if (action.equalsIgnoreCase(ACTION_CREATE)) {
         // Write the entry to the search service.
         searchAgent.postDocument(index, eventEntity.getAsJson(), headers);
-
+        
       } else if (action.equalsIgnoreCase(ACTION_DELETE)) {
         // Run the GET to retrieve the ETAG from the search service
         OperationResult storedEntity = searchAgent.getDocument(index, entityId);
@@ -991,7 +998,7 @@ public class EntityEventPolicy implements Processor {
             logger.error(EntityEventPolicyMsgs.NO_ETAG_AVAILABLE_FAILURE, index,
                 entityId);
           }
-
+          
           /*
            * The Spring-Boot version of the search-data-service rejects the DELETE operation unless
            * we specify a Content-Type.
@@ -1063,7 +1070,7 @@ public class EntityEventPolicy implements Processor {
   // put this here until we find a better spot
   /**
    * Helper utility to concatenate substrings of a URI together to form a proper URI.
-   *
+   * 
    * @param suburis the list of substrings to concatenate together
    * @return the concatenated list of substrings
    */
diff --git a/src/main/java/org/onap/aai/datarouter/policy/EntityEventPolicyConfig.java b/src/main/java/org/onap/aai/datarouter/policy/EntityEventPolicyConfig.java
index 826a419..ec45b74 100644
--- a/src/main/java/org/onap/aai/datarouter/policy/EntityEventPolicyConfig.java
+++ b/src/main/java/org/onap/aai/datarouter/policy/EntityEventPolicyConfig.java
@@ -20,6 +20,9 @@
  */
 package org.onap.aai.datarouter.policy;
 
+import org.onap.aai.setup.SchemaLocationsBean;
+import org.onap.aai.setup.SchemaVersions;
+
 public class EntityEventPolicyConfig {
 
   private String sourceDomain;
@@ -33,6 +36,8 @@ public class EntityEventPolicyConfig {
   private String searchCertName;
   private String searchKeystorePwd;
   private String searchKeystore;
+  private SchemaVersions schemaVersions;
+  private SchemaLocationsBean schemaLocationsBean;
 
   
   public String getSourceDomain() {
@@ -122,4 +127,20 @@ public class EntityEventPolicyConfig {
   public void setSearchAggregationVnfIndex(String searchAggregationVnfIndex) {
       this.searchAggregationVnfIndex = searchAggregationVnfIndex;
   }
+  
+  public SchemaVersions getSchemaVersions() {
+    return schemaVersions;
+  }
+  
+  public void setSchemaVersions(SchemaVersions schemaVersions) {
+    this.schemaVersions = schemaVersions;
+  }
+  
+  public SchemaLocationsBean getSchemaLocationsBean() {
+    return schemaLocationsBean;
+  }
+  
+  public void setSchemaLocationsBean(SchemaLocationsBean schemaLocationsBean) {
+    this.schemaLocationsBean = schemaLocationsBean;
+  }
 }
diff --git a/src/main/java/org/onap/aai/datarouter/policy/SpikeAggregateGenericVnfProcessor.java b/src/main/java/org/onap/aai/datarouter/policy/SpikeAggregateGenericVnfProcessor.java
index c723d2b..b1a5a87 100644
--- a/src/main/java/org/onap/aai/datarouter/policy/SpikeAggregateGenericVnfProcessor.java
+++ b/src/main/java/org/onap/aai/datarouter/policy/SpikeAggregateGenericVnfProcessor.java
@@ -21,16 +21,12 @@
 package org.onap.aai.datarouter.policy;
 
 import java.io.FileNotFoundException;
-import java.util.ArrayList;
 import java.util.List;
 
 import org.apache.camel.Exchange;
 import org.onap.aai.datarouter.entity.SpikeAggregationEntity;
 import org.onap.aai.datarouter.entity.SpikeEventMeta;
 import org.onap.aai.datarouter.logging.EntityEventPolicyMsgs;
-import org.onap.aai.util.EntityOxmReferenceHelper;
-import org.onap.aai.util.Version;
-import org.onap.aai.util.VersionedOxmEntities;
 
 import com.fasterxml.jackson.databind.JsonNode;
 
@@ -49,36 +45,25 @@ public class SpikeAggregateGenericVnfProcessor extends AbstractSpikeEntityEventP
     // Create the indexes in the search service if they do not already exist.
     searchAgent.createSearchIndex(searchIndexName, searchIndexSchema, createIndexUrl);
     logger.info(EntityEventPolicyMsgs.ENTITY_EVENT_POLICY_REGISTERED);
-    
   }
-  
+
   @Override
   public void process(Exchange exchange) throws Exception {
 
     long startTime = System.currentTimeMillis();
 
     SpikeEventMeta meta = processSpikeEvent(exchange);
-    
+
     if (meta == null) {
       return;
     }
 
     String oxmEntityType = getOxmEntityType(meta.getSpikeEventVertex().getType());
-    
-    VersionedOxmEntities oxmEntities =
-        EntityOxmReferenceHelper.getInstance().getVersionedOxmEntities(Version.valueOf(oxmVersion.toLowerCase()));
-    
-    List<String> suggestibleAttrInPayload = new ArrayList<>();
-    List<String> suggestibleAttrInOxm = extractSuggestableAttr(oxmEntities, meta.getSpikeEventVertex().getType());
-    if (suggestibleAttrInOxm != null) {
-      for (String attr: suggestibleAttrInOxm){
-        if (meta.getVertexProperties().has(attr)) {
-          suggestibleAttrInPayload.add(attr);
-        }
-      }
-    }
 
-    if (suggestibleAttrInPayload.isEmpty()) {
+    List<String> searchableAttr = getSearchableAttibutes(meta.getOxmJaxbContext(), oxmEntityType,
+        meta.getSpikeEventVertex().getType(), meta.getEventEntity().toString(), exchange);
+
+    if (searchableAttr == null) {
       return;
     }
 
diff --git a/src/main/java/org/onap/aai/datarouter/policy/SpikeAutosuggestIndexProcessor.java b/src/main/java/org/onap/aai/datarouter/policy/SpikeAutosuggestIndexProcessor.java
index c101425..b2f9202 100644
--- a/src/main/java/org/onap/aai/datarouter/policy/SpikeAutosuggestIndexProcessor.java
+++ b/src/main/java/org/onap/aai/datarouter/policy/SpikeAutosuggestIndexProcessor.java
@@ -141,6 +141,23 @@ public class SpikeAutosuggestIndexProcessor extends AbstractSpikeEntityEventProc
     return;
   }
  
+  public List<String> extractSuggestableAttr(VersionedOxmEntities oxmEntities, String entityType) {
+    // Extract suggestable attributeshandleTopographicalData
+    Map<String, OxmEntityDescriptor> rootDescriptor = oxmEntities.getSuggestableEntityDescriptors();
+
+    if (rootDescriptor == null) {
+      return Collections.emptyList();
+    }
+
+    OxmEntityDescriptor desc = rootDescriptor.get(entityType);
+
+    if (desc == null) {
+      return Collections.emptyList();
+    }
+
+    return desc.getSuggestableAttributes();
+  }
+
 
   public List<String> extractAliasForSuggestableEntity(VersionedOxmEntities oxmEntities,
       String entityType) {
diff --git a/src/main/java/org/onap/aai/datarouter/policy/SpikeEntityEventPolicy.java b/src/main/java/org/onap/aai/datarouter/policy/SpikeEntityEventPolicy.java
index 9826743..649fe6b 100644
--- a/src/main/java/org/onap/aai/datarouter/policy/SpikeEntityEventPolicy.java
+++ b/src/main/java/org/onap/aai/datarouter/policy/SpikeEntityEventPolicy.java
@@ -53,6 +53,7 @@ import org.onap.aai.entity.OxmEntityDescriptor;
 import org.onap.aai.util.EntityOxmReferenceHelper;
 import org.onap.aai.util.ExternalOxmModelProcessor;
 import org.onap.aai.schema.OxmModelLoader;
+import org.onap.aai.setup.SchemaVersions;
 import org.onap.aai.restclient.client.Headers;
 import org.onap.aai.restclient.client.OperationResult;
 import org.onap.aai.restclient.rest.HttpUtil;
@@ -112,7 +113,7 @@ public class SpikeEntityEventPolicy implements Processor {
 
   private Logger logger;
   private Logger metricsLogger;
-
+  
   public enum ResponseType {
     SUCCESS, PARTIAL_SUCCESS, FAILURE;
   };
@@ -137,7 +138,7 @@ public class SpikeEntityEventPolicy implements Processor {
     this.externalOxmModelProcessors = new ArrayList<>();
     this.externalOxmModelProcessors.add(EntityOxmReferenceHelper.getInstance());
     OxmModelLoader.registerExternalOxmModelProcessors(externalOxmModelProcessors);
-    OxmModelLoader.loadModels();
+    OxmModelLoader.loadModels(config.getSchemaVersions(), config.getSchemaLocationsBean());
     oxmVersionContextMap = OxmModelLoader.getVersionContextMap();
     parseLatestOxmVersion();
   }
diff --git a/src/main/java/org/onap/aai/datarouter/policy/SpikeEntityEventPolicyConfig.java b/src/main/java/org/onap/aai/datarouter/policy/SpikeEntityEventPolicyConfig.java
index 0005119..cc90e89 100644
--- a/src/main/java/org/onap/aai/datarouter/policy/SpikeEntityEventPolicyConfig.java
+++ b/src/main/java/org/onap/aai/datarouter/policy/SpikeEntityEventPolicyConfig.java
@@ -20,6 +20,9 @@
  */
 package org.onap.aai.datarouter.policy;
 
+import org.onap.aai.setup.SchemaLocationsBean;
+import org.onap.aai.setup.SchemaVersions;
+
 public class SpikeEntityEventPolicyConfig {
 
   private String sourceDomain;
@@ -30,7 +33,8 @@ public class SpikeEntityEventPolicyConfig {
   private String searchCertName;
   private String searchKeystorePwd;
   private String searchKeystore;
-
+  private SchemaVersions schemaVersions;
+  private SchemaLocationsBean schemaLocationsBean;
   
   public String getSourceDomain() {
     return sourceDomain;
@@ -94,4 +98,20 @@ public class SpikeEntityEventPolicyConfig {
   public void setSearchKeystorePwd(String searchKeystorePwd) {
     this.searchKeystorePwd = searchKeystorePwd;
   } 
+  
+  public SchemaVersions getSchemaVersions() {
+    return schemaVersions;
+  }
+  
+  public void setSchemaVersions(SchemaVersions schemaVersions) {
+    this.schemaVersions = schemaVersions;
+  }
+  
+  public SchemaLocationsBean getSchemaLocationsBean() {
+    return schemaLocationsBean;
+  }
+  
+  public void setSchemaLocationsBean(SchemaLocationsBean schemaLocationsBean) {
+    this.schemaLocationsBean = schemaLocationsBean;
+  }
 }
diff --git a/src/main/java/org/onap/aai/datarouter/policy/SpikeEventPolicyConfig.java b/src/main/java/org/onap/aai/datarouter/policy/SpikeEventPolicyConfig.java
index 55db200..6c4fb95 100644
--- a/src/main/java/org/onap/aai/datarouter/policy/SpikeEventPolicyConfig.java
+++ b/src/main/java/org/onap/aai/datarouter/policy/SpikeEventPolicyConfig.java
@@ -20,6 +20,9 @@
  */
 package org.onap.aai.datarouter.policy;
 
+import org.onap.aai.setup.SchemaLocationsBean;
+import org.onap.aai.setup.SchemaVersions;
+
 public class SpikeEventPolicyConfig {
 
   private String sourceDomain;
@@ -29,7 +32,8 @@ public class SpikeEventPolicyConfig {
   private String searchCertName;
   private String searchKeystorePwd;
   private String searchKeystore;
-
+  private SchemaVersions schemaVersions;
+  private SchemaLocationsBean schemaLocationsBean;
   
   public String getSourceDomain() {
     return sourceDomain;
@@ -87,4 +91,20 @@ public class SpikeEventPolicyConfig {
   public void setSearchKeystorePwd(String searchKeystorePwd) {
     this.searchKeystorePwd = searchKeystorePwd;
   } 
+  
+  public SchemaVersions getSchemaVersions() {
+    return schemaVersions;
+  }
+  
+  public void setSchemaVersions(SchemaVersions schemaVersions) {
+    this.schemaVersions = schemaVersions;
+  }
+  
+  public SchemaLocationsBean getSchemaLocationsBean() {
+    return schemaLocationsBean;
+  }
+  
+  public void setSchemaLocationsBean(SchemaLocationsBean schemaLocationsBean) {
+    this.schemaLocationsBean = schemaLocationsBean;
+  }
 }