wikimedia/mediawiki-extensions-Wikibase

<?php

namespace Wikibase\Client\RecentChanges;

use RecentChange;
use Wikimedia\Rdbms\SessionConsistentConnectionManager;

/**
 * @license GPL-2.0-or-later
 * @author Katie Filbert < aude.wiki@gmail.com >
 * @author Daniel Kinzler
 */
class RecentChangesFinder {

    /**
     * @var SessionConsistentConnectionManager
     */
    private $connectionManager;

    public function __construct( SessionConsistentConnectionManager $connectionManager ) {
        $this->connectionManager = $connectionManager;
    }

    /**
     * Checks if a recent change entry already exists in the recentchanges table and returns its id.
     *
     * @param RecentChange $change
     *
     * @return int|null
     */
    public function getRecentChangeId( RecentChange $change ) {
        $attribs = $change->getAttributes();

        //XXX: need to check master?
        $db = $this->connectionManager->getReadConnection();

        $res = $db->newSelectQueryBuilder()
            ->select( [ 'rc_id', 'rc_params' ] )
            ->from( 'recentchanges' )
            ->where( [
                'rc_namespace' => $attribs['rc_namespace'],
                'rc_title' => $attribs['rc_title'],
                'rc_timestamp' => $db->timestamp( $attribs['rc_timestamp'] ),
                'rc_source' => RecentChangeFactory::SRC_WIKIBASE,
            ] )
            ->caller( __METHOD__ )
            ->fetchResultSet();

        if ( $res->numRows() === 0 ) {
            return null;
        }

        $changeMetadata = $this->getMetadata( $attribs['rc_params'] );

        $changeRevId = $changeMetadata[ 'rev_id' ];
        $changeParentId = $changeMetadata[ 'parent_id' ];

        foreach ( $res as $rc ) {
            $metadata = $this->getMetadata( $rc->rc_params );

            $parent_id = $metadata[ 'parent_id' ];
            $rev_id = $metadata[ 'rev_id' ];

            if ( $rev_id === $changeRevId
                && $parent_id === $changeParentId ) {
                return (int)$rc->rc_id;
            }
        }

        return null;
    }

    /**
     * Extracts the metadata array from the value of an rc_params field.
     *
     * @param array|string $rc_params
     *
     * @return array
     */
    private function getMetadata( $rc_params ) {
        if ( is_string( $rc_params ) ) {
            $rc_params = unserialize( $rc_params );
        }

        if ( is_array( $rc_params ) && array_key_exists( 'wikibase-repo-change', $rc_params ) ) {
            $metadata = $rc_params['wikibase-repo-change'];
        } else {
            $metadata = [];
        }

        $metadata = array_merge( [ 'parent_id' => 0, 'rev_id' => 0 ], $metadata );
        return $metadata;
    }

}