opendaylight/md-sal/sal-binding-broker/src/test/java/org/opendaylight/controller/sal/binding/test/bugfix/DOMCodecBug01Test.java

   1 package org.opendaylight.controller.sal.binding.test.bugfix;
   2
   3 import java.util.Collections;
   4 import java.util.Map;
   5
   6 import org.junit.Test;
   7 import org.opendaylight.controller.md.sal.common.api.TransactionStatus;
   8 import org.opendaylight.controller.sal.binding.test.AbstractDataServiceTest;
   9 import org.opendaylight.controller.sal.binding.api.data.DataModificationTransaction;
  10 import org.opendaylight.yang.gen.v1.urn.opendaylight.flow.config.rev130819.Flows;
  11 import org.opendaylight.yang.gen.v1.urn.opendaylight.flow.config.rev130819.flows.Flow;
  12 import org.opendaylight.yang.gen.v1.urn.opendaylight.flow.config.rev130819.flows.FlowBuilder;
  13 import org.opendaylight.yang.gen.v1.urn.opendaylight.flow.config.rev130819.flows.FlowKey;
  14 import org.opendaylight.yang.gen.v1.urn.opendaylight.flow.types.rev131026.flow.Match;
  15 import org.opendaylight.yang.gen.v1.urn.opendaylight.flow.types.rev131026.flow.MatchBuilder;
  16 import org.opendaylight.yang.gen.v1.urn.opendaylight.inventory.rev130819.nodes.Node;
  17 import org.opendaylight.yang.gen.v1.urn.opendaylight.inventory.rev130819.NodeId;
  18 import org.opendaylight.yang.gen.v1.urn.opendaylight.inventory.rev130819.NodeRef;
  19 import org.opendaylight.yang.gen.v1.urn.opendaylight.inventory.rev130819.Nodes;
  20 import org.opendaylight.yang.gen.v1.urn.opendaylight.inventory.rev130819.nodes.NodeKey;
  21 import org.opendaylight.yang.gen.v1.urn.opendaylight.l2.types.rev130827.VlanId;
  22 import org.opendaylight.yang.gen.v1.urn.opendaylight.model.match.types.rev131026.match.VlanMatchBuilder;
  23 import org.opendaylight.yang.gen.v1.urn.opendaylight.model.match.types.rev131026.vlan.match.fields.VlanIdBuilder;
  24 import org.opendaylight.yangtools.yang.binding.DataObject;
  25 import org.opendaylight.yangtools.yang.binding.InstanceIdentifier;
  26 import org.opendaylight.yangtools.yang.common.QName;
  27 import org.opendaylight.yangtools.yang.common.RpcResult;
  28 import org.opendaylight.yangtools.yang.data.api.CompositeNode;
  29
  30 import com.google.common.collect.ImmutableMap;
  31
  32 import static org.junit.Assert.*;
  33
  34 /**
  35  *
  36  * Testcase for https://bugs.opendaylight.org/show_bug.cgi?id=144
  37  *
  38  * Cannot compile CoDec for org.opendaylight.yang.gen.v1.urn.opendaylight.flow.config.rev130819.flows.Flow
  39  *
  40  * @author ttkacik
  41  *
  42  */
  43 public class DOMCodecBug01Test extends AbstractDataServiceTest {
  44
  45     private static final QName NODE_ID_QNAME = QName.create(Node.QNAME, "id");
  46     private static final QName FLOW_ID_QNAME = QName.create(Flow.QNAME, "id");
  47     private static final QName FLOW_NODE_QNAME = QName.create(Flow.QNAME, "node");
  48
  49     private static final long FLOW_ID = 1234;
  50     private static final String NODE_ID = "node:1";
  51
  52     private static final NodeKey NODE_KEY = new NodeKey(new NodeId(NODE_ID));
  53     private static final InstanceIdentifier<Node> NODE_INSTANCE_ID_BA = InstanceIdentifier.builder().node(Nodes.class)
  54             .node(Node.class, NODE_KEY).toInstance();
  55
  56
  57     private static final Map<QName, Object> NODE_KEY_BI = Collections.<QName, Object> singletonMap(NODE_ID_QNAME,
  58             NODE_ID);
  59
  60     private static final org.opendaylight.yangtools.yang.data.api.InstanceIdentifier NODE_INSTANCE_ID_BI = //
  61             org.opendaylight.yangtools.yang.data.api.InstanceIdentifier.builder() //
  62                     .node(Nodes.QNAME) //
  63                     .nodeWithKey(Node.QNAME, NODE_KEY_BI) //
  64                     .toInstance();
  65     private static final NodeRef NODE_REF = new NodeRef(NODE_INSTANCE_ID_BA);
  66
  67     private static final FlowKey FLOW_KEY = new FlowKey(FLOW_ID, NODE_REF);
  68
  69     private static final Map<QName, Object> FLOW_KEY_BI = //
  70             ImmutableMap.<QName,Object>of(FLOW_ID_QNAME, FLOW_ID, FLOW_NODE_QNAME, NODE_REF);
  71
  72
  73
  74
  75     private static final org.opendaylight.yangtools.yang.data.api.InstanceIdentifier FLOW_INSTANCE_ID_BI = //
  76             org.opendaylight.yangtools.yang.data.api.InstanceIdentifier.builder() //
  77                     .node(Flows.QNAME) //
  78                     .nodeWithKey(Flow.QNAME, FLOW_KEY_BI) //
  79                     .toInstance();
  80     private static final InstanceIdentifier<? extends DataObject> FLOW_INSTANCE_ID_BA = //
  81             InstanceIdentifier.builder() //
  82                 .node(Flows.class) //
  83                 .node(Flow.class, FLOW_KEY) //
  84                 .toInstance();
  85     /**
  86      *
  87      * When invoking following code in the consumer, user got an
  88      * IllegalStateException during creation of mapping between Java DTOs and
  89      * data-dom.
  90      *
  91      * Exception was compilation error which was caused by incorect generation
  92      * of code.
  93      *
  94      *
  95      */
  96     @Test
  97     public void testIndirectGeneration() throws Exception {
  98
  99         DataModificationTransaction modification = baDataService.beginTransaction();
 100
 101        FlowBuilder flow = new FlowBuilder();
 102         MatchBuilder match = new MatchBuilder();
 103         VlanMatchBuilder vlanBuilder = new VlanMatchBuilder();
 104         VlanIdBuilder vlanIdBuilder = new VlanIdBuilder();
 105         VlanId vlanId = new VlanId(10);
 106         vlanBuilder.setVlanId(vlanIdBuilder.setVlanId(vlanId).build());
 107         match.setVlanMatch(vlanBuilder.build());
 108
 109         flow.setKey(FLOW_KEY);
 110         flow.setMatch(match.build());
 111         flow.setNode(NODE_REF);
 112
 113         modification.putConfigurationData(FLOW_INSTANCE_ID_BA, flow.build());
 114         RpcResult<TransactionStatus> ret = modification.commit().get();
 115         assertNotNull(ret);
 116         assertEquals(TransactionStatus.COMMITED, ret.getResult());
 117
 118         verifyDataAreStoredProperly();
 119
 120
 121         DataModificationTransaction modification2 = baDataService.beginTransaction();
 122         modification2.removeConfigurationData(FLOW_INSTANCE_ID_BA);
 123
 124         DataObject originalData = modification2.getOriginalConfigurationData().get(FLOW_INSTANCE_ID_BA);
 125         assertNotNull(originalData);
 126         RpcResult<TransactionStatus> ret2 = modification2.commit().get();
 127
 128         assertNotNull(ret2);
 129         assertEquals(TransactionStatus.COMMITED, ret2.getResult());
 130
 131
 132         // Data are not in the store.
 133         assertNull(baDataService.readOperationalData(FLOW_INSTANCE_ID_BA));
 134
 135
 136     }
 137
 138     private void verifyDataAreStoredProperly() {
 139         CompositeNode biFlow = biDataService.readConfigurationData(FLOW_INSTANCE_ID_BI);
 140         assertNotNull(biFlow);
 141         CompositeNode biMatch = biFlow.getFirstCompositeByName(QName.create(Flow.QNAME,Match.QNAME.getLocalName()));
 142         assertNotNull(biMatch);
 143     }
 144 }