svn commit: r1330738 - /jackrabbit/oak/trunk/oak-jcr/src/main/java/org/apache/jackrabbit/oak/jcr/NodeDelegate.java

[re...@apache.org]

Author: reschke
Date: Thu Apr 26 10:01:35 2012
New Revision: 1330738

URL: http://svn.apache.org/viewvc?rev=1330738&view=rev
Log:
OAK-61: split NodeImpl into NodeImpl and NodeDelegate

Added:
    jackrabbit/oak/trunk/oak-jcr/src/main/java/org/apache/jackrabbit/oak/jcr/NodeDelegate.java

Added: jackrabbit/oak/trunk/oak-jcr/src/main/java/org/apache/jackrabbit/oak/jcr/NodeDelegate.java
URL: http://svn.apache.org/viewvc/jackrabbit/oak/trunk/oak-jcr/src/main/java/org/apache/jackrabbit/oak/jcr/NodeDelegate.java?rev=1330738&view=auto
==============================================================================
--- jackrabbit/oak/trunk/oak-jcr/src/main/java/org/apache/jackrabbit/oak/jcr/NodeDelegate.java (added)
+++ jackrabbit/oak/trunk/oak-jcr/src/main/java/org/apache/jackrabbit/oak/jcr/NodeDelegate.java Thu Apr 26 10:01:35 2012
@@ -0,0 +1,191 @@
+/*
+ * Licensed to the Apache Software Foundation (ASF) under one or more
+ * contributor license agreements.  See the NOTICE file distributed with
+ * this work for additional information regarding copyright ownership.
+ * The ASF licenses this file to You under the Apache License, Version 2.0
+ * (the "License"); you may not use this file except in compliance with
+ * the License.  You may obtain a copy of the License at
+ *
+ *      http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ */
+package org.apache.jackrabbit.oak.jcr;
+
+import java.util.Iterator;
+import java.util.List;
+
+import javax.jcr.ItemNotFoundException;
+import javax.jcr.Node;
+import javax.jcr.PathNotFoundException;
+import javax.jcr.RepositoryException;
+
+import org.apache.jackrabbit.oak.api.CoreValue;
+import org.apache.jackrabbit.oak.api.PropertyState;
+import org.apache.jackrabbit.oak.api.Root;
+import org.apache.jackrabbit.oak.api.Tree;
+import org.apache.jackrabbit.oak.api.Tree.Status;
+import org.apache.jackrabbit.oak.namepath.Paths;
+import org.apache.jackrabbit.oak.util.Function1;
+import org.apache.jackrabbit.oak.util.Iterators;
+
+public class NodeDelegate {
+
+    private final SessionContext<SessionImpl> sessionContext;
+    private Tree tree;
+
+    NodeDelegate(SessionContext<SessionImpl> sessionContext, Tree tree) {
+        this.sessionContext = sessionContext;
+        this.tree = tree;
+    }
+
+    NodeDelegate addNode(String relPath) throws RepositoryException {
+        String parentPath = Paths.concat(getPath(),
+                Paths.getParentPath(relPath));
+        Tree parentState = getBranch().getTree(parentPath);
+        if (parentState == null) {
+            throw new PathNotFoundException(relPath);
+        }
+
+        String name = Paths.getName(relPath);
+        parentState.addChild(name);
+        return new NodeDelegate(sessionContext, parentState.getChild(name));
+    }
+
+    NodeDelegate getAncestor(int depth) throws RepositoryException {
+        int current = getDepth();
+        if (depth < 0 || depth > current) {
+            throw new ItemNotFoundException("ancestor at depth " + depth
+                    + " does not exist");
+        }
+        Tree ancestor = getTree();
+        while (depth < current) {
+            ancestor = ancestor.getParent();
+            current -= 1;
+        }
+        return new NodeDelegate(sessionContext, ancestor);
+    }
+
+    Iterator<NodeDelegate> getChildren() throws RepositoryException {
+        return nodeDelegateIterator(getTree().getChildren().iterator());
+    }
+
+    long getChildrenCount() throws RepositoryException {
+        return getTree().getChildrenCount();
+    }
+
+    int getDepth() throws RepositoryException {
+        return Paths.getDepth(getPath());
+    }
+
+    String getName() {
+        return getTree().getName();
+    }
+
+    Status getNodeStatus() {
+        return getTree().getParent().getChildStatus(getName());
+    }
+
+    NodeDelegate getNodeOrNull(String relOakPath) {
+        String absPath = Paths.concat(getPath(), relOakPath);
+        Tree tree = getBranch().getTree(absPath);
+        return tree == null ? null : new NodeDelegate(sessionContext, tree);
+    }
+
+    NodeDelegate getParent() throws RepositoryException {
+        if (getTree().getParent() == null) {
+            throw new ItemNotFoundException("Root has no parent");
+        }
+
+        return new NodeDelegate(sessionContext, getTree().getParent());
+    }
+
+    String getPath() {
+        return '/' + getTree().getPath();
+    }
+
+    Iterator<PropertyDelegate> getProperties() throws RepositoryException {
+        return propertyDelegateIterator(getTree().getProperties().iterator());
+    }
+    
+    long getPropertyCount() throws RepositoryException {
+        return getTree().getPropertyCount();
+    }
+
+    PropertyDelegate getPropertyOrNull(String relOakPath)
+            throws RepositoryException {
+
+        String absPath = Paths.concat(getPath(),
+                Paths.getParentPath(relOakPath));
+        Tree parent = getBranch().getTree(absPath);
+        if (parent == null) {
+            return null;
+        }
+
+        String name = Paths.getName(relOakPath);
+        PropertyState propertyState = parent.getProperty(name);
+        return propertyState == null ? null : new PropertyDelegate(
+                sessionContext, parent, propertyState);
+    }
+
+    SessionContext<SessionImpl> getSessionContext() {
+        return sessionContext;
+    }
+    
+    void remove() throws RepositoryException {
+        getTree().getParent().removeChild(getName());
+    }
+
+    PropertyDelegate setProperty(String oakName, CoreValue value) throws RepositoryException {
+
+        getState().setProperty(oakName, value);
+        return getPropertyOrNull(oakName);
+    }
+
+    PropertyDelegate setProperty(String oakName, List<CoreValue> value) throws RepositoryException {
+
+        getState().setProperty(oakName, value);
+        return getPropertyOrNull(oakName);
+    }
+
+    // ------------------------------------------------------------< private >---
+
+    private Root getBranch() {
+        return sessionContext.getBranch();
+    }
+
+    private Tree getState() {
+        return getTree();
+    }
+
+    private synchronized Tree getTree() {
+        return tree = getBranch().getTree(tree.getPath());
+    }
+
+    private Iterator<NodeDelegate> nodeDelegateIterator(
+            Iterator<Tree> childNodeStates) {
+        return Iterators.map(childNodeStates,
+                new Function1<Tree, NodeDelegate>() {
+                    @Override
+                    public NodeDelegate apply(Tree state) {
+                        return new NodeDelegate(sessionContext, state);
+                    }
+                });
+    }
+
+    private Iterator<PropertyDelegate> propertyDelegateIterator(
+            Iterator<PropertyState> properties) {
+        return Iterators.map(properties,
+                new Function1<PropertyState, PropertyDelegate>() {
+                    @Override
+                    public PropertyDelegate apply(PropertyState propertyState) {
+                        return new PropertyDelegate(sessionContext, tree,
+                                propertyState);
+                    }
+                });
+    }
+}