DatabaseLogEntry.php

Go to the documentation of this file.

<?php
use Wikimedia\Rdbms\IDatabase;
 
class DatabaseLogEntry extends LogEntryBase {
 
    public static function getSelectQueryData() {
        $commentQuery = CommentStore::getStore()->getJoin( 'log_comment' );
        $actorQuery = ActorMigration::newMigration()->getJoin( 'log_user' );
 
        $tables = array_merge(
            [ 'logging' ], $commentQuery['tables'], $actorQuery['tables'], [ 'user' ]
        );
        $fields = [
            'log_id', 'log_type', 'log_action', 'log_timestamp',
            'log_namespace', 'log_title', // unused log_page
            'log_params', 'log_deleted',
            'user_id', 'user_name', 'user_editcount',
        ] + $commentQuery['fields'] + $actorQuery['fields'];
 
        $joins = [
            // IPs don't have an entry in user table
            'user' => [ 'LEFT JOIN', 'user_id=' . $actorQuery['fields']['log_user'] ],
        ] + $commentQuery['joins'] + $actorQuery['joins'];
 
        return [
            'tables' => $tables,
            'fields' => $fields,
            'conds' => [],
            'options' => [],
            'join_conds' => $joins,
        ];
    }
 
    public static function newFromRow( $row ) {
        $row = (object)$row;
        if ( isset( $row->rc_logid ) ) {
            return new RCDatabaseLogEntry( $row );
        } else {
            return new self( $row );
        }
    }
 
    public static function newFromId( $id, IDatabase $db ) {
        $queryInfo = self::getSelectQueryData();
        $queryInfo['conds'] += [ 'log_id' => $id ];
        $row = $db->selectRow(
            $queryInfo['tables'],
            $queryInfo['fields'],
            $queryInfo['conds'],
            __METHOD__,
            $queryInfo['options'],
            $queryInfo['join_conds']
        );
        if ( !$row ) {
            return null;
        }
        return self::newFromRow( $row );
    }
 
    protected $row;
 
    protected $performer;
 
    protected $params;
 
    protected $revId = null;
 
    protected $legacy;
 
    protected function __construct( $row ) {
        $this->row = $row;
    }
 
    public function getId() {
        return (int)$this->row->log_id;
    }
 
    protected function getRawParameters() {
        return $this->row->log_params;
    }
 
    public function isLegacy() {
        // This extracts the property
        $this->getParameters();
        return $this->legacy;
    }
 
    public function getType() {
        return $this->row->log_type;
    }
 
    public function getSubtype() {
        return $this->row->log_action;
    }
 
    public function getParameters() {
        if ( !isset( $this->params ) ) {
            $blob = $this->getRawParameters();
            Wikimedia\suppressWarnings();
            $params = LogEntryBase::extractParams( $blob );
            Wikimedia\restoreWarnings();
            if ( $params !== false ) {
                $this->params = $params;
                $this->legacy = false;
            } else {
                $this->params = LogPage::extractParams( $blob );
                $this->legacy = true;
            }
 
            if ( isset( $this->params['associated_rev_id'] ) ) {
                $this->revId = $this->params['associated_rev_id'];
                unset( $this->params['associated_rev_id'] );
            }
        }
 
        return $this->params;
    }
 
    public function getAssociatedRevId() {
        // This extracts the property
        $this->getParameters();
        return $this->revId;
    }
 
    public function getPerformer() {
        if ( !$this->performer ) {
            $actorId = isset( $this->row->log_actor ) ? (int)$this->row->log_actor : 0;
            $userId = (int)$this->row->log_user;
            if ( $userId !== 0 || $actorId !== 0 ) {
                // logged-in users
                if ( isset( $this->row->user_name ) ) {
                    $this->performer = User::newFromRow( $this->row );
                } elseif ( $actorId !== 0 ) {
                    $this->performer = User::newFromActorId( $actorId );
                } else {
                    $this->performer = User::newFromId( $userId );
                }
            } else {
                // IP users
                $userText = $this->row->log_user_text;
                $this->performer = User::newFromName( $userText, false );
            }
        }
 
        return $this->performer;
    }
 
    public function getTarget() {
        $namespace = $this->row->log_namespace;
        $page = $this->row->log_title;
        return Title::makeTitle( $namespace, $page );
    }
 
    public function getTimestamp() {
        return wfTimestamp( TS_MW, $this->row->log_timestamp );
    }
 
    public function getComment() {
        return CommentStore::getStore()->getComment( 'log_comment', $this->row )->text;
    }
 
    public function getDeleted() {
        return $this->row->log_deleted;
    }
}