SiteStats.php

Go to the documentation of this file.

<?php
use Wikimedia\Rdbms\Database;
use Wikimedia\Rdbms\IDatabase;
use MediaWiki\MediaWikiServices;
use Wikimedia\Rdbms\LoadBalancer;
 
class SiteStats {
    private static $row;
 
    public static function unload() {
        self::$row = null;
    }
 
    protected static function load() {
        if ( self::$row === null ) {
            self::$row = self::loadAndLazyInit();
        }
    }
 
    protected static function loadAndLazyInit() {
        $config = MediaWikiServices::getInstance()->getMainConfig();
 
        $lb = self::getLB();
        $dbr = $lb->getConnection( DB_REPLICA );
        wfDebug( __METHOD__ . ": reading site_stats from replica DB\n" );
        $row = self::doLoadFromDB( $dbr );
 
        if ( !self::isRowSane( $row ) && $lb->hasOrMadeRecentMasterChanges() ) {
            // Might have just been initialized during this request? Underflow?
            wfDebug( __METHOD__ . ": site_stats damaged or missing on replica DB\n" );
            $row = self::doLoadFromDB( $lb->getConnection( DB_MASTER ) );
        }
 
        if ( !self::isRowSane( $row ) ) {
            if ( $config->get( 'MiserMode' ) ) {
                // Start off with all zeroes, assuming that this is a new wiki or any
                // repopulations where done manually via script.
                SiteStatsInit::doPlaceholderInit();
            } else {
                // Normally the site_stats table is initialized at install time.
                // Some manual construction scenarios may leave the table empty or
                // broken, however, for instance when importing from a dump into a
                // clean schema with mwdumper.
                wfDebug( __METHOD__ . ": initializing damaged or missing site_stats\n" );
                SiteStatsInit::doAllAndCommit( $dbr );
            }
 
            $row = self::doLoadFromDB( $lb->getConnection( DB_MASTER ) );
        }
 
        if ( !self::isRowSane( $row ) ) {
            wfDebug( __METHOD__ . ": site_stats persistently nonsensical o_O\n" );
            // Always return a row-like object
            $row = self::salvageInsaneRow( $row );
        }
 
        return $row;
    }
 
    public static function edits() {
        self::load();
 
        return (int)self::$row->ss_total_edits;
    }
 
    public static function articles() {
        self::load();
 
        return (int)self::$row->ss_good_articles;
    }
 
    public static function pages() {
        self::load();
 
        return (int)self::$row->ss_total_pages;
    }
 
    public static function users() {
        self::load();
 
        return (int)self::$row->ss_users;
    }
 
    public static function activeUsers() {
        self::load();
 
        return (int)self::$row->ss_active_users;
    }
 
    public static function images() {
        self::load();
 
        return (int)self::$row->ss_images;
    }
 
    public static function numberingroup( $group ) {
        $cache = MediaWikiServices::getInstance()->getMainWANObjectCache();
        $fname = __METHOD__;
 
        return $cache->getWithSetCallback(
            $cache->makeKey( 'SiteStats', 'groupcounts', $group ),
            $cache::TTL_HOUR,
            function ( $oldValue, &$ttl, array &$setOpts ) use ( $group, $fname ) {
                $dbr = self::getLB()->getConnection( DB_REPLICA );
                $setOpts += Database::getCacheSetOptions( $dbr );
 
                return (int)$dbr->selectField(
                    'user_groups',
                    'COUNT(*)',
                    [
                        'ug_group' => $group,
                        'ug_expiry IS NULL OR ug_expiry >= ' . $dbr->addQuotes( $dbr->timestamp() )
                    ],
                    $fname
                );
            },
            [ 'pcTTL' => $cache::TTL_PROC_LONG ]
        );
    }
 
    public static function jobs() {
        $cache = MediaWikiServices::getInstance()->getMainWANObjectCache();
 
        return $cache->getWithSetCallback(
            $cache->makeKey( 'SiteStats', 'jobscount' ),
            $cache::TTL_MINUTE,
            function ( $oldValue, &$ttl, array &$setOpts ) {
                try{
                    $jobs = array_sum( JobQueueGroup::singleton()->getQueueSizes() );
                } catch ( JobQueueError $e ) {
                    $jobs = 0;
                }
                return $jobs;
            },
            [ 'pcTTL' => $cache::TTL_PROC_LONG ]
        );
    }
 
    public static function pagesInNs( $ns ) {
        $cache = MediaWikiServices::getInstance()->getMainWANObjectCache();
        $fname = __METHOD__;
 
        return $cache->getWithSetCallback(
            $cache->makeKey( 'SiteStats', 'page-in-namespace', $ns ),
            $cache::TTL_HOUR,
            function ( $oldValue, &$ttl, array &$setOpts ) use ( $ns, $fname ) {
                $dbr = self::getLB()->getConnection( DB_REPLICA );
                $setOpts += Database::getCacheSetOptions( $dbr );
 
                return (int)$dbr->selectField(
                    'page',
                    'COUNT(*)',
                    [ 'page_namespace' => $ns ],
                    $fname
                );
            },
            [ 'pcTTL' => $cache::TTL_PROC_LONG ]
        );
    }
 
    public static function selectFields() {
        return [
            'ss_total_edits',
            'ss_good_articles',
            'ss_total_pages',
            'ss_users',
            'ss_active_users',
            'ss_images',
        ];
    }
 
    private static function doLoadFromDB( IDatabase $db ) {
        return $db->selectRow(
            'site_stats',
            self::selectFields(),
            [ 'ss_row_id' => 1 ],
            __METHOD__
        );
    }
 
    private static function isRowSane( $row ) {
        if ( $row === false
            || $row->ss_total_pages < $row->ss_good_articles
            || $row->ss_total_edits < $row->ss_total_pages
        ) {
            return false;
        }
        // Now check for underflow/overflow
        foreach ( [
            'ss_total_edits',
            'ss_good_articles',
            'ss_total_pages',
            'ss_users',
            'ss_images',
        ] as $member ) {
            if ( $row->$member < 0 ) {
                return false;
            }
        }
 
        return true;
    }
 
    private static function salvageInsaneRow( $row ) {
        $map = $row ? (array)$row : [];
        // Fill in any missing values with zero
        $map += array_fill_keys( self::selectFields(), 0 );
        // Convert negative values to zero
        foreach ( $map as $field => $value ) {
            $map[$field] = max( 0, $value );
        }
 
        return (object)$row;
    }
 
    private static function getLB() {
        return MediaWikiServices::getInstance()->getDBLoadBalancer();
    }
}