12 use Psr\Log\LoggerInterface;
39 private $revisionStore;
44 private $slotRoleRegistry;
49 private $wikiPageFactory;
52 private $pageUpdaterFactory;
69 LoggerInterface $logger,
77 $this->doUpdates = $doUpdates;
78 $this->logger = $logger;
79 $this->dbProvider = $dbProvider;
80 $this->revisionStore = $revisionStore;
81 $this->slotRoleRegistry = $slotRoleRegistry;
83 $services = MediaWikiServices::getInstance();
85 $this->wikiPageFactory = $wikiPageFactory ?? $services->getWikiPageFactory();
86 $this->pageUpdaterFactory = $pageUpdaterFactory ?? $services->getPageUpdaterFactory();
87 $this->userFactory = $userFactory ?? $services->getUserFactory();
92 $dbw = $this->dbProvider->getPrimaryDatabase();
94 # Sneak a single revision into place
95 $user = $importableRevision->
getUserObj() ?: $this->userFactory->newFromName( $importableRevision->
getUser() );
97 $userId = $user->getId();
98 $userText = $user->getName();
101 $userText = $importableRevision->
getUser();
102 $user = $this->userFactory->newAnonymous();
106 Title::clearCaches();
108 $page = $this->wikiPageFactory->newFromTitle( $importableRevision->
getTitle() );
109 $page->loadPageData( WikiPage::READ_LATEST );
110 $mustCreatePage = !$page->exists();
111 if ( $mustCreatePage ) {
112 $pageId = $page->insertOn( $dbw );
114 $pageId = $page->getId();
119 $prior = (bool)$dbw->newSelectQueryBuilder()
123 'rev_page' => $pageId,
124 'rev_timestamp' => $dbw->timestamp( $importableRevision->
getTimestamp() ),
127 ->caller( __METHOD__ )->fetchField();
130 $this->logger->debug( __METHOD__ .
": skipping existing revision for [[" .
131 $importableRevision->
getTitle()->getPrefixedText() .
"]], timestamp " .
141 $this->logger->debug( __METHOD__ .
': got invalid $pageId when importing revision of [[' .
142 $importableRevision->
getTitle()->getPrefixedText() .
']], timestamp ' .
150 $queryBuilder = $this->revisionStore->newSelectQueryBuilder( $dbw )
152 ->where( [
'rev_page' => $pageId ] )
153 ->andWhere( $dbw->buildComparison(
155 [
'rev_timestamp' => $dbw->timestamp( $importableRevision->
getTimestamp() ) ]
157 ->orderBy( [
'rev_timestamp',
'rev_id' ], SelectQueryBuilder::SORT_DESC );
158 $prevRevRow = $queryBuilder->caller( __METHOD__ )->fetchRow();
160 # @todo FIXME: Use original rev_id optionally (better for backups)
163 $revisionRecord->setParentId( $prevRevRow ? (
int)$prevRevRow->rev_id : 0 );
164 $revisionRecord->setComment(
165 CommentStoreComment::newUnsavedComment( $importableRevision->
getComment() )
169 $revUser = $this->userFactory->newFromAnyId( $userId, $userText );
170 }
catch ( InvalidArgumentException $ex ) {
173 $revisionRecord->setUser( $revUser );
175 $originalRevision = $prevRevRow
176 ? $this->revisionStore->newRevisionFromRow(
178 IDBAccessObject::READ_LATEST,
183 foreach ( $importableRevision->
getSlotRoles() as $role ) {
184 if ( !$this->slotRoleRegistry->isDefinedRole( $role ) ) {
185 throw new RuntimeException(
"Undefined slot role $role" );
188 $newContent = $importableRevision->
getContent( $role );
189 if ( !$originalRevision || !$originalRevision->hasSlot( $role ) ) {
190 $revisionRecord->setContent( $role, $newContent );
192 $originalSlot = $originalRevision->getSlot( $role );
193 if ( !$originalSlot->hasSameContent( $importableRevision->
getSlot( $role ) ) ) {
194 $revisionRecord->setContent( $role, $newContent );
196 $revisionRecord->inheritSlot( $originalRevision->getSlot( $role ) );
201 $revisionRecord->setTimestamp( $importableRevision->
getTimestamp() );
202 $revisionRecord->setMinorEdit( $importableRevision->
getMinor() );
203 $revisionRecord->setPageId( $pageId );
205 $latestRevId = $page->getLatest();
207 $inserted = $this->revisionStore->insertRevisionOn( $revisionRecord, $dbw );
208 if ( $latestRevId ) {
211 $latestRevTimestamp = (int)$this->revisionStore->getTimestampFromId(
213 RevisionStore::READ_LATEST
216 $latestRevTimestamp = 0;
218 if ( $importableRevision->
getTimestamp() >= $latestRevTimestamp ) {
219 $changed = $page->updateRevisionOn( $dbw, $inserted, $latestRevId );
224 $tags = $importableRevision->
getTags();
225 if ( $tags !== [] ) {
229 if ( $changed !==
false && $this->doUpdates ) {
230 $this->logger->debug( __METHOD__ .
": running updates" );
234 'created' => $mustCreatePage,
235 'oldcountable' =>
'no-change',
236 'causeAction' =>
'import-page',
237 'causeAgent' => $user->getName(),
240 $updater = $this->pageUpdaterFactory->newDerivedPageDataUpdater( $page );
241 $updater->prepareUpdate( $inserted, $options );
242 $updater->doUpdates();
__construct( $doUpdates, LoggerInterface $logger, IConnectionProvider $dbProvider, RevisionStore $revisionStore, SlotRoleRegistry $slotRoleRegistry, WikiPageFactory $wikiPageFactory=null, PageUpdaterFactory $pageUpdaterFactory=null, UserFactory $userFactory=null)
Service for creating WikiPage objects.
A factory for PageUpdater and DerivedPageDataUpdater instances.
static getMain()
Get the RequestContext object associated with the main request.
getContent( $role=SlotRecord::MAIN)