aai-core/src/test/java/org/onap/aai/parsers/query/RelationshipGremlinQueryTest.java

   1 /**
   2  * ============LICENSE_START=======================================================
   3  * org.onap.aai
   4  * ================================================================================
   5  * Copyright © 2017-2018 AT&T Intellectual Property. All rights reserved.
   6  * ================================================================================
   7  * Licensed under the Apache License, Version 2.0 (the "License");
   8  * you may not use this file except in compliance with the License.
   9  * You may obtain a copy of the License at
  10  *
  11  *    http://www.apache.org/licenses/LICENSE-2.0
  12  *
  13  * Unless required by applicable law or agreed to in writing, software
  14  * distributed under the License is distributed on an "AS IS" BASIS,
  15  * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
  16  * See the License for the specific language governing permissions and
  17  * limitations under the License.
  18  * ============LICENSE_END=========================================================
  19  */
  20 package org.onap.aai.parsers.query;
  21
  22 import org.eclipse.persistence.dynamic.DynamicEntity;
  23 import org.eclipse.persistence.jaxb.UnmarshallerProperties;
  24 import org.eclipse.persistence.jaxb.dynamic.DynamicJAXBContext;
  25 import org.junit.Before;
  26 import org.junit.Ignore;
  27 import org.junit.Rule;
  28 import org.junit.Test;
  29 import org.junit.rules.ExpectedException;
  30 import org.onap.aai.AAISetup;
  31 import org.onap.aai.exceptions.AAIException;
  32 import org.onap.aai.introspection.*;
  33 import org.onap.aai.nodes.NodeIngestor;
  34 import org.onap.aai.setup.SchemaVersion;
  35 import org.springframework.beans.factory.annotation.Autowired;
  36 import org.onap.aai.serialization.engines.QueryStyle;
  37 import org.onap.aai.serialization.engines.JanusGraphDBEngine;
  38 import org.onap.aai.serialization.engines.TransactionalGraphEngine;
  39
  40 import javax.xml.bind.JAXBException;
  41 import javax.xml.bind.Unmarshaller;
  42 import javax.xml.transform.stream.StreamSource;
  43 import java.io.StringReader;
  44 import java.io.UnsupportedEncodingException;
  45
  46 import static org.hamcrest.CoreMatchers.containsString;
  47 import static org.junit.Assert.assertEquals;
  48
  49 @Ignore
  50 public class RelationshipGremlinQueryTest extends AAISetup {
  51
  52     @Autowired
  53     private NodeIngestor injestor;
  54     private TransactionalGraphEngine dbEngine;
  55     private SchemaVersion version;
  56     private DynamicJAXBContext context = injestor.getContextForVersion(version);
  57
  58     @Rule
  59     public ExpectedException thrown = ExpectedException.none();
  60
  61     @Before
  62     public void setup(){
  63         version = new SchemaVersion("v10");
  64         dbEngine =
  65             new JanusGraphDBEngine(QueryStyle.GREMLIN_TRAVERSAL,
  66                 loaderFactory.createLoaderForVersion(ModelType.MOXY, version),
  67                 false);
  68     }
  69
  70     /**
  71      * Parent query.
  72      *
  73      * @throws JAXBException the JAXB exception
  74      * @throws UnsupportedEncodingException the unsupported encoding exception
  75      * @throws AAIException the AAI exception
  76      */
  77     @Test
  78     public void parentQuery() throws JAXBException, UnsupportedEncodingException, AAIException {
  79
  80         String content =
  81                 "{"
  82                 + "\"related-to\" : \"pserver\","
  83                 + "\"relationship-data\" : [{"
  84                 + "\"relationship-key\" : \"pserver.hostname\","
  85                 + "\"relationship-value\" : \"key1\""
  86                 + "}]"
  87                 + "}";
  88
  89         Unmarshaller unmarshaller = context.createUnmarshaller();
  90         unmarshaller.setProperty(UnmarshallerProperties.MEDIA_TYPE, "application/json");
  91         unmarshaller.setProperty(UnmarshallerProperties.JSON_INCLUDE_ROOT, false);
  92         unmarshaller.setProperty(UnmarshallerProperties.JSON_WRAPPER_AS_ARRAY_NAME, true);
  93         Object obj = context.newDynamicEntity("Relationship");
  94
  95         DynamicEntity entity = (DynamicEntity)unmarshaller.unmarshal(new StreamSource(new StringReader(content)), obj.getClass()).getValue();
  96
  97         Introspector wrappedObj = IntrospectorFactory.newInstance(ModelType.MOXY, entity);
  98         QueryParser query = dbEngine.getQueryBuilder().createQueryFromRelationship(wrappedObj);
  99
 100         String expected =
 101                 ".has('hostname', 'key1').has('aai-node-type', 'pserver')";
 102         assertEquals(
 103                 "gremlin query should be " + expected,
 104                 expected,
 105                 query.getQueryBuilder().getQuery());
 106         assertEquals(
 107                 "parent gremlin query should be equal to normal query",
 108                 expected,
 109                 query.getQueryBuilder().getParentQuery().getQuery());
 110         assertEquals(
 111                 "result type should be pserver",
 112                 "pserver",
 113                 query.getResultType());
 114
 115     }
 116
 117     /**
 118      * Child query.
 119      *
 120      * @throws JAXBException the JAXB exception
 121      * @throws UnsupportedEncodingException the unsupported encoding exception
 122      * @throws AAIException the AAI exception
 123      */
 124     @Test
 125     public void childQuery() throws JAXBException, UnsupportedEncodingException, AAIException {
 126         String content =
 127                 "{"
 128                 + "\"related-to\" : \"lag-interface\","
 129                 + "\"relationship-data\" : [{"
 130                 + "\"relationship-key\" : \"pserver.hostname\","
 131                 + "\"relationship-value\" : \"key1\""
 132                 + "}, {"
 133                 + "\"relationship-key\" : \"lag-interface.interface-name\","
 134                 + "\"relationship-value\" : \"key2\""
 135                 + "}]"
 136                 + "}";
 137
 138         Unmarshaller unmarshaller = context.createUnmarshaller();
 139         unmarshaller.setProperty(UnmarshallerProperties.MEDIA_TYPE, "application/json");
 140         unmarshaller.setProperty(UnmarshallerProperties.JSON_INCLUDE_ROOT, false);
 141         unmarshaller.setProperty(UnmarshallerProperties.JSON_WRAPPER_AS_ARRAY_NAME, true);
 142         Object obj = context.newDynamicEntity("Relationship");
 143
 144         DynamicEntity entity = (DynamicEntity)unmarshaller.unmarshal(new StreamSource(new StringReader(content)), obj.getClass()).getValue();
 145
 146         Introspector wrappedObj = IntrospectorFactory.newInstance(ModelType.MOXY, entity);
 147         QueryParser query = dbEngine.getQueryBuilder().createQueryFromRelationship(wrappedObj);
 148
 149         String expected = ".has('hostname', 'key1').has('aai-node-type', 'pserver').in('tosca.relationships.BindsTo').has('aai-node-type', 'lag-interface')"
 150                 + ".has('interface-name', 'key2')";
 151         String parentExpected =
 152                 ".has('hostname', 'key1').has('aai-node-type', 'pserver')";
 153         assertEquals(
 154                 "gremlin query should be for node",
 155                 expected,
 156                 query.getQueryBuilder().getQuery());
 157         assertEquals(
 158                 "parent gremlin query should be for parent",
 159                 parentExpected,
 160                 query.getQueryBuilder().getParentQuery().getQuery());
 161         assertEquals(
 162                 "result type should be lag-interface",
 163                 "lag-interface",
 164                 query.getResultType());
 165     }
 166
 167     /**
 168      * Naming exceptions.
 169      *
 170      * @throws JAXBException the JAXB exception
 171      * @throws UnsupportedEncodingException the unsupported encoding exception
 172      * @throws AAIException the AAI exception
 173      */
 174     @Test
 175     public void namingExceptions() throws JAXBException, UnsupportedEncodingException, AAIException {
 176         String content =
 177                 "{"
 178                 + "\"related-to\" : \"cvlan-tag\","
 179                 + "\"relationship-data\" : [{"
 180                 + "\"relationship-key\" : \"vce.vnf-id\","
 181                 + "\"relationship-value\" : \"key1\""
 182                 + "}, {"
 183                 + "\"relationship-key\" : \"port-group.interface-id\","
 184                 + "\"relationship-value\" : \"key2\""
 185                 + "},{"
 186                 + "\"relationship-key\" : \"cvlan-tag.cvlan-tag\","
 187                 + "\"relationship-value\" : \"655\""
 188                 + "}]"
 189                 + "}";
 190
 191         Unmarshaller unmarshaller = context.createUnmarshaller();
 192         unmarshaller.setProperty(UnmarshallerProperties.MEDIA_TYPE, "application/json");
 193         unmarshaller.setProperty(UnmarshallerProperties.JSON_INCLUDE_ROOT, false);
 194         unmarshaller.setProperty(UnmarshallerProperties.JSON_WRAPPER_AS_ARRAY_NAME, true);
 195         Object obj = context.newDynamicEntity("Relationship");
 196
 197         DynamicEntity entity = (DynamicEntity)unmarshaller.unmarshal(new StreamSource(new StringReader(content)), obj.getClass()).getValue();
 198
 199         Introspector wrappedObj = IntrospectorFactory.newInstance(ModelType.MOXY, entity);
 200         QueryParser query = dbEngine.getQueryBuilder().createQueryFromRelationship(wrappedObj);
 201         String expected =
 202                 ".has('vnf-id', 'key1').has('aai-node-type', 'vce')"
 203                 + ".in('org.onap.relationships.inventory.BelongsTo').has('aai-node-type', 'port-group')"
 204                 + ".has('interface-id', 'key2').in('org.onap.relationships.inventory.BelongsTo').has('aai-node-type', 'cvlan-tag')"
 205                 + ".has('cvlan-tag', 655)";
 206         String expectedParent =
 207                         ".has('vnf-id', 'key1').has('aai-node-type', 'vce')"
 208                         + ".in('org.onap.relationships.inventory.BelongsTo').has('aai-node-type', 'port-group')"
 209                         + ".has('interface-id', 'key2')";
 210         assertEquals(
 211                 "gremlin query should be " + expected,
 212                 expected,
 213                 query.getQueryBuilder().getQuery());
 214         assertEquals(
 215                 "parent gremlin query should be equal the query for port group",
 216                 expectedParent,
 217                 query.getQueryBuilder().getParentQuery().getQuery());
 218         assertEquals(
 219                 "result type should be cvlan-tag",
 220                 "cvlan-tag",
 221                 query.getResultType());
 222
 223     }
 224
 225     /**
 226      * Scrambled relationship.
 227      *
 228      * @throws JAXBException the JAXB exception
 229      * @throws UnsupportedEncodingException the unsupported encoding exception
 230      * @throws AAIException the AAI exception
 231      */
 232     @Test
 233     public void scrambledRelationship() throws JAXBException, UnsupportedEncodingException, AAIException {
 234         String content =
 235                 "{"
 236                 + "\"related-to\" : \"l3-interface-ipv4-address-list\","
 237                 + "\"relationship-data\" : [{"
 238                 + "\"relationship-key\" : \"l3-interface-ipv4-address-list.l3-interface-ipv4-address\","
 239                 + "\"relationship-value\" : \"key5\""
 240                 + "},{"
 241                 + "\"relationship-key\" : \"lag-interface.interface-name\","
 242                 + "\"relationship-value\" : \"key2\""
 243                 + "},{"
 244                 + "\"relationship-key\" : \"l-interface.interface-name\","
 245                 + "\"relationship-value\" : \"key3\""
 246                 + "},{"
 247                 + "\"relationship-key\" : \"vlan.vlan-interface\","
 248                 + "\"relationship-value\" : \"key4\""
 249                 + "},{"
 250                 + "\"relationship-key\" : \"generic-vnf.vnf-id\","
 251                 + "\"relationship-value\" : \"key1\""
 252                 + "}]"
 253                 + "}";
 254         scrambledRelationshipSpec(content);
 255     }
 256
 257     /**
 258      * Reversed relationship.
 259      *
 260      * @throws JAXBException the JAXB exception
 261      * @throws UnsupportedEncodingException the unsupported encoding exception
 262      * @throws AAIException the AAI exception
 263      */
 264     @Test
 265     public void reversedRelationship() throws JAXBException, UnsupportedEncodingException, AAIException {
 266         String content =
 267                 "{"
 268                 + "\"related-to\" : \"l3-interface-ipv4-address-list\","
 269                 + "\"relationship-data\" : [{"
 270                 + "\"relationship-key\" : \"l3-interface-ipv4-address-list.l3-interface-ipv4-address\","
 271                 + "\"relationship-value\" : \"key5\""
 272                 + "},{"
 273                 + "\"relationship-key\" : \"vlan.vlan-interface\","
 274                 + "\"relationship-value\" : \"key4\""
 275                 + "},{"
 276                 + "\"relationship-key\" : \"l-interface.interface-name\","
 277                 + "\"relationship-value\" : \"key3\""
 278                 + "},{"
 279                 + "\"relationship-key\" : \"lag-interface.interface-name\","
 280                 + "\"relationship-value\" : \"key2\""
 281                 + "},{"
 282                 + "\"relationship-key\" : \"generic-vnf.vnf-id\","
 283                 + "\"relationship-value\" : \"key1\""
 284                 + "}]"
 285                 + "}";
 286         scrambledRelationshipSpec(content);
 287     }
 288
 289     /**
 290      * Ordered ambiguous relationship.
 291      *
 292      * @throws JAXBException the JAXB exception
 293      * @throws UnsupportedEncodingException the unsupported encoding exception
 294      * @throws AAIException the AAI exception
 295      */
 296     @Test
 297     public void orderedAmbiguousRelationship() throws JAXBException, UnsupportedEncodingException, AAIException {
 298         String content =
 299                 "{"
 300                 + "\"related-to\" : \"l3-interface-ipv4-address-list\","
 301                 + "\"relationship-data\" : [{"
 302                 + "\"relationship-key\" : \"generic-vnf.vnf-id\","
 303                 + "\"relationship-value\" : \"key1\""
 304                 + "},{"
 305                 + "\"relationship-key\" : \"lag-interface.interface-name\","
 306                 + "\"relationship-value\" : \"key2\""
 307                 + "},{"
 308                 + "\"relationship-key\" : \"l-interface.interface-name\","
 309                 + "\"relationship-value\" : \"key3\""
 310                 + "},{"
 311                 + "\"relationship-key\" : \"vlan.vlan-interface\","
 312                 + "\"relationship-value\" : \"key4\""
 313                 + "},{"
 314                 + "\"relationship-key\" : \"l3-interface-ipv4-address-list.l3-interface-ipv4-address\","
 315                 + "\"relationship-value\" : \"key5\""
 316                 + "}]"
 317                 + "}";
 318         scrambledRelationshipSpec(content);
 319     }
 320
 321     /**
 322      * Scrambled relationship spec.
 323      *
 324      * @param content the content
 325      * @throws JAXBException the JAXB exception
 326      * @throws UnsupportedEncodingException the unsupported encoding exception
 327      * @throws AAIException the AAI exception
 328      */
 329     public void scrambledRelationshipSpec(String content) throws JAXBException, UnsupportedEncodingException, AAIException {
 330
 331
 332         Unmarshaller unmarshaller = context.createUnmarshaller();
 333         unmarshaller.setProperty(UnmarshallerProperties.MEDIA_TYPE, "application/json");
 334         unmarshaller.setProperty(UnmarshallerProperties.JSON_INCLUDE_ROOT, false);
 335         unmarshaller.setProperty(UnmarshallerProperties.JSON_WRAPPER_AS_ARRAY_NAME, true);
 336         Object obj = context.newDynamicEntity("Relationship");
 337
 338         DynamicEntity entity = (DynamicEntity)unmarshaller.unmarshal(new StreamSource(new StringReader(content)), obj.getClass()).getValue();
 339
 340         Introspector wrappedObj = IntrospectorFactory.newInstance(ModelType.MOXY, entity);
 341         QueryParser query = dbEngine.getQueryBuilder().createQueryFromRelationship(wrappedObj);
 342         String expected =
 343                 ".has('vnf-id', 'key1').has('aai-node-type', 'generic-vnf')"
 344                 + ".in('org.onap.relationships.inventory.BelongsTo').has('aai-node-type', 'lag-interface')"
 345                 + ".has('interface-name', 'key2').in('org.onap.relationships.inventory.BelongsTo').has('aai-node-type', 'l-interface')"
 346                 + ".has('interface-name', 'key3').out('tosca.relationships.LinksTo').has('aai-node-type', 'vlan')"
 347                 + ".has('vlan-interface', 'key4').in('org.onap.relationships.inventory.BelongsTo').has('aai-node-type', 'l3-interface-ipv4-address-list')"
 348                 + ".has('l3-interface-ipv4-address', 'key5')";
 349         String expectedParent =
 350                 ".has('vnf-id', 'key1').has('aai-node-type', 'generic-vnf')"
 351                         + ".in('org.onap.relationships.inventory.BelongsTo').has('aai-node-type', 'lag-interface')"
 352                         + ".has('interface-name', 'key2').in('org.onap.relationships.inventory.BelongsTo').has('aai-node-type', 'l-interface')"
 353                         + ".has('interface-name', 'key3').out('tosca.relationships.LinksTo').has('aai-node-type', 'vlan')"
 354                         + ".has('vlan-interface', 'key4')";
 355         assertEquals(
 356                 "gremlin query should be " + expected,
 357                 expected,
 358                 query.getQueryBuilder().getQuery());
 359         assertEquals(
 360                 "parent gremlin query should be equal the query for vlan",
 361                 expectedParent,
 362                 query.getQueryBuilder().getParentQuery().getQuery());
 363         assertEquals(
 364                 "result type should be l3-interface-ipv4-address-list",
 365                 "l3-interface-ipv4-address-list",
 366                 query.getResultType());
 367
 368     }
 369
 370     /**
 371      * Short circuit.
 372      *
 373      * @throws JAXBException the JAXB exception
 374      * @throws UnsupportedEncodingException the unsupported encoding exception
 375      * @throws AAIException the AAI exception
 376      */
 377     @Test
 378     public void shortCircuit() throws JAXBException, UnsupportedEncodingException, AAIException {
 379         String content =
 380                 "{"
 381                 + "\"related-to\" : \"cvlan-tag\","
 382                 + "\"related-link\" : \"http://mock-system-name.com:8443/aai/v6/network/vces/vce/key1/port-groups/port-group/key2/cvlan-tags/cvlan-tag/655\","
 383                 + "\"relationship-data\" : [{"
 384                 + "\"relationship-key\" : \"vce.vnf-id\","
 385                 + "\"relationship-value\" : \"key1\""
 386                 + "}, {"
 387                 + "\"relationship-key\" : \"port-group.interface-id\","
 388                 + "\"relationship-value\" : \"key2\""
 389                 + "},{"
 390                 + "\"relationship-key\" : \"cvlan-tag.cvlan-tag\","
 391                 + "\"relationship-value\" : \"655\""
 392                 + "}]"
 393                 + "}";
 394
 395         Unmarshaller unmarshaller = context.createUnmarshaller();
 396         unmarshaller.setProperty(UnmarshallerProperties.MEDIA_TYPE, "application/json");
 397         unmarshaller.setProperty(UnmarshallerProperties.JSON_INCLUDE_ROOT, false);
 398         unmarshaller.setProperty(UnmarshallerProperties.JSON_WRAPPER_AS_ARRAY_NAME, true);
 399         Object obj = context.newDynamicEntity("Relationship");
 400
 401         DynamicEntity entity = (DynamicEntity)unmarshaller.unmarshal(new StreamSource(new StringReader(content)), obj.getClass()).getValue();
 402
 403         Introspector wrappedObj = IntrospectorFactory.newInstance(ModelType.MOXY, entity);
 404         QueryParser query = dbEngine.getQueryBuilder().createQueryFromRelationship(wrappedObj);
 405         String expected =
 406                 ".has('vnf-id', 'key1').has('aai-node-type', 'vce')"
 407                 + ".in('org.onap.relationships.inventory.BelongsTo').has('aai-node-type', 'port-group')"
 408                 + ".has('interface-id', 'key2').in('org.onap.relationships.inventory.BelongsTo').has('aai-node-type', 'cvlan-tag')"
 409                 + ".has('cvlan-tag', 655)";
 410         String expectedParent =
 411                         ".has('vnf-id', 'key1').has('aai-node-type', 'vce')"
 412                         + ".in('org.onap.relationships.inventory.BelongsTo').has('aai-node-type', 'port-group')"
 413                         + ".has('interface-id', 'key2')";
 414         assertEquals(
 415                 "gremlin query should be " + expected,
 416                 expected,
 417                 query.getQueryBuilder().getQuery());
 418         assertEquals(
 419                 "parent gremlin query should be equal the query for port group",
 420                 expectedParent,
 421                 query.getQueryBuilder().getParentQuery().getQuery());
 422         assertEquals(
 423                 "result type should be cvlan-tag",
 424                 "cvlan-tag",
 425                 query.getResultType());
 426
 427     }
 428
 429     @Test
 430     public void shorterCircuit() throws JAXBException, UnsupportedEncodingException, AAIException {
 431         String content =
 432                 "{"
 433                 + "\"related-to\" : \"cvlan-tag\","
 434                 + "\"related-link\" : \"file:///network/vces/vce/key1/port-groups/port-group/key2/cvlan-tags/cvlan-tag/655\""
 435                 + "}";
 436
 437         Unmarshaller unmarshaller = context.createUnmarshaller();
 438         unmarshaller.setProperty(UnmarshallerProperties.MEDIA_TYPE, "application/json");
 439         unmarshaller.setProperty(UnmarshallerProperties.JSON_INCLUDE_ROOT, false);
 440         unmarshaller.setProperty(UnmarshallerProperties.JSON_WRAPPER_AS_ARRAY_NAME, true);
 441         Object obj = context.newDynamicEntity("Relationship");
 442
 443         DynamicEntity entity = (DynamicEntity)unmarshaller.unmarshal(new StreamSource(new StringReader(content)), obj.getClass()).getValue();
 444
 445         Introspector wrappedObj = IntrospectorFactory.newInstance(ModelType.MOXY, entity);
 446         QueryParser query = dbEngine.getQueryBuilder().createQueryFromRelationship(wrappedObj);
 447         String expected =
 448                 ".has('vnf-id', 'key1').has('aai-node-type', 'vce')"
 449                 + ".in('org.onap.relationships.inventory.BelongsTo').has('aai-node-type', 'port-group')"
 450                 + ".has('interface-id', 'key2').in('org.onap.relationships.inventory.BelongsTo').has('aai-node-type', 'cvlan-tag')"
 451                 + ".has('cvlan-tag', 655)";
 452         String expectedParent =
 453                         ".has('vnf-id', 'key1').has('aai-node-type', 'vce')"
 454                         + ".in('org.onap.relationships.inventory.BelongsTo').has('aai-node-type', 'port-group')"
 455                         + ".has('interface-id', 'key2')";
 456         assertEquals(
 457                 "gremlin query should be " + expected,
 458                 expected,
 459                 query.getQueryBuilder().getQuery());
 460         assertEquals(
 461                 "parent gremlin query should be equal the query for port group",
 462                 expectedParent,
 463                 query.getQueryBuilder().getParentQuery().getQuery());
 464         assertEquals(
 465                 "result type should be cvlan-tag",
 466                 "cvlan-tag",
 467                 query.getResultType());
 468
 469     }
 470
 471     /**
 472      * Double key.
 473      *
 474      * @throws JAXBException the JAXB exception
 475      * @throws UnsupportedEncodingException the unsupported encoding exception
 476      * @throws AAIException the AAI exception
 477      */
 478     @Test
 479     public void doubleKey() throws JAXBException, UnsupportedEncodingException, AAIException {
 480         String content =
 481                 "{"
 482                 + "\"related-to\" : \"ctag-pool\","
 483                 + "\"relationship-data\" : [{"
 484                 + "\"relationship-key\" : \"complex.physical-location-id\","
 485                 + "\"relationship-value\" : \"key1\""
 486                 + " }, { "
 487                 + "\"relationship-key\" : \"ctag-pool.target-pe\","
 488                 + " \"relationship-value\" : \"key2\""
 489                 + " },{"
 490                 + "\"relationship-key\" : \"ctag-pool.availability-zone-name\","
 491                 + "\"relationship-value\" : \"key3\""
 492                 + "}]"
 493                 + "}";
 494
 495
 496         Unmarshaller unmarshaller = context.createUnmarshaller();
 497         unmarshaller.setProperty(UnmarshallerProperties.MEDIA_TYPE, "application/json");
 498         unmarshaller.setProperty(UnmarshallerProperties.JSON_INCLUDE_ROOT, false);
 499         unmarshaller.setProperty(UnmarshallerProperties.JSON_WRAPPER_AS_ARRAY_NAME, true);
 500         Object obj = context.newDynamicEntity("Relationship");
 501
 502         DynamicEntity entity = (DynamicEntity)unmarshaller.unmarshal(new StreamSource(new StringReader(content)), obj.getClass()).getValue();
 503
 504         Introspector wrappedObj = IntrospectorFactory.newInstance(ModelType.MOXY, entity);
 505         QueryParser query = dbEngine.getQueryBuilder().createQueryFromRelationship(wrappedObj);
 506
 507         String expected =
 508                 ".has('physical-location-id', 'key1').has('aai-node-type', 'complex')"
 509                 + ".in('org.onap.relationships.inventory.BelongsTo').has('aai-node-type', 'ctag-pool')"
 510                 + ".has('target-pe', 'key2')"
 511                 + ".has('availability-zone-name', 'key3')";
 512         String expectedParent =
 513                 ".has('physical-location-id', 'key1').has('aai-node-type', 'complex')";
 514
 515         assertEquals(
 516                 "gremlin query should be " + expected,
 517                 expected,
 518                 query.getQueryBuilder().getQuery());
 519         assertEquals(
 520                 "parent gremlin query should be equal the query for port group",
 521                 expectedParent,
 522                 query.getQueryBuilder().getParentQuery().getQuery());
 523         assertEquals(
 524                 "result type should be ctag-pool",
 525                 "ctag-pool",
 526                 query.getResultType());
 527
 528     }
 529
 530     /**
 531      * Abstract type.
 532      *
 533      * @throws JAXBException the JAXB exception
 534      * @throws UnsupportedEncodingException the unsupported encoding exception
 535      * @throws AAIException the AAI exception
 536      */
 537     @Test
 538     public void abstractType() throws JAXBException, UnsupportedEncodingException, AAIException {
 539         String content =
 540                 "{"
 541                 + "\"related-to\" : \"vnf\","
 542                 + "\"relationship-data\" : [{"
 543                 + "\"relationship-key\" : \"vnf.vnf-id\","
 544                 + "\"relationship-value\" : \"key1\""
 545                 + " }]"
 546                 + "}";
 547
 548
 549         Unmarshaller unmarshaller = context.createUnmarshaller();
 550         unmarshaller.setProperty(UnmarshallerProperties.MEDIA_TYPE, "application/json");
 551         unmarshaller.setProperty(UnmarshallerProperties.JSON_INCLUDE_ROOT, false);
 552         unmarshaller.setProperty(UnmarshallerProperties.JSON_WRAPPER_AS_ARRAY_NAME, true);
 553         Object obj = context.newDynamicEntity("Relationship");
 554
 555         DynamicEntity entity = (DynamicEntity)unmarshaller.unmarshal(new StreamSource(new StringReader(content)), obj.getClass()).getValue();
 556
 557         Introspector wrappedObj = IntrospectorFactory.newInstance(ModelType.MOXY, entity);
 558         QueryParser query = dbEngine.getQueryBuilder().createQueryFromRelationship(wrappedObj);
 559
 560         String expected =
 561                 ".has('vnf-id', 'key1')"
 562                 + ".has('aai-node-type', P.within('vce','generic-vnf'))";
 563
 564         String expectedParent =
 565                 ".has('vnf-id', 'key1')"
 566                         + ".has('aai-node-type', P.within('vce','generic-vnf'))";
 567
 568         assertEquals(
 569                 "gremlin query should be " + expected,
 570                 expected,
 571                 query.getQueryBuilder().getQuery());
 572         assertEquals(
 573                 "parent gremlin query should be equal the query for port group",
 574                 expectedParent,
 575                 query.getQueryBuilder().getParentQuery().getQuery());
 576         assertEquals(
 577                 "result type should be vnf",
 578                 "vnf",
 579                 query.getResultType());
 580
 581     }
 582
 583     /**
 584      * Invalid node name.
 585      *
 586      * @throws JAXBException the JAXB exception
 587      * @throws UnsupportedEncodingException the unsupported encoding exception
 588      * @throws AAIException the AAI exception
 589      */
 590     @Test
 591     public void invalidNodeName() throws JAXBException, UnsupportedEncodingException, AAIException {
 592         String content =
 593                 "{"
 594                 + "\"related-to\" : \"l3-interface-ipv4-address-list\","
 595                 + "\"relationship-data\" : [{"
 596                 + "\"relationship-key\" : \"generic-vnf.vnf-id\","
 597                 + "\"relationship-value\" : \"key1\""
 598                 + "},{"
 599                 + "\"relationship-key\" : \"lag-interface.interface-name\","
 600                 + "\"relationship-value\" : \"key2\""
 601                 + "},{"
 602                 + "\"relationship-key\" : \"l-infeaterface.interface-name\","
 603                 + "\"relationship-value\" : \"key3\""
 604                 + "},{"
 605                 + "\"relationship-key\" : \"vlan.vlan-interface\","
 606                 + "\"relationship-value\" : \"key4\""
 607                 + "},{"
 608                 + "\"relationship-key\" : \"l3-interface-ipv4-address-list.l3-interface-ipv4-address\","
 609                 + "\"relationship-value\" : \"key5\""
 610                 + "}]"
 611                 + "}";
 612         thrown.expect(AAIException.class);
 613         thrown.expectMessage(containsString("invalid object name"));
 614
 615         Unmarshaller unmarshaller = context.createUnmarshaller();
 616         unmarshaller.setProperty(UnmarshallerProperties.MEDIA_TYPE, "application/json");
 617         unmarshaller.setProperty(UnmarshallerProperties.JSON_INCLUDE_ROOT, false);
 618         unmarshaller.setProperty(UnmarshallerProperties.JSON_WRAPPER_AS_ARRAY_NAME, true);
 619         Object obj = context.newDynamicEntity("Relationship");
 620
 621         DynamicEntity entity = (DynamicEntity)unmarshaller.unmarshal(new StreamSource(new StringReader(content)), obj.getClass()).getValue();
 622
 623         Introspector wrappedObj = IntrospectorFactory.newInstance(ModelType.MOXY, entity);
 624         dbEngine.getQueryBuilder().createQueryFromRelationship(wrappedObj);
 625
 626     }
 627
 628     /**
 629      * Invalid property name.
 630      *
 631      * @throws JAXBException the JAXB exception
 632      * @throws UnsupportedEncodingException the unsupported encoding exception
 633      * @throws AAIException the AAI exception
 634      */
 635     @Test
 636     public void invalidPropertyName() throws JAXBException, UnsupportedEncodingException, AAIException {
 637         String content =
 638                 "{"
 639                 + "\"related-to\" : \"l3-interface-ipv4-address-list\","
 640                 + "\"relationship-data\" : [{"
 641                 + "\"relationship-key\" : \"generic-vnf.vnf-id\","
 642                 + "\"relationship-value\" : \"key1\""
 643                 + "},{"
 644                 + "\"relationship-key\" : \"lag-interface.intfdaferface-name\","
 645                 + "\"relationship-value\" : \"key2\""
 646                 + "},{"
 647                 + "\"relationship-key\" : \"l-interface.interface-name\","
 648                 + "\"relationship-value\" : \"key3\""
 649                 + "},{"
 650                 + "\"relationship-key\" : \"vlan.vlan-interface\","
 651                 + "\"relationship-value\" : \"key4\""
 652                 + "},{"
 653                 + "\"relationship-key\" : \"l3-interface-ipv4-address-list.l3-interface-ipv4-address\","
 654                 + "\"relationship-value\" : \"key5\""
 655                 + "}]"
 656                 + "}";
 657         thrown.expect(AAIException.class);
 658         thrown.expectMessage(containsString("invalid property name"));
 659
 660         Unmarshaller unmarshaller = context.createUnmarshaller();
 661         unmarshaller.setProperty(UnmarshallerProperties.MEDIA_TYPE, "application/json");
 662         unmarshaller.setProperty(UnmarshallerProperties.JSON_INCLUDE_ROOT, false);
 663         unmarshaller.setProperty(UnmarshallerProperties.JSON_WRAPPER_AS_ARRAY_NAME, true);
 664         Object obj = context.newDynamicEntity("Relationship");
 665
 666         DynamicEntity entity = (DynamicEntity)unmarshaller.unmarshal(new StreamSource(new StringReader(content)), obj.getClass()).getValue();
 667
 668         Introspector wrappedObj = IntrospectorFactory.newInstance(ModelType.MOXY, entity);
 669         dbEngine.getQueryBuilder().createQueryFromRelationship(wrappedObj);
 670
 671     }
 672 }