SMW\Notifications\ChangeNotification\UserLocator

Complexity

Total Complexity

5

Size/Duplication

Total Lines	81
Duplicated Lines	0 %

Coupling/Cohesion

Components	0
Dependencies	4

Test Coverage

Coverage

100%

Importance

Changes

0

1 Method

Rating	Name	Duplication	Size	Complexity
B	doLocateEventSubscribers()	0	66	5

<?php

namespace SMW\Notifications\ChangeNotification;

use SMW\ApplicationFactory;
use SMW\Notifications\IteratorFactory;
use EchoEvent;
use User;

/**
 * @license GNU GPL v2+
 * @since 1.0
 *
 * @author mwjames
 */
class UserLocator {

	/**
	 * Find out for which of the properties that have changed the assigned group
	 * and for each group do locate its members(users).
	 *
	 * @see EchoUserLocator::locateArticleCreator
	 * @since 1.0
	 *
	 * @param EchoEvent $event
	 *
	 * @return User[]|\Iterator
	 */
	public static function doLocateEventSubscribers( EchoEvent $event ) {

		$start = microtime( true );
		$extra = $event->getExtra();

		if ( !isset( $extra['subject'] ) || !isset( $extra['properties'] ) ) {
			return array();
		}

		$store = ApplicationFactory::getInstance()->getStore();
		$iteratorFactory = new IteratorFactory();

		$notificationGroupsLocator = new NotificationGroupsLocator(
			$store
		);

		$subSemanticDataMatch = isset( $extra['subSemanticDataMatch'] ) ? $extra['subSemanticDataMatch'] : array();
		$type = $event->getType();

		if ( $type === ChangeNotificationFilter::SPECIFICATION_CHANGE ) {
			$groups = $notificationGroupsLocator->getSpecialGroupOnSpecificationChange();
		} else {
			// Find groups assigned to properties on a "lazy" request during the
			// iteration process
			$groups = $iteratorFactory->newMappingIterator(
				$extra['properties'],
				$notificationGroupsLocator->getNotificationsToGroupListAsCallback( $subSemanticDataMatch )
			);
		}

		$recursiveMembersIterator = $iteratorFactory->newRecursiveMembersIterator(
			$groups,
			$store
		);

		$agentName = $event->getAgent()->getName();

		$recursiveMembersIterator->notifyAgent(
			$event->getExtraParam( 'notifyAgent', false )
		);

		$recursiveMembersIterator->setAgentName(
			$agentName
		);

		$recursiveMembersIterator->setSubject(
			$extra['subject']
		);

		// Returns a flat array when iterating over the children
		$recursiveIteratorIterator = $iteratorFactory->newRecursiveIteratorIterator(
			$recursiveMembersIterator
		);

		wfDebugLog( 'smw', 'Agent ' . $agentName );

		// Access the user only on request by the iterator
		$mappingIterator = $iteratorFactory->newMappingIterator( $recursiveIteratorIterator, function( $recipient ) {
			wfDebugLog( 'smw', 'User ' . $recipient );
			return User::newFromName( $recipient, false );
		} );

		wfDebugLog( 'smw', __METHOD__ . ' procTime (sec): ' . round( ( microtime( true ) - $start ), 7 ) );

		return $mappingIterator;
	}

}