X-Git-Url: http://git.cyclocoop.org/?a=blobdiff_plain;f=includes%2FArticle.php;h=677b163cd990d5329b805810b113bc5748497096;hb=5698c6bcc77f6527d7eac5af5658b92e871f0ffd;hp=f9d076d4ef85958e1d855ff9c6339b11c852de9d;hpb=e8c1b6c3167be79d4f3df798316cf62faf5f72c1;p=lhc%2Fweb%2Fwiklou.git diff --git a/includes/Article.php b/includes/Article.php index f9d076d4ef..677b163cd9 100644 --- a/includes/Article.php +++ b/includes/Article.php @@ -1,11 +1,17 @@ mTitle =& $title; $this->clear(); } - - /* private */ function clear() - { + + /* private */ function clear() { $this->mContentLoaded = false; $this->mCurID = $this->mUser = $this->mCounter = -1; # Not loaded $this->mRedirectedFrom = $this->mUserText = - $this->mTimestamp = $this->mComment = $this->mFileCache = ""; + $this->mTimestamp = $this->mComment = $this->mFileCache = ''; $this->mCountAdjustment = 0; - $this->mTouched = "19700101000000"; + $this->mTouched = '19700101000000'; } - /* static */ function getRevisionText( $row, $prefix = "old_" ) { - # Deal with optional compression of archived pages. - # This can be done periodically via maintenance/compressOld.php, and - # as pages are saved if $wgCompressRevisions is set. - $text = $prefix . "text"; - $flags = $prefix . "flags"; - if( isset( $row->$flags ) && (false !== strpos( $row->$flags, "gzip" ) ) ) { - return gzinflate( $row->$text ); + # Get revision text associated with an old or archive row + # $row is usually an object from wfFetchRow(), both the flags and the text field must be included + /* static */ function getRevisionText( $row, $prefix = 'old_' ) { + # Get data + $textField = $prefix . 'text'; + $flagsField = $prefix . 'flags'; + + if ( isset( $row->$flagsField ) ) { + $flags = explode( ",", $row->$flagsField ); + } else { + $flags = array(); + } + + if ( isset( $row->$textField ) ) { + $text = $row->$textField; + } else { + return false; } - if( isset( $row->$text ) ) { - return $row->$text; + + if ( in_array( 'link', $flags ) ) { + # Handle link type + $text = Article::followLink( $text ); + } elseif ( in_array( 'gzip', $flags ) ) { + # Deal with optional compression of archived pages. + # This can be done periodically via maintenance/compressOld.php, and + # as pages are saved if $wgCompressRevisions is set. + return gzinflate( $text ); } - return false; + return $text; } - + /* static */ function compressRevisionText( &$text ) { global $wgCompressRevisions; if( !$wgCompressRevisions ) { - return ""; + return ''; } - if( !function_exists( "gzdeflate" ) ) { + if( !function_exists( 'gzdeflate' ) ) { wfDebug( "Article::compressRevisionText() -- no zlib support, not compressing\n" ); - return ""; + return ''; } $text = gzdeflate( $text ); - return "gzip"; + return 'gzip'; } - + + # Returns the text associated with a "link" type old table row + /* static */ function followLink( $link ) { + # Split the link into fields and values + $lines = explode( '\n', $link ); + $hash = ''; + $locations = array(); + foreach ( $lines as $line ) { + # Comments + if ( $line{0} == '#' ) { + continue; + } + # Field/value pairs + if ( preg_match( '/^(.*?)\s*:\s*(.*)$/', $line, $matches ) ) { + $field = strtolower($matches[1]); + $value = $matches[2]; + if ( $field == 'hash' ) { + $hash = $value; + } elseif ( $field == 'location' ) { + $locations[] = $value; + } + } + } + + if ( $hash === '' ) { + return false; + } + + # Look in each specified location for the text + $text = false; + foreach ( $locations as $location ) { + $text = Article::fetchFromLocation( $location, $hash ); + if ( $text !== false ) { + break; + } + } + + return $text; + } + + /* static */ function fetchFromLocation( $location, $hash ) { + global $wgLoadBalancer; + $fname = 'fetchFromLocation'; + wfProfileIn( $fname ); + + $p = strpos( $location, ':' ); + if ( $p === false ) { + wfProfileOut( $fname ); + return false; + } + + $type = substr( $location, 0, $p ); + $text = false; + switch ( $type ) { + case 'mysql': + # MySQL locations are specified by mysql:///// + # Machine ID 0 is the current connection + if ( preg_match( '/^mysql:\/\/(\d+)\/([A-Za-z_]+)\/([A-Za-z_]+)\/([A-Za-z_]+)$/', + $location, $matches ) ) { + $machineID = $matches[1]; + $dbName = $matches[2]; + $tblName = $matches[3]; + $index = $matches[4]; + if ( $machineID == 0 ) { + # Current connection + $db =& wfGetDB( DB_SLAVE ); + } else { + # Alternate connection + $db =& $wgLoadBalancer->getConnection( $machineID ); + + if ( array_key_exists( $machineId, $wgKnownMysqlServers ) ) { + # Try to open, return false on failure + $params = $wgKnownDBServers[$machineId]; + $db = Database::newFromParams( $params['server'], $params['user'], $params['password'], + $dbName, 1, DBO_IGNORE ); + } + } + if ( $db->isOpen() ) { + $index = $db->strencode( $index ); + $res = $db->query( "SELECT blob_data FROM $dbName.$tblName WHERE blob_index='$index'", $fname ); + $row = $db->fetchObject( $res ); + $text = $row->text_data; + } + } + break; + case 'file': + # File locations are of the form file://, relative to the current directory + if ( preg_match( '/^file:\/\/(.*)$', $location, $matches ) ) + $filename = strstr( $location, 'file://' ); + $text = @file_get_contents( $matches[1] ); + } + if ( $text !== false ) { + # Got text, now we need to interpret it + # The first line contains information about how to do this + $p = strpos( $text, '\n' ); + $type = substr( $text, 0, $p ); + $text = substr( $text, $p + 1 ); + switch ( $type ) { + case 'plain': + break; + case 'gzip': + $text = gzinflate( $text ); + break; + case 'object': + $object = unserialize( $text ); + $text = $object->getItem( $hash ); + break; + default: + $text = false; + } + } + wfProfileOut( $fname ); + return $text; + } + # Note that getContent/loadContent may follow redirects if # not told otherwise, and so may cause a change to mTitle. # Return the text of this revision - function getContent( $noredir = false ) - { + function getContent( $noredir ) { global $wgRequest; # Get variables from query string :P $action = $wgRequest->getText( 'action', 'view' ); $section = $wgRequest->getText( 'section' ); - $fname = "Article::getContent"; + $fname = 'Article::getContent'; wfProfileIn( $fname ); if ( 0 == $this->getID() ) { - if ( "edit" == $action ) { + if ( 'edit' == $action ) { wfProfileOut( $fname ); - return ""; # was "newarticletext", now moved above the box) + return ''; # was "newarticletext", now moved above the box) } wfProfileOut( $fname ); - return wfMsg( "noarticletext" ); + return wfMsg( 'noarticletext' ); } else { $this->loadContent( $noredir ); - - if( - # check if we're displaying a [[User talk:x.x.x.x]] anonymous talk page - ( $this->mTitle->getNamespace() == Namespace::getTalk( Namespace::getUser()) ) && - preg_match("/^\d{1,3}\.\d{1,3}.\d{1,3}\.\d{1,3}$/",$this->mTitle->getText()) && - $action=="view" - ) - { + # check if we're displaying a [[User talk:x.x.x.x]] anonymous talk page + if ( $this->mTitle->getNamespace() == NS_USER_TALK && + preg_match('/^\d{1,3}\.\d{1,3}.\d{1,3}\.\d{1,3}$/',$this->mTitle->getText()) && + $action=='view' + ) { wfProfileOut( $fname ); - return $this->mContent . "\n" .wfMsg("anontalkpagetext"); } - else { - if($action=="edit") { - if($section!="") { - if($section=="new") { + return $this->mContent . "\n" .wfMsg('anontalkpagetext'); + } else { + if($action=='edit') { + if($section!='') { + if($section=='new') { wfProfileOut( $fname ); - return ""; + return ''; } # strip NOWIKI etc. to avoid confusion (true-parameter causes HTML # comments to be stripped as well) - $striparray=array(); - $parser=new Parser(); - $parser->mOutputType=OT_WIKI; - $striptext=$parser->strip($this->mContent, $striparray, true); - - # now that we can be sure that no pseudo-sections are in the source, - # split it up by section - $secs = - preg_split( - "/(^=+.*?=+|^.*?<\/h[1-6].*?>)/mi", - $striptext, -1, - PREG_SPLIT_DELIM_CAPTURE); - - if($section==0) { - $rv=$secs[0]; - } else { - $rv=$secs[$section*2-1] . $secs[$section*2]; - } - - # reinsert stripped tags - $rv=$parser->unstrip($rv,$striparray); - $rv=trim($rv); + $rv=$this->getSection($this->mContent,$section); wfProfileOut( $fname ); return $rv; } @@ -134,77 +244,150 @@ class Article { } } + # This function returns the text of a section, specified by a number ($section). + # A section is text under a heading like == Heading == or

Heading

, or + # the first section before any such heading (section 0). + # + # If a section contains subsections, these are also returned. + # + function getSection($text,$section) { + + # strip NOWIKI etc. to avoid confusion (true-parameter causes HTML + # comments to be stripped as well) + $striparray=array(); + $parser=new Parser(); + $parser->mOutputType=OT_WIKI; + $striptext=$parser->strip($text, $striparray, true); + + # now that we can be sure that no pseudo-sections are in the source, + # split it up by section + $secs = + preg_split( + '/(^=+.*?=+|^.*?<\/h[1-6].*?' . '>)/mi', + $striptext, -1, + PREG_SPLIT_DELIM_CAPTURE); + if($section==0) { + $rv=$secs[0]; + } else { + $headline=$secs[$section*2-1]; + preg_match( '/^(=+).*?=+|^.*?<\/h[1-6].*?' . '>/mi',$headline,$matches); + $hlevel=$matches[1]; + + # translate wiki heading into level + if(strpos($hlevel,'=')!==false) { + $hlevel=strlen($hlevel); + } + + $rv=$headline. $secs[$section*2]; + $count=$section+1; + + $break=false; + while(!empty($secs[$count*2-1]) && !$break) { + + $subheadline=$secs[$count*2-1]; + preg_match( '/^(=+).*?=+|^.*?<\/h[1-6].*?' . '>/mi',$subheadline,$matches); + $subhlevel=$matches[1]; + if(strpos($subhlevel,'=')!==false) { + $subhlevel=strlen($subhlevel); + } + if($subhlevel > $hlevel) { + $rv.=$subheadline.$secs[$count*2]; + } + if($subhlevel <= $hlevel) { + $break=true; + } + $count++; + + } + } + # reinsert stripped tags + $rv=$parser->unstrip($rv,$striparray); + $rv=$parser->unstripNoWiki($rv,$striparray); + $rv=trim($rv); + return $rv; + + } + + # Return an array of the columns of the "cur"-table + function &getCurContentFields() { + global $wgArticleCurContentFields; + if ( !$wgArticleCurContentFields ) { + $wgArticleCurContentFields = array( 'cur_text','cur_timestamp','cur_user', 'cur_user_text', + 'cur_comment','cur_counter','cur_restrictions','cur_touched' ); + } + return $wgArticleCurContentFields; + } + + # Return an array of the columns of the "old"-table + function &getOldContentFields() { + global $wgArticleOldContentFields; + if ( !$wgArticleOldContentFields ) { + $wgArticleOldContentFields = array( 'old_namespace','old_title','old_text','old_timestamp', + 'old_user','old_user_text','old_comment','old_flags' ); + } + return $wgArticleOldContentFields; + } + # Load the revision (including cur_text) into this object - function loadContent( $noredir = false ) - { + function loadContent( $noredir = false ) { global $wgOut, $wgMwRedir, $wgRequest; + $dbr =& wfGetDB( DB_SLAVE ); # Query variables :P $oldid = $wgRequest->getVal( 'oldid' ); $redirect = $wgRequest->getVal( 'redirect' ); if ( $this->mContentLoaded ) return; - $fname = "Article::loadContent"; - - # Pre-fill content with error message so that if something + $fname = 'Article::loadContent'; + + # Pre-fill content with error message so that if something # fails we'll have something telling us what we intended. - $t = $this->mTitle->getPrefixedText(); - if ( isset( $oldid ) ) { - $oldid = IntVal( $oldid ); + $t = $this->mTitle->getPrefixedText(); + if ( isset( $oldid ) ) { + $oldid = IntVal( $oldid ); $t .= ",oldid={$oldid}"; - } - if ( isset( $redirect ) ) { - $redirect = ($redirect == "no") ? "no" : "yes"; - $t .= ",redirect={$redirect}"; - } - $this->mContent = wfMsg( "missingarticle", $t ); - + } + if ( isset( $redirect ) ) { + $redirect = ($redirect == 'no') ? 'no' : 'yes'; + $t .= ",redirect={$redirect}"; + } + $this->mContent = wfMsg( 'missingarticle', $t ); + if ( ! $oldid ) { # Retrieve current version $id = $this->getID(); if ( 0 == $id ) return; - $sql = "SELECT " . - "cur_text,cur_timestamp,cur_user,cur_counter,cur_restrictions,cur_touched " . - "FROM cur WHERE cur_id={$id}"; - wfDebug( "$sql\n" ); - $res = wfQuery( $sql, DB_READ, $fname ); - if ( 0 == wfNumRows( $res ) ) { - return; + $s = $dbr->getArray( 'cur', $this->getCurContentFields(), array( 'cur_id' => $id ), $fname ); + if ( $s === false ) { + return; } - $s = wfFetchObject( $res ); # If we got a redirect, follow it (unless we've been told # not to by either the function parameter or the query - if ( ( "no" != $redirect ) && ( false == $noredir ) && - ( $wgMwRedir->matchStart( $s->cur_text ) ) ) { - if ( preg_match( "/\\[\\[([^\\]\\|]+)[\\]\\|]/", - $s->cur_text, $m ) ) { - $rt = Title::newFromText( $m[1] ); - if( $rt ) { - # Gotta hand redirects to special pages differently: - # Fill the HTTP response "Location" header and ignore - # the rest of the page we're on. - - if ( $rt->getInterwiki() != "" ) { - $wgOut->redirect( $rt->getFullURL() ) ; - return; - } - if ( $rt->getNamespace() == Namespace::getSpecial() ) { - $wgOut->redirect( $rt->getFullURL() ); - return; - } - $rid = $rt->getArticleID(); - if ( 0 != $rid ) { - $sql = "SELECT cur_text,cur_timestamp,cur_user," . - "cur_counter,cur_restrictions,cur_touched FROM cur WHERE cur_id={$rid}"; - $res = wfQuery( $sql, DB_READ, $fname ); - - if ( 0 != wfNumRows( $res ) ) { - $this->mRedirectedFrom = $this->mTitle->getPrefixedText(); - $this->mTitle = $rt; - $s = wfFetchObject( $res ); - } + if ( ( 'no' != $redirect ) && ( false == $noredir ) ) { + $rt = Title::newFromRedirect( $s->cur_text ); + if ( $rt ) { + # Gotta hand redirects to special pages differently: + # Fill the HTTP response "Location" header and ignore + # the rest of the page we're on. + + if ( $rt->getInterwiki() != '' ) { + $wgOut->redirect( $rt->getFullURL() ) ; + return; + } + if ( $rt->getNamespace() == NS_SPECIAL ) { + $wgOut->redirect( $rt->getFullURL() ); + return; + } + $rid = $rt->getArticleID(); + if ( 0 != $rid ) { + $redirRow = $dbr->getArray( 'cur', $this->getCurContentFields(), array( 'cur_id' => $rid ), $fname ); + + if ( $redirRow !== false ) { + $this->mRedirectedFrom = $this->mTitle->getPrefixedText(); + $this->mTitle = $rt; + $s = $redirRow; } } } @@ -212,24 +395,31 @@ class Article { $this->mContent = $s->cur_text; $this->mUser = $s->cur_user; + $this->mUserText = $s->cur_user_text; + $this->mComment = $s->cur_comment; $this->mCounter = $s->cur_counter; $this->mTimestamp = $s->cur_timestamp; $this->mTouched = $s->cur_touched; - $this->mTitle->mRestrictions = explode( ",", trim( $s->cur_restrictions ) ); + $this->mTitle->mRestrictions = explode( ',', trim( $s->cur_restrictions ) ); $this->mTitle->mRestrictionsLoaded = true; - wfFreeResult( $res ); } else { # oldid set, retrieve historical version - $sql = "SELECT old_text,old_timestamp,old_user,old_flags FROM old " . - "WHERE old_id={$oldid}"; - $res = wfQuery( $sql, DB_READ, $fname ); - if ( 0 == wfNumRows( $res ) ) { return; } + $s = $dbr->getArray( 'old', $this->getOldContentFields(), array( 'old_id' => $oldid ), $fname ); + if ( $s === false ) { + return; + } - $s = wfFetchObject( $res ); + if( $this->mTitle->getNamespace() != $s->old_namespace || + $this->mTitle->getDBkey() != $s->old_title ) { + $oldTitle = Title::makeTitle( $s->old_namesapce, $s->old_title ); + $this->mTitle = $oldTitle; + $wgTitle = $oldTitle; + } $this->mContent = Article::getRevisionText( $s ); $this->mUser = $s->old_user; + $this->mUserText = $s->old_user_text; + $this->mComment = $s->old_comment; $this->mCounter = 0; $this->mTimestamp = $s->old_timestamp; - wfFreeResult( $res ); } $this->mContentLoaded = true; return $this->mContent; @@ -244,42 +434,34 @@ class Article { return $this->mContent; } $this->mContent = false; - - $fname = "Article::loadContent"; - + + $fname = 'Article::getContentWithout'; + $dbr =& wfGetDB( DB_SLAVE ); + if ( ! $oldid ) { # Retrieve current version $id = $this->getID(); if ( 0 == $id ) { return false; } - $sql = "SELECT " . - "cur_text,cur_timestamp,cur_user,cur_counter,cur_restrictions,cur_touched " . - "FROM cur WHERE cur_id={$id}"; - $res = wfQuery( $sql, DB_READ, $fname ); - if ( 0 == wfNumRows( $res ) ) { - return false; + $s = $dbr->getArray( 'cur', $this->getCurContentFields(), array( 'cur_id' => $id ), $fname ); + if ( $s === false ) { + return false; } - $s = wfFetchObject( $res ); # If we got a redirect, follow it (unless we've been told # not to by either the function parameter or the query - if ( !$noredir && $wgMwRedir->matchStart( $s->cur_text ) ) { - if ( preg_match( "/\\[\\[([^\\]\\|]+)[\\]\\|]/", - $s->cur_text, $m ) ) { - $rt = Title::newFromText( $m[1] ); - if( $rt && $rt->getInterwiki() == "" && $rt->getNamespace() != Namespace::getSpecial() ) { - $rid = $rt->getArticleID(); - if ( 0 != $rid ) { - $sql = "SELECT cur_text,cur_timestamp,cur_user," . - "cur_counter,cur_restrictions,cur_touched FROM cur WHERE cur_id={$rid}"; - $res = wfQuery( $sql, DB_READ, $fname ); - - if ( 0 != wfNumRows( $res ) ) { - $this->mRedirectedFrom = $this->mTitle->getPrefixedText(); - $this->mTitle = $rt; - $s = wfFetchObject( $res ); - } + if ( !$noredir ) { + $rt = Title::newFromRedirect( $s->cur_text ); + if( $rt && $rt->getInterwiki() == '' && $rt->getNamespace() != NS_SPECIAL ) { + $rid = $rt->getArticleID(); + if ( 0 != $rid ) { + $redirRow = $dbr->getArray( 'cur', $this->getCurContentFields(), array( 'cur_id' => $rid ), $fname ); + + if ( $redirRow !== false ) { + $this->mRedirectedFrom = $this->mTitle->getPrefixedText(); + $this->mTitle = $rt; + $s = $redirRow; } } } @@ -287,26 +469,24 @@ class Article { $this->mContent = $s->cur_text; $this->mUser = $s->cur_user; + $this->mUserText = $s->cur_user_text; + $this->mComment = $s->cur_comment; $this->mCounter = $s->cur_counter; $this->mTimestamp = $s->cur_timestamp; $this->mTouched = $s->cur_touched; $this->mTitle->mRestrictions = explode( ",", trim( $s->cur_restrictions ) ); $this->mTitle->mRestrictionsLoaded = true; - wfFreeResult( $res ); } else { # oldid set, retrieve historical version - $sql = "SELECT old_text,old_timestamp,old_user,old_flags FROM old " . - "WHERE old_id={$oldid}"; - $res = wfQuery( $sql, DB_READ, $fname ); - if ( 0 == wfNumRows( $res ) ) { - return false; + $s = $dbr->getArray( 'old', $this->getOldContentFields(), array( 'old_id' => $oldid ) ); + if ( $s === false ) { + return false; } - - $s = wfFetchObject( $res ); $this->mContent = Article::getRevisionText( $s ); $this->mUser = $s->old_user; + $this->mUserText = $s->old_user_text; + $this->mComment = $s->old_comment; $this->mCounter = 0; $this->mTimestamp = $s->old_timestamp; - wfFreeResult( $res ); } $this->mContentLoaded = true; return $this->mContent; @@ -320,44 +500,41 @@ class Article { } } - function getCount() - { + function getCount() { if ( -1 == $this->mCounter ) { $id = $this->getID(); - $this->mCounter = wfGetSQL( "cur", "cur_counter", "cur_id={$id}" ); + $dbr =& wfGetDB( DB_SLAVE ); + $this->mCounter = $dbr->getField( 'cur', 'cur_counter', "cur_id={$id}" ); } return $this->mCounter; } # Would the given text make this article a "good" article (i.e., # suitable for including in the article count)? - - function isCountable( $text ) - { + function isCountable( $text ) { global $wgUseCommaCount, $wgMwRedir; - + if ( 0 != $this->mTitle->getNamespace() ) { return 0; } if ( $wgMwRedir->matchStart( $text ) ) { return 0; } - $token = ($wgUseCommaCount ? "," : "[[" ); + $token = ($wgUseCommaCount ? ',' : '[[' ); if ( false === strstr( $text, $token ) ) { return 0; } return 1; } # Loads everything from cur except cur_text # This isn't necessary for all uses, so it's only done if needed. - - /* private */ function loadLastEdit() - { + /* private */ function loadLastEdit() { global $wgOut; if ( -1 != $this->mUser ) return; - $sql = "SELECT cur_user,cur_user_text,cur_timestamp," . - "cur_comment,cur_minor_edit FROM cur WHERE " . - "cur_id=" . $this->getID(); - $res = wfQuery( $sql, DB_READ, "Article::loadLastEdit" ); + $fname = 'Article::loadLastEdit'; + + $dbr =& wfGetDB( DB_SLAVE ); + $s = $dbr->getArray( 'cur', + array( 'cur_user','cur_user_text','cur_timestamp', 'cur_comment','cur_minor_edit' ), + array( 'cur_id' => $this->getID() ), $fname ); - if ( wfNumRows( $res ) > 0 ) { - $s = wfFetchObject( $res ); + if ( $s !== false ) { $this->mUser = $s->cur_user; $this->mUserText = $s->cur_user_text; $this->mTimestamp = $s->cur_timestamp; @@ -366,113 +543,100 @@ class Article { } } - function getTimestamp() - { + function getTimestamp() { $this->loadLastEdit(); return $this->mTimestamp; } - function getUser() - { + function getUser() { $this->loadLastEdit(); return $this->mUser; } - function getUserText() - { + function getUserText() { $this->loadLastEdit(); return $this->mUserText; } - function getComment() - { + function getComment() { $this->loadLastEdit(); return $this->mComment; } - function getMinorEdit() - { + function getMinorEdit() { $this->loadLastEdit(); return $this->mMinorEdit; } - function getContributors($limit = 0, $offset = 0) - { - $fname = "Article::getContributors"; + function getContributors($limit = 0, $offset = 0) { + $fname = 'Article::getContributors'; - # XXX: this is expensive; cache this info somewhere. - - $title = $this->mTitle; + # XXX: this is expensive; cache this info somewhere. - $contribs = array(); + $title = $this->mTitle; + $contribs = array(); + $dbr =& wfGetDB( DB_SLAVE ); + $oldTable = $dbr->tableName( 'old' ); + $userTable = $dbr->tableName( 'user' ); + $encDBkey = $dbr->strencode( $title->getDBkey() ); + $ns = $title->getNamespace(); + $user = $this->getUser(); - $sql = "SELECT old.old_user, old.old_user_text, " . - " user.user_real_name, MAX(old.old_timestamp) as timestamp" . - " FROM old, user " . - " WHERE old.old_user = user.user_id " . - " AND old.old_namespace = " . $title->getNamespace() . - " AND old.old_title = '" . $title->getDBkey() . "'" . - " AND old.old_user != 0 " . - " AND old.old_user != " . $this->getUser() . - " GROUP BY old.old_user " . - " ORDER BY timestamp DESC "; + $sql = "SELECT old_user, old_user_text, user_real_name, MAX(old_timestamp) as timestamp + FROM $oldTable LEFT JOIN $userTable ON old_user = user_id + WHERE old_namespace = $user + AND old_title = $encDBkey + AND old_user != $user + GROUP BY old_user + ORDER BY timestamp DESC"; - if ($limit > 0) { - $sql .= " LIMIT $limit"; - } + if ($limit > 0) { $sql .= ' LIMIT '.$limit; } - $res = wfQuery($sql, DB_READ, $fname); - - while ( $line = wfFetchObject( $res ) ) { - $contribs[$line->old_user] = - array($line->old_user_text, $line->user_real_name); - } - - # Count anonymous users - - $res = wfQuery("SELECT COUNT(*) AS cnt " . - " FROM old " . - " WHERE old_namespace = " . $title->getNamespace() . - " AND old_title = '" . $title->getDBkey() . "'" . - " AND old_user = 0 ", DB_READ, $fname); - - while ( $line = wfFetchObject( $res ) ) { - $contribs[0] = array($line->cnt, 'Anonymous'); - } + $res = $dbr->query($sql, $fname); - return $contribs; + while ( $line = $dbr->fetchObject( $res ) ) { + $contribs[] = array($line->old_user, $line->old_user_text, $line->user_real_name); + } + + $dbr->freeResult($res); + return $contribs; } - + # This is the default action of the script: just view the page of # the given title. - function view() - { - global $wgUser, $wgOut, $wgLang, $wgRequest; - global $wgLinkCache, $IP, $wgEnableParserCache; - - $fname = "Article::view"; + function view() { + global $wgUser, $wgOut, $wgLang, $wgRequest, $wgMwRedir, $wgOnlySysopsCanPatrol; + global $wgLinkCache, $IP, $wgEnableParserCache, $wgStylePath, $wgUseRCPatrol; + $sk = $wgUser->getSkin(); + + $fname = 'Article::view'; wfProfileIn( $fname ); - # Get variables from query string :P + # Get variables from query string $oldid = $wgRequest->getVal( 'oldid' ); $diff = $wgRequest->getVal( 'diff' ); + $rcid = $wgRequest->getVal( 'rcid' ); $wgOut->setArticleFlag( true ); - $wgOut->setRobotpolicy( "index,follow" ); + $wgOut->setRobotpolicy( 'index,follow' ); # If we got diff and oldid in the query, we want to see a # diff page instead of the article. if ( !is_null( $diff ) ) { $wgOut->setPageTitle( $this->mTitle->getPrefixedText() ); - $de = new DifferenceEngine( intval($oldid), intval($diff) ); + $de = new DifferenceEngine( intval($oldid), intval($diff), intval($rcid) ); $de->showDiffPage(); wfProfileOut( $fname ); + if( $diff == 0 ) { + # Run view updates for current revision only + $this->viewUpdates(); + } return; } - if ( !is_null( $oldid ) and $this->checkTouched() ) { + if ( empty( $oldid ) && $this->checkTouched() ) { if( $wgOut->checkLastModified( $this->mTouched ) ){ return; } else if ( $this->tryFileCache() ) { @@ -483,37 +647,87 @@ class Article { } } - $text = $this->getContent(); # May change mTitle - $wgOut->setPageTitle( $this->mTitle->getPrefixedText() ); - - # We're looking at an old revision - - if ( !empty( $oldid ) ) { - $this->setOldSubtitle(); - $wgOut->setRobotpolicy( "noindex,follow" ); + # Should the parser cache be used? + if ( $wgEnableParserCache && intval($wgUser->getOption( 'stubthreshold' )) == 0 && empty( $oldid ) ) { + $pcache = true; + } else { + $pcache = false; } - if ( "" != $this->mRedirectedFrom ) { - $sk = $wgUser->getSkin(); - $redir = $sk->makeKnownLink( $this->mRedirectedFrom, "", - "redirect=no" ); - $s = wfMsg( "redirectedfrom", $redir ); - $wgOut->setSubtitle( $s ); + + $outputDone = false; + if ( $pcache ) { + if ( $wgOut->tryParserCache( $this, $wgUser ) ) { + $outputDone = true; + } } - $wgLinkCache->preFill( $this->mTitle ); + if ( !$outputDone ) { + $text = $this->getContent( false ); # May change mTitle by following a redirect - # wrap user css and user js in pre and don't parse - if ( - $this->mTitle->getNamespace() == Namespace::getUser() && - preg_match("/\\/[\\w]+\\.(css|js)$/", $this->mTitle->getDBkey()) - ) { - $wgOut->addHTML( '
'.htmlspecialchars($this->mContent)."\n
" ); - } else if( $wgEnableParserCache && intval($wgUser->getOption( "stubthreshold" )) == 0 ){ - $wgOut->addWikiText( $text, true, $this ); - } else { - $wgOut->addWikiText( $text ); + # Another whitelist check in case oldid or redirects are altering the title + if ( !$this->mTitle->userCanRead() ) { + $wgOut->loginToUse(); + $wgOut->output(); + exit; + } + + + # We're looking at an old revision + + if ( !empty( $oldid ) ) { + $this->setOldSubtitle(); + $wgOut->setRobotpolicy( 'noindex,follow' ); + } + if ( '' != $this->mRedirectedFrom ) { + $sk = $wgUser->getSkin(); + $redir = $sk->makeKnownLink( $this->mRedirectedFrom, '', + 'redirect=no' ); + $s = wfMsg( 'redirectedfrom', $redir ); + $wgOut->setSubtitle( $s ); + + # Can't cache redirects + $pcache = false; + } + + # wrap user css and user js in pre and don't parse + # XXX: use $this->mTitle->usCssJsSubpage() when php is fixed/ a workaround is found + if ( + $this->mTitle->getNamespace() == NS_USER && + preg_match('/\\/[\\w]+\\.(css|js)$/', $this->mTitle->getDBkey()) + ) { + $wgOut->addWikiText( wfMsg('clearyourcache')); + $wgOut->addHTML( '
'.htmlspecialchars($this->mContent)."\n
" ); + } else if ( $rt = Title::newFromRedirect( $text ) ) { + # Display redirect + $imageUrl = "$wgStylePath/images/redirect.png"; + $targetUrl = $rt->escapeLocalURL(); + $titleText = htmlspecialchars( $rt->getPrefixedText() ); + $link = $sk->makeLinkObj( $rt ); + $wgOut->addHTML( "" . + "$link" ); + } else if ( $pcache ) { + # Display content and save to parser cache + $wgOut->addWikiText( $text, true, $this ); + } else { + # Display content, don't attempt to save to parser cache + $wgOut->addWikiText( $text ); + } + } + $wgOut->setPageTitle( $this->mTitle->getPrefixedText() ); + + # If we have been passed an &rcid= parameter, we want to give the user a + # chance to mark this new article as patrolled. + if ( $wgUseRCPatrol && !is_null ( $rcid ) && $rcid != 0 && $wgUser->getID() != 0 && + ( $wgUser->isSysop() || !$wgOnlySysopsCanPatrol ) ) + { + $wgOut->addHTML( wfMsg ( 'markaspatrolledlink', + $sk->makeKnownLinkObj ( $this->mTitle, wfMsg ( 'markaspatrolledtext' ), + "action=markpatrolled&rcid={$rcid}" ) + ) ); } + # Put link titles into the link cache + $wgOut->replaceLinkHolders(); # Add link titles as META keywords $wgOut->addMetaTags() ; @@ -526,12 +740,11 @@ class Article { # of faith, and we want to be able to report database # errors at some point. - /* private */ function insertNewArticle( $text, $summary, $isminor, $watchthis ) - { - global $wgOut, $wgUser, $wgLinkCache, $wgMwRedir; + /* private */ function insertNewArticle( $text, $summary, $isminor, $watchthis ) { + global $wgOut, $wgUser, $wgMwRedir; global $wgUseSquid, $wgDeferredUpdateList, $wgInternalServer; - - $fname = "Article::insertNewArticle"; + + $fname = 'Article::insertNewArticle'; $this->mCountAdjustment = $this->isCountable( $text ); @@ -544,51 +757,63 @@ class Article { $now = wfTimestampNow(); $won = wfInvertTimestamp( $now ); wfSeedRandom(); - $rand = number_format( mt_rand() / mt_getrandmax(), 12, ".", "" ); + $rand = number_format( mt_rand() / mt_getrandmax(), 12, '.', '' ); + $dbw =& wfGetDB( DB_MASTER ); + + $cur_id = $dbw->nextSequenceValue( 'cur_cur_id_seq' ); + $isminor = ( $isminor && $wgUser->getID() ) ? 1 : 0; - $sql = "INSERT INTO cur (cur_namespace,cur_title,cur_text," . - "cur_comment,cur_user,cur_timestamp,cur_minor_edit,cur_counter," . - "cur_restrictions,cur_user_text,cur_is_redirect," . - "cur_is_new,cur_random,cur_touched,inverse_timestamp) VALUES ({$ns},'" . wfStrencode( $ttl ) . "', '" . - wfStrencode( $text ) . "', '" . - wfStrencode( $summary ) . "', '" . - $wgUser->getID() . "', '{$now}', " . - $isminor . ", 0, '', '" . - wfStrencode( $wgUser->getName() ) . "', $redir, 1, $rand, '{$now}', '{$won}')"; - $res = wfQuery( $sql, DB_WRITE, $fname ); - - $newid = wfInsertId(); + + $dbw->insertArray( 'cur', array( + 'cur_id' => $cur_id, + 'cur_namespace' => $ns, + 'cur_title' => $ttl, + 'cur_text' => $text, + 'cur_comment' => $summary, + 'cur_user' => $wgUser->getID(), + 'cur_timestamp' => $now, + 'cur_minor_edit' => $isminor, + 'cur_counter' => 0, + 'cur_restrictions' => '', + 'cur_user_text' => $wgUser->getName(), + 'cur_is_redirect' => $redir, + 'cur_is_new' => 1, + 'cur_random' => $rand, + 'cur_touched' => $now, + 'inverse_timestamp' => $won, + ), $fname ); + + $newid = $dbw->insertId(); $this->mTitle->resetArticleID( $newid ); Article::onArticleCreate( $this->mTitle ); RecentChange::notifyNew( $now, $this->mTitle, $isminor, $wgUser, $summary ); - - if ($watchthis) { - if(!$this->mTitle->userIsWatching()) $this->watch(); + + if ($watchthis) { + if(!$this->mTitle->userIsWatching()) $this->watch(); } else { if ( $this->mTitle->userIsWatching() ) { $this->unwatch(); } } - + # The talk page isn't in the regular link tables, so we need to update manually: $talkns = $ns ^ 1; # talk -> normal; normal -> talk - $sql = "UPDATE cur set cur_touched='$now' WHERE cur_namespace=$talkns AND cur_title='" . wfStrencode( $ttl ) . "'"; - wfQuery( $sql, DB_WRITE ); - + $dbw->updateArray( 'cur', array( 'cur_touched' => $now ), array( 'cur_namespace' => $talkns, 'cur_title' => $ttl ), $fname ); + # standard deferred updates $this->editUpdates( $text ); - $this->showArticle( $text, wfMsg( "newarticle" ) ); + $this->showArticle( $text, wfMsg( 'newarticle' ) ); } /* Side effects: loads last edit */ - function getTextOfLastEditWithSectionReplacedOrAdded($section, $text, $summary = ""){ + function getTextOfLastEditWithSectionReplacedOrAdded($section, $text, $summary = '') { $this->loadLastEdit(); - $oldtext = $this->getContent(); - if ($section != "") { - if($section=="new") { + $oldtext = $this->getContent( true ); + if ($section != '') { + if($section=='new') { if($summary) $subject="== {$summary} ==\n\n"; $text=$oldtext."\n\n".$subject.$text; } else { @@ -602,95 +827,163 @@ class Article { # now that we can be sure that no pseudo-sections are in the source, # split it up - $secs=preg_split("/(^=+.*?=+|^.*?<\/h[1-6].*?>)/mi", + # Unfortunately we can't simply do a preg_replace because that might + # replace the wrong section, so we have to use the section counter instead + $secs=preg_split('/(^=+.*?=+|^.*?<\/h[1-6].*?' . '>)/mi', $oldtext,-1,PREG_SPLIT_DELIM_CAPTURE); $secs[$section*2]=$text."\n\n"; // replace with edited - if($section) { $secs[$section*2-1]=""; } // erase old headline - $text=join("",$secs); + # section 0 is top (intro) section + if($section!=0) { + + # headline of old section - we need to go through this section + # to determine if there are any subsections that now need to + # be erased, as the mother section has been replaced with + # the text of all subsections. + $headline=$secs[$section*2-1]; + preg_match( '/^(=+).*?=+|^.*?<\/h[1-6].*?' . '>/mi',$headline,$matches); + $hlevel=$matches[1]; + + # determine headline level for wikimarkup headings + if(strpos($hlevel,'=')!==false) { + $hlevel=strlen($hlevel); + } + + $secs[$section*2-1]=''; // erase old headline + $count=$section+1; + $break=false; + while(!empty($secs[$count*2-1]) && !$break) { + + $subheadline=$secs[$count*2-1]; + preg_match( + '/^(=+).*?=+|^.*?<\/h[1-6].*?' . '>/mi',$subheadline,$matches); + $subhlevel=$matches[1]; + if(strpos($subhlevel,'=')!==false) { + $subhlevel=strlen($subhlevel); + } + if($subhlevel > $hlevel) { + // erase old subsections + $secs[$count*2-1]=''; + $secs[$count*2]=''; + } + if($subhlevel <= $hlevel) { + $break=true; + } + $count++; + + } + + } + $text=join('',$secs); # reinsert the stuff that we stripped out earlier - $text=$parser->unstrip($text,$striparray,true); + $text=$parser->unstrip($text,$striparray); + $text=$parser->unstripNoWiki($text,$striparray); } + } return $text; } - function updateArticle( $text, $summary, $minor, $watchthis, $forceBot = false ) - { - global $wgOut, $wgUser, $wgLinkCache; + function updateArticle( $text, $summary, $minor, $watchthis, $forceBot = false, $sectionanchor = '' ) { + global $wgOut, $wgUser; global $wgDBtransactions, $wgMwRedir; global $wgUseSquid, $wgInternalServer; - $fname = "Article::updateArticle"; + + $fname = 'Article::updateArticle'; + $good = true; if ( $this->mMinorEdit ) { $me1 = 1; } else { $me1 = 0; } - if ( $minor && $wgUser->getID() ) { $me2 = 1; } else { $me2 = 0; } - if ( preg_match( "/^((" . $wgMwRedir->getBaseRegex() . ")[^\\n]+)/i", $text, $m ) ) { + if ( $minor && $wgUser->getID() ) { $me2 = 1; } else { $me2 = 0; } + if ( preg_match( "/^((" . $wgMwRedir->getBaseRegex() . ')[^\\n]+)/i', $text, $m ) ) { $redir = 1; $text = $m[1] . "\n"; # Remove all content but redirect } else { $redir = 0; } $text = $this->preSaveTransform( $text ); - + $dbw =& wfGetDB( DB_MASTER ); + # Update article, but only if changed. + # It's important that we either rollback or complete, otherwise an attacker could + # overwrite cur entries by sending precisely timed user aborts. Random bored users + # could conceivably have the same effect, especially if cur is locked for long periods. if( $wgDBtransactions ) { - $sql = "BEGIN"; - wfQuery( $sql, DB_WRITE ); + $dbw->query( 'BEGIN', $fname ); + } else { + $userAbort = ignore_user_abort( true ); } + $oldtext = $this->getContent( true ); if ( 0 != strcmp( $text, $oldtext ) ) { $this->mCountAdjustment = $this->isCountable( $text ) - $this->isCountable( $oldtext ); - $now = wfTimestampNow(); $won = wfInvertTimestamp( $now ); - $sql = "UPDATE cur SET cur_text='" . wfStrencode( $text ) . - "',cur_comment='" . wfStrencode( $summary ) . - "',cur_minor_edit={$me2}, cur_user=" . $wgUser->getID() . - ",cur_timestamp='{$now}',cur_user_text='" . - wfStrencode( $wgUser->getName() ) . - "',cur_is_redirect={$redir}, cur_is_new=0, cur_touched='{$now}', inverse_timestamp='{$won}' " . - "WHERE cur_id=" . $this->getID() . - " AND cur_timestamp='" . $this->getTimestamp() . "'"; - $res = wfQuery( $sql, DB_WRITE, $fname ); - - if( wfAffectedRows() == 0 ) { + + # First update the cur row + $dbw->updateArray( 'cur', + array( /* SET */ + 'cur_text' => $text, + 'cur_comment' => $summary, + 'cur_minor_edit' => $me2, + 'cur_user' => $wgUser->getID(), + 'cur_timestamp' => $now, + 'cur_user_text' => $wgUser->getName(), + 'cur_is_redirect' => $redir, + 'cur_is_new' => 0, + 'cur_touched' => $now, + 'inverse_timestamp' => $won + ), array( /* WHERE */ + 'cur_id' => $this->getID(), + 'cur_timestamp' => $this->getTimestamp() + ), $fname + ); + + if( $dbw->affectedRows() == 0 ) { /* Belated edit conflict! Run away!! */ - return false; + $good = false; + } else { + # Now insert the previous revision into old + + # This overwrites $oldtext if revision compression is on + $flags = Article::compressRevisionText( $oldtext ); + + $dbw->insertArray( 'old', + array( + 'old_id' => $dbw->nextSequenceValue( 'old_old_id_seq' ), + 'old_namespace' => $this->mTitle->getNamespace(), + 'old_title' => $this->mTitle->getDBkey(), + 'old_text' => $oldtext, + 'old_comment' => $this->getComment(), + 'old_user' => $this->getUser(), + 'old_user_text' => $this->getUserText(), + 'old_timestamp' => $this->getTimestamp(), + 'old_minor_edit' => $me1, + 'inverse_timestamp' => wfInvertTimestamp( $this->getTimestamp() ), + 'old_flags' => $flags, + ), $fname + ); + + $oldid = $dbw->insertId(); + + $bot = (int)($wgUser->isBot() || $forceBot); + RecentChange::notifyEdit( $now, $this->mTitle, $me2, $wgUser, $summary, + $oldid, $this->getTimestamp(), $bot ); + Article::onArticleEdit( $this->mTitle ); } - - # This overwrites $oldtext if revision compression is on - $flags = Article::compressRevisionText( $oldtext ); - - $sql = "INSERT INTO old (old_namespace,old_title,old_text," . - "old_comment,old_user,old_user_text,old_timestamp," . - "old_minor_edit,inverse_timestamp,old_flags) VALUES (" . - $this->mTitle->getNamespace() . ", '" . - wfStrencode( $this->mTitle->getDBkey() ) . "', '" . - wfStrencode( $oldtext ) . "', '" . - wfStrencode( $this->getComment() ) . "', " . - $this->getUser() . ", '" . - wfStrencode( $this->getUserText() ) . "', '" . - $this->getTimestamp() . "', " . $me1 . ", '" . - wfInvertTimestamp( $this->getTimestamp() ) . "','$flags')"; - $res = wfQuery( $sql, DB_WRITE, $fname ); - $oldid = wfInsertID( $res ); - - $bot = (int)($wgUser->isBot() || $forceBot); - RecentChange::notifyEdit( $now, $this->mTitle, $me2, $wgUser, $summary, - $oldid, $this->getTimestamp(), $bot ); - Article::onArticleEdit( $this->mTitle ); } if( $wgDBtransactions ) { - $sql = "COMMIT"; - wfQuery( $sql, DB_WRITE ); + $dbw->query( 'COMMIT', $fname ); + } else { + ignore_user_abort( $userAbort ); } - - if ($watchthis) { - if (!$this->mTitle->userIsWatching()) $this->watch(); + + if ( $good ) { + if ($watchthis) { + if (!$this->mTitle->userIsWatching()) $this->watch(); } else { if ( $this->mTitle->userIsWatching() ) { $this->unwatch(); @@ -698,8 +991,8 @@ class Article { } # standard deferred updates $this->editUpdates( $text ); - - + + $urls = array(); # Template namespace # Purge all articles linking here @@ -707,12 +1000,12 @@ class Article { $titles = $this->mTitle->getLinksTo(); Title::touchArray( $titles ); if ( $wgUseSquid ) { - foreach ( $titles as $title ) { - $urls[] = $title->getInternalURL(); - } + foreach ( $titles as $title ) { + $urls[] = $title->getInternalURL(); + } } } - + # Squid updates if ( $wgUseSquid ) { $urls = array_merge( $urls, $this->mTitle->getSquidURLs() ); @@ -720,44 +1013,98 @@ class Article { $u->doUpdate(); } - $this->showArticle( $text, wfMsg( "updated" ) ); - return true; + $this->showArticle( $text, wfMsg( 'updated' ), $sectionanchor ); + } + return $good; } # After we've either updated or inserted the article, update # the link tables and redirect to the new page. - function showArticle( $text, $subtitle ) - { + function showArticle( $text, $subtitle , $sectionanchor = '' ) { global $wgOut, $wgUser, $wgLinkCache; global $wgMwRedir; $wgLinkCache = new LinkCache(); + # Select for update + $wgLinkCache->forUpdate( true ); # Get old version of link table to allow incremental link updates $wgLinkCache->preFill( $this->mTitle ); $wgLinkCache->clear(); - # Now update the link cache by parsing the text + # Parse the text and replace links with placeholders $wgOut = new OutputPage(); $wgOut->addWikiText( $text ); + # Look up the links in the DB and add them to the link cache + $wgOut->replaceLinkHolders( RLH_FOR_UPDATE ); + if( $wgMwRedir->matchStart( $text ) ) - $r = "redirect=no"; + $r = 'redirect=no'; else - $r = ""; - $wgOut->redirect( $this->mTitle->getFullURL( $r ) ); + $r = ''; + $wgOut->redirect( $this->mTitle->getFullURL( $r ).$sectionanchor ); + } + + # Validate article + + function validate () { + global $wgOut ; + $wgOut->setPagetitle( wfMsg( 'validate' ) . ": " . $this->mTitle->getPrefixedText() ); + $wgOut->setRobotpolicy( 'noindex,follow' ); + if ( $this->mTitle->getNamespace() != 0 ) + { + $wgOut->addHTML ( wfMsg ( 'val_validate_article_namespace_only' ) ) ; + return ; + } + $v = new Validation ; + $v->validate_form ( $this->mTitle->getDBkey() ) ; + } + + # Mark this particular edit as patrolled + function markpatrolled() { + global $wgOut, $wgRequest, $wgOnlySysopsCanPatrol, $wgUseRCPatrol, $wgUser; + $wgOut->setRobotpolicy( 'noindex,follow' ); + + if ( !$wgUseRCPatrol ) + { + $wgOut->errorpage( 'rcpatroldisabled', 'rcpatroldisabledtext' ); + return; + } + if ( $wgUser->getID() == 0 ) + { + $wgOut->loginToUse(); + return; + } + if ( $wgOnlySysopsCanPatrol && !$wgUser->isSysop() ) + { + $wgOut->sysopRequired(); + return; + } + $rcid = $wgRequest->getVal( 'rcid' ); + if ( !is_null ( $rcid ) ) + { + RecentChange::markPatrolled( $rcid ); + $wgOut->setPagetitle( wfMsg( 'markedaspatrolled' ) ); + $wgOut->addWikiText( wfMsg( 'markedaspatrolledtext' ) ); + $wgOut->returnToMain( true, $this->mTitle->getPrefixedText() ); + } + else + { + $wgOut->errorpage( 'markedaspatrollederror', 'markedaspatrollederrortext' ); + } } - # Add this page to my watchlist - function watch( $add = true ) - { + # Add this page to my watchlist + + function watch( $add = true ) { global $wgUser, $wgOut, $wgLang; global $wgDeferredUpdateList; if ( 0 == $wgUser->getID() ) { - $wgOut->errorpage( "watchnologin", "watchnologintext" ); + $wgOut->errorpage( 'watchnologin', 'watchnologintext' ); return; } if ( wfReadOnly() ) { @@ -769,31 +1116,31 @@ class Article { else $wgUser->removeWatch( $this->mTitle ); - $wgOut->setPagetitle( wfMsg( $add ? "addedwatch" : "removedwatch" ) ); - $wgOut->setRobotpolicy( "noindex,follow" ); + $wgOut->setPagetitle( wfMsg( $add ? 'addedwatch' : 'removedwatch' ) ); + $wgOut->setRobotpolicy( 'noindex,follow' ); $sk = $wgUser->getSkin() ; $link = $this->mTitle->getPrefixedText(); if($add) - $text = wfMsg( "addedwatchtext", $link ); + $text = wfMsg( 'addedwatchtext', $link ); else - $text = wfMsg( "removedwatchtext", $link ); + $text = wfMsg( 'removedwatchtext', $link ); $wgOut->addWikiText( $text ); $up = new UserUpdate(); array_push( $wgDeferredUpdateList, $up ); - $wgOut->returnToMain( false ); + $wgOut->returnToMain( true, $this->mTitle->getPrefixedText() ); } - function unwatch() - { + function unwatch() { $this->watch( false ); } - function protect( $limit = "sysop" ) - { + # protect a page + + function protect( $limit = 'sysop' ) { global $wgUser, $wgOut, $wgRequest; if ( ! $wgUser->isSysop() ) { @@ -806,7 +1153,7 @@ class Article { } $id = $this->mTitle->getArticleID(); if ( 0 == $id ) { - $wgOut->fatalError( wfMsg( "badarticleerror" ) ); + $wgOut->fatalError( wfMsg( 'badarticleerror' ) ); return; } @@ -814,53 +1161,60 @@ class Article { $reason = $wgRequest->getText( 'wpReasonProtect' ); if ( $confirm ) { + $dbw =& wfGetDB( DB_MASTER ); + $dbw->updateArray( 'cur', + array( /* SET */ + 'cur_touched' => wfTimestampNow(), + 'cur_restrictions' => (string)$limit + ), array( /* WHERE */ + 'cur_id' => $id + ), 'Article::protect' + ); - $sql = "UPDATE cur SET cur_touched='" . wfTimestampNow() . "'," . - "cur_restrictions='{$limit}' WHERE cur_id={$id}"; - wfQuery( $sql, DB_WRITE, "Article::protect" ); - - $log = new LogPage( wfMsg( "protectlogpage" ), wfMsg( "protectlogtext" ) ); - if ( $limit === "" ) { - $log->addEntry( wfMsg( "unprotectedarticle", $this->mTitle->getPrefixedText() ), $reason ); - } else { - $log->addEntry( wfMsg( "protectedarticle", $this->mTitle->getPrefixedText() ), $reason ); - } - $wgOut->redirect( $this->mTitle->getFullURL() ); + $log = new LogPage( wfMsg( 'protectlogpage' ), wfMsg( 'protectlogtext' ) ); + if ( $limit === "" ) { + $log->addEntry( wfMsg( 'unprotectedarticle', $this->mTitle->getPrefixedText() ), $reason ); + } else { + $log->addEntry( wfMsg( 'protectedarticle', $this->mTitle->getPrefixedText() ), $reason ); + } + $wgOut->redirect( $this->mTitle->getFullURL() ); return; } else { - $reason = htmlspecialchars( wfMsg( "protectreason" ) ); - return $this->confirmProtect( "", $reason, $limit ); + $reason = htmlspecialchars( wfMsg( 'protectreason' ) ); + return $this->confirmProtect( '', $reason, $limit ); } } - # Output protection confirmation dialog - function confirmProtect( $par, $reason, $limit = "sysop" ) - { + # Output protection confirmation dialog + + function confirmProtect( $par, $reason, $limit = 'sysop' ) { global $wgOut; wfDebug( "Article::confirmProtect\n" ); $sub = htmlspecialchars( $this->mTitle->getPrefixedText() ); - $wgOut->setRobotpolicy( "noindex,nofollow" ); - - $check = ""; - $protcom = ""; - - if ( $limit === "" ) { - $wgOut->setSubtitle( wfMsg( "unprotectsub", $sub ) ); - $wgOut->addWikiText( wfMsg( "confirmunprotecttext" ) ); - $check = htmlspecialchars( wfMsg( "confirmunprotect" ) ); - $protcom = htmlspecialchars( wfMsg( "unprotectcomment" ) ); - $formaction = $this->mTitle->escapeLocalURL( "action=unprotect" . $par ); + $wgOut->setRobotpolicy( 'noindex,nofollow' ); + + $check = ''; + $protcom = ''; + + if ( $limit === '' ) { + $wgOut->setPageTitle( wfMsg( 'confirmunprotect' ) ); + $wgOut->setSubtitle( wfMsg( 'unprotectsub', $sub ) ); + $wgOut->addWikiText( wfMsg( 'confirmunprotecttext' ) ); + $check = htmlspecialchars( wfMsg( 'confirmunprotect' ) ); + $protcom = htmlspecialchars( wfMsg( 'unprotectcomment' ) ); + $formaction = $this->mTitle->escapeLocalURL( 'action=unprotect' . $par ); } else { - $wgOut->setSubtitle( wfMsg( "protectsub", $sub ) ); - $wgOut->addWikiText( wfMsg( "confirmprotecttext" ) ); - $check = htmlspecialchars( wfMsg( "confirmprotect" ) ); - $protcom = htmlspecialchars( wfMsg( "protectcomment" ) ); - $formaction = $this->mTitle->escapeLocalURL( "action=protect" . $par ); + $wgOut->setPageTitle( wfMsg( 'confirmprotect' ) ); + $wgOut->setSubtitle( wfMsg( 'protectsub', $sub ) ); + $wgOut->addWikiText( wfMsg( 'confirmprotecttext' ) ); + $check = htmlspecialchars( wfMsg( 'confirmprotect' ) ); + $protcom = htmlspecialchars( wfMsg( 'protectcomment' ) ); + $formaction = $this->mTitle->escapeLocalURL( 'action=protect' . $par ); } - $confirm = htmlspecialchars( wfMsg( "confirm" ) ); + $confirm = htmlspecialchars( wfMsg( 'confirm' ) ); $wgOut->addHTML( "
@@ -896,21 +1250,20 @@ class Article { $wgOut->returnToMain( false ); } - function unprotect() - { - return $this->protect( "" ); + function unprotect() { + return $this->protect( '' ); } - # UI entry point for page deletion - function delete() - { + # UI entry point for page deletion + + function delete() { global $wgUser, $wgOut, $wgMessageCache, $wgRequest; - $fname = "Article::delete"; + $fname = 'Article::delete'; $confirm = $wgRequest->getBool( 'wpConfirm' ) && $wgRequest->wasPosted(); $reason = $wgRequest->getText( 'wpReason' ); - + # This code desperately needs to be totally rewritten - + # Check permissions if ( ( ! $wgUser->isSysop() ) ) { $wgOut->sysopRequired(); @@ -922,10 +1275,10 @@ class Article { } # Better double-check that it hasn't been deleted yet! - $wgOut->setPagetitle( wfMsg( "confirmdelete" ) ); - if ( ( "" == trim( $this->mTitle->getText() ) ) + $wgOut->setPagetitle( wfMsg( 'confirmdelete' ) ); + if ( ( '' == trim( $this->mTitle->getText() ) ) or ( $this->mTitle->getArticleId() == 0 ) ) { - $wgOut->fatalError( wfMsg( "cannotdelete" ) ); + $wgOut->fatalError( wfMsg( 'cannotdelete' ) ); return; } @@ -937,21 +1290,33 @@ class Article { # determine whether this page has earlier revisions # and insert a warning if it does # we select the text because it might be useful below + $dbr =& wfGetDB( DB_SLAVE ); $ns = $this->mTitle->getNamespace(); $title = $this->mTitle->getDBkey(); - $etitle = wfStrencode( $title ); - $sql = "SELECT old_text,old_flags FROM old WHERE old_namespace=$ns and old_title='$etitle' ORDER BY inverse_timestamp LIMIT 1"; - $res = wfQuery( $sql, DB_READ, $fname ); - if( ($old=wfFetchObject($res)) && !$confirm ) { + $old = $dbr->getArray( 'old', + array( 'old_text', 'old_flags' ), + array( + 'old_namespace' => $ns, + 'old_title' => $title, + ), $fname, array( 'ORDER BY' => 'inverse_timestamp' ) + ); + + if( $old !== false && !$confirm ) { $skin=$wgUser->getSkin(); - $wgOut->addHTML("".wfMsg("historywarning")); - $wgOut->addHTML( $skin->historyLink() .""); + $wgOut->addHTML(''.wfMsg('historywarning')); + $wgOut->addHTML( $skin->historyLink() .''); } - $sql="SELECT cur_text FROM cur WHERE cur_namespace=$ns and cur_title='$etitle'"; - $res=wfQuery($sql, DB_READ, $fname); - if( ($s=wfFetchObject($res))) { + # Fetch cur_text + $s = $dbr->getArray( 'cur', + array( 'cur_text' ), + array( + 'cur_namespace' => $ns, + 'cur_title' => $title, + ), $fname + ); + if( $s !== false ) { # if this is a mini-text, we can paste part of it into the deletion reason #if this is empty, an earlier revision may contain "useful" text @@ -963,57 +1328,57 @@ class Article { $text = Article::getRevisionText( $old ); $blanked = true; } - + } - - $length=strlen($text); - + + $length=strlen($text); + # this should not happen, since it is not possible to store an empty, new # page. Let's insert a standard text in case it does, though - if($length == 0 && $reason === "") { - $reason = wfMsg("exblank"); + if($length == 0 && $reason === '') { + $reason = wfMsg('exblank'); } - - if($length < 500 && $reason === "") { - + + if($length < 500 && $reason === '') { + # comment field=255, let's grep the first 150 to have some user # space left $text=substr($text,0,150); # let's strip out newlines and HTML tags - $text=preg_replace("/\"/","'",$text); - $text=preg_replace("/\/",">",$text); - $text=preg_replace("/[\n\r]/","",$text); + $text=preg_replace('/\"/',"'",$text); + $text=preg_replace('/\/','>',$text); + $text=preg_replace("/[\n\r]/",'',$text); if(!$blanked) { - $reason=wfMsg("excontent"). " '".$text; + $reason=wfMsg('excontent'). " '".$text; } else { - $reason=wfMsg("exbeforeblank") . " '".$text; + $reason=wfMsg('exbeforeblank') . " '".$text; } - if($length>150) { $reason .= "..."; } # we've only pasted part of the text - $reason.="'"; + if($length>150) { $reason .= '...'; } # we've only pasted part of the text + $reason.="'"; } } - return $this->confirmDelete( "", $reason ); + return $this->confirmDelete( '', $reason ); } - + # Output deletion confirmation dialog - function confirmDelete( $par, $reason ) - { + + function confirmDelete( $par, $reason ) { global $wgOut; wfDebug( "Article::confirmDelete\n" ); - + $sub = htmlspecialchars( $this->mTitle->getPrefixedText() ); - $wgOut->setSubtitle( wfMsg( "deletesub", $sub ) ); - $wgOut->setRobotpolicy( "noindex,nofollow" ); - $wgOut->addWikiText( wfMsg( "confirmdeletetext" ) ); + $wgOut->setSubtitle( wfMsg( 'deletesub', $sub ) ); + $wgOut->setRobotpolicy( 'noindex,nofollow' ); + $wgOut->addWikiText( wfMsg( 'confirmdeletetext' ) ); + + $formaction = $this->mTitle->escapeLocalURL( 'action=delete' . $par ); - $formaction = $this->mTitle->escapeLocalURL( "action=delete" . $par ); - - $confirm = htmlspecialchars( wfMsg( "confirm" ) ); - $check = htmlspecialchars( wfMsg( "confirmcheck" ) ); - $delcom = htmlspecialchars( wfMsg( "deletecomment" ) ); + $confirm = htmlspecialchars( wfMsg( 'confirm' ) ); + $check = htmlspecialchars( wfMsg( 'confirmcheck' ) ); + $delcom = htmlspecialchars( wfMsg( 'deletecomment' ) ); $wgOut->addHTML( " @@ -1049,62 +1414,62 @@ class Article { $wgOut->returnToMain( false ); } + # Perform a deletion and output success or failure messages - function doDelete( $reason ) - { + + function doDelete( $reason ) { global $wgOut, $wgUser, $wgLang; - $fname = "Article::doDelete"; + $fname = 'Article::doDelete'; wfDebug( "$fname\n" ); - if ( $this->doDeleteArticle( $reason ) ) { + if ( $this->doDeleteArticle( $reason ) ) { $deleted = $this->mTitle->getPrefixedText(); - $wgOut->setPagetitle( wfMsg( "actioncomplete" ) ); - $wgOut->setRobotpolicy( "noindex,nofollow" ); + $wgOut->setPagetitle( wfMsg( 'actioncomplete' ) ); + $wgOut->setRobotpolicy( 'noindex,nofollow' ); $sk = $wgUser->getSkin(); - $loglink = $sk->makeKnownLink( $wgLang->getNsText( - Namespace::getWikipedia() ) . - ":" . wfMsg( "dellogpage" ), wfMsg( "deletionlog" ) ); + $loglink = $sk->makeKnownLink( $wgLang->getNsText( NS_WIKIPEDIA ) . + ':' . wfMsg( 'dellogpage' ), wfMsg( 'deletionlog' ) ); $text = wfMsg( "deletedtext", $deleted, $loglink ); - $wgOut->addHTML( "

" . $text . "

\n" ); + $wgOut->addHTML( '

' . $text . "

\n" ); $wgOut->returnToMain( false ); } else { - $wgOut->fatalError( wfMsg( "cannotdelete" ) ); + $wgOut->fatalError( wfMsg( 'cannotdelete' ) ); } } # Back-end article deletion # Deletes the article with database consistency, writes logs, purges caches # Returns success - function doDeleteArticle( $reason ) - { + function doDeleteArticle( $reason ) { global $wgUser, $wgLang; global $wgUseSquid, $wgDeferredUpdateList, $wgInternalServer; - $fname = "Article::doDeleteArticle"; - wfDebug( "$fname\n" ); + $fname = 'Article::doDeleteArticle'; + wfDebug( $fname."\n" ); + $dbw =& wfGetDB( DB_MASTER ); $ns = $this->mTitle->getNamespace(); - $t = wfStrencode( $this->mTitle->getDBkey() ); + $t = $this->mTitle->getDBkey(); $id = $this->mTitle->getArticleID(); - if ( "" == $t || $id == 0 ) { + if ( '' == $t || $id == 0 ) { return false; } $u = new SiteStatsUpdate( 0, 1, -$this->isCountable( $this->getContent( true ) ) ); array_push( $wgDeferredUpdateList, $u ); - + $linksTo = $this->mTitle->getLinksTo(); # Squid purging if ( $wgUseSquid ) { - $urls = array( + $urls = array( $this->mTitle->getInternalURL(), - $this->mTitle->getInternalURL( "history" ) + $this->mTitle->getInternalURL( 'history' ) ); foreach ( $linksTo as $linkTo ) { $urls[] = $linkTo->getInternalURL(); @@ -1119,68 +1484,78 @@ class Article { Title::touchArray( $linksTo ); # Move article and history to the "archive" table - $sql = "INSERT INTO archive (ar_namespace,ar_title,ar_text," . - "ar_comment,ar_user,ar_user_text,ar_timestamp,ar_minor_edit," . - "ar_flags) SELECT cur_namespace,cur_title,cur_text,cur_comment," . - "cur_user,cur_user_text,cur_timestamp,cur_minor_edit,0 FROM cur " . - "WHERE cur_namespace={$ns} AND cur_title='{$t}'"; - wfQuery( $sql, DB_WRITE, $fname ); - - $sql = "INSERT INTO archive (ar_namespace,ar_title,ar_text," . - "ar_comment,ar_user,ar_user_text,ar_timestamp,ar_minor_edit," . - "ar_flags) SELECT old_namespace,old_title,old_text,old_comment," . - "old_user,old_user_text,old_timestamp,old_minor_edit,old_flags " . - "FROM old WHERE old_namespace={$ns} AND old_title='{$t}'"; - wfQuery( $sql, DB_WRITE, $fname ); + $archiveTable = $dbw->tableName( 'archive' ); + $oldTable = $dbw->tableName( 'old' ); + $curTable = $dbw->tableName( 'cur' ); + $recentchangesTable = $dbw->tableName( 'recentchanges' ); + $linksTable = $dbw->tableName( 'links' ); + $brokenlinksTable = $dbw->tableName( 'brokenlinks' ); + + $dbw->insertSelect( 'archive', 'cur', + array( + 'ar_namespace' => 'cur_namespace', + 'ar_title' => 'cur_title', + 'ar_text' => 'cur_text', + 'ar_comment' => 'cur_comment', + 'ar_user' => 'cur_user', + 'ar_user_text' => 'cur_user_text', + 'ar_timestamp' => 'cur_timestamp', + 'ar_minor_edit' => 'cur_minor_edit', + 'ar_flags' => 0, + ), array( + 'cur_namespace' => $ns, + 'cur_title' => $t, + ), $fname + ); + + $dbw->insertSelect( 'archive', 'old', + array( + 'ar_namespace' => 'old_namespace', + 'ar_title' => 'old_title', + 'ar_text' => 'old_text', + 'ar_comment' => 'old_comment', + 'ar_user' => 'old_user', + 'ar_user_text' => 'old_user_text', + 'ar_timestamp' => 'old_timestamp', + 'ar_minor_edit' => 'old_minor_edit', + 'ar_flags' => 'old_flags' + ), array( + 'old_namespace' => $ns, + 'old_title' => $t, + ), $fname + ); # Now that it's safely backed up, delete it - $sql = "DELETE FROM cur WHERE cur_namespace={$ns} AND " . - "cur_title='{$t}'"; - wfQuery( $sql, DB_WRITE, $fname ); - - $sql = "DELETE FROM old WHERE old_namespace={$ns} AND " . - "old_title='{$t}'"; - wfQuery( $sql, DB_WRITE, $fname ); - - $sql = "DELETE FROM recentchanges WHERE rc_namespace={$ns} AND " . - "rc_title='{$t}'"; - wfQuery( $sql, DB_WRITE, $fname ); + $dbw->delete( 'cur', array( 'cur_namespace' => $ns, 'cur_title' => $t ), $fname ); + $dbw->delete( 'old', array( 'old_namespace' => $ns, 'old_title' => $t ), $fname ); + $dbw->delete( 'recentchanges', array( 'rc_namespace' => $ns, 'rc_title' => $t ), $fname ); # Finally, clean up the link tables - $t = wfStrencode( $this->mTitle->getPrefixedDBkey() ); + $t = $this->mTitle->getPrefixedDBkey(); Article::onArticleDelete( $this->mTitle ); - - $sql = "INSERT INTO brokenlinks (bl_from,bl_to) VALUES "; - $first = true; + # Insert broken links + $brokenLinks = array(); foreach ( $linksTo as $titleObj ) { - if ( ! $first ) { $sql .= ","; } - $first = false; # Get article ID. Efficient because it was loaded into the cache by getLinksTo(). - $linkID = $titleObj->getArticleID(); - $sql .= "({$linkID},'{$t}')"; - } - if ( ! $first ) { - wfQuery( $sql, DB_WRITE, $fname ); + $linkID = $titleObj->getArticleID(); + $brokenLinks[] = array( 'bl_from' => $linkID, 'bl_to' => $t ); } + $dbw->insert( 'brokenlinks', $brokenLinks, $fname, 'IGNORE' ); - $sql = "DELETE FROM links WHERE l_to={$id}"; - wfQuery( $sql, DB_WRITE, $fname ); - - $sql = "DELETE FROM links WHERE l_from={$id}"; - wfQuery( $sql, DB_WRITE, $fname ); + # Delete live links + $dbw->delete( 'links', array( 'l_to' => $id ) ); + $dbw->delete( 'links', array( 'l_from' => $id ) ); + $dbw->delete( 'imagelinks', array( 'il_from' => $id ) ); + $dbw->delete( 'brokenlinks', array( 'bl_from' => $id ) ); + $dbw->delete( 'categorylinks', array( 'cl_from' => $id ) ); - $sql = "DELETE FROM imagelinks WHERE il_from={$id}"; - wfQuery( $sql, DB_WRITE, $fname ); - - $sql = "DELETE FROM brokenlinks WHERE bl_from={$id}"; - wfQuery( $sql, DB_WRITE, $fname ); - - $log = new LogPage( wfMsg( "dellogpage" ), wfMsg( "dellogpagetext" ) ); + # Log the deletion + $log = new LogPage( wfMsg( 'dellogpage' ), wfMsg( 'dellogpagetext' ) ); $art = $this->mTitle->getPrefixedText(); - $log->addEntry( wfMsg( "deletedarticle", $art ), $reason ); + $log->addEntry( wfMsg( 'deletedarticle', $art ), $reason ); # Clear the cached article id so the interface doesn't act like we exist $this->mTitle->resetArticleID( 0 ); @@ -1188,91 +1563,99 @@ class Article { return true; } - function rollback() - { + function rollback() { global $wgUser, $wgLang, $wgOut, $wgRequest; + $fname = "Article::rollback"; if ( ! $wgUser->isSysop() ) { $wgOut->sysopRequired(); return; } if ( wfReadOnly() ) { - $wgOut->readOnlyPage( $this->getContent() ); + $wgOut->readOnlyPage( $this->getContent( true ) ); return; } - + $dbw =& wfGetDB( DB_MASTER ); + # Enhanced rollback, marks edits rc_bot=1 $bot = $wgRequest->getBool( 'bot' ); - + # Replace all this user's current edits with the next one down - $tt = wfStrencode( $this->mTitle->getDBKey() ); + $tt = $this->mTitle->getDBKey(); $n = $this->mTitle->getNamespace(); - - # Get the last editor - $sql = "SELECT cur_id,cur_user,cur_user_text,cur_comment FROM cur WHERE cur_title='{$tt}' AND cur_namespace={$n}"; - $res = wfQuery( $sql, DB_READ ); - if( ($x = wfNumRows( $res )) != 1 ) { + + # Get the last editor, lock table exclusively + $s = $dbw->getArray( 'cur', + array( 'cur_id','cur_user','cur_user_text','cur_comment' ), + array( 'cur_title' => $tt, 'cur_namespace' => $n ), + $fname, 'FOR UPDATE' + ); + if( $s === false ) { # Something wrong - $wgOut->addHTML( wfMsg( "notanarticle" ) ); + $wgOut->addHTML( wfMsg( 'notanarticle' ) ); return; } - $s = wfFetchObject( $res ); - $ut = wfStrencode( $s->cur_user_text ); + $ut = $dbw->strencode( $s->cur_user_text ); $uid = $s->cur_user; $pid = $s->cur_id; - - $from = str_replace( '_', ' ', $wgRequest->getVal( "from" ) ); + + $from = str_replace( '_', ' ', $wgRequest->getVal( 'from' ) ); if( $from != $s->cur_user_text ) { - $wgOut->setPageTitle(wfmsg("rollbackfailed")); - $wgOut->addWikiText( wfMsg( "alreadyrolled", + $wgOut->setPageTitle(wfmsg('rollbackfailed')); + $wgOut->addWikiText( wfMsg( 'alreadyrolled', htmlspecialchars( $this->mTitle->getPrefixedText()), htmlspecialchars( $from ), htmlspecialchars( $s->cur_user_text ) ) ); - if($s->cur_comment != "") { + if($s->cur_comment != '') { $wgOut->addHTML( - wfMsg("editcomment", + wfMsg('editcomment', htmlspecialchars( $s->cur_comment ) ) ); } return; } - + # Get the last edit not by this guy - $sql = "SELECT old_text,old_user,old_user_text,old_timestamp,old_flags - FROM old USE INDEX (name_title_timestamp) - WHERE old_namespace={$n} AND old_title='{$tt}' - AND (old_user <> {$uid} OR old_user_text <> '{$ut}') - ORDER BY inverse_timestamp LIMIT 1"; - $res = wfQuery( $sql, DB_READ ); - if( wfNumRows( $res ) != 1 ) { + $s = $dbw->getArray( 'old', + array( 'old_text','old_user','old_user_text','old_timestamp','old_flags' ), + array( + 'old_namespace' => $n, + 'old_title' => $tt, + "old_user <> {$uid} OR old_user_text <> '{$ut}'" + ), $fname, array( 'FOR UPDATE', 'USE INDEX' => 'name_title_timestamp' ) + ); + if( $s === false ) { # Something wrong - $wgOut->setPageTitle(wfMsg("rollbackfailed")); - $wgOut->addHTML( wfMsg( "cantrollback" ) ); + $wgOut->setPageTitle(wfMsg('rollbackfailed')); + $wgOut->addHTML( wfMsg( 'cantrollback' ) ); return; } - $s = wfFetchObject( $res ); - + if ( $bot ) { # Mark all reverted edits as bot - $sql = "UPDATE recentchanges SET rc_bot=1 WHERE - rc_cur_id=$pid AND rc_user=$uid AND rc_timestamp > '{$s->old_timestamp}'"; - wfQuery( $sql, DB_WRITE, $fname ); + $dbw->updateArray( 'recentchanges', + array( /* SET */ + 'rc_bot' => 1 + ), array( /* WHERE */ + 'rc_user' => $uid, + "rc_timestamp > '{$s->old_timestamp}'", + ), $fname + ); } # Save it! - $newcomment = wfMsg( "revertpage", $s->old_user_text, $from ); - $wgOut->setPagetitle( wfMsg( "actioncomplete" ) ); - $wgOut->setRobotpolicy( "noindex,nofollow" ); - $wgOut->addHTML( "

" . $newcomment . "

\n
\n" ); + $newcomment = wfMsg( 'revertpage', $s->old_user_text, $from ); + $wgOut->setPagetitle( wfMsg( 'actioncomplete' ) ); + $wgOut->setRobotpolicy( 'noindex,nofollow' ); + $wgOut->addHTML( '

' . $newcomment . "

\n
\n" ); $this->updateArticle( Article::getRevisionText( $s ), $newcomment, 1, $this->mTitle->userIsWatching(), $bot ); Article::onArticleEdit( $this->mTitle ); $wgOut->returnToMain( false ); } - + # Do standard deferred updates after page view - /* private */ function viewUpdates() - { + /* private */ function viewUpdates() { global $wgDeferredUpdateList; if ( 0 != $this->getID() ) { global $wgDisableCounters; @@ -1281,30 +1664,30 @@ class Article { $u = new SiteStatsUpdate( 1, 0, 0 ); array_push( $wgDeferredUpdateList, $u ); } - $u = new UserTalkUpdate( 0, $this->mTitle->getNamespace(), - $this->mTitle->getDBkey() ); - array_push( $wgDeferredUpdateList, $u ); } + $u = new UserTalkUpdate( 0, $this->mTitle->getNamespace(), + $this->mTitle->getDBkey() ); + array_push( $wgDeferredUpdateList, $u ); } # Do standard deferred updates after page edit. # Every 1000th edit, prune the recent changes table. - /* private */ function editUpdates( $text ) - { + /* private */ function editUpdates( $text ) { global $wgDeferredUpdateList, $wgDBname, $wgMemc; global $wgMessageCache; wfSeedRandom(); if ( 0 == mt_rand( 0, 999 ) ) { + $dbw =& wfGetDB( DB_MASTER ); $cutoff = wfUnix2Timestamp( time() - ( 7 * 86400 ) ); $sql = "DELETE FROM recentchanges WHERE rc_timestamp < '{$cutoff}'"; - wfQuery( $sql, DB_WRITE ); + $dbw->query( $sql ); } $id = $this->getID(); $title = $this->mTitle->getPrefixedDBkey(); $shortTitle = $this->mTitle->getDBkey(); - + $adj = $this->mCountAdjustment; if ( 0 != $id ) { @@ -1324,24 +1707,22 @@ class Article { } } - /* private */ function setOldSubtitle() - { + /* private */ function setOldSubtitle() { global $wgLang, $wgOut; $td = $wgLang->timeanddate( $this->mTimestamp, true ); - $r = wfMsg( "revisionasof", $td ); + $r = wfMsg( 'revisionasof', $td ); $wgOut->setSubtitle( "({$r})" ); } # This function is called right before saving the wikitext, # so we can do things like signatures and links-in-context. - function preSaveTransform( $text ) - { + function preSaveTransform( $text ) { global $wgParser, $wgUser; return $wgParser->preSaveTransform( $text, $this->mTitle, $wgUser, ParserOptions::newFromUser( $wgUser ) ); } - + /* Caching functions */ # checkLastModified returns true if it has taken care of all @@ -1356,7 +1737,7 @@ class Article { $called = true; if($this->isFileCacheable()) { $touched = $this->mTouched; - if( $this->mTitle->getPrefixedDBkey() == wfMsg( "mainpage" ) ) { + if( $this->mTitle->getPrefixedDBkey() == wfMsg( 'mainpage' ) ) { # Expire the main page quicker $expire = wfUnix2Timestamp( time() - 3600 ); $touched = max( $expire, $touched ); @@ -1368,7 +1749,7 @@ class Article { $cache->loadFromFileCache(); return true; } else { - wfDebug( " tryFileCache() - starting buffer\n" ); + wfDebug( " tryFileCache() - starting buffer\n" ); ob_start( array(&$cache, 'saveToFileCache' ) ); } } else { @@ -1379,92 +1760,159 @@ class Article { function isFileCacheable() { global $wgUser, $wgUseFileCache, $wgShowIPinHeader, $wgRequest; extract( $wgRequest->getValues( 'action', 'oldid', 'diff', 'redirect', 'printable' ) ); - + return $wgUseFileCache and (!$wgShowIPinHeader) and ($this->getID() != 0) and ($wgUser->getId() == 0) and (!$wgUser->getNewtalk()) - and ($this->mTitle->getNamespace() != Namespace::getSpecial()) - and ($action == "view") + and ($this->mTitle->getNamespace() != NS_SPECIAL ) + and (empty( $action ) || $action == 'view') and (!isset($oldid)) and (!isset($diff)) and (!isset($redirect)) and (!isset($printable)) and (!$this->mRedirectedFrom); } - + + # Loads cur_touched and returns a value indicating if it should be used function checkTouched() { + $fname = 'Article::checkTouched'; + $id = $this->getID(); - $sql = "SELECT cur_touched,cur_is_redirect FROM cur WHERE cur_id=$id"; - $res = wfQuery( $sql, DB_READ, "Article::checkTouched" ); - if( $s = wfFetchObject( $res ) ) { + $dbr =& wfGetDB( DB_SLAVE ); + $s = $dbr->getArray( 'cur', array( 'cur_touched', 'cur_is_redirect' ), + array( 'cur_id' => $id ), $fname ); + if( $s !== false ) { $this->mTouched = $s->cur_touched; return !$s->cur_is_redirect; } else { return false; } } - - /* static */ function incViewCount( $id ) - { + + # Edit an article without doing all that other stuff + function quickEdit( $text, $comment = '', $minor = 0 ) { + global $wgUser, $wgMwRedir; + $fname = 'Article::quickEdit'; + wfProfileIn( $fname ); + + $dbw =& wfGetDB( DB_MASTER ); + $ns = $this->mTitle->getNamespace(); + $dbkey = $this->mTitle->getDBkey(); + $encDbKey = $dbw->strencode( $dbkey ); + $timestamp = wfTimestampNow(); + + # Save to history + $dbw->insertSelect( 'old', 'cur', + array( + 'old_namespace' => 'cur_namespace', + 'old_title' => 'cur_title', + 'old_text' => 'cur_text', + 'old_comment' => 'cur_comment', + 'old_user' => 'cur_user', + 'old_user_text' => 'cur_user_text', + 'old_timestamp' => 'cur_timestamp', + 'inverse_timestamp' => '99999999999999-cur_timestamp', + ), array( + 'cur_namespace' => $ns, + 'cur_title' => $dbkey, + ), $fname + ); + + # Use the affected row count to determine if the article is new + $numRows = $dbw->affectedRows(); + + # Make an array of fields to be inserted + $fields = array( + 'cur_text' => $text, + 'cur_timestamp' => $timestamp, + 'cur_user' => $wgUser->getID(), + 'cur_user_text' => $wgUser->getName(), + 'inverse_timestamp' => wfInvertTimestamp( $timestamp ), + 'cur_comment' => $comment, + 'cur_is_redirect' => $wgMwRedir->matchStart( $text ) ? 1 : 0, + 'cur_minor_edit' => intval($minor), + 'cur_touched' => $timestamp, + ); + + if ( $numRows ) { + # Update article + $fields['cur_is_new'] = 0; + $dbw->updateArray( 'cur', $fields, array( 'cur_namespace' => $ns, 'cur_title' => $dbkey ), $fname ); + } else { + # Insert new article + $fields['cur_is_new'] = 1; + $fields['cur_namespace'] = $ns; + $fields['cur_title'] = $dbkey; + $fields['cur_random'] = $rand = number_format( mt_rand() / mt_getrandmax(), 12, '.', '' ); + $dbw->insertArray( 'cur', $fields, $fname ); + } + wfProfileOut( $fname ); + } + + /* static */ function incViewCount( $id ) { $id = intval( $id ); global $wgHitcounterUpdateFreq; - if( $wgHitcounterUpdateFreq <= 1 ){ // - wfQuery("UPDATE cur SET cur_counter = cur_counter + 1 " . - "WHERE cur_id = $id", DB_WRITE); + $dbw =& wfGetDB( DB_MASTER ); + $curTable = $dbw->tableName( 'cur' ); + $hitcounterTable = $dbw->tableName( 'hitcounter' ); + $acchitsTable = $dbw->tableName( 'acchits' ); + + if( $wgHitcounterUpdateFreq <= 1 ){ // + $dbw->query( "UPDATE $curTable SET cur_counter = cur_counter + 1 WHERE cur_id = $id" ); return; } # Not important enough to warrant an error page in case of failure - $oldignore = wfIgnoreSQLErrors( true ); + $oldignore = $dbw->ignoreErrors( true ); - wfQuery("INSERT INTO hitcounter (hc_id) VALUES ({$id})", DB_WRITE); + $dbw->query( "INSERT INTO $hitcounterTable (hc_id) VALUES ({$id})" ); $checkfreq = intval( $wgHitcounterUpdateFreq/25 + 1 ); - if( (rand() % $checkfreq != 0) or (wfLastErrno() != 0) ){ + if( (rand() % $checkfreq != 0) or ($dbw->lastErrno() != 0) ){ # Most of the time (or on SQL errors), skip row count check - wfIgnoreSQLErrors( $oldignore ); + $dbw->ignoreErrors( $oldignore ); return; } - $res = wfQuery("SELECT COUNT(*) as n FROM hitcounter", DB_WRITE); - $row = wfFetchObject( $res ); + $res = $dbw->query("SELECT COUNT(*) as n FROM $hitcounterTable"); + $row = $dbw->fetchObject( $res ); $rown = intval( $row->n ); - if( $rown >= $wgHitcounterUpdateFreq ){ - wfProfileIn( "Article::incViewCount-collect" ); + if( $rown >= $wgHitcounterUpdateFreq ){ + wfProfileIn( 'Article::incViewCount-collect' ); $old_user_abort = ignore_user_abort( true ); - wfQuery("LOCK TABLES hitcounter WRITE", DB_WRITE); - wfQuery("CREATE TEMPORARY TABLE acchits TYPE=HEAP ". - "SELECT hc_id,COUNT(*) AS hc_n FROM hitcounter ". - "GROUP BY hc_id", DB_WRITE); - wfQuery("DELETE FROM hitcounter", DB_WRITE); - wfQuery("UNLOCK TABLES", DB_WRITE); - wfQuery("UPDATE cur,acchits SET cur_counter=cur_counter + hc_n ". - "WHERE cur_id = hc_id", DB_WRITE); - wfQuery("DROP TABLE acchits", DB_WRITE); + $dbw->query("LOCK TABLES $hitcounterTable WRITE"); + $dbw->query("CREATE TEMPORARY TABLE $acchitsTable TYPE=HEAP ". + "SELECT hc_id,COUNT(*) AS hc_n FROM $hitcounterTable ". + 'GROUP BY hc_id'); + $dbw->query("DELETE FROM $hitcounterTable"); + $dbw->query('UNLOCK TABLES'); + $dbw->query("UPDATE $curTable,$acchitsTable SET cur_counter=cur_counter + hc_n ". + 'WHERE cur_id = hc_id'); + $dbw->query("DROP TABLE $acchitsTable"); ignore_user_abort( $old_user_abort ); - wfProfileOut( "Article::incViewCount-collect" ); + wfProfileOut( 'Article::incViewCount-collect' ); } - wfIgnoreSQLErrors( $oldignore ); + $dbw->ignoreErrors( $oldignore ); } # The onArticle*() functions are supposed to be a kind of hooks - # which should be called whenever any of the specified actions - # are done. + # which should be called whenever any of the specified actions + # are done. # - # This is a good place to put code to clear caches, for instance. + # This is a good place to put code to clear caches, for instance. - # This is called on page move and undelete, as well as edit - /* static */ function onArticleCreate($title_obj){ - global $wgEnablePersistentLC, $wgEnableParserCache, $wgUseSquid, $wgDeferredUpdateList; + # This is called on page move and undelete, as well as edit + /* static */ function onArticleCreate($title_obj) { + global $wgUseSquid, $wgDeferredUpdateList; $titles = $title_obj->getBrokenLinksTo(); - - # Purge squid + + # Purge squid if ( $wgUseSquid ) { $urls = $title_obj->getSquidURLs(); foreach ( $titles as $linkTitle ) { @@ -1475,33 +1923,83 @@ class Article { } # Clear persistent link cache - if ( $wgEnablePersistentLC ) { - LinkCache::linksccClearBrokenLinksTo( $title_obj->getPrefixedDBkey() ); - } + LinkCache::linksccClearBrokenLinksTo( $title_obj->getPrefixedDBkey() ); + } - # Clear parser cache (not really used) - if ( $wgEnableParserCache ) { - OutputPage::parsercacheClearBrokenLinksTo( $title_obj->getPrefixedDBkey() ); - } + /* static */ function onArticleDelete($title_obj) { + LinkCache::linksccClearLinksTo( $title_obj->getArticleID() ); } - /* static */ function onArticleDelete($title_obj){ - global $wgEnablePersistentLC, $wgEnableParserCache; - if ( $wgEnablePersistentLC ) { - LinkCache::linksccClearLinksTo( $title_obj->getArticleID() ); - } - if ( $wgEnableParserCache ) { - OutputPage::parsercacheClearLinksTo( $title_obj->getArticleID() ); - } + /* static */ function onArticleEdit($title_obj) { + LinkCache::linksccClearPage( $title_obj->getArticleID() ); } - /* static */ function onArticleEdit($title_obj){ - global $wgEnablePersistentLC, $wgEnableParserCache; - if ( $wgEnablePersistentLC ) { - LinkCache::linksccClearPage( $title_obj->getArticleID() ); + + # Info about this page + + function info() { + global $wgUser, $wgTitle, $wgOut, $wgLang, $wgAllowPageInfo; + $fname = 'Article::info'; + + if ( !$wgAllowPageInfo ) { + $wgOut->errorpage( "nosuchaction", "nosuchactiontext" ); + return; } - if ( $wgEnableParserCache ) { - OutputPage::parsercacheClearPage( $title_obj->getArticleID(), $title_obj->getNamespace() ); + + $dbr =& wfGetDB( DB_SLAVE ); + + $basenamespace = $wgTitle->getNamespace() & (~1); + $cur_clause = array( 'cur_title' => $wgTitle->getDBkey(), 'cur_namespace' => $basenamespace ); + $old_clause = array( 'old_title' => $wgTitle->getDBkey(), 'old_namespace' => $basenamespace ); + $wl_clause = array( 'wl_title' => $wgTitle->getDBkey(), 'wl_namespace' => $basenamespace ); + $fullTitle = $wgTitle->makeName($basenamespace, $wgTitle->getDBKey()); + $wgOut->setPagetitle( $fullTitle ); + $wgOut->setSubtitle( wfMsg( "infosubtitle" )); + + # first, see if the page exists at all. + $exists = $dbr->selectField( 'cur', 'COUNT(*)', $cur_clause, $fname ); + if ($exists < 1) { + $wgOut->addHTML( wfMsg("noarticletext") ); + } else { + $numwatchers = $dbr->selectField( 'watchlist', 'COUNT(*)', $wl_clause, $fname ); + $wgOut->addHTML( "
  • " . wfMsg("numwatchers", $numwatchers) . "
  • " ); + $old = $dbr->selectField( 'old', 'COUNT(*)', $old_clause, $fname ); + $wgOut->addHTML( "
  • " . wfMsg("numedits", $old + 1) . "
  • "); + + # to find number of distinct authors, we need to do some + # funny stuff because of the cur/old table split: + # - first, find the name of the 'cur' author + # - then, find the number of *other* authors in 'old' + + # find 'cur' author + $cur_author = $dbr->selectField( 'cur', 'cur_user_text', $cur_clause, $fname ); + + # find number of 'old' authors excluding 'cur' author + $authors = $dbr->selectField( 'old', 'COUNT(DISTINCT old_user_text)', + $old_clause + array( 'old_user_text<>' . $dbr->addQuotes( $cur_author ) ), $fname ) + 1; + + # now for the Talk page ... + $cur_clause = array( 'cur_title' => $wgTitle->getDBkey(), 'cur_namespace' => $basenamespace+1 ); + $old_clause = array( 'old_title' => $wgTitle->getDBkey(), 'old_namespace' => $basenamespace+1 ); + + # does it exist? + $exists = $dbr->selectField( 'cur', 'COUNT(*)', $cur_clause, $fname ); + + # number of edits + if ($exists > 0) { + $old = $dbr->selectField( 'old', 'COUNT(*)', $old_clause, $fname ); + $wgOut->addHTML( "
  • " . wfMsg("numtalkedits", $old + 1) . "
  • "); + } + $wgOut->addHTML( "
  • " . wfMsg("numauthors", $authors) . "
  • " ); + + # number of authors + if ($exists > 0) { + $cur_author = $dbr->selectField( 'cur', 'cur_user_text', $cur_clause, $fname ); + $authors = $dbr->selectField( 'cur', 'COUNT(DISTINCT old_user_text)', + $old_clause + array( 'old_user_text<>' . $dbr->addQuotes( $cur_author ) ), $fname ); + + $wgOut->addHTML( "
  • " . wfMsg("numtalkauthors", $authors) . "
" ); + } } } }