fetchText.php

Go to the documentation of this file.

<?php
// @codeCoverageIgnoreStart
require_once __DIR__ . '/Maintenance.php';
// @codeCoverageIgnoreEnd
 
use MediaWiki\MainConfigNames;
use MediaWiki\Settings\SettingsBuilder;
use MediaWiki\Storage\BlobAccessException;
use MediaWiki\Storage\BlobStore;
use MediaWiki\Storage\SqlBlobStore;
 
class FetchText extends Maintenance {
 
    public function __construct() {
        parent::__construct();
        $this->addDescription( "Fetch the raw revision blob from a blob address.\n" .
            "Integer IDs are interpreted as referring to text.old_id for backwards compatibility.\n" .
            "NOTE: Export transformations are NOT applied. " .
            "This is left to dumpTextPass.php"
        );
    }
 
    public function finalSetup( SettingsBuilder $settingsBuilder ) {
        // This script should always try to run all db queries in the 'dump' group if such
        // a group exists, just like the BackupDumper and TextPassDumper modules.
        // To account for parts of MediaWiki that get their own db connection outside of
        // Maintenance::getDB(), we set this global variable so that they will attempt
        // to use this group.
        $settingsBuilder->putConfigValue( MainConfigNames::DBDefaultGroup, 'dump' );
        // do this last so that options can override
 
        parent::finalSetup( $settingsBuilder );
    }
 
    private function getBlobStore() {
        return $this->getServiceContainer()->getBlobStore();
    }
 
    public function execute() {
        $stdin = $this->getStdin();
        while ( !feof( $stdin ) ) {
            $line = fgets( $stdin );
            if ( $line === false ) {
                // We appear to have lost contact...
                break;
            }
            $blobAddress = trim( $line );
 
            // Plain integers are supported for backwards compatibility with pre-MCR dumps.
            if ( strpos( $blobAddress, ':' ) === false && is_numeric( $blobAddress ) ) {
                $blobAddress = SqlBlobStore::makeAddressFromTextId( intval( $blobAddress ) );
            }
 
            try {
                $text = $this->getBlobStore()->getBlob( $blobAddress );
                $textLen = strlen( $text );
            } catch ( BlobAccessException | InvalidArgumentException $ex ) {
                // XXX: log $ex to stderr?
                $textLen = '-1';
                $text = '';
            }
 
            $this->output( $blobAddress . "\n" . $textLen . "\n" . $text );
        }
    }
 
}
 
// @codeCoverageIgnoreStart
$maintClass = FetchText::class;
require_once RUN_MAINTENANCE_IF_MAIN;
// @codeCoverageIgnoreEnd