Add 'features/protocol-framework/' from commit 'cb42405784db97d0ce2c5991d12a89b46d185949'
[netconf.git] / netconf / mdsal-netconf-connector / src / main / java / org / opendaylight / netconf / mdsal / connector / ops / get / Get.java
1 /*
2  * Copyright (c) 2015 Cisco Systems, Inc. and others.  All rights reserved.
3  *
4  * This program and the accompanying materials are made available under the
5  * terms of the Eclipse Public License v1.0 which accompanies this distribution,
6  * and is available at http://www.eclipse.org/legal/epl-v10.html
7  */
8
9 package org.opendaylight.netconf.mdsal.connector.ops.get;
10
11 import com.google.common.base.Optional;
12 import org.opendaylight.controller.config.util.xml.DocumentedException;
13 import org.opendaylight.controller.config.util.xml.DocumentedException.ErrorSeverity;
14 import org.opendaylight.controller.config.util.xml.DocumentedException.ErrorTag;
15 import org.opendaylight.controller.config.util.xml.DocumentedException.ErrorType;
16 import org.opendaylight.controller.config.util.xml.XmlElement;
17 import org.opendaylight.controller.config.util.xml.XmlUtil;
18 import org.opendaylight.controller.md.sal.common.api.data.LogicalDatastoreType;
19 import org.opendaylight.controller.md.sal.common.api.data.ReadFailedException;
20 import org.opendaylight.controller.md.sal.dom.api.DOMDataReadWriteTransaction;
21 import org.opendaylight.netconf.api.xml.XmlNetconfConstants;
22 import org.opendaylight.netconf.mdsal.connector.CurrentSchemaContext;
23 import org.opendaylight.netconf.mdsal.connector.TransactionProvider;
24 import org.opendaylight.netconf.mdsal.connector.ops.Datastore;
25 import org.opendaylight.yangtools.yang.data.api.YangInstanceIdentifier;
26 import org.opendaylight.yangtools.yang.data.api.schema.NormalizedNode;
27 import org.slf4j.Logger;
28 import org.slf4j.LoggerFactory;
29 import org.w3c.dom.Document;
30 import org.w3c.dom.Element;
31
32 public class Get extends AbstractGet {
33
34     private static final Logger LOG = LoggerFactory.getLogger(Get.class);
35
36     private static final String OPERATION_NAME = "get";
37     private final TransactionProvider transactionProvider;
38
39     public Get(final String netconfSessionIdForReporting, final CurrentSchemaContext schemaContext,
40                final TransactionProvider transactionProvider) {
41         super(netconfSessionIdForReporting, schemaContext);
42         this.transactionProvider = transactionProvider;
43     }
44
45     @Override
46     protected Element handleWithNoSubsequentOperations(final Document document, final XmlElement operationElement)
47             throws DocumentedException {
48
49         final Optional<YangInstanceIdentifier> dataRootOptional = getDataRootFromFilter(operationElement);
50         if (!dataRootOptional.isPresent()) {
51             return XmlUtil.createElement(document, XmlNetconfConstants.DATA_KEY, Optional.<String>absent());
52         }
53
54         final YangInstanceIdentifier dataRoot = dataRootOptional.get();
55
56         final DOMDataReadWriteTransaction rwTx = getTransaction(Datastore.running);
57         try {
58             final Optional<NormalizedNode<?, ?>> normalizedNodeOptional = rwTx.read(
59                     LogicalDatastoreType.OPERATIONAL, dataRoot).checkedGet();
60             transactionProvider.abortRunningTransaction(rwTx);
61
62             if (!normalizedNodeOptional.isPresent()) {
63                 return XmlUtil.createElement(document, XmlNetconfConstants.DATA_KEY, Optional.<String>absent());
64             }
65
66             return serializeNodeWithParentStructure(document, dataRoot, normalizedNodeOptional.get());
67         } catch (final ReadFailedException e) {
68             LOG.warn("Unable to read data: {}", dataRoot, e);
69             throw new IllegalStateException("Unable to read data " + dataRoot, e);
70         }
71     }
72
73     private DOMDataReadWriteTransaction getTransaction(final Datastore datastore) throws DocumentedException {
74         if (datastore == Datastore.candidate) {
75             return transactionProvider.getOrCreateTransaction();
76         } else if (datastore == Datastore.running) {
77             return transactionProvider.createRunningTransaction();
78         }
79         throw new DocumentedException("Incorrect Datastore: ", ErrorType.PROTOCOL, ErrorTag.BAD_ELEMENT,
80                 ErrorSeverity.ERROR);
81     }
82
83     @Override
84     protected String getOperationName() {
85         return OPERATION_NAME;
86     }
87 }