| Server IP : 167.235.224.122 / Your IP : 216.73.216.110 Web Server : Apache/2.4.58 (Ubuntu) System : Linux newplayground 6.8.0-136-generic #136-Ubuntu SMP PREEMPT_DYNAMIC Wed Jul 1 21:33:11 UTC 2026 aarch64 User : deploy ( 1000) PHP Version : 8.4.23 Disable Function : NONE MySQL : OFF | cURL : ON | WGET : ON | Perl : ON | Python : OFF | Sudo : ON | Pkexec : OFF Directory : /var/www/html/wiki/extensions/SemanticMediaWiki/src/Property/ |
Upload File : |
<?php
namespace SMW\Property;
use SMW\DIProperty;
use SMW\DIWikiPage;
use SMW\MediaWiki\Jobs\ChangePropagationDispatchJob;
use SMW\SemanticData;
use SMW\SerializerFactory;
use SMW\Store;
use SMWDataItem;
use SMWDIBlob as DIBlob;
/**
* Before a new set of data (type, constraints etc.) is stored about a property
* the class tries to compare old and new specifications (values about that property)
* and notifies a dispatcher about a change.
*
* @license GPL-2.0-or-later
* @since 1.9
*
* @author mwjames
* @author Markus Krötzsch
*/
class ChangePropagationNotifier {
/**
* @var Store
*/
private $store;
/**
* @var SerializerFactory
*/
private $serializerFactory;
/**
* @var array
*/
private $propertyList = [];
/**
* @var bool
*/
private $hasDiff = false;
/**
* @var bool
*/
private $isTypePropagation = false;
/**
* @var bool
*/
private $isCommandLineMode = false;
/**
* @since 1.9
*
* @param Store $store
* @param SerializerFactory $serializerFactory
*/
public function __construct( Store $store, SerializerFactory $serializerFactory ) {
$this->store = $store;
$this->serializerFactory = $serializerFactory;
}
/**
* @since 2.5
*
* @param array $propertyList
*/
public function setPropertyList( array $propertyList ) {
$this->propertyList = $propertyList;
}
/**
* @see https://www.mediawiki.org/wiki/Manual:$wgCommandLineMode
* Indicates whether MW is running in command-line mode.
*
* @since 3.0
*
* @param bool $isCommandLineMode
*/
public function isCommandLineMode( $isCommandLineMode ) {
$this->isCommandLineMode = $isCommandLineMode;
}
/**
* @since 1.9
*
* @return bool
*/
public function hasDiff() {
return $this->hasDiff;
}
/**
* @since 2.5
*
* @param DIWikiPage $subject
*/
public function notify( DIWikiPage $subject ) {
if ( !$this->hasDiff() || !$this->inNamespace( $subject ) ) {
return false;
}
$params = [];
if ( $this->isTypePropagation ) {
$params['isTypePropagation'] = true;
}
return ChangePropagationDispatchJob::planAsJob( $subject, $params );
}
/**
* @since 3.1
*
* @param DIWikiPage $subject
*
* @return bool
*/
public function inNamespace( DIWikiPage $subject ) {
return $subject->getNamespace() === SMW_NS_PROPERTY || $subject->getNamespace() === NS_CATEGORY;
}
/**
* Compare and detect differences between the invoked semantic data
* and the current stored data
*
* @note Compare on extra properties from `smwgChangePropagationWatchlist`
* (e.g '_PLIST') to find a possible specification change
*
* @since 1.9
*/
public function checkAndNotify( SemanticData &$semanticData ) {
if ( !$this->inNamespace( $semanticData->getSubject() ) ) {
return;
}
$this->hasDiff = false;
// Check the type first
$propertyList = array_merge(
[
'_TYPE',
'_CONV',
'_UNIT',
'_REDI'
],
$this->propertyList
);
foreach ( $propertyList as $key ) {
// No need to keep comparing once a diff has been
// detected
if ( $this->hasDiff() ) {
break;
}
$this->doCompare( $semanticData, $key );
}
$this->doNotifyAndPostpone( $semanticData );
}
private function doCompare( $semanticData, $key ) {
$property = new DIProperty( $key );
$newValues = $semanticData->getPropertyValues( $property );
$oldValues = $this->store->getPropertyValues(
$semanticData->getSubject(),
$property
);
$this->setDiff( !$this->isEqual( $oldValues, $newValues ), $key );
}
private function setDiff( $hasDiff, $key ) {
if ( !$hasDiff || $this->hasDiff ) {
return;
}
$this->hasDiff = true;
$this->isTypePropagation = $key === '_TYPE';
}
/**
* Helper function that compares two arrays of data values to check whether
* they contain the same content. Returns true if the two arrays contain the
* same data values (irrespective of their order), false otherwise.
*
* @param SMWDataItem[] $oldDataValue
* @param SMWDataItem[] $newDataValue
*
* @return bool
*/
private function isEqual( array $oldDataValue, array $newDataValue ) {
// The hashes of all values of both arrays are taken, then sorted
// and finally concatenated, thus creating one long hash out of each
// of the data value arrays. These are compared.
$values = [];
foreach ( $oldDataValue as $v ) {
$values[] = htmlspecialchars_decode( $v->getHash() );
}
sort( $values );
$oldDataValueHash = implode( '___', $values );
$values = [];
foreach ( $newDataValue as $v ) {
$values[] = htmlspecialchars_decode( $v->getHash() );
}
sort( $values );
$newDataValueHash = implode( '___', $values );
return $oldDataValueHash == $newDataValueHash;
}
private function doNotifyAndPostpone( SemanticData &$semanticData ) {
if ( !$this->hasDiff() ) {
return;
}
$this->notify( $semanticData->getSubject() );
// If executed from the commandLine (cronJob etc.), do not
// suspend the update
if ( $this->isCommandLineMode === true ) {
return;
}
$previous = $this->store->getSemanticData(
$semanticData->getSubject()
);
$semanticDataSerializer = $this->serializerFactory->newSemanticDataSerializer();
$new = $semanticDataSerializer->serialize(
$semanticData
);
// Encode and store the new version of the SemanticData and suspend
// the update until ChangePropagationDispatchJob was able to select
// all connected entities
$previous->addPropertyObjectValue(
new DIProperty( DIProperty::TYPE_CHANGE_PROP ),
new DIBlob( json_encode( $new ) )
);
$semanticData = $previous;
}
}