/* * Copyright (c) 2018 Pantheon Technologies, s.r.o. 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.schema.tree; import java.util.Optional; import org.opendaylight.yangtools.yang.data.api.schema.NormalizedNode; import org.opendaylight.yangtools.yang.data.api.schema.NormalizedNodeContainer; import org.opendaylight.yangtools.yang.data.api.schema.OrderedNodeContainer; import org.opendaylight.yangtools.yang.data.api.schema.tree.ModificationType; import org.opendaylight.yangtools.yang.data.api.schema.tree.spi.TreeNode; import org.opendaylight.yangtools.yang.data.api.schema.tree.spi.TreeNodeFactory; import org.opendaylight.yangtools.yang.data.api.schema.tree.spi.Version; /** * Mixin-type support class for subclasses of {@link ModificationApplyOperation} which need to provide automatic * lifecycle management. */ final class AutomaticLifecycleMixin { /** * This is a capture of {@link ModificationApplyOperation#apply(ModifiedNode, Optional, Version)}. */ @FunctionalInterface interface Apply { Optional apply(ModifiedNode modification, Optional storeMeta, Version version); } /** * This is a capture of * {@link SchemaAwareApplyOperation#applyWrite(ModifiedNode, NormalizedNode, Optional, Version)}. */ @FunctionalInterface interface ApplyWrite { TreeNode applyWrite(ModifiedNode modification, NormalizedNode newValue, Optional storeMeta, Version version); } private AutomaticLifecycleMixin() { } static Optional apply(final Apply delegate, final ApplyWrite writeDelegate, final NormalizedNode emptyNode, final ModifiedNode modification, final Optional storeMeta, final Version version) { final Optional ret; if (modification.getOperation() == LogicalOperation.DELETE) { if (modification.getChildren().isEmpty()) { return delegate.apply(modification, storeMeta, version); } // Delete with children, implies it really is an empty write ret = Optional.of(writeDelegate.applyWrite(modification, emptyNode, storeMeta, version)); } else if (modification.getOperation() == LogicalOperation.TOUCH && !storeMeta.isPresent()) { ret = applyTouch(delegate, emptyNode, modification, storeMeta, version); } else { // No special handling required here, run normal apply operation ret = delegate.apply(modification, storeMeta, version); } return ret.isPresent() ? disappearResult(modification, ret.get(), storeMeta) : ret; } private static Optional applyTouch(final Apply delegate, final NormalizedNode emptyNode, final ModifiedNode modification, final Optional storeMeta, final Version version) { // Container is not present, let's take care of the 'magically appear' part of our job final Optional ret = delegate.apply(modification, fakeMeta(emptyNode, version), version); // If the delegate indicated SUBTREE_MODIFIED, account for the fake and report APPEARED if (modification.getModificationType() == ModificationType.SUBTREE_MODIFIED) { modification.resolveModificationType(ModificationType.APPEARED); } return ret; } private static Optional disappearResult(final ModifiedNode modification, final TreeNode result, final Optional storeMeta) { // Check if the result is in fact empty before pulling any tricks if (!isEmpty(result)) { return Optional.of(result); } // We are pulling the 'disappear' trick, but what we report can be three different things final ModificationType finalType; if (!storeMeta.isPresent()) { // ... there was nothing in the datastore, no change finalType = ModificationType.UNMODIFIED; } else if (modification.getModificationType() == ModificationType.WRITE) { // ... this was an empty write, possibly originally a delete finalType = ModificationType.DELETE; } else { // ... it really disappeared finalType = ModificationType.DISAPPEARED; } modification.resolveModificationType(finalType); return Optional.empty(); } private static Optional fakeMeta(final NormalizedNode emptyNode, final Version version) { return Optional.of(TreeNodeFactory.createTreeNode(emptyNode, version)); } private static boolean isEmpty(final TreeNode treeNode) { final NormalizedNode data = treeNode.getData(); if (data instanceof NormalizedNodeContainer) { return ((NormalizedNodeContainer) data).getValue().isEmpty(); } if (data instanceof OrderedNodeContainer) { return ((OrderedNodeContainer) data).getSize() == 0; } throw new IllegalStateException("Unhandled data " + data); } }