Code Coverage
 
Lines
Functions and Methods
Classes and Traits
Total
0.00% covered (danger)
0.00%
0 / 23
0.00% covered (danger)
0.00%
0 / 4
CRAP
0.00% covered (danger)
0.00%
0 / 1
FetchText
0.00% covered (danger)
0.00%
0 / 23
0.00% covered (danger)
0.00%
0 / 4
90
0.00% covered (danger)
0.00%
0 / 1
 __construct
0.00% covered (danger)
0.00%
0 / 6
0.00% covered (danger)
0.00%
0 / 1
2
 finalSetup
0.00% covered (danger)
0.00%
0 / 2
0.00% covered (danger)
0.00%
0 / 1
2
 getBlobStore
0.00% covered (danger)
0.00%
0 / 1
0.00% covered (danger)
0.00%
0 / 1
2
 execute
0.00% covered (danger)
0.00%
0 / 14
0.00% covered (danger)
0.00%
0 / 1
42
1<?php
2/**
3 * Communications protocol.
4 * This is used by dumpTextPass.php when the --spawn option is present.
5 *
6 * This program is free software; you can redistribute it and/or modify
7 * it under the terms of the GNU General Public License as published by
8 * the Free Software Foundation; either version 2 of the License, or
9 * (at your option) any later version.
10 *
11 * This program is distributed in the hope that it will be useful,
12 * but WITHOUT ANY WARRANTY; without even the implied warranty of
13 * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the
14 * GNU General Public License for more details.
15 *
16 * You should have received a copy of the GNU General Public License along
17 * with this program; if not, write to the Free Software Foundation, Inc.,
18 * 51 Franklin Street, Fifth Floor, Boston, MA 02110-1301, USA.
19 * http://www.gnu.org/copyleft/gpl.html
20 *
21 * @file
22 * @ingroup Maintenance
23 */
24
25// @codeCoverageIgnoreStart
26require_once __DIR__ . '/Maintenance.php';
27// @codeCoverageIgnoreEnd
28
29use MediaWiki\MainConfigNames;
30use MediaWiki\Settings\SettingsBuilder;
31use MediaWiki\Storage\BlobAccessException;
32use MediaWiki\Storage\BlobStore;
33use MediaWiki\Storage\SqlBlobStore;
34
35/**
36 * Maintenance script used to fetch page text in a subprocess.
37 *
38 * @ingroup Maintenance
39 */
40class FetchText extends Maintenance {
41
42    public function __construct() {
43        parent::__construct();
44        $this->addDescription( "Fetch the raw revision blob from a blob address.\n" .
45            "Integer IDs are interpreted as referring to text.old_id for backwards compatibility.\n" .
46            "NOTE: Export transformations are NOT applied. " .
47            "This is left to dumpTextPass.php"
48        );
49    }
50
51    public function finalSetup( SettingsBuilder $settingsBuilder ) {
52        // This script should always try to run all db queries in the 'dump' group if such
53        // a group exists, just like the BackupDumper and TextPassDumper modules.
54        // To account for parts of MediaWiki that get their own db connection outside of
55        // Maintenance::getDB(), we set this global variable so that they will attempt
56        // to use this group.
57        $settingsBuilder->putConfigValue( MainConfigNames::DBDefaultGroup, 'dump' );
58        // do this last so that options can override
59
60        parent::finalSetup( $settingsBuilder );
61    }
62
63    /**
64     * @return BlobStore
65     */
66    private function getBlobStore() {
67        return $this->getServiceContainer()->getBlobStore();
68    }
69
70    /**
71     * returns a string containing the following in order:
72     *   textid
73     *   \n
74     *   length of text (-1 on error = failure to retrieve/unserialize/gunzip/etc)
75     *   \n
76     *   text  (may be empty)
77     *
78     * note that the text string itself is *not* followed by newline
79     */
80    public function execute() {
81        $stdin = $this->getStdin();
82        while ( !feof( $stdin ) ) {
83            $line = fgets( $stdin );
84            if ( $line === false ) {
85                // We appear to have lost contact...
86                break;
87            }
88            $blobAddress = trim( $line );
89
90            // Plain integers are supported for backwards compatibility with pre-MCR dumps.
91            if ( strpos( $blobAddress, ':' ) === false && is_numeric( $blobAddress ) ) {
92                $blobAddress = SqlBlobStore::makeAddressFromTextId( intval( $blobAddress ) );
93            }
94
95            try {
96                $text = $this->getBlobStore()->getBlob( $blobAddress );
97                $textLen = strlen( $text );
98            } catch ( BlobAccessException | InvalidArgumentException $ex ) {
99                // XXX: log $ex to stderr?
100                $textLen = '-1';
101                $text = '';
102            }
103
104            $this->output( $blobAddress . "\n" . $textLen . "\n" . $text );
105        }
106    }
107
108}
109
110// @codeCoverageIgnoreStart
111$maintClass = FetchText::class;
112require_once RUN_MAINTENANCE_IF_MAIN;
113// @codeCoverageIgnoreEnd