X-Git-Url: https://git.heureux-cyclage.org/?a=blobdiff_plain;f=includes%2FArticle.php;h=361b9d4a8ddbfee6a70bca5aa7f413ac1809a322;hb=341bfb5f449e28efae03809ac2df9615f33ffee6;hp=7e83b96822ef1c8141712c52b76d5a421e100392;hpb=21ca86666fcbd61ef86a3532250c9921b496a21c;p=lhc%2Fweb%2Fwiklou.git diff --git a/includes/Article.php b/includes/Article.php index 7e83b96822..361b9d4a8d 100644 --- a/includes/Article.php +++ b/includes/Article.php @@ -1,11 +1,17 @@ mTitle =& $title; $this->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 $action,$section,$count; # From query string - $fname = "Article::getContent"; + global $wgRequest; + + # Get variables from query string :P + $action = $wgRequest->getText( 'action', 'view' ); + $section = $wgRequest->getText( 'section' ); + + $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 ''; } - $secs=preg_split("/(^=+.*?=+|^.*?<\/h[1-6].*?>)/mi", - $this->mContent, -1, - PREG_SPLIT_DELIM_CAPTURE); - if($section==0) { - wfProfileOut( $fname ); - return trim($secs[0]); - } else { - wfProfileOut( $fname ); - return trim($secs[$section*2-1] . $secs[$section*2]); - } + # strip NOWIKI etc. to avoid confusion (true-parameter causes HTML + # comments to be stripped as well) + $rv=$this->getSection($this->mContent,$section); + wfProfileOut( $fname ); + return $rv; } } wfProfileOut( $fname ); @@ -112,62 +245,152 @@ 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 ) { - global $wgOut, $wgMwRedir; - global $oldid, $redirect; # From query + 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"; - $success = true; - + $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 .= ",oldid={$oldid}"; + } + 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; } } } @@ -175,42 +398,101 @@ 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; + } + + # Gets the article text without using so many damn globals + # Returns false on error + function getContentWithoutUsingSoManyDamnGlobals( $oldid = 0, $noredir = false ) { + global $wgMwRedir; + + if ( $this->mContentLoaded ) { + return $this->mContent; + } + $this->mContent = false; - # Return error message :P - # Horrible, confusing UI and data. I think this should return false on error -- TS - if ( !$success ) { - $t = $this->mTitle->getPrefixedText(); - if ( isset( $oldid ) ) { - $oldid = IntVal( $oldid ); - $t .= ",oldid={$oldid}"; + $fname = 'Article::getContentWithout'; + $dbr =& wfGetDB( DB_SLAVE ); + + if ( ! $oldid ) { # Retrieve current version + $id = $this->getID(); + if ( 0 == $id ) { + return false; } - if ( isset( $redirect ) ) { - $redirect = ($redirect == "no") ? "no" : "yes"; - $t .= ",redirect={$redirect}"; + + $s = $dbr->getArray( 'cur', $this->getCurContentFields(), array( 'cur_id' => $id ), $fname ); + if ( $s === false ) { + return false; } - $this->mContent = wfMsg( "missingarticle", $t ); - } + # If we got a redirect, follow it (unless we've been told + # not to by either the function parameter or the query + 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; + } + } + } + } + + $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; + } else { # oldid set, retrieve historical version + $s = $dbr->getArray( 'old', $this->getOldContentFields(), array( 'old_id' => $oldid ) ); + if ( $s === false ) { + return false; + } + $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; + } $this->mContentLoaded = true; + return $this->mContent; } function getID() { @@ -225,7 +507,8 @@ class Article { { 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; } @@ -236,10 +519,10 @@ class Article { 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; } @@ -252,13 +535,14 @@ class Article { 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'; - if ( wfNumRows( $res ) > 0 ) { - $s = wfFetchObject( $res ); + $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 ( $s !== false ) { $this->mUser = $s->cur_user; $this->mUserText = $s->cur_user_text; $this->mTimestamp = $s->cur_timestamp; @@ -297,33 +581,80 @@ class Article { return $this->mMinorEdit; } + function getContributors($limit = 0, $offset = 0) + { + $fname = 'Article::getContributors'; + + # XXX: this is expensive; cache this info somewhere. + + $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_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; + } + + $res = $dbr->query($sql, $fname); + + 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; - global $oldid, $diff, $printable; # From query - global $wgLinkCache, $IP, $wgEnableParserCache; - - $fname = "Article::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 + $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 ( isset( $diff ) ) { + if ( !is_null( $diff ) ) { $wgOut->setPageTitle( $this->mTitle->getPrefixedText() ); - $de = new DifferenceEngine( $oldid, $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 ( !isset( $oldid ) and $this->checkTouched() ) { + if ( empty( $oldid ) && $this->checkTouched() ) { if( $wgOut->checkLastModified( $this->mTouched ) ){ return; } else if ( $this->tryFileCache() ) { @@ -334,37 +665,88 @@ class Article { } } - $text = $this->getContent(); # May change mTitle - $wgOut->setPageTitle( $this->mTitle->getPrefixedText() ); - $wgOut->setHTMLTitle( $this->mTitle->getPrefixedText() . - " - " . wfMsg( "wikititlesuffix" ) ); - - # We're looking at an old revision - - if ( $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 ( $printable == "yes" ) { - $wgOut->mParserOptions->setPrintable( true ); + if ( !$outputDone ) { + $text = $this->getContent( false ); # May change mTitle by following a redirect + + # 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( $wgEnableParserCache && intval($wgUser->getOption( "stubthreshold" )) == 0 ){ - $wgOut->addWikiText( $text, true, $this ); - } else { - $wgOut->addWikiText( $text ); + # 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}" ) + ) ); } + # Add link titles as META keywords + $wgOut->addMetaTags() ; + $this->viewUpdates(); wfProfileOut( $fname ); } @@ -376,10 +758,10 @@ class Article { /* private */ function insertNewArticle( $text, $summary, $isminor, $watchthis ) { - global $wgOut, $wgUser, $wgLinkCache, $wgMwRedir; + global $wgOut, $wgUser, $wgMwRedir; global $wgUseSquid, $wgDeferredUpdateList, $wgInternalServer; - - $fname = "Article::insertNewArticle"; + + $fname = 'Article::insertNewArticle'; $this->mCountAdjustment = $this->isCountable( $text ); @@ -392,149 +774,234 @@ 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 ); - - # Squid purging - if ( $wgUseSquid ) { - $urlArr = Array( - $this->mTitle->getInternalURL(), - $this->mTitle->getInternalURL('action=history') - ); - wfPurgeSquidServers($urlArr); - /* this needs to be done after LinksUpdate */ - $u = new SquidUpdate($this->mTitle); - array_push( $wgDeferredUpdateList, $u ); - } - - $this->showArticle( $text, wfMsg( "newarticle" ) ); + + $this->showArticle( $text, wfMsg( 'newarticle' ) ); } - function updateArticle( $text, $summary, $minor, $watchthis, $section = "", $forceBot = false ) - { - global $wgOut, $wgUser, $wgLinkCache; - global $wgDBtransactions, $wgMwRedir; - global $wgUseSquid, $wgInternalServer; - $fname = "Article::updateArticle"; + /* Side effects: loads last edit */ + function getTextOfLastEditWithSectionReplacedOrAdded($section, $text, $summary = ''){ $this->loadLastEdit(); - - // insert updated section into old text if we have only edited part - // of the article - if ($section != "") { - $oldtext=$this->getContent(); - 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 { - $secs=preg_split("/(^=+.*?=+|^.*?<\/h[1-6].*?>)/mi", + + # 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; + $oldtext=$parser->strip($oldtext, $striparray, true); + + # now that we can be sure that no pseudo-sections are in the source, + # split it up + # 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); + $text=$parser->unstripNoWiki($text,$striparray); } + } + return $text; + } + + function updateArticle( $text, $summary, $minor, $watchthis, $forceBot = false, $sectionanchor = '' ) + { + global $wgOut, $wgUser; + global $wgDBtransactions, $wgMwRedir; + global $wgUseSquid, $wgInternalServer; + + $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(); @@ -542,55 +1009,124 @@ class Article { } # standard deferred updates $this->editUpdates( $text ); - + + + $urls = array(); + # Template namespace + # Purge all articles linking here + if ( $this->mTitle->getNamespace() == NS_TEMPLATE) { + $titles = $this->mTitle->getLinksTo(); + Title::touchArray( $titles ); + if ( $wgUseSquid ) { + foreach ( $titles as $title ) { + $urls[] = $title->getInternalURL(); + } + } + } + # Squid updates - if ( $wgUseSquid ) { - $urlArr = Array( - $this->mTitle->getInternalURL(), - $this->mTitle->getInternalURL('action=history') - ); - wfPurgeSquidServers($urlArr); + $urls = array_merge( $urls, $this->mTitle->getSquidURLs() ); + $u = new SquidUpdate( $urls ); + $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 + # Switch on use of link cache in the skin + $sk =& $wgUser->getSkin(); + $sk->postParseLinkColour( false ); + + # Now update the link cache by parsing the text $wgOut = new OutputPage(); $wgOut->addWikiText( $text ); 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 ); } - # Add this page to my watchlist + # 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; + $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 ) { global $wgUser, $wgOut, $wgLang; global $wgDeferredUpdateList; if ( 0 == $wgUser->getID() ) { - $wgOut->errorpage( "watchnologin", "watchnologintext" ); + $wgOut->errorpage( 'watchnologin', 'watchnologintext' ); return; } if ( wfReadOnly() ) { @@ -602,22 +1138,22 @@ 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 = $sk->makeKnownLink ( $this->mTitle->getPrefixedText() ) ; + $link = $this->mTitle->getPrefixedText(); if($add) - $text = wfMsg( "addedwatchtext", $link ); + $text = wfMsg( 'addedwatchtext', $link ); else - $text = wfMsg( "removedwatchtext", $link ); - $wgOut->addHTML( $text ); + $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() @@ -625,9 +1161,9 @@ class Article { $this->watch( false ); } - function protect( $limit = "sysop" ) + function protect( $limit = 'sysop' ) { - global $wgUser, $wgOut; + global $wgUser, $wgOut, $wgRequest; if ( ! $wgUser->isSysop() ) { $wgOut->sysopRequired(); @@ -639,34 +1175,119 @@ class Article { } $id = $this->mTitle->getArticleID(); if ( 0 == $id ) { - $wgOut->fatalEror( wfMsg( "badarticleerror" ) ); + $wgOut->fatalError( wfMsg( 'badarticleerror' ) ); return; } - $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() ), "" ); + $confirm = $wgRequest->getBool( 'wpConfirmProtect' ) && $wgRequest->wasPosted(); + $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' + ); + + $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 ); + } + } + + # 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->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 { - $log->addEntry( wfMsg( "protectedarticle", $this->mTitle->getPrefixedText() ), "" ); + $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 ); } - $wgOut->redirect( $this->mTitle->getFullURL() ); + + $confirm = htmlspecialchars( wfMsg( 'confirm' ) ); + + $wgOut->addHTML( " +
+ + + + + + + + + + + + + + + + +
+ + + +
 
+ + + +
  + +
+
\n" ); + + $wgOut->returnToMain( false ); } function unprotect() { - return $this->protect( "" ); + return $this->protect( '' ); } + # UI entry point for page deletion function delete() { - global $wgUser, $wgOut, $wgMessageCache; - global $wpConfirm, $wpReason, $image, $oldimage; + global $wgUser, $wgOut, $wgMessageCache, $wgRequest; + $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(); return; @@ -676,353 +1297,385 @@ class Article { return; } - # Can't delete cached MediaWiki namespace (i.e. vital messages) - if ( $this->mTitle->getNamespace() == NS_MEDIAWIKI && $wgMessageCache->isCacheable( $this->mTitle->getDBkey() ) ) { - $wgOut->fatalError( wfMsg( "cannotdelete" ) ); - return; - } - # 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; } - if ( $_POST["wpConfirm"] ) { - $this->doDelete(); + if ( $confirm ) { + $this->doDelete( $reason ); return; } # 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)) && !$wpConfirm ) { + $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 + $blanked = false; if($s->cur_text!="") { $text=$s->cur_text; } else { if($old) { $text = Article::getRevisionText( $old ); - $blanked=1; + $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 && !$wpReason) { $wpReason=wfmsg("exblank");} - - - if($length < 500 && !$wpReason) { - + if($length == 0 && $reason === '') { + $reason = wfMsg('exblank'); + } + + 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) { - $wpReason=wfMsg("excontent"). " '".$text; + $reason=wfMsg('excontent'). " '".$text; } else { - $wpReason=wfMsg("exbeforeblank") . " '".$text; + $reason=wfMsg('exbeforeblank') . " '".$text; } - if($length>150) { $wpReason .= "..."; } # we've only pasted part of the text - $wpReason.="'"; + if($length>150) { $reason .= '...'; } # we've only pasted part of the text + $reason.="'"; } } - return $this->confirmDelete(); + return $this->confirmDelete( '', $reason ); } - - function confirmDelete( $par = "" ) + + # Output deletion confirmation dialog + function confirmDelete( $par, $reason ) { global $wgOut; - global $wpReason; 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 ); - - $confirm = wfMsg( "confirm" ); - $check = wfMsg( "confirmcheck" ); - $delcom = wfMsg( "deletecomment" ); + $formaction = $this->mTitle->escapeLocalURL( 'action=delete' . $par ); + + $confirm = htmlspecialchars( wfMsg( 'confirm' ) ); + $check = htmlspecialchars( wfMsg( 'confirmcheck' ) ); + $delcom = htmlspecialchars( wfMsg( 'deletecomment' ) ); $wgOut->addHTML( " -

- - -
-{$delcom}: - -
 
- -
  - -
\n" ); +
+ + + + + + + + + + + + + + + + +
+ + + +
 
+ + + +
  + +
+
\n" ); $wgOut->returnToMain( false ); } - function doDelete() + # Perform a deletion and output success or failure messages + function doDelete( $reason ) { global $wgOut, $wgUser, $wgLang; - global $wpReason; - $fname = "Article::doDelete"; + $fname = 'Article::doDelete'; wfDebug( "$fname\n" ); - $this->doDeleteArticle( $this->mTitle ); - $deleted = $this->mTitle->getPrefixedText(); + 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" ) ); + $sk = $wgUser->getSkin(); + $loglink = $sk->makeKnownLink( $wgLang->getNsText( NS_WIKIPEDIA ) . + ':' . wfMsg( 'dellogpage' ), wfMsg( 'deletionlog' ) ); - $text = wfMsg( "deletedtext", $deleted, $loglink ); + $text = wfMsg( "deletedtext", $deleted, $loglink ); - $wgOut->addHTML( "

" . $text ); - $wgOut->returnToMain( false ); + $wgOut->addHTML( '

' . $text . "

\n" ); + $wgOut->returnToMain( false ); + } else { + $wgOut->fatalError( wfMsg( 'cannotdelete' ) ); + } } - function doDeleteArticle( $title ) + # Back-end article deletion + # Deletes the article with database consistency, writes logs, purges caches + # Returns success + function doDeleteArticle( $reason ) { - global $wgUser, $wgOut, $wgLang, $wgRequest; + global $wgUser, $wgLang; global $wgUseSquid, $wgDeferredUpdateList, $wgInternalServer; - $fname = "Article::doDeleteArticle"; - wfDebug( "$fname\n" ); + $fname = 'Article::doDeleteArticle'; + wfDebug( $fname."\n" ); - $ns = $title->getNamespace(); - $t = wfStrencode( $title->getDBkey() ); - $id = $title->getArticleID(); + $dbw =& wfGetDB( DB_MASTER ); + $ns = $this->mTitle->getNamespace(); + $t = $this->mTitle->getDBkey(); + $id = $this->mTitle->getArticleID(); - if ( "" == $t ) { - $wgOut->fatalError( wfMsg( "cannotdelete" ) ); - return; + 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 ) { - $urlArr = Array( + $urls = array( $this->mTitle->getInternalURL(), - $this->mTitle->getInternalURL('action=history') + $this->mTitle->getInternalURL( 'history' ) ); - wfPurgeSquidServers($urlArr); - - /* prepare the list of urls to purge */ - $sql = "SELECT l_from FROM links WHERE l_to={$id}" ; - $res = wfQuery ( $sql, DB_READ ) ; - while ( $BL = wfFetchObject ( $res ) ) - { - $tobj = Title::newFromDBkey( $BL->l_from) ; - $blurlArr[] = $tobj->getInternalURL(); + foreach ( $linksTo as $linkTo ) { + $urls[] = $linkTo->getInternalURL(); } - wfFreeResult ( $res ) ; - $u = new SquidUpdate( $this->mTitle, $blurlArr ); + + $u = new SquidUpdate( $urls ); array_push( $wgDeferredUpdateList, $u ); } - + # Client and file cache invalidation + 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 = $this->mTitle->getPrefixedDBkey(); - if ( 0 != $id ) { - - $t = wfStrencode( $title->getPrefixedDBkey() ); - - Article::onArticleDelete( $title ); - - $sql = "SELECT l_from FROM links WHERE l_to={$id}"; - $res = wfQuery( $sql, DB_READ, $fname ); - - $sql = "INSERT INTO brokenlinks (bl_from,bl_to) VALUES "; - $now = wfTimestampNow(); - $sql2 = "UPDATE cur SET cur_touched='{$now}' WHERE cur_id IN ("; - $first = true; - - while ( $s = wfFetchObject( $res ) ) { - $nt = Title::newFromDBkey( $s->l_from ); - $lid = $nt->getArticleID(); - - if ( ! $first ) { $sql .= ","; $sql2 .= ","; } - $first = false; - $sql .= "({$lid},'{$t}')"; - $sql2 .= "{$lid}"; - } - $sql2 .= ")"; - if ( ! $first ) { - wfQuery( $sql, DB_WRITE, $fname ); - wfQuery( $sql2, DB_WRITE, $fname ); - } - wfFreeResult( $res ); - - $sql = "DELETE FROM links WHERE l_to={$id}"; - wfQuery( $sql, DB_WRITE, $fname ); + Article::onArticleDelete( $this->mTitle ); - $sql = "DELETE FROM links WHERE l_from='{$t}'"; - wfQuery( $sql, DB_WRITE, $fname ); + # Insert broken links + $brokenLinks = array(); + foreach ( $linksTo as $titleObj ) { + # Get article ID. Efficient because it was loaded into the cache by getLinksTo(). + $linkID = $titleObj->getArticleID(); + $brokenLinks[] = array( 'bl_from' => $linkID, 'bl_to' => $t ); + } + $dbw->insert( 'brokenlinks', $brokenLinks, $fname, 'IGNORE' ); - $sql = "DELETE FROM imagelinks WHERE il_from='{$t}'"; - 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 brokenlinks WHERE bl_from={$id}"; - wfQuery( $sql, DB_WRITE, $fname ); - } - - $log = new LogPage( wfMsg( "dellogpage" ), wfMsg( "dellogpagetext" ) ); - $art = $title->getPrefixedText(); - $wpReason = $wgRequest->getText( "wpReason" ); - $log->addEntry( wfMsg( "deletedarticle", $art ), $wpReason ); + # Log the deletion + $log = new LogPage( wfMsg( 'dellogpage' ), wfMsg( 'dellogpagetext' ) ); + $art = $this->mTitle->getPrefixedText(); + $log->addEntry( wfMsg( 'deletedarticle', $art ), $reason ); # Clear the cached article id so the interface doesn't act like we exist $this->mTitle->resetArticleID( 0 ); $this->mTitle->mArticleID = 0; + return true; } 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" ); - $this->updateArticle( Article::getRevisionText( $s ), $newcomment, 1, $this->mTitle->userIsWatching(), "", $bot ); - + $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 @@ -1036,10 +1689,10 @@ 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. @@ -1052,14 +1705,15 @@ class Article { 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 ) { @@ -1084,7 +1738,7 @@ class Article { global $wgLang, $wgOut; $td = $wgLang->timeanddate( $this->mTimestamp, true ); - $r = wfMsg( "revisionasof", $td ); + $r = wfMsg( 'revisionasof', $td ); $wgOut->setSubtitle( "({$r})" ); } @@ -1096,10 +1750,10 @@ class Article { global $wgParser, $wgUser; return $wgParser->preSaveTransform( $text, $this->mTitle, $wgUser, ParserOptions::newFromUser( $wgUser ) ); } - + /* Caching functions */ - # checkLastModified returns true iff it has taken care of all + # checkLastModified returns true if it has taken care of all # output to the client that is necessary for this request. # (that is, it has sent a cached version of the page) function tryFileCache() { @@ -1111,7 +1765,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 ); @@ -1123,7 +1777,7 @@ class Article { $cache->loadFromFileCache(); return true; } else { - wfDebug( " tryFileCache() - starting buffer\n" ); + wfDebug( " tryFileCache() - starting buffer\n" ); ob_start( array(&$cache, 'saveToFileCache' ) ); } } else { @@ -1132,119 +1786,251 @@ class Article { } function isFileCacheable() { - global $wgUser, $wgUseFileCache, $wgShowIPinHeader; - global $action, $oldid, $diff, $redirect, $printable; + 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; } } - + + # 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; - if ( $wgEnablePersistentLC ) { - LinkCache::linksccClearBrokenLinksTo( $title_obj->getPrefixedDBkey() ); - } - if ( $wgEnableParserCache ) { - OutputPage::parsercacheClearBrokenLinksTo( $title_obj->getPrefixedDBkey() ); + global $wgUseSquid, $wgDeferredUpdateList; + + $titles = $title_obj->getBrokenLinksTo(); + + # Purge squid + if ( $wgUseSquid ) { + $urls = $title_obj->getSquidURLs(); + foreach ( $titles as $linkTitle ) { + $urls[] = $linkTitle->getInternalURL(); + } + $u = new SquidUpdate( $urls ); + array_push( $wgDeferredUpdateList, $u ); } + + # Clear persistent link cache + LinkCache::linksccClearBrokenLinksTo( $title_obj->getPrefixedDBkey() ); } /* static */ function onArticleDelete($title_obj){ - global $wgEnablePersistentLC, $wgEnableParserCache; - if ( $wgEnablePersistentLC ) { - LinkCache::linksccClearLinksTo( $title_obj->getArticleID() ); - } - if ( $wgEnableParserCache ) { - OutputPage::parsercacheClearLinksTo( $title_obj->getArticleID() ); - } + LinkCache::linksccClearLinksTo( $title_obj->getArticleID() ); } /* static */ function onArticleEdit($title_obj){ - global $wgEnablePersistentLC, $wgEnableParserCache; - if ( $wgEnablePersistentLC ) { - LinkCache::linksccClearPage( $title_obj->getArticleID() ); + 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) . "
" ); + } } } } -function wfReplaceSubstVar( $matches ) { - return wfMsg( $matches[1] ); -} - ?>