1 files changed, 371 insertions, 0 deletions
diff --git a/www/wiki/extensions/SemanticMediaWiki/src/SQLStore/ChangeOp/ChangeOp.php b/www/wiki/extensions/SemanticMediaWiki/src/SQLStore/ChangeOp/ChangeOp.php
new file mode 100644
index 00000000..30726851
--- /dev/null
+++ b/www/wiki/extensions/SemanticMediaWiki/src/SQLStore/ChangeOp/ChangeOp.php
@@ -0,0 +1,371 @@
+<?php
+
+namespace SMW\SQLStore\ChangeOp;
+
+use ArrayIterator;
+use IteratorAggregate;
+use SMW\DIWikiPage;
+
+/**
+ * @license GNU GPL v2+
+ * @since 2.3
+ *
+ * @author mwjames
+ */
+class ChangeOp implements IteratorAggregate {
+
+	/**
+	 * Type of change operations
+	 */
+	const OP_INSERT = 'insert';
+	const OP_DELETE = 'delete';
+
+	/**
+	 * @var array
+	 */
+	private $diff = [];
+
+	/**
+	 * @var array
+	 */
+	private $data = [];
+
+	/**
+	 * @var array
+	 */
+	private $textItems = [];
+
+	/**
+	 * @var array
+	 */
+	private $orderedDiff = [];
+
+	/**
+	 * @var DIWikiPage
+	 */
+	private $subject;
+
+	/**
+	 * @var array
+	 */
+	private $fixedPropertyRecords = [];
+
+	/**
+	 * @var array
+	 */
+	private $propertyList = [];
+
+	/**
+	 * @var boolean
+	 */
+	private $textItemsFlag = false;
+
+	/**
+	 * @since 2.3
+	 *
+	 * @param DIWikiPage|null $subject
+	 * @param array $diff
+	 */
+	public function __construct( DIWikiPage $subject = null, array $diff = [] ) {
+		$this->subject = $subject;
+		$this->diff = $diff;
+	}
+
+	/**
+	 * @since 3.0
+	 *
+	 * @param boolean $textItemsFlag
+	 */
+	public function setTextItemsFlag( $textItemsFlag ) {
+		$this->textItemsFlag = (bool)$textItemsFlag;
+	}
+
+	/**
+	 * @since 2.5
+	 *
+	 * @return DIWikiPage
+	 */
+	public function getSubject() {
+		return $this->subject;
+	}
+
+	/**
+	 * @since 2.3
+	 *
+	 * @return ArrayIterator
+	 */
+	public function getIterator() {
+		return new ArrayIterator( $this->diff );
+	}
+
+	/**
+	 * @since 2.5
+	 *
+	 * @return string
+	 */
+	public function getHash() {
+		return $this->subject->getHash();
+	}
+
+	/**
+	 * @since 2.3
+	 *
+	 * @param array $fixedPropertyRecord
+	 */
+	public function addFixedPropertyRecord( $tableName, array $fixedPropertyRecord ) {
+		$this->fixedPropertyRecords[$tableName] = $fixedPropertyRecord;
+	}
+
+	/**
+	 * @since 2.4
+	 *
+	 * @return array
+	 */
+	public function getFixedPropertyRecords() {
+		return $this->fixedPropertyRecords;
+	}
+
+	/**
+	 * @since 3.0
+	 *
+	 * @return array
+	 */
+	public function addPropertyList( $propertyList ) {
+		$this->propertyList = array_merge( $this->propertyList, $propertyList );
+	}
+
+	/**
+	 * @since 3.0
+	 *
+	 * @return array
+	 */
+	public function getPropertyList() {
+		return $this->propertyList;
+	}
+
+	/**
+	 * @since 3.0
+	 *
+	 * @param string $hash
+	 * @param array $data
+	 */
+	public function addDataOp( $hash, array $data ) {
+		$this->data[$hash] = $data;
+	}
+
+	/**
+	 * @since 3.0
+	 *
+	 * @return TableChangeOp[]
+	 */
+	public function getDataOps() {
+
+		$dataChangeOps = [];
+
+		foreach ( $this->data as $hash => $data ) {
+			foreach ( $data as $tableName => $d ) {
+
+				if ( isset( $this->fixedPropertyRecords[$tableName] ) ) {
+					$d['property'] = $this->fixedPropertyRecords[$tableName];
+				}
+
+				$dataChangeOps[] = new TableChangeOp( $tableName, $d );
+			}
+		}
+
+		return $dataChangeOps;
+	}
+
+	/**
+	 * @since 3.0
+	 *
+	 * @param integer $id
+	 * @param array $data
+	 */
+	public function addTextItems( $id, array $textItems ) {
+		if ( $this->textItemsFlag ) {
+			$this->textItems[$id] = $textItems;
+		}
+	}
+
+	/**
+	 * @since 2.3
+	 *
+	 * @param array $insertOp
+	 * @param array $deleteOp
+	 */
+	public function addDiffOp( array $insertOp, array $deleteOp ) {
+
+		$diff = [
+			'insert' => $insertOp,
+			'delete' => $deleteOp
+		];
+
+		$this->diff[] = $diff;
+	}
+
+	/**
+	 * ChangeOp (TableChangeOp/FieldChangeOp) representation of the composite
+	 * diff.
+	 *
+	 * @since 2.4
+	 *
+	 * @param string|null $table
+	 *
+	 * @return TableChangeOp[]|[]
+	 */
+	public function getTableChangeOps( $table = null ) {
+
+		$tableChangeOps = [];
+
+		foreach ( $this->getOrderedDiffByTable( $table ) as $tableName => $diff ) {
+			$tableChangeOps[] = new TableChangeOp( $tableName, $diff );
+		}
+
+		return $tableChangeOps;
+	}
+
+	/**
+	 * @since 3.0
+	 *
+	 * @return ChangeDiff
+	 */
+	public function newChangeDiff() {
+
+		$changeDiff = new ChangeDiff(
+			$this->subject,
+			$this->getTableChangeOps(),
+			$this->getDataOps(),
+			$this->getPropertyList(),
+			$this->textItems
+		);
+
+		$changeDiff->setChangeList(
+			self::OP_INSERT,
+			$this->getChangedEntityIdListByType( self::OP_INSERT )
+		);
+
+		$changeDiff->setChangeList(
+			self::OP_DELETE,
+			$this->getChangedEntityIdListByType( self::OP_DELETE )
+		);
+
+		return $changeDiff;
+	}
+
+	/**
+	 * Simplified (ordered by table) diff array to allow for an easier
+	 * post-processing
+	 *
+	 * @since 2.3
+	 *
+	 * @return array
+	 */
+	public function getOrderedDiffByTable( $table = null ) {
+
+		if ( $table === null && $this->orderedDiff !== [] ) {
+			return $this->orderedDiff;
+		}
+
+		$ordered = [];
+
+		foreach ( $this as $diff ) {
+			foreach ( $diff as $key => $value ) {
+				foreach ( $value as $tableName => $val ) {
+
+					if ( $val === [] || ( $table !== null && $table !== $tableName ) ) {
+						continue;
+					}
+
+					if ( isset( $this->fixedPropertyRecords[$tableName] ) ) {
+						$ordered[$tableName]['property'] = $this->fixedPropertyRecords[$tableName];
+					}
+
+					if ( !isset( $ordered[$tableName] ) ) {
+						$ordered[$tableName] = [];
+					}
+
+					if ( !isset( $ordered[$tableName][$key] ) ) {
+						$ordered[$tableName][$key] = [];
+					}
+
+					foreach ( $val as $v ) {
+						$ordered[$tableName][$key][] = $v;
+					}
+				}
+			}
+		}
+
+		if ( $table === null ) {
+			$this->orderedDiff = $ordered;
+		}
+
+		return $ordered;
+	}
+
+	/**
+	 * @since 3.0
+	 *
+	 * @param string|null $type
+	 *
+	 * @return array
+	 */
+	public function getChangedEntityIdListByType( $type = null ) {
+
+		$changedEntities = [];
+
+		foreach ( $this->getOrderedDiffByTable() as $diff ) {
+
+			if ( ( $type === 'insert' || $type === null ) && isset( $diff['insert'] )  ) {
+				$this->addToIdList( $changedEntities, $diff['insert'] );
+			}
+
+			if ( ( $type === 'delete' || $type === null ) && isset( $diff['delete'] )  ) {
+				$this->addToIdList( $changedEntities, $diff['delete'] );
+			}
+
+			if ( $type === null && isset( $diff['property'] )  ) {
+				$changedEntities[$diff['property']['p_id']] = true;
+			}
+		}
+
+		return $changedEntities;
+	}
+
+	/**
+	 * @since 3.0
+	 *
+	 * @return array
+	 */
+	public function getChangedEntityIdSummaryList() {
+		return array_keys( $this->getChangedEntityIdListByType() );
+	}
+
+	/**
+	 * @deprecated since 3.0, use ChangeOp::getChangedEntityIdSummaryList
+	 * @since 2.3
+	 *
+	 * @return array
+	 */
+	public function getCombinedIdListOfChangedEntities() {
+		return $this->getChangedEntityIdSummaryList();
+	}
+
+	private function addToIdList( &$list, $value ) {
+		foreach ( $value as $element ) {
+
+			if ( isset( $element['p_id'] ) ) {
+				$list[$element['p_id']] = true;
+			}
+
+			if ( isset( $element['s_id'] ) ) {
+				$list[$element['s_id']] = true;
+			}
+
+			if ( isset( $element['o_id'] ) ) {
+				$list[$element['o_id']] = true;
+			}
+		}
+	}
+
+}