1 files changed, 148 insertions, 0 deletions
diff --git a/www/wiki/extensions/SemanticMediaWiki/src/SQLStore/QueryDependency/DependencyLinksUpdateJournal.php b/www/wiki/extensions/SemanticMediaWiki/src/SQLStore/QueryDependency/DependencyLinksUpdateJournal.php
new file mode 100644
index 00000000..ff9d8526
--- /dev/null
+++ b/www/wiki/extensions/SemanticMediaWiki/src/SQLStore/QueryDependency/DependencyLinksUpdateJournal.php
@@ -0,0 +1,148 @@
+<?php
+
+namespace SMW\SQLStore\QueryDependency;
+
+use Onoi\Cache\Cache;
+use Psr\Log\LoggerAwareTrait;
+use SMW\DIWikiPage;
+use SMW\MediaWiki\Deferred\CallableUpdate;
+use Title;
+
+/**
+ * Temporary storage of entities that are expected to be refreshed (or updated)
+ * during an article view due to being a dependency of an altered query.
+ *
+ * @license GNU GPL v2+
+ * @since 3.0
+ *
+ * @author mwjames
+ */
+class DependencyLinksUpdateJournal {
+
+	use LoggerAwareTrait;
+
+	/**
+	 * @var string
+	 */
+	const VERSION = '0.1';
+
+	/**
+	 * Namespace for the cache instance
+	 */
+	const CACHE_NAMESPACE = 'smw:update:qdep';
+
+	/**
+	 * @var Cache
+	 */
+	private $cache;
+
+	/**
+	 * @var CallableUpdate
+	 */
+	private $callableUpdate;
+
+	/**
+	 * @since 3.0
+	 *
+	 * @param Cache $cache
+	 * @param callableUpdate $callableUpdate
+	 */
+	public function __construct( Cache $cache, CallableUpdate $callableUpdate ) {
+		$this->cache = $cache;
+		$this->callableUpdate = $callableUpdate;
+	}
+
+	/**
+	 * @since 3.0
+	 *
+	 * @param DIWikiPage $subject
+	 *
+	 * @return string
+	 */
+	public static function makeKey( $subject ) {
+
+		$segments = [];
+
+		if ( $subject instanceof DIWikiPage || $subject instanceof Title ) {
+			$segments = [ $subject->getDBKey(), $subject->getNamespace(), $subject->getInterwiki(), '' ];
+		}
+
+		return smwfCacheKey(
+			self::CACHE_NAMESPACE,
+			[
+				implode( '#', $segments ),
+				self::VERSION
+			]
+		);
+	}
+
+	/**
+	 * @since 3.0
+	 *
+	 * @param array $hashList
+	 * @param integer|true $revID
+	 */
+	public function updateFromList( array $hashList, $revID = true ) {
+
+		foreach ( $hashList as $hash ) {
+
+			$key = smwfCacheKey(
+				self::CACHE_NAMESPACE,
+				[
+					$hash,
+					self::VERSION
+				]
+			);
+
+			$this->cache->save( $key, $revID );
+		}
+
+	}
+
+	/**
+	 * @since 3.0
+	 *
+	 * @param DIWikiPage|Title $subject
+	 * @param integer|true $revID
+	 */
+	public function update( $subject, $revID = true ) {
+		$this->cache->save( self::makeKey( $subject ), $revID );
+	}
+
+	/**
+	 * @since 3.0
+	 *
+	 * @param DIWikiPage|Title $subject
+	 */
+	public function has( $subject ) {
+		return $this->cache->contains( self::makeKey( $subject ) ) === true;
+	}
+
+	/**
+	 * @since 3.0
+	 *
+	 * @param DIWikiPage $subject
+	 */
+	public function delete( $subject ) {
+
+		if ( !$subject instanceof Title && !$subject instanceof DIWikiPage ) {
+			throw new RuntimeException( "Invalid subject instance" );
+		}
+
+		// Avoid interference with any other process during a preOutputCommit
+		// stage especially when CACHE_DB is used as instance
+		$this->callableUpdate->setCallback( function() use( $subject ) {
+			$this->cache->delete( self::makeKey( $subject ) );
+		} );
+
+		$this->callableUpdate->setOrigin(
+			[
+				__METHOD__,
+				$subject->getDBKey() . '#' . $subject->getNamespace() . '#' . $subject->getInterwiki()
+			]
+		);
+
+		$this->callableUpdate->pushUpdate();
+	}
+
+}