package org.opendaylight.controller.cluster.datastore.modification; import static org.junit.Assert.assertEquals; import com.google.common.base.Optional; import org.apache.commons.lang.SerializationUtils; import org.junit.Assert; import org.junit.Test; import org.opendaylight.controller.md.cluster.datastore.model.TestModel; import org.opendaylight.controller.sal.core.spi.data.DOMStoreReadWriteTransaction; import org.opendaylight.yangtools.yang.data.api.YangInstanceIdentifier; import org.opendaylight.yangtools.yang.data.api.schema.NormalizedNode; import org.opendaylight.yangtools.yang.data.impl.schema.ImmutableNodes; import org.opendaylight.yangtools.yang.data.impl.schema.builder.impl.ImmutableContainerNodeBuilder; public class MergeModificationTest extends AbstractModificationTest{ @Test public void testApply() throws Exception { //TODO : Need to write a better test for this //Write something into the datastore DOMStoreReadWriteTransaction writeTransaction = store.newReadWriteTransaction(); MergeModification writeModification = new MergeModification(TestModel.TEST_PATH, ImmutableNodes.containerNode(TestModel.TEST_QNAME)); writeModification.apply(writeTransaction); commitTransaction(writeTransaction); //Check if it's in the datastore Optional> data = readData(TestModel.TEST_PATH); Assert.assertTrue(data.isPresent()); } @Test public void testSerialization() { YangInstanceIdentifier path = TestModel.TEST_PATH; NormalizedNode data = ImmutableContainerNodeBuilder.create().withNodeIdentifier( new YangInstanceIdentifier.NodeIdentifier(TestModel.TEST_QNAME)). withChild(ImmutableNodes.leafNode(TestModel.DESC_QNAME, "foo")).build(); MergeModification expected = new MergeModification(path, data); MergeModification clone = (MergeModification) SerializationUtils.clone(expected); assertEquals("getPath", expected.getPath(), clone.getPath()); assertEquals("getData", expected.getData(), clone.getData()); } }