1 files changed, 190 insertions, 0 deletions
diff --git a/www/wiki/extensions/SemanticMediaWiki/src/EventListenerRegistry.php b/www/wiki/extensions/SemanticMediaWiki/src/EventListenerRegistry.php
new file mode 100644
index 00000000..28e4a2c1
--- /dev/null
+++ b/www/wiki/extensions/SemanticMediaWiki/src/EventListenerRegistry.php
@@ -0,0 +1,190 @@
+<?php
+
+namespace SMW;
+
+use Onoi\EventDispatcher\EventListenerCollection;
+use SMW\Query\QueryComparator;
+use SMW\SQLStore\QueryDependency\DependencyLinksUpdateJournal;
+use SMWExporter as Exporter;
+
+/**
+ * @license GNU GPL v2+
+ * @since 2.2
+ *
+ * @author mwjames
+ */
+class EventListenerRegistry implements EventListenerCollection {
+
+	/**
+	 * @var EventListenerCollection
+	 */
+	private $eventListenerCollection = null;
+
+	/**
+	 * @var LoggerInterface
+	 */
+	private $logger;
+
+	/**
+	 * @since 2.2
+	 *
+	 * @param EventListenerCollection $eventListenerCollection
+	 */
+	public function __construct( EventListenerCollection $eventListenerCollection ) {
+		$this->eventListenerCollection = $eventListenerCollection;
+	}
+
+	/**
+	 * @see  EventListenerCollection::getCollection
+	 *
+	 * @since 2.2
+	 */
+	public function getCollection() {
+		return $this->addListenersToCollection()->getCollection();
+	}
+
+	private function addListenersToCollection() {
+
+		$this->logger = ApplicationFactory::getInstance()->getMediaWikiLogger();
+
+		/**
+		 * Emitted during UpdateJob, ArticlePurge
+		 */
+		$this->eventListenerCollection->registerCallback(
+			'factbox.cache.delete', function( $dispatchContext ) {
+
+				if ( $dispatchContext->has( 'subject' ) ) {
+					$title = $dispatchContext->get( 'subject' )->getTitle();
+				} else {
+					$title = $dispatchContext->get( 'title' );
+				}
+
+				$applicationFactory = ApplicationFactory::getInstance();
+
+				$applicationFactory->getCache()->delete(
+					\SMW\Factbox\CachedFactbox::makeCacheKey( $title )
+				);
+			}
+		);
+
+		$this->eventListenerCollection->registerCallback(
+			'exporter.reset', function() {
+				Exporter::getInstance()->clear();
+			}
+		);
+
+		$this->eventListenerCollection->registerCallback(
+			'query.comparator.reset', function() {
+				QueryComparator::getInstance()->clear();
+			}
+		);
+
+		/**
+		 * Emitted during UpdateJob
+		 */
+		$this->eventListenerCollection->registerCallback(
+			'cached.propertyvalues.prefetcher.reset', function( $dispatchContext ) {
+
+				if ( $dispatchContext->has( 'title' ) ) {
+					$subject = DIWikiPage::newFromTitle( $dispatchContext->get( 'title' ) );
+				} else{
+					$subject = $dispatchContext->get( 'subject' );
+				}
+
+				$applicationFactory = ApplicationFactory::getInstance();
+
+				$logContext = [
+					'role' => 'developer',
+					'event' => 'cached.propertyvalues.prefetcher.reset',
+					'origin' => $subject
+				];
+
+				$this->logger->info( '[Event] {event}: {origin}', $logContext );
+
+				$applicationFactory->singleton( 'CachedPropertyValuesPrefetcher' )->resetCacheBy(
+					$subject
+				);
+
+				$dispatchContext->set( 'propagationstop', true );
+			}
+		);
+
+		/**
+		 * Emitted during NewRevisionFromEditComplete, ArticleDelete, TitleMoveComplete,
+		 * PropertyTableIdReferenceDisposer, ArticlePurge
+		 */
+		$this->eventListenerCollection->registerCallback(
+			'cached.prefetcher.reset', function( $dispatchContext ) {
+
+				if ( $dispatchContext->has( 'title' ) ) {
+					$subject = DIWikiPage::newFromTitle( $dispatchContext->get( 'title' ) );
+				} else{
+					$subject = $dispatchContext->get( 'subject' );
+				}
+
+				$context = $dispatchContext->has( 'context' ) ? $dispatchContext->get( 'context' ) : '';
+
+				$applicationFactory = ApplicationFactory::getInstance();
+
+				$logContext = [
+					'role' => 'developer',
+					'event' => 'cached.prefetcher.reset',
+					'origin' => $subject
+				];
+
+				$this->logger->info( '[Event] {event}: {origin}', $logContext );
+
+				$applicationFactory->singleton( 'CachedPropertyValuesPrefetcher' )->resetCacheBy(
+					$subject
+				);
+
+				$applicationFactory->singleton( 'CachedQueryResultPrefetcher' )->resetCacheBy(
+					$subject,
+					$context
+				);
+
+				if ( $dispatchContext->has( 'ask' ) ) {
+					$applicationFactory->singleton( 'CachedQueryResultPrefetcher' )->resetCacheBy(
+						$dispatchContext->get( 'ask' ),
+						$context
+					);
+				}
+
+				$dispatchContext->set( 'propagationstop', true );
+			}
+		);
+
+		$this->registerStateChangeEvents();
+
+		return $this->eventListenerCollection;
+	}
+
+	private function registerStateChangeEvents() {
+
+		/**
+		 * Emitted during ArticleDelete
+		 */
+		$this->eventListenerCollection->registerCallback(
+			'cached.update.marker.delete', function( $dispatchContext ) {
+
+				$cache = ApplicationFactory::getInstance()->getCache();
+
+				if ( $dispatchContext->has( 'subject' ) ) {
+					$cache->delete(
+						DependencyLinksUpdateJournal::makeKey(
+							$dispatchContext->get( 'subject' )
+						)
+					);
+
+					$cache->delete(
+						smwfCacheKey(
+							ParserData::CACHE_NAMESPACE,
+							$dispatchContext->get( 'subject' )->getHash()
+						)
+					);
+				}
+			}
+		);
+	}
+
+}