Support order of tree operations

Author: dantleech

lib/Doctrine/ODM/PHPCR/DocumentManager.php

@@ -389,7 +389,9 @@ public function findMany($className, array $ids)
         }
 
         $nodes = $this->session->getNodes($ids);
-        $hints = array('fallback' => true);
+        $hints = array(
+            'fallback' => true,
+        );
         $documents = $this->unitOfWork->getOrCreateDocuments($className, $nodes, $hints);
 
         return new ArrayCollection($documents);

lib/Doctrine/ODM/PHPCR/Queue/TreeOperation.php

@@ -0,0 +1,47 @@
+<?php
+
+namespace Doctrine\ODM\PHPCR\Queue;
+
+class TreeOperation
+{
+    const OP_MOVE = 'move';
+    const OP_REMOVE = 'remove';
+    const OP_INSERT = 'insert';
+
+    private $oid;
+    private $type;
+    private $args;
+    private $valid = true;
+
+    public function __construct($type, $oid, $args)
+    {
+        $this->oid = $oid;
+        $this->type = $type;
+        $this->args = $args;
+    }
+
+    public function getOid() 
+    {
+        return $this->oid;
+    }
+
+    public function getType() 
+    {
+        return $this->type;
+    }
+
+    public function getArgs() 
+    {
+        return $this->args;
+    }
+
+    public function invalidate()
+    {
+        $this->valid = false;
+    }
+
+    public function isValid()
+    {
+        return $this->valid;
+    }
+}

lib/Doctrine/ODM/PHPCR/Queue/TreeOperationBatch.php

@@ -0,0 +1,29 @@
+<?php
+
+namespace Doctrine\ODM\PHPCR\Queue;
+
+class TreeOperationBatch
+{
+    private $type;
+    private $schedule = array();
+
+    public function __construct($type)
+    {
+        $this->type = $type;
+    }
+
+    public function getSchedule() 
+    {
+        return $this->schedule;
+    }
+
+    public function schedule($oid, $args)
+    {
+        $this->schedule[$oid] = $args;
+    }
+
+    public function getType() 
+    {
+        return $this->type;
+    }
+}

lib/Doctrine/ODM/PHPCR/Queue/TreeOperationQueue.php

@@ -0,0 +1,107 @@
+<?php
+
+namespace Doctrine\ODM\PHPCR\Queue;
+
+use Doctrine\ODM\PHPCR\Queue\TreeOperation;
+use Doctrine\ODM\PHPCR\Queue\TreeOperationBatch;
+
+class TreeOperationQueue
+{
+    private $queue = array();
+
+    public function push(TreeOperation $operation)
+    {
+        $this->queue[] = $operation;
+    }
+
+    /**
+     * Partition into contiguous sets of operations
+     */
+    public function getBatches()
+    {
+        $type = null;
+        $batches = array();
+
+        foreach ($this->queue as $operation) {
+            if (false === $operation->isValid()) {
+                continue;
+            }
+
+            if ($operation->getType() !== $type) {
+                $batch = new TreeOperationBatch($operation->getType());
+                $type = $operation->getType();
+                $batches[] = $batch;
+            }
+
+            $batch->schedule(
+                $operation->getOid(),
+                $operation->getArgs()
+            );
+        }
+
+        return $batches;
+    }
+
+    public function clear()
+    {
+        $this->queue = array();
+    }
+
+    public function getSchedule($type)
+    {
+        $schedule = array();
+
+        foreach ($this->queue as $operation) {
+            if (false === $operation->isValid()) {
+                continue;
+            }
+
+            $schedule[$operation->getOid()] = $operation->getArgs();
+        }
+
+        return $schedule;
+    }
+
+    public function isQueued($type, $oid)
+    {
+        foreach ($this->queue as $operation) {
+            if (false === $operation->isValid()) {
+                continue;
+            }
+
+            if ($operation->getType() !== $type) {
+                continue;
+            }
+
+            if ($oid == $operation->getOid()) {
+                return true;
+            }
+        }
+
+        return false;
+    }
+
+    public function unqueue($type, $oid)
+    {
+        foreach ($this->queue as $operation) {
+            if ($operation->getType() !== $type) {
+                continue;
+            }
+
+            if ($operation->getOid() !== $oid) {
+                continue;
+            }
+
+            $operation->invalidate();
+        }
+    }
+
+    public function unregister($oid)
+    {
+        foreach ($this->queue as $operation) {
+            if ($operation->getOid() == $oid) {
+                $operation->invalidate();
+            }
+        }
+    }
+}