mediawiki-extensions-DiscussionTools/includes/Hooks/DataUpdatesHooks.php

<?php
/**
 * DiscussionTools data updates hooks
 *
 * @file
 * @ingroup Extensions
 * @license MIT
 */

namespace MediaWiki\Extension\DiscussionTools\Hooks;

use MediaWiki\Deferred\DeferrableUpdate;
use MediaWiki\Deferred\MWCallableUpdate;
use MediaWiki\Extension\DiscussionTools\ThreadItemStore;
use MediaWiki\Revision\RenderedRevision;
use MediaWiki\Storage\Hook\RevisionDataUpdatesHook;
use MediaWiki\Title\Title;
use MWExceptionHandler;
use Throwable;

class DataUpdatesHooks implements RevisionDataUpdatesHook {

	private ThreadItemStore $threadItemStore;

	public function __construct(
		ThreadItemStore $threadItemStore
	) {
		$this->threadItemStore = $threadItemStore;
	}

	/**
	 * @param Title $title
	 * @param RenderedRevision $renderedRevision
	 * @param DeferrableUpdate[] &$updates
	 * @return bool|void
	 */
	public function onRevisionDataUpdates( $title, $renderedRevision, &$updates ) {
		// This doesn't trigger on action=purge, only on automatic purge after editing a template or
		// transcluded page, and API action=purge&forcelinkupdate=1.

		// TODO: Deduplicate the thread-item-processing done here with the Echo hook
		// (which thread-item-processes the current and previous revisions).
		$rev = $renderedRevision->getRevision();
		if ( HookUtils::isAvailableForTitle( $title ) ) {
			$method = __METHOD__;
			$updates[] = new MWCallableUpdate( function () use ( $rev, $method ) {
				try {
					$threadItemSet = HookUtils::parseRevisionParsoidHtml( $rev, $method );
					if ( !$this->threadItemStore->isDisabled() ) {
						$this->threadItemStore->insertThreadItems( $rev, $threadItemSet );
					}
				} catch ( Throwable $e ) {
					// Catch errors, so that they don't cause other updates to fail (T315383), but log them.
					MWExceptionHandler::logException( $e );
				}
			}, __METHOD__ );
		}
	}
}