/* * Copyright (c) 2015 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.netconf.mdsal.connector.ops; import static org.junit.Assert.assertEquals; import static org.junit.Assert.assertFalse; import static org.junit.Assert.assertTrue; import static org.junit.Assert.fail; import static org.mockito.Matchers.any; import static org.mockito.Mockito.doAnswer; import com.google.common.io.ByteSource; import com.google.common.util.concurrent.Futures; import java.io.InputStream; import java.io.StringWriter; import java.util.ArrayList; import java.util.Arrays; import java.util.EnumMap; import java.util.List; import java.util.concurrent.ExecutorService; import javax.xml.transform.OutputKeys; import javax.xml.transform.Transformer; import javax.xml.transform.TransformerFactory; import javax.xml.transform.dom.DOMSource; import javax.xml.transform.stream.StreamResult; import org.custommonkey.xmlunit.DetailedDiff; import org.custommonkey.xmlunit.Diff; import org.custommonkey.xmlunit.XMLUnit; import org.junit.Before; import org.junit.Test; import org.mockito.Mock; import org.mockito.MockitoAnnotations; import org.opendaylight.controller.cluster.databroker.ConcurrentDOMDataBroker; import org.opendaylight.controller.config.util.xml.DocumentedException; import org.opendaylight.controller.config.util.xml.DocumentedException.ErrorSeverity; import org.opendaylight.controller.config.util.xml.DocumentedException.ErrorTag; import org.opendaylight.controller.config.util.xml.DocumentedException.ErrorType; import org.opendaylight.controller.config.util.xml.XmlElement; import org.opendaylight.controller.config.util.xml.XmlUtil; import org.opendaylight.controller.md.sal.common.api.data.LogicalDatastoreType; import org.opendaylight.controller.md.sal.dom.store.impl.InMemoryDOMDataStoreFactory; import org.opendaylight.controller.sal.core.api.model.SchemaService; import org.opendaylight.controller.sal.core.spi.data.DOMStore; import org.opendaylight.netconf.mapping.api.NetconfOperation; import org.opendaylight.netconf.mapping.api.NetconfOperationChainedExecution; import org.opendaylight.netconf.mdsal.connector.CurrentSchemaContext; import org.opendaylight.netconf.mdsal.connector.TransactionProvider; import org.opendaylight.netconf.mdsal.connector.ops.get.Get; import org.opendaylight.netconf.mdsal.connector.ops.get.GetConfig; import org.opendaylight.netconf.util.test.NetconfXmlUnitRecursiveQualifier; import org.opendaylight.netconf.util.test.XmlFileLoader; import org.opendaylight.yangtools.concepts.ListenerRegistration; import org.opendaylight.yangtools.util.concurrent.SpecialExecutors; import org.opendaylight.yangtools.yang.common.QName; import org.opendaylight.yangtools.yang.data.api.YangInstanceIdentifier; import org.opendaylight.yangtools.yang.model.api.Module; import org.opendaylight.yangtools.yang.model.api.SchemaContext; import org.opendaylight.yangtools.yang.model.api.SchemaContextListener; import org.opendaylight.yangtools.yang.model.repo.api.SourceIdentifier; import org.opendaylight.yangtools.yang.model.repo.api.YangTextSchemaSource; import org.opendaylight.yangtools.yang.model.repo.spi.SchemaSourceProvider; import org.opendaylight.yangtools.yang.test.util.YangParserTestUtils; import org.slf4j.Logger; import org.slf4j.LoggerFactory; import org.w3c.dom.Document; import org.w3c.dom.Node; import org.w3c.dom.NodeList; public class NetconfMDSalMappingTest { private static final Logger LOG = LoggerFactory.getLogger(NetconfMDSalMappingTest.class); private static final String RPC_REPLY_ELEMENT = "rpc-reply"; private static final String DATA_ELEMENT = "data"; private static final String FILTER_NODE = "filter"; private static final String GET_CONFIG = "get-config"; private static final QName TOP = QName.create("urn:opendaylight:mdsal:mapping:test", "2015-02-26", "top"); private static final QName USERS = QName.create("urn:opendaylight:mdsal:mapping:test", "2015-02-26", "users"); private static final QName USER = QName.create("urn:opendaylight:mdsal:mapping:test", "2015-02-26", "user"); private static final QName MODULES = QName.create("urn:opendaylight:mdsal:mapping:test", "2015-02-26", "modules"); private static final QName AUGMENTED_CONTAINER = QName.create("urn:opendaylight:mdsal:mapping:test", "2015-02-26", "augmented-container"); private static final QName AUGMENTED_STRING_IN_CONT = QName.create("urn:opendaylight:mdsal:mapping:test", "2015-02-26", "identifier"); private static final QName CHOICE_NODE = QName.create("urn:opendaylight:mdsal:mapping:test", "2015-02-26", "choice-node"); private static final QName AUGMENTED_CASE = QName.create("urn:opendaylight:mdsal:mapping:test", "2015-02-26", "augmented-case"); private static final QName CHOICE_WRAPPER = QName.create("urn:opendaylight:mdsal:mapping:test", "2015-02-26", "choice-wrapper"); private static final QName INNER_CHOICE = QName.create("urn:opendaylight:mdsal:mapping:test", "2015-02-26", "inner-choice"); private static final QName INNER_CHOICE_TEXT = QName.create("urn:opendaylight:mdsal:mapping:test", "2015-02-26", "text"); private static final YangInstanceIdentifier AUGMENTED_CONTAINER_IN_MODULES = YangInstanceIdentifier.builder().node(TOP).node(MODULES).build(); private static final String SESSION_ID_FOR_REPORTING = "netconf-test-session1"; private static final Document RPC_REPLY_OK = NetconfMDSalMappingTest.getReplyOk(); private CurrentSchemaContext currentSchemaContext = null; private SchemaContext schemaContext = null; private TransactionProvider transactionProvider = null; @Mock private SchemaSourceProvider sourceProvider; @SuppressWarnings("illegalCatch") private static Document getReplyOk() { Document doc; try { doc = XmlFileLoader.xmlFileToDocument("messages/mapping/rpc-reply_ok.xml"); } catch (final Exception e) { LOG.debug("unable to load rpc reply ok.", e); doc = XmlUtil.newDocument(); } return doc; } @Before public void setUp() throws Exception { MockitoAnnotations.initMocks(this); XMLUnit.setIgnoreWhitespace(true); XMLUnit.setIgnoreAttributeOrder(true); this.schemaContext = YangParserTestUtils.parseYangStreams(getYangSchemas()); schemaContext.getModules(); final SchemaService schemaService = createSchemaService(); final DOMStore operStore = InMemoryDOMDataStoreFactory.create("DOM-OPER", schemaService); final DOMStore configStore = InMemoryDOMDataStoreFactory.create("DOM-CFG", schemaService); final EnumMap datastores = new EnumMap<>(LogicalDatastoreType.class); datastores.put(LogicalDatastoreType.CONFIGURATION, configStore); datastores.put(LogicalDatastoreType.OPERATIONAL, operStore); final ExecutorService listenableFutureExecutor = SpecialExecutors.newBlockingBoundedCachedThreadPool( 16, 16, "CommitFutures"); final ConcurrentDOMDataBroker cdb = new ConcurrentDOMDataBroker(datastores, listenableFutureExecutor); this.transactionProvider = new TransactionProvider(cdb, SESSION_ID_FOR_REPORTING); doAnswer(invocationOnMock -> { final SourceIdentifier sId = (SourceIdentifier) invocationOnMock.getArguments()[0]; final YangTextSchemaSource yangTextSchemaSource = YangTextSchemaSource.delegateForByteSource(sId, ByteSource.wrap("module test".getBytes())); return Futures.immediateCheckedFuture(yangTextSchemaSource); }).when(sourceProvider).getSource(any(SourceIdentifier.class)); this.currentSchemaContext = new CurrentSchemaContext(schemaService, sourceProvider); } @Test public void testEmptyDatastore() throws Exception { assertEmptyDatastore(get()); assertEmptyDatastore(getConfigCandidate()); assertEmptyDatastore(getConfigRunning()); } @Test public void testIncorrectGet() throws Exception { try { executeOperation(new GetConfig(SESSION_ID_FOR_REPORTING, currentSchemaContext, transactionProvider), "messages/mapping/bad_getConfig.xml"); fail("Should have failed, this is an incorrect request"); } catch (final DocumentedException e) { assertTrue(e.getErrorSeverity() == ErrorSeverity.ERROR); assertTrue(e.getErrorTag() == ErrorTag.OPERATION_FAILED); assertTrue(e.getErrorType() == ErrorType.APPLICATION); } try { executeOperation(new GetConfig(SESSION_ID_FOR_REPORTING, currentSchemaContext, transactionProvider), "messages/mapping/bad_namespace_getConfig.xml"); fail("Should have failed, this is an incorrect request"); } catch (final DocumentedException e) { assertTrue(e.getErrorSeverity() == ErrorSeverity.ERROR); assertTrue(e.getErrorTag() == ErrorTag.OPERATION_FAILED); assertTrue(e.getErrorType() == ErrorType.APPLICATION); } } @Test public void testEditRunning() throws Exception { try { edit("messages/mapping/editConfigs/editConfig_running.xml"); fail("Should have failed - edit config on running datastore is not supported"); } catch (final DocumentedException e) { assertTrue(e.getErrorSeverity() == ErrorSeverity.ERROR); assertTrue(e.getErrorTag() == ErrorTag.OPERATION_NOT_SUPPORTED); assertTrue(e.getErrorType() == ErrorType.PROTOCOL); } } @Test public void testCommitWithoutOpenTransaction() throws Exception { verifyResponse(commit(), RPC_REPLY_OK); assertEmptyDatastore(getConfigCandidate()); } @Test public void testCandidateTransaction() throws Exception { verifyResponse(edit("messages/mapping/editConfigs/editConfig_merge_n1.xml"), RPC_REPLY_OK); verifyResponse(getConfigCandidate(), XmlFileLoader.xmlFileToDocument( "messages/mapping/editConfigs/editConfig_merge_n1_control.xml")); assertEmptyDatastore(getConfigRunning()); verifyResponse(discardChanges(), RPC_REPLY_OK); assertEmptyDatastore(getConfigCandidate()); } @Test public void testEditWithCommit() throws Exception { verifyResponse(edit("messages/mapping/editConfigs/editConfig_merge_n1.xml"), RPC_REPLY_OK); verifyResponse(getConfigCandidate(), XmlFileLoader.xmlFileToDocument( "messages/mapping/editConfigs/editConfig_merge_n1_control.xml")); verifyResponse(commit(), RPC_REPLY_OK); verifyResponse(getConfigRunning(), XmlFileLoader.xmlFileToDocument( "messages/mapping/editConfigs/editConfig_merge_n1_control.xml")); deleteDatastore(); } @Test public void testKeyOrder() throws Exception { verifyResponse(edit("messages/mapping/editConfigs/editConfig_merge_multiple_keys_1.xml"), RPC_REPLY_OK); verifyResponse(commit(), RPC_REPLY_OK); final Document configRunning = getConfigRunning(); final String responseAsString = XmlUtil.toString(configRunning); verifyResponse(configRunning, XmlFileLoader.xmlFileToDocument( "messages/mapping/editConfigs/editConfig_merge_multiple_keys_1_control.xml")); final int key3 = responseAsString.indexOf("key3"); final int key1 = responseAsString.indexOf("key1"); final int key2 = responseAsString.indexOf("key2"); assertTrue(String.format("Key ordering invalid, should be key3(%d) < key1(%d) < key2(%d)", key3, key1, key2), key3 < key1 && key1 < key2); deleteDatastore(); } @Test public void testMultipleEditsWithMerge() throws Exception { verifyResponse(edit("messages/mapping/editConfigs/editConfig_merge_multiple_1.xml"), RPC_REPLY_OK); verifyResponse(getConfigCandidate(), XmlFileLoader.xmlFileToDocument( "messages/mapping/editConfigs/editConfig_merge_multiple_control_1.xml")); verifyResponse(edit("messages/mapping/editConfigs/editConfig_merge_single_1.xml"), RPC_REPLY_OK); verifyResponse(getConfigCandidate(), XmlFileLoader.xmlFileToDocument( "messages/mapping/editConfigs/editConfig_merge_multiple_control_2.xml")); assertEmptyDatastore(getConfigRunning()); verifyResponse(commit(), RPC_REPLY_OK); verifyResponse(getConfigRunning(), XmlFileLoader.xmlFileToDocument( "messages/mapping/editConfigs/editConfig_merge_multiple_control_2.xml")); deleteDatastore(); } @Test public void testMoreComplexEditConfigs() throws Exception { verifyResponse(edit("messages/mapping/editConfigs/editConfig_merge_multiple_1.xml"), RPC_REPLY_OK); verifyResponse(edit("messages/mapping/editConfigs/editConfig_merge_single_1.xml"), RPC_REPLY_OK); verifyResponse(edit("messages/mapping/editConfigs/editConfig_merge_multiple_2.xml"), RPC_REPLY_OK); verifyResponse(getConfigCandidate(), XmlFileLoader.xmlFileToDocument( "messages/mapping/editConfigs/editConfig_merge_multiple_after_more_complex_merge.xml")); verifyResponse(edit("messages/mapping/editConfigs/editConfig_merge_multiple_3.xml"), RPC_REPLY_OK); verifyResponse(getConfigCandidate(), XmlFileLoader.xmlFileToDocument( "messages/mapping/editConfigs/editConfig_merge_multiple_after_more_complex_merge_2.xml")); verifyResponse(edit("messages/mapping/editConfigs/editConfig_merge_multiple_4_replace.xml"), RPC_REPLY_OK); verifyResponse(getConfigCandidate(), XmlFileLoader.xmlFileToDocument( "messages/mapping/editConfigs/editConfig_merge_multiple_after_replace.xml")); verifyResponse(commit(), RPC_REPLY_OK); verifyResponse(getConfigRunning(), XmlFileLoader.xmlFileToDocument( "messages/mapping/editConfigs/editConfig_merge_multiple_after_replace.xml")); verifyResponse(edit("messages/mapping/editConfigs/editConfig_replace_default.xml"), RPC_REPLY_OK); verifyResponse(getConfigCandidate(), XmlFileLoader.xmlFileToDocument( "messages/mapping/editConfigs/editConfig_replace_default_control.xml")); verifyResponse(commit(), RPC_REPLY_OK); verifyResponse(getConfigRunning(), XmlFileLoader.xmlFileToDocument( "messages/mapping/editConfigs/editConfig_replace_default_control.xml")); deleteDatastore(); } @Test public void testOrderedListEdits() throws Exception { verifyResponse(edit("messages/mapping/editConfigs/editConfig_ordered_list_create.xml"), RPC_REPLY_OK); verifyResponse(commit(), RPC_REPLY_OK); verifyResponse(edit("messages/mapping/editConfigs/editConfig_ordered_list_replace.xml"), RPC_REPLY_OK); verifyResponse(commit(), RPC_REPLY_OK); deleteDatastore(); } @Test public void testAugmentedOrderedListEdits() throws Exception { verifyResponse(edit("messages/mapping/editConfigs/editConfig_augmented_ordered_list_create.xml"), RPC_REPLY_OK); verifyResponse(commit(), RPC_REPLY_OK); verifyResponse(edit("messages/mapping/editConfigs/editConfig_augmented_ordered_list_replace.xml"), RPC_REPLY_OK); verifyResponse(commit(), RPC_REPLY_OK); deleteDatastore(); } @Test public void testAugmentedContainerReplace() throws Exception { verifyResponse(edit("messages/mapping/editConfigs/editConfig_empty_modules_create.xml"), RPC_REPLY_OK); verifyResponse(commit(), RPC_REPLY_OK); verifyResponse(edit("messages/mapping/editConfigs/editConfig_augmented_container_replace.xml"), RPC_REPLY_OK); verifyResponse(commit(), RPC_REPLY_OK); deleteDatastore(); } @Test public void testLeafFromAugmentReplace() throws Exception { verifyResponse(edit("messages/mapping/editConfigs/editConfig_empty_modules_create.xml"), RPC_REPLY_OK); verifyResponse(commit(), RPC_REPLY_OK); verifyResponse(edit("messages/mapping/editConfigs/editConfig_leaf_from_augment_replace.xml"), RPC_REPLY_OK); verifyResponse(commit(), RPC_REPLY_OK); deleteDatastore(); } @Test public void testLock() throws Exception { verifyResponse(lockCandidate(), RPC_REPLY_OK); try { lock(); fail("Should have failed - locking of running datastore is not supported"); } catch (final DocumentedException e) { assertTrue(e.getErrorSeverity() == ErrorSeverity.ERROR); assertTrue(e.getErrorTag() == ErrorTag.OPERATION_NOT_SUPPORTED); assertTrue(e.getErrorType() == ErrorType.APPLICATION); } try { lockWithoutTarget(); fail("Should have failed, target is missing"); } catch (final DocumentedException e) { assertTrue(e.getErrorSeverity() == ErrorSeverity.ERROR); assertTrue(e.getErrorTag() == ErrorTag.INVALID_VALUE); assertTrue(e.getErrorType() == ErrorType.APPLICATION); } } @Test public void testUnlock() throws Exception { verifyResponse(unlockCandidate(), RPC_REPLY_OK); try { unlock(); fail("Should have failed - unlocking of running datastore is not supported"); } catch (final DocumentedException e) { assertTrue(e.getErrorSeverity() == ErrorSeverity.ERROR); assertTrue(e.getErrorTag() == ErrorTag.OPERATION_NOT_SUPPORTED); assertTrue(e.getErrorType() == ErrorType.APPLICATION); } try { unlockWithoutTarget(); fail("Should have failed, target is missing"); } catch (final DocumentedException e) { assertTrue(e.getErrorSeverity() == ErrorSeverity.ERROR); assertTrue(e.getErrorTag() == ErrorTag.INVALID_VALUE); assertTrue(e.getErrorType() == ErrorType.APPLICATION); } } @Test public void testEditWithCreate() throws Exception { verifyResponse(edit("messages/mapping/editConfigs/editConfig_create.xml"), RPC_REPLY_OK); verifyResponse(getConfigCandidate(), XmlFileLoader.xmlFileToDocument( "messages/mapping/editConfig_create_n1_control.xml")); try { edit("messages/mapping/editConfigs/editConfig_create.xml"); fail("Create should have failed - data already exists"); } catch (final DocumentedException e) { assertTrue(e.getErrorSeverity() == ErrorSeverity.ERROR); assertTrue(e.getErrorTag() == ErrorTag.DATA_EXISTS); assertTrue(e.getErrorType() == ErrorType.PROTOCOL); } verifyResponse(discardChanges(), RPC_REPLY_OK); } @Test public void testDeleteNonExisting() throws Exception { assertEmptyDatastore(getConfigCandidate()); assertEmptyDatastore(getConfigRunning()); try { edit("messages/mapping/editConfigs/editConfig_delete-top.xml"); fail("Delete should have failed - data is missing"); } catch (final DocumentedException e) { assertTrue(e.getErrorSeverity() == ErrorSeverity.ERROR); assertTrue(e.getErrorTag() == ErrorTag.DATA_MISSING); assertTrue(e.getErrorType() == ErrorType.PROTOCOL); } } @Test public void testEditMissingDefaultOperation() throws Exception { verifyResponse(edit("messages/mapping/editConfigs/editConfig_merge_missing_default-operation_1.xml"), RPC_REPLY_OK); verifyResponse(edit("messages/mapping/editConfigs/editConfig_merge_missing_default-operation_2.xml"), RPC_REPLY_OK); verifyResponse(getConfigCandidate(), XmlFileLoader.xmlFileToDocument( "messages/mapping/editConfigs/editConfig_merge_missing_default-operation_control.xml")); verifyResponse(commit(), RPC_REPLY_OK); verifyResponse(getConfigRunning(), XmlFileLoader.xmlFileToDocument( "messages/mapping/editConfigs/editConfig_merge_missing_default-operation_control.xml")); deleteDatastore(); } private static void printDocument(final Document doc) throws Exception { final TransformerFactory tf = TransformerFactory.newInstance(); final Transformer transformer = tf.newTransformer(); transformer.setOutputProperty(OutputKeys.OMIT_XML_DECLARATION, "no"); transformer.setOutputProperty(OutputKeys.METHOD, "xml"); transformer.setOutputProperty(OutputKeys.INDENT, "yes"); transformer.setOutputProperty(OutputKeys.ENCODING, "UTF-8"); transformer.setOutputProperty("{http://xml.apache.org/xslt}indent-amount", "4"); final StringWriter writer = new StringWriter(); transformer.transform(new DOMSource(doc), new StreamResult(writer)); LOG.warn(writer.getBuffer().toString()); } @Test public void testEditConfigWithMultipleOperations() throws Exception { deleteDatastore(); verifyResponse(edit("messages/mapping/editConfigs/editConfig_merge_multiple_operations_setup.xml"), RPC_REPLY_OK); verifyResponse(edit("messages/mapping/editConfigs/editConfig_merge_multiple_operations_1.xml"), RPC_REPLY_OK); verifyResponse(edit("messages/mapping/editConfigs/editConfig_merge_multiple_operations_2.xml"), RPC_REPLY_OK); verifyResponse(getConfigCandidate(), XmlFileLoader.xmlFileToDocument( "messages/mapping/editConfigs/editConfig_merge_multiple_operations_2_control.xml")); verifyResponse(edit("messages/mapping/editConfigs/editConfig_merge_multiple_operations_3_leaf_operations.xml"), RPC_REPLY_OK); verifyResponse(getConfigCandidate(), XmlFileLoader.xmlFileToDocument( "messages/mapping/editConfigs/editConfig_merge_multiple_operations_3_control.xml")); deleteDatastore(); verifyResponse(edit("messages/mapping/editConfigs/editConfig_merge_multiple_operations_4_setup.xml"), RPC_REPLY_OK); verifyResponse(edit("messages/mapping/editConfigs/editConfig_merge_multiple_operations_4_default-replace.xml"), RPC_REPLY_OK); try { edit("messages/mapping/editConfigs/editConfig_merge_multiple_operations_4_create_existing.xml"); fail(); } catch (final DocumentedException e) { assertTrue(e.getErrorSeverity() == ErrorSeverity.ERROR); assertTrue(e.getErrorTag() == ErrorTag.DATA_EXISTS); assertTrue(e.getErrorType() == ErrorType.PROTOCOL); } verifyResponse(edit( "messages/mapping/editConfigs/" + "editConfig_merge_multiple_operations_4_delete_children_operations.xml"), RPC_REPLY_OK); verifyResponse(getConfigCandidate(), XmlFileLoader.xmlFileToDocument( "messages/mapping/editConfigs/" + "editConfig_merge_multiple_operations_4_delete_children_operations_control.xml")); verifyResponse(edit( "messages/mapping/editConfigs/" + "editConfig_merge_multiple_operations_4_remove-non-existing.xml"), RPC_REPLY_OK); try { edit("messages/mapping/editConfigs/" + "editConfig_merge_multiple_operations_4_delete-non-existing.xml"); fail(); } catch (final DocumentedException e) { assertTrue(e.getErrorSeverity() == ErrorSeverity.ERROR); assertTrue(e.getErrorTag() == ErrorTag.DATA_MISSING); assertTrue(e.getErrorType() == ErrorType.PROTOCOL); } verifyResponse(edit("messages/mapping/editConfigs/editConfig_merge_multiple_operations_5_choice_setup.xml"), RPC_REPLY_OK); verifyResponse(getConfigCandidate(), XmlFileLoader.xmlFileToDocument( "messages/mapping/editConfigs/editConfig_merge_multiple_operations_5_choice_setup-control.xml")); // Test files have been modified. RFC6020 requires that at most once case inside a choice is present at any time verifyResponse(edit("messages/mapping/editConfigs/editConfig_merge_multiple_operations_5_choice_setup2.xml"), RPC_REPLY_OK); verifyResponse(getConfigCandidate(), XmlFileLoader.xmlFileToDocument( "messages/mapping/editConfigs/editConfig_merge_multiple_operations_5_choice_setup2-control.xml")); verifyResponse(edit("messages/mapping/editConfigs/editConfig_merge_multiple_operations_5_choice_delete.xml"), RPC_REPLY_OK); verifyResponse(getConfigCandidate(), XmlFileLoader.xmlFileToDocument( "messages/mapping/editConfigs" + "/editConfig_merge_multiple_operations_4_delete_children_operations_control.xml")); deleteDatastore(); } @Test public void testReplaceMapEntry() throws Exception { verifyResponse(edit("messages/mapping/editConfigs/edit-config-replace-map-entry.xml"), RPC_REPLY_OK); verifyResponse(commit(), RPC_REPLY_OK); verifyResponse(getConfigRunning(), XmlFileLoader.xmlFileToDocument("messages/mapping/get-config-map-entry.xml")); } @Test public void testMergeMapEntry() throws Exception { verifyResponse(edit("messages/mapping/editConfigs/edit-config-merge-map-entry.xml"), RPC_REPLY_OK); verifyResponse(commit(), RPC_REPLY_OK); verifyResponse(getConfigRunning(), XmlFileLoader.xmlFileToDocument("messages/mapping/get-config-map-entry.xml")); } @Test public void testFiltering() throws Exception { assertEmptyDatastore(getConfigCandidate()); assertEmptyDatastore(getConfigRunning()); verifyResponse(getConfigWithFilter("messages/mapping/filters/get-config-empty-filter.xml"), XmlFileLoader.xmlFileToDocument("messages/mapping/get-empty-response.xml")); verifyResponse(getWithFilter("messages/mapping/filters/get-empty-filter.xml"), XmlFileLoader.xmlFileToDocument("messages/mapping/get-empty-response.xml")); verifyResponse(getConfigCandidate(), XmlFileLoader.xmlFileToDocument("messages/mapping/get-empty-response" + ".xml")); verifyResponse(getConfigRunning(), XmlFileLoader.xmlFileToDocument("messages/mapping/get-empty-response.xml")); verifyResponse(getConfigWithFilter("messages/mapping/filters/get-filter-users.xml"), XmlFileLoader.xmlFileToDocument("messages/mapping/get-empty-response.xml")); verifyResponse(edit("messages/mapping/editConfigs/editConfig-filtering-setup.xml"), RPC_REPLY_OK); verifyResponse(commit(), RPC_REPLY_OK); verifyFilterIdentifier("messages/mapping/filters/get-filter-alluser.xml", YangInstanceIdentifier.builder().node(TOP).node(USERS).node(USER).build()); verifyFilterIdentifier("messages/mapping/filters/get-filter-company-info.xml", YangInstanceIdentifier.builder().node(TOP).node(USERS).node(USER).build()); verifyFilterIdentifier("messages/mapping/filters/get-filter-modules-and-admin.xml", YangInstanceIdentifier.builder().node(TOP).build()); verifyFilterIdentifier("messages/mapping/filters/get-filter-only-names-types.xml", YangInstanceIdentifier.builder().node(TOP).node(USERS).node(USER).build()); verifyFilterIdentifier("messages/mapping/filters/get-filter-specific-module-type-and-user.xml", YangInstanceIdentifier.builder().node(TOP).build()); verifyFilterIdentifier("messages/mapping/filters/get-filter-superuser.xml", YangInstanceIdentifier.builder().node(TOP).node(USERS).node(USER).build()); verifyFilterIdentifier("messages/mapping/filters/get-filter-users.xml", YangInstanceIdentifier.builder().node(TOP).node(USERS).build()); final YangInstanceIdentifier ident = YangInstanceIdentifier .builder(AUGMENTED_CONTAINER_IN_MODULES) .node(AUGMENTED_CONTAINER) .node(AUGMENTED_STRING_IN_CONT).build(); verifyFilterIdentifier("messages/mapping/filters/get-filter-augmented-string.xml", ident); verifyFilterIdentifier("messages/mapping/filters/get-filter-augmented-case.xml", YangInstanceIdentifier.builder().node(TOP).node(CHOICE_NODE).node(AUGMENTED_CASE).build()); verifyResponse(getConfigWithFilter("messages/mapping/filters/get-filter-augmented-case.xml"), XmlFileLoader.xmlFileToDocument("messages/mapping/filters/response-augmented-case.xml")); /* * RFC6020 requires that at most once case inside a choice is present at any time. * Therefore * augmented case * from * messages/mapping/editConfigs/editConfig-filtering-setup.xml * cannot exists together with * augmented nested choice text1 * from * messages/mapping/editConfigs/editConfig-filtering-setup2.xml */ //verifyResponse(edit("messages/mapping/editConfigs/editConfig-filtering-setup2.xml"), RPC_REPLY_OK); //verifyResponse(commit(), RPC_REPLY_OK); verifyFilterIdentifier("messages/mapping/filters/get-filter-augmented-case-inner-choice.xml", YangInstanceIdentifier.builder().node(TOP).node(CHOICE_NODE).node(CHOICE_WRAPPER).build()); verifyFilterIdentifier("messages/mapping/filters/get-filter-augmented-case-inner-case.xml", YangInstanceIdentifier.builder().node(TOP).node(CHOICE_NODE).node(CHOICE_WRAPPER).node(INNER_CHOICE) .node(INNER_CHOICE_TEXT).build()); // verifyResponse(getConfigWithFilter("messages/mapping/filters/get-filter-augmented-string.xml"), // XmlFileLoader.xmlFileToDocument("messages/mapping/filters/response-augmented-string.xml")); // verifyResponse(getConfigWithFilter("messages/mapping/filters/get-filter-augmented-case-inner-choice.xml"), // XmlFileLoader.xmlFileToDocument("messages/mapping/filters/response-augmented-case-inner-choice.xml")); // verifyResponse(getConfigWithFilter("messages/mapping/filters/get-filter-augmented-case-inner-case.xml"), // XmlFileLoader.xmlFileToDocument("messages/mapping/filters/response-augmented-case-inner-choice.xml")); verifyResponse(edit("messages/mapping/editConfigs/editConfig_delete-top.xml"), RPC_REPLY_OK); verifyResponse(commit(), RPC_REPLY_OK); } private void verifyFilterIdentifier(final String resource, final YangInstanceIdentifier identifier) throws Exception { final TestingGetConfig getConfig = new TestingGetConfig(SESSION_ID_FOR_REPORTING, currentSchemaContext, transactionProvider); final Document request = XmlFileLoader.xmlFileToDocument(resource); final YangInstanceIdentifier iid = getConfig.getInstanceIdentifierFromDocument(request); assertEquals(identifier, iid); } private class TestingGetConfig extends GetConfig { TestingGetConfig(final String sessionId, final CurrentSchemaContext schemaContext, final TransactionProvider transactionProvider) { super(sessionId, schemaContext, transactionProvider); } YangInstanceIdentifier getInstanceIdentifierFromDocument(final Document request) throws DocumentedException { final XmlElement filterElement = XmlElement.fromDomDocument(request).getOnlyChildElement(GET_CONFIG) .getOnlyChildElement(FILTER_NODE); return getInstanceIdentifierFromFilter(filterElement); } } private void deleteDatastore() throws Exception { verifyResponse(edit("messages/mapping/editConfigs/editConfig_delete-root.xml"), RPC_REPLY_OK); assertEmptyDatastore(getConfigCandidate()); verifyResponse(commit(), RPC_REPLY_OK); assertEmptyDatastore(getConfigRunning()); } private static void verifyResponse(final Document response, final Document template) throws Exception { final DetailedDiff dd = new DetailedDiff(new Diff(response, template)); dd.overrideElementQualifier(new NetconfXmlUnitRecursiveQualifier()); printDocument(response); printDocument(template); assertTrue(dd.toString(), dd.similar()); } private static void assertEmptyDatastore(final Document response) { final NodeList nodes = response.getChildNodes(); assertTrue(nodes.getLength() == 1); assertEquals(nodes.item(0).getLocalName(), RPC_REPLY_ELEMENT); final NodeList replyNodes = nodes.item(0).getChildNodes(); assertTrue(replyNodes.getLength() == 1); final Node dataNode = replyNodes.item(0); assertEquals(dataNode.getLocalName(), DATA_ELEMENT); assertFalse(dataNode.hasChildNodes()); } private Document commit() throws Exception { final Commit commit = new Commit(SESSION_ID_FOR_REPORTING, transactionProvider); return executeOperation(commit, "messages/mapping/commit.xml"); } private Document discardChanges() throws Exception { final DiscardChanges discardOp = new DiscardChanges(SESSION_ID_FOR_REPORTING, transactionProvider); return executeOperation(discardOp, "messages/mapping/discardChanges.xml"); } private Document edit(final String resource) throws Exception { final EditConfig editConfig = new EditConfig(SESSION_ID_FOR_REPORTING, currentSchemaContext, transactionProvider); return executeOperation(editConfig, resource); } private Document get() throws Exception { final Get get = new Get(SESSION_ID_FOR_REPORTING, currentSchemaContext, transactionProvider); return executeOperation(get, "messages/mapping/get.xml"); } private Document getWithFilter(final String resource) throws Exception { final Get get = new Get(SESSION_ID_FOR_REPORTING, currentSchemaContext, transactionProvider); return executeOperation(get, resource); } private Document getConfigRunning() throws Exception { final GetConfig getConfig = new GetConfig(SESSION_ID_FOR_REPORTING, currentSchemaContext, transactionProvider); return executeOperation(getConfig, "messages/mapping/getConfig.xml"); } private Document getConfigCandidate() throws Exception { final GetConfig getConfig = new GetConfig(SESSION_ID_FOR_REPORTING, currentSchemaContext, transactionProvider); return executeOperation(getConfig, "messages/mapping/getConfig_candidate.xml"); } private Document getConfigWithFilter(final String resource) throws Exception { final GetConfig getConfig = new GetConfig(SESSION_ID_FOR_REPORTING, currentSchemaContext, transactionProvider); return executeOperation(getConfig, resource); } private static Document lock() throws Exception { final Lock lock = new Lock(SESSION_ID_FOR_REPORTING); return executeOperation(lock, "messages/mapping/lock.xml"); } private static Document unlock() throws Exception { final Unlock unlock = new Unlock(SESSION_ID_FOR_REPORTING); return executeOperation(unlock, "messages/mapping/unlock.xml"); } private static Document lockWithoutTarget() throws Exception { final Lock lock = new Lock(SESSION_ID_FOR_REPORTING); return executeOperation(lock, "messages/mapping/lock_notarget.xml"); } private static Document unlockWithoutTarget() throws Exception { final Unlock unlock = new Unlock(SESSION_ID_FOR_REPORTING); return executeOperation(unlock, "messages/mapping/unlock_notarget.xml"); } private static Document lockCandidate() throws Exception { final Lock lock = new Lock(SESSION_ID_FOR_REPORTING); return executeOperation(lock, "messages/mapping/lock_candidate.xml"); } private static Document unlockCandidate() throws Exception { final Unlock unlock = new Unlock(SESSION_ID_FOR_REPORTING); return executeOperation(unlock, "messages/mapping/unlock_candidate.xml"); } private static Document executeOperation(final NetconfOperation op, final String filename) throws Exception { final Document request = XmlFileLoader.xmlFileToDocument(filename); final Document response = op.handle(request, NetconfOperationChainedExecution.EXECUTION_TERMINATION_POINT); LOG.debug("Got response {}", response); return response; } private List getYangSchemas() { final List schemaPaths = Arrays.asList("/META-INF/yang/config.yang", "/yang/mdsal-netconf-mapping-test.yang"); final List schemas = new ArrayList<>(); for (final String schemaPath : schemaPaths) { final InputStream resourceAsStream = getClass().getResourceAsStream(schemaPath); schemas.add(resourceAsStream); } return schemas; } private SchemaService createSchemaService() { return new SchemaService() { @Override public void addModule(final Module module) { } @Override public void removeModule(final Module module) { } @Override public SchemaContext getSessionContext() { return schemaContext; } @Override public SchemaContext getGlobalContext() { return schemaContext; } @Override public ListenerRegistration registerSchemaContextListener( final SchemaContextListener listener) { listener.onGlobalContextUpdated(getGlobalContext()); return new ListenerRegistration() { @Override public void close() { } @Override public SchemaContextListener getInstance() { return listener; } }; } }; } }