MediaWiki  master
SiteStatsUpdate.php
Go to the documentation of this file.
1 <?php
23 
29  protected $edits = 0;
31  protected $pages = 0;
33  protected $articles = 0;
35  protected $users = 0;
37  protected $images = 0;
38 
40  private const COUNTERS = [
41  'ss_total_edits' => 'edits',
42  'ss_total_pages' => 'pages',
43  'ss_good_articles' => 'articles',
44  'ss_users' => 'users',
45  'ss_images' => 'images'
46  ];
47 
48  // @todo deprecate this constructor
49  function __construct( $views, $edits, $good, $pages = 0, $users = 0 ) {
50  $this->edits = $edits;
51  $this->articles = $good;
52  $this->pages = $pages;
53  $this->users = $users;
54  }
55 
56  public function merge( MergeableUpdate $update ) {
58  Assert::parameterType( __CLASS__, $update, '$update' );
59  '@phan-var SiteStatsUpdate $update';
60 
61  foreach ( self::COUNTERS as $field ) {
62  $this->$field += $update->$field;
63  }
64  }
65 
71  public static function factory( array $deltas ) {
72  $update = new self( 0, 0, 0 );
73 
74  foreach ( $deltas as $name => $unused ) {
75  if ( !in_array( $name, self::COUNTERS ) ) { // T187585
76  throw new UnexpectedValueException( __METHOD__ . ": no field called '$name'" );
77  }
78  }
79 
80  foreach ( self::COUNTERS as $field ) {
81  $update->$field = $deltas[$field] ?? 0;
82  }
83 
84  return $update;
85  }
86 
87  public function doUpdate() {
88  $services = MediaWikiServices::getInstance();
89  $stats = $services->getStatsdDataFactory();
90 
91  $deltaByType = [];
92  foreach ( self::COUNTERS as $type ) {
93  $delta = $this->$type;
94  if ( $delta !== 0 ) {
95  $stats->updateCount( "site.$type", $delta );
96  }
97  $deltaByType[$type] = $delta;
98  }
99 
100  ( new AutoCommitUpdate(
101  $services->getDBLoadBalancer()->getConnectionRef( DB_MASTER ),
102  __METHOD__,
103  function ( IDatabase $dbw, $fname ) use ( $deltaByType ) {
104  $set = [];
105  foreach ( self::COUNTERS as $column => $type ) {
106  $delta = (int)$deltaByType[$type];
107  if ( $delta > 0 ) {
108  $set[] = "$column=$column+" . abs( $delta );
109  } elseif ( $delta < 0 ) {
110  $set[] = "$column=$column-" . abs( $delta );
111  }
112  }
113 
114  if ( $set ) {
115  $dbw->update( 'site_stats', $set, [ 'ss_row_id' => 1 ], $fname );
116  }
117  }
118  ) )->doUpdate();
119 
120  // Invalidate cache used by parser functions
122  }
123 
128  public static function cacheUpdate( IDatabase $dbw ) {
129  $services = MediaWikiServices::getInstance();
130  $config = $services->getMainConfig();
131 
132  $dbr = $services->getDBLoadBalancer()->getConnectionRef( DB_REPLICA, 'vslow' );
133  # Get non-bot users than did some recent action other than making accounts.
134  # If account creation is included, the number gets inflated ~20+ fold on enwiki.
135  $rcQuery = RecentChange::getQueryInfo();
136  $activeUsers = $dbr->selectField(
137  $rcQuery['tables'],
138  'COUNT( DISTINCT ' . $rcQuery['fields']['rc_user_text'] . ' )',
139  [
140  'rc_type != ' . $dbr->addQuotes( RC_EXTERNAL ), // Exclude external (Wikidata)
141  ActorMigration::newMigration()->isNotAnon( $rcQuery['fields']['rc_user'] ),
142  'rc_bot' => 0,
143  'rc_log_type != ' . $dbr->addQuotes( 'newusers' ) . ' OR rc_log_type IS NULL',
144  'rc_timestamp >= ' . $dbr->addQuotes(
145  $dbr->timestamp( time() - $config->get( 'ActiveUserDays' ) * 24 * 3600 ) ),
146  ],
147  __METHOD__,
148  [],
149  $rcQuery['joins']
150  );
151  $dbw->update(
152  'site_stats',
153  [ 'ss_active_users' => intval( $activeUsers ) ],
154  [ 'ss_row_id' => 1 ],
155  __METHOD__
156  );
157 
158  // Invalid cache used by parser functions
160 
161  return $activeUsers;
162  }
163 }
merge(MergeableUpdate $update)
Merge this update with $update.
Interface that deferrable updates can implement to signal that updates can be combined.
const DB_MASTER
Definition: defines.php:26
static unload()
Trigger a reload next time a field is accessed.
Definition: SiteStats.php:38
__construct( $views, $edits, $good, $pages=0, $users=0)
static newMigration()
Static constructor.
static factory(array $deltas)
Basic database interface for live and lazy-loaded relation database handles.
Definition: IDatabase.php:38
static cacheUpdate(IDatabase $dbw)
doUpdate()
Perform the actual work.
static getQueryInfo()
Return the tables, fields, and join conditions to be selected to create a new recentchanges object...
const RC_EXTERNAL
Definition: Defines.php:125
const DB_REPLICA
Definition: defines.php:25
update( $table, $values, $conds, $fname=__METHOD__, $options=[])
UPDATE wrapper.