/* * Copyright (c) 2016 Cisco Systems, Inc. and others. All rights reserved. * * This program and the accompanying materials are made available under the * terms of the Eclipse Public License v1.0 which accompanies this distribution, * and is available at http://www.eclipse.org/legal/epl-v10.html */ package org.opendaylight.yangtools.yang.data.impl.leafref.context; import static org.junit.Assert.assertEquals; import static org.junit.Assert.assertThrows; import java.util.Map; import org.junit.AfterClass; import org.junit.BeforeClass; import org.junit.Test; import org.opendaylight.yangtools.yang.common.QName; import org.opendaylight.yangtools.yang.common.QNameModule; import org.opendaylight.yangtools.yang.data.api.YangInstanceIdentifier; import org.opendaylight.yangtools.yang.data.api.YangInstanceIdentifier.NodeIdentifier; import org.opendaylight.yangtools.yang.data.api.YangInstanceIdentifier.NodeIdentifierWithPredicates; import org.opendaylight.yangtools.yang.data.api.schema.ContainerNode; import org.opendaylight.yangtools.yang.data.api.schema.MapEntryNode; import org.opendaylight.yangtools.yang.data.api.schema.tree.DataTree; import org.opendaylight.yangtools.yang.data.api.schema.tree.DataTreeCandidate; import org.opendaylight.yangtools.yang.data.api.schema.tree.DataTreeConfiguration; import org.opendaylight.yangtools.yang.data.api.schema.tree.DataTreeModification; import org.opendaylight.yangtools.yang.data.api.schema.tree.DataValidationFailedException; import org.opendaylight.yangtools.yang.data.impl.leafref.LeafRefContext; import org.opendaylight.yangtools.yang.data.impl.leafref.LeafRefDataValidationFailedException; import org.opendaylight.yangtools.yang.data.impl.leafref.LeafRefValidation; import org.opendaylight.yangtools.yang.data.impl.schema.Builders; import org.opendaylight.yangtools.yang.data.impl.schema.ImmutableNodes; import org.opendaylight.yangtools.yang.data.impl.schema.tree.InMemoryDataTreeFactory; import org.opendaylight.yangtools.yang.model.api.EffectiveModelContext; import org.opendaylight.yangtools.yang.model.api.Module; import org.opendaylight.yangtools.yang.test.util.YangParserTestUtils; import org.slf4j.Logger; import org.slf4j.LoggerFactory; public class DataTreeCandidateValidatorTest3 { private static EffectiveModelContext context; private static Module mainModule; private static QNameModule rootModuleQname; private static LeafRefContext rootLeafRefContext; public static DataTree inMemoryDataTree; private static QName chips; private static QName chip; private static QName devType; private static QName chipDesc; private static QName devices; private static QName device; private static QName typeText1; private static QName typeText2; private static QName typeText3; private static QName devDesc; private static QName sn; private static QName defaultIp; private static QName deviceTypeStr; private static QName deviceType; private static QName type1; private static QName type2; private static QName type3; private static QName desc; private static final Logger LOG = LoggerFactory.getLogger(DataTreeCandidateValidatorTest3.class); private static final String NEW_LINE = System.getProperty("line.separator"); @BeforeClass public static void init() throws DataValidationFailedException { context = YangParserTestUtils.parseYangResourceDirectory("/leafref-validation"); for (final Module module : context.getModules()) { if (module.getName().equals("leafref-validation3")) { mainModule = module; } } rootModuleQname = mainModule.getQNameModule(); rootLeafRefContext = LeafRefContext.create(context); chips = QName.create(rootModuleQname, "chips"); chip = QName.create(rootModuleQname, "chip"); devType = QName.create(rootModuleQname, "dev_type"); chipDesc = QName.create(rootModuleQname, "chip_desc"); devices = QName.create(rootModuleQname, "devices"); device = QName.create(rootModuleQname, "device"); typeText1 = QName.create(rootModuleQname, "type_text1"); typeText2 = QName.create(rootModuleQname, "type_text2"); typeText3 = QName.create(rootModuleQname, "type_text3"); devDesc = QName.create(rootModuleQname, "dev_desc"); sn = QName.create(rootModuleQname, "sn"); defaultIp = QName.create(rootModuleQname, "default_ip"); deviceTypeStr = QName.create(rootModuleQname, "device_types"); deviceType = QName.create(rootModuleQname, "device_type"); type1 = QName.create(rootModuleQname, "type1"); type2 = QName.create(rootModuleQname, "type2"); type3 = QName.create(rootModuleQname, "type3"); desc = QName.create(rootModuleQname, "desc"); inMemoryDataTree = new InMemoryDataTreeFactory().create(DataTreeConfiguration.DEFAULT_OPERATIONAL, context); final DataTreeModification initialDataTreeModification = inMemoryDataTree.takeSnapshot().newModification(); initialDataTreeModification.write(YangInstanceIdentifier.of(chips), Builders.containerBuilder() .withNodeIdentifier(new NodeIdentifier(chips)) .addChild(Builders.mapBuilder() .withNodeIdentifier(new NodeIdentifier(chip)) .addChild(createChipsListEntry("dev_type_1", "desc1")) .addChild(createChipsListEntry("dev_type_2", "desc2")) .build()) .build()); initialDataTreeModification.write(YangInstanceIdentifier.of(deviceTypeStr), Builders.containerBuilder() .withNodeIdentifier(new NodeIdentifier(deviceTypeStr)) .addChild(Builders.mapBuilder() .withNodeIdentifier(new NodeIdentifier(deviceType)) .addChild(createDevTypeListEntry("dev_type1_1", "dev_type2_1", "dev_type3_1", "typedesc1")) .addChild(createDevTypeListEntry("dev_type1_2", "dev_type2_2", "dev_type3_2", "typedesc2")) .addChild(createDevTypeListEntry("dev_type1_3", "dev_type2_3", "dev_type3_3", "typedesc3")) .build()) .build()); initialDataTreeModification.ready(); final DataTreeCandidate writeChipsCandidate = inMemoryDataTree.prepare(initialDataTreeModification); inMemoryDataTree.commit(writeChipsCandidate); LOG.debug("{}", inMemoryDataTree); } @AfterClass public static void cleanup() { inMemoryDataTree = null; rootLeafRefContext = null; mainModule = null; context = null; } @Test public void dataTreeCanditateValidationTest2() throws DataValidationFailedException { writeDevices(); mergeDevices(); } private static void writeDevices() throws DataValidationFailedException { final DataTreeModification writeModification = inMemoryDataTree.takeSnapshot().newModification(); writeModification.write(YangInstanceIdentifier.of(devices), Builders.containerBuilder() .withNodeIdentifier(new NodeIdentifier(devices)) .addChild(Builders.mapBuilder() .withNodeIdentifier(new NodeIdentifier(device)) .addChild(createDeviceListEntry("dev_type1_1", "dev_type2_1", "dev_type3_1", "typedesc1", 123456, "192.168.0.1")) .addChild(createDeviceListEntry("dev_type1_2", "dev_type2_2", "dev_type3_2", "typedesc1", 123457, "192.168.0.1")) .addChild(createDeviceListEntry("dev_type1_1", "dev_type2_2", "dev_type3_3", "typedesc2", 123458, "192.168.0.1")) .addChild(createDeviceListEntry("unk11", "unk22", "unk33", "unk_desc2", 123457, "192.168.0.1")) .build()) .build()); writeModification.ready(); final DataTreeCandidate writeDevicesCandidate = inMemoryDataTree.prepare(writeModification); LOG.debug("*************************"); LOG.debug("Before writeDevices: "); LOG.debug("*************************"); LOG.debug("{}", inMemoryDataTree); final LeafRefDataValidationFailedException ex = assertThrows(LeafRefDataValidationFailedException.class, () -> LeafRefValidation.validate(writeDevicesCandidate, rootLeafRefContext)); assertEquals(6, ex.getValidationsErrorsCount()); inMemoryDataTree.commit(writeDevicesCandidate); LOG.debug("*************************"); LOG.debug("After writeDevices: "); LOG.debug("*************************"); LOG.debug("{}", inMemoryDataTree); } private static void mergeDevices() throws DataValidationFailedException { final ContainerNode devicesContainer = Builders.containerBuilder() .withNodeIdentifier(new NodeIdentifier(devices)) .addChild(Builders.mapBuilder() .withNodeIdentifier(new NodeIdentifier(device)) .addChild(createDeviceListEntry("dev_type1_3", "dev_type2_3", "dev_type3_3", "typedesc3", 123459, "192.168.0.1")) .addChild(createDeviceListEntry("dev_type1_3", "dev_type2_3", "dev_type3_3", "typedesc2", 123460, "192.168.0.1")) .addChild(createDeviceListEntry("dev_type1_3", "dev_type2_2", "dev_type3_1", "typedesc1", 123461, "192.168.0.1")) .addChild(createDeviceListEntry("unk1", "unk2", "unk3", "unk_desc", 123462, "192.168.0.1")) .build()) .build(); final YangInstanceIdentifier devicesPath = YangInstanceIdentifier.of(devices); final DataTreeModification mergeModification = inMemoryDataTree.takeSnapshot().newModification(); mergeModification.write(devicesPath, devicesContainer); mergeModification.merge(devicesPath, devicesContainer); mergeModification.ready(); final DataTreeCandidate mergeDevicesCandidate = inMemoryDataTree.prepare(mergeModification); LOG.debug("*************************"); LOG.debug("Before mergeDevices: "); LOG.debug("*************************"); LOG.debug("{}", inMemoryDataTree); final LeafRefDataValidationFailedException ex = assertThrows(LeafRefDataValidationFailedException.class, () -> LeafRefValidation.validate(mergeDevicesCandidate, rootLeafRefContext)); // :TODO verify errors count gz assertEquals(6, ex.getValidationsErrorsCount()); inMemoryDataTree.commit(mergeDevicesCandidate); LOG.debug("*************************"); LOG.debug("After mergeDevices: "); LOG.debug("*************************"); LOG.debug("{}", inMemoryDataTree); } private static MapEntryNode createDevTypeListEntry(final String type1Val, final String type2Val, final String type3Val, final String descVal) { return Builders.mapEntryBuilder() .withNodeIdentifier(NodeIdentifierWithPredicates.of(deviceType, Map.of(type1, type1Val, type2, type2Val, type3, type3Val))) .addChild(ImmutableNodes.leafNode(type1, type1Val)) .addChild(ImmutableNodes.leafNode(type2, type2Val)) .addChild(ImmutableNodes.leafNode(type3, type3Val)) .addChild(ImmutableNodes.leafNode(desc, descVal)) .build(); } private static MapEntryNode createChipsListEntry(final String devTypeVal, final String chipDescVal) { return Builders.mapEntryBuilder() .withNodeIdentifier(NodeIdentifierWithPredicates.of(chip, devType, devTypeVal)) .addChild(ImmutableNodes.leafNode(devType, devTypeVal)) .addChild(ImmutableNodes.leafNode(chipDesc, chipDescVal)) .build(); } private static MapEntryNode createDeviceListEntry(final String type1TextVal, final String type2TextVal, final String type3TextVal, final String descVal, final int snVal, final String defaultIpVal) { return Builders.mapEntryBuilder() .withNodeIdentifier(NodeIdentifierWithPredicates.of(device, Map.of(typeText1, type1TextVal, sn, snVal))) .addChild(ImmutableNodes.leafNode(typeText1, type1TextVal)) .addChild(ImmutableNodes.leafNode(typeText2, type2TextVal)) .addChild(ImmutableNodes.leafNode(typeText3, type3TextVal)) .addChild(ImmutableNodes.leafNode(devDesc, descVal)) .addChild(ImmutableNodes.leafNode(sn, snVal)) .addChild(ImmutableNodes.leafNode(defaultIp, defaultIpVal)) .build(); } }