[POC/RFC] Operations queue

lib/Doctrine/ODM/PHPCR/OperationQueue.php

@@ -0,0 +1,47 @@
+<?php
+
+namespace Doctrine\ODM\PHPCR;
+
+class OperationQueue extends \SplQueue
+{
+    public function hasOperationForDocument($document, $type)
+    {
+        foreach ($this as $operation) {
+            list($opType, $opDocument, $data) = $operation;
+            if ($document === $opDocument) {
+                return true;
+            }
+        }
+
+        return false;
+    }
+
+    public function removeOperationsForDocument($document, $type)
+    {
+        foreach ($this as $i => $operation) {
+            list($opType, $opDocument, $data) = $operation;
+
+            if ($document === $opDocument && $type === $opType) {
+                $this->offsetUnset($i);
+            }
+        }
+    }
+
+    public function filterByOperationType($targetOperationType)
+    {
+        $res = array();
+        foreach ($this as $operation) {
+            list ($operationType, $document, $data) = $operation;
+            if ($targetOperationType == $operationType) {
+                $res[] = $document;
+            }
+        }
+
+        return $res;
+    }
+
+    public function push($operationType, $document, $data = array())
+    {
+        parent::push(array($operationType, $document, $data));
+    }
+}