2 * Copyright (c) 2017 Pantheon Technologies s.r.o. and others. All rights reserved.
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
8 package org.opendaylight.mdsal.binding.javav2.dom.adapter.spi;
10 import com.google.common.annotations.Beta;
11 import com.google.common.base.Optional;
12 import java.util.HashMap;
13 import java.util.HashSet;
15 import java.util.Map.Entry;
17 import org.opendaylight.mdsal.binding.javav2.dom.codec.impl.BindingToNormalizedNodeCodec;
18 import org.opendaylight.mdsal.binding.javav2.spec.base.InstanceIdentifier;
19 import org.opendaylight.mdsal.binding.javav2.spec.base.TreeNode;
20 import org.opendaylight.mdsal.dom.api.DOMDataBroker;
21 import org.opendaylight.yangtools.concepts.Delegator;
22 import org.opendaylight.yangtools.yang.data.api.YangInstanceIdentifier;
23 import org.opendaylight.yangtools.yang.data.api.schema.NormalizedNode;
24 import org.opendaylight.yangtools.yang.data.impl.codec.DeserializationException;
25 import org.slf4j.Logger;
26 import org.slf4j.LoggerFactory;
29 * This abstract class forwards DOM Data Broker and provides de-serialization of DOM data to Binding data.
32 public abstract class AbstractForwardedDataBroker implements Delegator<DOMDataBroker>, AutoCloseable {
34 private static final Logger LOG = LoggerFactory.getLogger(AbstractForwardedDataBroker.class);
36 // The Broker to whom we do all forwarding
37 private final DOMDataBroker domDataBroker;
39 private final BindingToNormalizedNodeCodec codec;
41 protected AbstractForwardedDataBroker(final DOMDataBroker domDataBroker, final BindingToNormalizedNodeCodec codec) {
42 this.domDataBroker = domDataBroker;
46 protected BindingToNormalizedNodeCodec getCodec() {
51 public DOMDataBroker getDelegate() {
55 protected Map<InstanceIdentifier<? extends TreeNode>, TreeNode> toBinding(
56 final InstanceIdentifier<? extends TreeNode> path,
57 final Map<YangInstanceIdentifier, ? extends NormalizedNode<?, ?>> normalized) {
58 final Map<InstanceIdentifier<? extends TreeNode>, TreeNode> newMap = new HashMap<>();
60 for (final Map.Entry<YangInstanceIdentifier, ? extends NormalizedNode<?, ?>> entry : normalized.entrySet()) {
62 final Optional<Entry<InstanceIdentifier<? extends TreeNode>, TreeNode>> potential =
63 getCodec().toBinding(entry);
64 if (potential.isPresent()) {
65 final Entry<InstanceIdentifier<? extends TreeNode>, TreeNode> binding = potential.get();
66 newMap.put(binding.getKey(), binding.getValue());
68 } catch (final DeserializationException e) {
69 LOG.warn("Failed to transform {}, omitting it", entry, e);
75 protected Set<InstanceIdentifier<?>> toBinding(final InstanceIdentifier<?> path,
76 final Set<YangInstanceIdentifier> normalized) {
77 final Set<InstanceIdentifier<?>> hashSet = new HashSet<>();
78 for (final YangInstanceIdentifier normalizedPath : normalized) {
80 final Optional<InstanceIdentifier<? extends TreeNode>> potential =
81 getCodec().toBinding(normalizedPath);
82 if (potential.isPresent()) {
83 final InstanceIdentifier<? extends TreeNode> binding = potential.get();
85 } else if (normalizedPath
86 .getLastPathArgument() instanceof YangInstanceIdentifier.AugmentationIdentifier) {
89 } catch (final DeserializationException e) {
90 LOG.warn("Failed to transform {}, omitting it", normalizedPath, e);
96 @SuppressWarnings("unchecked")
97 protected Optional<TreeNode> toBindingData(final InstanceIdentifier<?> path, final NormalizedNode<?, ?> data) {
98 if (path.isWildcarded()) {
99 return Optional.absent();
101 return (Optional<TreeNode>) getCodec().deserializeFunction(path)
102 .apply(Optional.of(data));
106 public void close() {