RecentChangeNotifier.php

Go to the documentation of this file.

<?php
namespace MediaWiki\RecentChanges;
 
use MediaWiki\Config\Config;
use MediaWiki\HookContainer\HookRunner;
use MediaWiki\MainConfigNames;
use MediaWiki\MediaWikiServices;
use MediaWiki\Notification\RecipientSet;
use MediaWiki\Permissions\Authority;
use MediaWiki\Title\Title;
use MediaWiki\User\User;
use MediaWiki\User\UserArray;
use MediaWiki\User\UserIdentity;
use UnexpectedValueException;
 
class RecentChangeNotifier {
 
    protected string $pageStatus = '';
 
    public function getPageStatus() {
        wfDeprecated( __METHOD__, '1.45' );
        return $this->pageStatus;
    }
 
    public function notifyOnPageChange(
        RecentChange $recentChange
    ): bool {
        // Never send an RC notification email about categorization changes
        if ( $recentChange->getAttribute( 'rc_source' ) === RecentChange::SRC_CATEGORIZE ) {
            return false;
        }
        $mwServices = MediaWikiServices::getInstance();
        $config = $mwServices->getMainConfig();
 
        $minorEdit = $recentChange->getAttribute( 'rc_minor' );
        $editor = $mwServices->getUserFactory()
            ->newFromUserIdentity( $recentChange->getPerformerIdentity() );
 
        $title = Title::castFromPageReference( $recentChange->getPage() );
        if ( $title === null || $title->getNamespace() < 0 ) {
            return false;
        }
 
        // update wl_notificationtimestamp for watchers
        $watchers = [];
        if ( $config->get( MainConfigNames::EnotifWatchlist ) || $config->get( MainConfigNames::ShowUpdatedMarker ) ) {
            $watchers = $mwServices->getWatchedItemStore()->updateNotificationTimestamp(
                $editor,
                $title,
                $recentChange->getAttribute( 'rc_timestamp' )
            );
        }
 
        $sendNotification = $this->shouldSendNotification(
            $editor, $title, $watchers, $minorEdit, $config
        );
 
        if ( $sendNotification ) {
            $mwServices->getJobQueueGroup()->lazyPush( new RecentChangeNotifyJob(
                $title,
                [
                    'editor' => $editor->getName(),
                    'editorID' => $editor->getId(),
                    'watchers' => $watchers,
                    'pageStatus' => $recentChange->mExtra['pageStatus'] ?? 'changed',
                    'rc_id' => $recentChange->getAttribute( 'rc_id' ),
                ],
                $mwServices->getRecentChangeLookup()
            ) );
        }
 
        return $sendNotification;
    }
 
    private function shouldSendNotification(
        User $editor,
        Title $title,
        array $watchers,
        bool $minorEdit,
        Config $config
    ): bool {
        // Don't send notifications for bots
        if ( $editor->isBot() ) {
            return false;
        }
 
        // If someone is watching the page or there are users notified on all changes
        if ( count( $watchers ) ||
            count( $config->get( MainConfigNames::UsersNotifiedOnAllChanges ) ) ) {
            return true;
        }
 
        // if it's a talk page with an applicable notification.
        if ( !$minorEdit ||
            ( $config->get( MainConfigNames::EnotifMinorEdits ) &&
                !$editor->isAllowed( 'nominornewtalk' ) )
        ) {
            return $this->canSendUserTalkEmail( $editor, $title, $minorEdit );
        }
 
        return false;
    }
 
    public function actuallyNotifyOnPageChange(
        Authority $editor,
        $title,
        RecentChange $recentChange,
        array $watchers,
        $pageStatus = 'changed'
    ) {
        # we use $wgPasswordSender as sender's address
        $mwServices = MediaWikiServices::getInstance();
        $config = $mwServices->getMainConfig();
        $notifService = $mwServices->getNotificationService();
        $userFactory = $mwServices->getUserFactory();
        $hookRunner = new HookRunner( $mwServices->getHookContainer() );
 
        $minorEdit = $recentChange->getAttribute( 'rc_minor' );
        # The following code is only run, if several conditions are met:
        # 1. RecentChangeNotifier for pages (other than user_talk pages) must be enabled
        # 2. minor edits (changes) are only regarded if the global flag indicates so
        $this->pageStatus = $pageStatus;
        $formattedPageStatus = [ 'deleted', 'created', 'moved', 'restored', 'changed' ];
 
        $hookRunner->onUpdateUserMailerFormattedPageStatus( $formattedPageStatus );
        if ( !in_array( $this->pageStatus, $formattedPageStatus ) ) {
            throw new UnexpectedValueException( 'Not a valid page status!' );
        }
        $agent = $mwServices->getUserFactory()->newFromAuthority( $editor );
 
        $userTalkId = false;
        if ( !$minorEdit ||
            ( $config->get( MainConfigNames::EnotifMinorEdits ) &&
                !$editor->isAllowed( 'nominornewtalk' ) )
        ) {
            if ( $config->get( MainConfigNames::EnotifUserTalk )
                && $title->getNamespace() === NS_USER_TALK
                && $this->canSendUserTalkEmail( $editor->getUser(), $title, $minorEdit )
            ) {
                $targetUser = $userFactory->newFromName( $title->getText() );
                if ( $targetUser ) {
                    $talkNotification = new RecentChangeNotification(
                        $agent,
                        $title,
                        $recentChange,
                        $pageStatus,
                        RecentChangeNotification::TALK_NOTIFICATION
                    );
                    $notifService->notify( $talkNotification, new RecipientSet( [ $targetUser ] ) );
                    $userTalkId = $targetUser->getId();
                }
            }
 
            if ( $config->get( MainConfigNames::EnotifWatchlist ) ) {
                $userOptionsLookup = $mwServices->getUserOptionsLookup();
                // Send updates to watchers other than the current editor
                // and don't send to watchers who are blocked and cannot login
                $userArray = UserArray::newFromIDs( $watchers );
                $recipients = new RecipientSet( [] );
                foreach ( $userArray as $watchingUser ) {
                    if ( $userOptionsLookup->getOption( $watchingUser, 'enotifwatchlistpages' )
                        && ( !$minorEdit || $userOptionsLookup->getOption( $watchingUser, 'enotifminoredits' ) )
                        && $watchingUser->getId() != $userTalkId
                        && !in_array( $watchingUser->getName(),
                            $config->get( MainConfigNames::UsersNotifiedOnAllChanges ) )
                        // @TODO Partial blocks should not prevent the user from logging in.
                        //       see: https://phabricator.wikimedia.org/T208895
                        && !( $config->get( MainConfigNames::BlockDisablesLogin ) &&
                            $watchingUser->getBlock() )
                        && $hookRunner->onSendWatchlistEmailNotification( $watchingUser, $title, $this )
                    ) {
                        $recipients->addRecipient( $watchingUser );
                    }
                }
                if ( count( $recipients ) !== 0 ) {
                    $talkNotification = new RecentChangeNotification(
                        $agent,
                        $title,
                        $recentChange,
                        $pageStatus,
                        RecentChangeNotification::WATCHLIST_NOTIFICATION
                    );
                    $notifService->notify( $talkNotification, $recipients );
                }
            }
        }
 
        foreach ( $config->get( MainConfigNames::UsersNotifiedOnAllChanges ) as $name ) {
            $admins = [];
            if ( $editor->getUser()->getName() == $name ) {
                // No point notifying the user that actually made the change!
                continue;
            }
            $user = $userFactory->newFromName( $name );
            if ( $user instanceof User ) {
                $admins[] = $user;
            }
            $notifService->notify(
                new RecentChangeNotification(
                    $agent,
                    $title,
                    $recentChange,
                    $pageStatus,
                    RecentChangeNotification::ADMIN_NOTIFICATION
                ),
                new RecipientSet( $admins )
            );
 
        }
    }
 
    private function canSendUserTalkEmail( UserIdentity $editor, $title, $minorEdit ) {
        $services = MediaWikiServices::getInstance();
        $config = $services->getMainConfig();
 
        if ( !$config->get( MainConfigNames::EnotifUserTalk ) || $title->getNamespace() !== NS_USER_TALK ) {
            return false;
        }
 
        $userOptionsLookup = $services->getUserOptionsLookup();
        $targetUser = User::newFromName( $title->getText() );
 
        if ( !$targetUser || $targetUser->isAnon() ) {
            wfDebug( __METHOD__ . ": user talk page edited, but user does not exist" );
        } elseif ( $targetUser->getId() == $editor->getId() ) {
            wfDebug( __METHOD__ . ": user edited their own talk page, no notification sent" );
        } elseif ( $targetUser->isTemp() ) {
            wfDebug( __METHOD__ . ": talk page owner is a temporary user so doesn't have email" );
        } elseif ( $config->get( MainConfigNames::BlockDisablesLogin ) &&
            $targetUser->getBlock()
        ) {
            // @TODO Partial blocks should not prevent the user from logging in.
            //       see: https://phabricator.wikimedia.org/T208895
            wfDebug( __METHOD__ . ": talk page owner is blocked and cannot login, no notification sent" );
        } elseif ( $userOptionsLookup->getOption( $targetUser, 'enotifusertalkpages' )
            && ( !$minorEdit || $userOptionsLookup->getOption( $targetUser, 'enotifminoredits' ) )
        ) {
            if ( !( new HookRunner( $services->getHookContainer() ) )
                ->onAbortTalkPageEmailNotification( $targetUser, $title )
            ) {
                wfDebug( __METHOD__ . ": talk page update notification is aborted for this user" );
            } else {
                wfDebug( __METHOD__ . ": sending talk page update notification" );
                return true;
            }
        } else {
            wfDebug( __METHOD__ . ": talk page owner doesn't want notifications" );
        }
        return false;
    }
 
}
 
class_alias( RecentChangeNotifier::class, 'EmailNotification' );