59 $dbw = $this->dbProvider->getPrimaryDatabase();
61 # Sneak a single revision into place
62 $user = $importableRevision->
getUserObj() ?: $this->userFactory->newFromName( $importableRevision->
getUser() );
64 $userId = $user->getId();
65 $userText = $user->getName();
68 $userText = $importableRevision->
getUser();
69 $user = $this->userFactory->newAnonymous();
75 $page = $this->wikiPageFactory->newFromTitle( $importableRevision->
getTitle() );
76 $page->loadPageData( IDBAccessObject::READ_LATEST );
77 $mustCreatePage = !$page->exists();
78 if ( $mustCreatePage ) {
79 $pageId = $page->insertOn( $dbw );
81 $pageId = $page->getId();
86 $prior = (bool)$dbw->newSelectQueryBuilder()
90 'rev_page' => $pageId,
91 'rev_timestamp' => $dbw->timestamp( $importableRevision->
getTimestamp() ),
94 ->caller( __METHOD__ )->fetchField();
97 $this->logger->debug( __METHOD__ .
": skipping existing revision for [[" .
98 $importableRevision->
getTitle()->getPrefixedText() .
"]], timestamp " .
108 $this->logger->debug( __METHOD__ .
': got invalid $pageId when importing revision of [[' .
109 $importableRevision->
getTitle()->getPrefixedText() .
']], timestamp ' .
117 $queryBuilder = $this->revisionStore->newSelectQueryBuilder( $dbw )
119 ->where( [
'rev_page' => $pageId ] )
120 ->andWhere( $dbw->expr(
121 'rev_timestamp',
'<=', $dbw->timestamp( $importableRevision->
getTimestamp() )
123 ->orderBy( [
'rev_timestamp',
'rev_id' ], SelectQueryBuilder::SORT_DESC );
124 $prevRevRow = $queryBuilder->caller( __METHOD__ )->fetchRow();
126 # @todo FIXME: Use original rev_id optionally (better for backups)
129 $revisionRecord->setParentId( $prevRevRow ? (
int)$prevRevRow->rev_id : 0 );
130 $revisionRecord->setComment(
131 CommentStoreComment::newUnsavedComment( $importableRevision->
getComment() )
135 $revUser = $this->userFactory->newFromAnyId( $userId, $userText );
136 }
catch ( InvalidArgumentException $ex ) {
137 $revUser = RequestContext::getMain()->getUser();
139 $revisionRecord->setUser( $revUser );
141 $originalRevision = $prevRevRow
142 ? $this->revisionStore->newRevisionFromRow(
144 IDBAccessObject::READ_LATEST,
149 foreach ( $importableRevision->
getSlotRoles() as $role ) {
150 if ( !$this->slotRoleRegistry->isDefinedRole( $role ) ) {
151 throw new RuntimeException(
"Undefined slot role $role" );
154 $newContent = $importableRevision->
getContent( $role );
155 if ( !$originalRevision || !$originalRevision->hasSlot( $role ) ) {
156 $revisionRecord->setContent( $role, $newContent );
158 $originalSlot = $originalRevision->getSlot( $role );
159 if ( !$originalSlot->hasSameContent( $importableRevision->
getSlot( $role ) ) ) {
160 $revisionRecord->setContent( $role, $newContent );
162 $revisionRecord->inheritSlot( $originalRevision->getSlot( $role ) );
167 $revisionRecord->setTimestamp( $importableRevision->
getTimestamp() );
168 $revisionRecord->setMinorEdit( $importableRevision->
getMinor() );
169 $revisionRecord->setPageId( $pageId );
171 $updater = $this->pageUpdaterFactory->newDerivedPageDataUpdater( $page );
172 $latestRev = $updater->grabCurrentRevision();
173 $latestRevId = $latestRev ? $latestRev->getId() :
null;
175 $inserted = $this->revisionStore->insertRevisionOn( $revisionRecord, $dbw );
179 $latestRevTimestamp = $latestRev->getTimestamp();
181 $latestRevTimestamp = 0;
183 if ( $importableRevision->
getTimestamp() >= $latestRevTimestamp ) {
184 $changed = $page->updateRevisionOn( $dbw, $inserted, $latestRevId );
189 $tags = $importableRevision->
getTags();
190 if ( $tags !== [] ) {
191 MediaWikiServices::getInstance()->getChangeTagsStore()->addTags( $tags,
null, $inserted->getId() );
194 if ( $changed !==
false && $this->doUpdates ) {
195 $this->logger->debug( __METHOD__ .
": running updates" );
199 PageUpdatedEvent::FLAG_SILENT =>
true,
200 PageUpdatedEvent::FLAG_AUTOMATED =>
true,
201 'created' => $mustCreatePage,
202 'oldcountable' =>
'no-change',
205 $updater->setCause( PageUpdater::CAUSE_IMPORT );
206 $updater->setPerformer( $user );
207 $updater->prepareUpdate( $inserted, $options );
208 $updater->doUpdates();