3 * ZIP file directories reader, for the purposes of upload verification.
5 * This program is free software; you can redistribute it and/or modify
6 * it under the terms of the GNU General Public License as published by
7 * the Free Software Foundation; either version 2 of the License, or
8 * (at your option) any later version.
10 * This program is distributed in the hope that it will be useful,
11 * but WITHOUT ANY WARRANTY; without even the implied warranty of
12 * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the
13 * GNU General Public License for more details.
15 * You should have received a copy of the GNU General Public License along
16 * with this program; if not, write to the Free Software Foundation, Inc.,
17 * 51 Franklin Street, Fifth Floor, Boston, MA 02110-1301, USA.
18 * http://www.gnu.org/copyleft/gpl.html
24 * A class for reading ZIP file directories, for the purposes of upload
27 * Only a functional interface is provided: ZipFileReader::read(). No access is
28 * given to object instances.
31 class ZipDirectoryReader
{
33 * Read a ZIP file and call a function for each file discovered in it.
35 * Because this class is aimed at verification, an error is raised on
36 * suspicious or ambiguous input, instead of emulating some standard
39 * @param string $fileName The archive file name
40 * @param array $callback The callback function. It will be called for each file
41 * with a single associative array each time, with members:
43 * - name: The file name. Directories conventionally have a trailing
46 * - mtime: The file modification time, in MediaWiki 14-char format
48 * - size: The uncompressed file size
50 * @param array $options An associative array of read options, with the option
51 * name in the key. This may currently contain:
53 * - zip64: If this is set to true, then we will emulate a
54 * library with ZIP64 support, like OpenJDK 7. If it is set to
55 * false, then we will emulate a library with no knowledge of
58 * NOTE: The ZIP64 code is untested and probably doesn't work. It
59 * turned out to be easier to just reject ZIP64 archive uploads,
60 * since they are likely to be very rare. Confirming safety of a
61 * ZIP64 file is fairly complex. What do you do with a file that is
62 * ambiguous and broken when read with a non-ZIP64 reader, but valid
63 * when read with a ZIP64 reader? This situation is normal for a
64 * valid ZIP64 file, and working out what non-ZIP64 readers will make
65 * of such a file is not trivial.
67 * @return Status A Status object. The following fatal errors are defined:
69 * - zip-file-open-error: The file could not be opened.
71 * - zip-wrong-format: The file does not appear to be a ZIP file.
73 * - zip-bad: There was something wrong or ambiguous about the file
76 * - zip-unsupported: The ZIP file uses features which
77 * ZipDirectoryReader does not support.
79 * The default messages for those fatal errors are written in a way that
80 * makes sense for upload verification.
82 * If a fatal error is returned, more information about the error will be
83 * available in the debug log.
85 * Note that the callback function may be called any number of times before
86 * a fatal error is returned. If this occurs, the data sent to the callback
87 * function should be discarded.
89 public static function read( $fileName, $callback, $options = [] ) {
90 $zdr = new self( $fileName, $callback, $options );
92 return $zdr->execute();
98 /** The opened file resource */
101 /** The cached length of the file, or null if it has not been loaded yet. */
102 protected $fileLength;
104 /** A segmented cache of the file contents */
107 /** The file data callback */
110 /** The ZIP64 mode */
111 protected $zip64 = false;
113 /** Stored headers */
114 protected $eocdr, $eocdr64, $eocdr64Locator;
118 /** The "extra field" ID for ZIP64 central directory entries */
119 const ZIP64_EXTRA_HEADER
= 0x0001;
121 /** The segment size for the file contents cache */
122 const SEGSIZE
= 16384;
124 /** The index of the "general field" bit for UTF-8 file names */
125 const GENERAL_UTF8
= 11;
127 /** The index of the "general field" bit for central directory encryption */
128 const GENERAL_CD_ENCRYPTED
= 13;
131 * Private constructor
132 * @param string $fileName
133 * @param callable $callback
134 * @param array $options
136 protected function __construct( $fileName, $callback, $options ) {
137 $this->fileName
= $fileName;
138 $this->callback
= $callback;
140 if ( isset( $options['zip64'] ) ) {
141 $this->zip64
= $options['zip64'];
146 * Read the directory according to settings in $this.
151 $this->file
= fopen( $this->fileName
, 'r' );
153 if ( !$this->file
) {
154 return Status
::newFatal( 'zip-file-open-error' );
157 $status = Status
::newGood();
159 $this->readEndOfCentralDirectoryRecord();
160 if ( $this->zip64
) {
161 list( $offset, $size ) = $this->findZip64CentralDirectory();
162 $this->readCentralDirectory( $offset, $size );
164 if ( $this->eocdr
['CD size'] == 0xffffffff
165 ||
$this->eocdr
['CD offset'] == 0xffffffff
166 ||
$this->eocdr
['CD entries total'] == 0xffff
168 $this->error( 'zip-unsupported', 'Central directory header indicates ZIP64, ' .
169 'but we are in legacy mode. Rejecting this upload is necessary to avoid ' .
170 'opening vulnerabilities on clients using OpenJDK 7 or later.' );
173 list( $offset, $size ) = $this->findOldCentralDirectory();
174 $this->readCentralDirectory( $offset, $size );
176 } catch ( ZipDirectoryReaderError
$e ) {
177 $status->fatal( $e->getErrorCode() );
180 fclose( $this->file
);
186 * Throw an error, and log a debug message
188 * @param string $debugMessage
189 * @throws ZipDirectoryReaderError
191 function error( $code, $debugMessage ) {
192 wfDebug( __CLASS__
. ": Fatal error: $debugMessage\n" );
193 throw new ZipDirectoryReaderError( $code );
197 * Read the header which is at the end of the central directory,
198 * unimaginatively called the "end of central directory record" by the ZIP
201 function readEndOfCentralDirectoryRecord() {
205 'CD start disk' => 2,
206 'CD entries this disk' => 2,
207 'CD entries total' => 2,
210 'file comment length' => 2,
212 $structSize = $this->getStructSize( $info );
213 $startPos = $this->getFileLength() - 65536 - $structSize;
214 if ( $startPos < 0 ) {
218 if ( $this->getFileLength() === 0 ) {
219 $this->error( 'zip-wrong-format', "The file is empty." );
222 $block = $this->getBlock( $startPos );
223 $sigPos = strrpos( $block, "PK\x05\x06" );
224 if ( $sigPos === false ) {
225 $this->error( 'zip-wrong-format',
226 "zip file lacks EOCDR signature. It probably isn't a zip file." );
229 $this->eocdr
= $this->unpack( substr( $block, $sigPos ), $info );
230 $this->eocdr
['EOCDR size'] = $structSize +
$this->eocdr
['file comment length'];
232 if ( $structSize +
$this->eocdr
['file comment length'] != strlen( $block ) - $sigPos ) {
233 $this->error( 'zip-bad', 'trailing bytes after the end of the file comment' );
235 if ( $this->eocdr
['disk'] !== 0
236 ||
$this->eocdr
['CD start disk'] !== 0
238 $this->error( 'zip-unsupported', 'more than one disk (in EOCDR)' );
240 $this->eocdr +
= $this->unpack(
242 [ 'file comment' => [ 'string', $this->eocdr
['file comment length'] ] ],
243 $sigPos +
$structSize );
244 $this->eocdr
['position'] = $startPos +
$sigPos;
248 * Read the header called the "ZIP64 end of central directory locator". An
249 * error will be raised if it does not exist.
251 function readZip64EndOfCentralDirectoryLocator() {
253 'signature' => [ 'string', 4 ],
254 'eocdr64 start disk' => 4,
255 'eocdr64 offset' => 8,
256 'number of disks' => 4,
258 $structSize = $this->getStructSize( $info );
260 $start = $this->getFileLength() - $this->eocdr
['EOCDR size'] - $structSize;
261 $block = $this->getBlock( $start, $structSize );
262 $this->eocdr64Locator
= $data = $this->unpack( $block, $info );
264 if ( $data['signature'] !== "PK\x06\x07" ) {
265 // Note: Java will allow this and continue to read the
266 // EOCDR64, so we have to reject the upload, we can't
267 // just use the EOCDR header instead.
268 $this->error( 'zip-bad', 'wrong signature on Zip64 end of central directory locator' );
273 * Read the header called the "ZIP64 end of central directory record". It
274 * may replace the regular "end of central directory record" in ZIP64 files.
276 function readZip64EndOfCentralDirectoryRecord() {
277 if ( $this->eocdr64Locator
['eocdr64 start disk'] != 0
278 ||
$this->eocdr64Locator
['number of disks'] != 0
280 $this->error( 'zip-unsupported', 'more than one disk (in EOCDR64 locator)' );
284 'signature' => [ 'string', 4 ],
286 'version made by' => 2,
287 'version needed' => 2,
289 'CD start disk' => 4,
290 'CD entries this disk' => 8,
291 'CD entries total' => 8,
295 $structSize = $this->getStructSize( $info );
296 $block = $this->getBlock( $this->eocdr64Locator
['eocdr64 offset'], $structSize );
297 $this->eocdr64
= $data = $this->unpack( $block, $info );
298 if ( $data['signature'] !== "PK\x06\x06" ) {
299 $this->error( 'zip-bad', 'wrong signature on Zip64 end of central directory record' );
301 if ( $data['disk'] !== 0
302 ||
$data['CD start disk'] !== 0
304 $this->error( 'zip-unsupported', 'more than one disk (in EOCDR64)' );
309 * Find the location of the central directory, as would be seen by a
312 * @return array List containing offset, size and end position.
314 function findOldCentralDirectory() {
315 $size = $this->eocdr
['CD size'];
316 $offset = $this->eocdr
['CD offset'];
317 $endPos = $this->eocdr
['position'];
319 // Some readers use the EOCDR position instead of the offset field
320 // to find the directory, so to be safe, we check if they both agree.
321 if ( $offset +
$size != $endPos ) {
322 $this->error( 'zip-bad', 'the central directory does not immediately precede the end ' .
323 'of central directory record' );
326 return [ $offset, $size ];
330 * Find the location of the central directory, as would be seen by a
331 * ZIP64-compliant reader.
333 * @return array List containing offset, size and end position.
335 function findZip64CentralDirectory() {
336 // The spec is ambiguous about the exact rules of precedence between the
337 // ZIP64 headers and the original headers. Here we follow zip_util.c
339 $size = $this->eocdr
['CD size'];
340 $offset = $this->eocdr
['CD offset'];
341 $numEntries = $this->eocdr
['CD entries total'];
342 $endPos = $this->eocdr
['position'];
343 if ( $size == 0xffffffff
344 ||
$offset == 0xffffffff
345 ||
$numEntries == 0xffff
347 $this->readZip64EndOfCentralDirectoryLocator();
349 if ( isset( $this->eocdr64Locator
['eocdr64 offset'] ) ) {
350 $this->readZip64EndOfCentralDirectoryRecord();
351 if ( isset( $this->eocdr64
['CD offset'] ) ) {
352 $size = $this->eocdr64
['CD size'];
353 $offset = $this->eocdr64
['CD offset'];
354 $endPos = $this->eocdr64Locator
['eocdr64 offset'];
358 // Some readers use the EOCDR position instead of the offset field
359 // to find the directory, so to be safe, we check if they both agree.
360 if ( $offset +
$size != $endPos ) {
361 $this->error( 'zip-bad', 'the central directory does not immediately precede the end ' .
362 'of central directory record' );
365 return [ $offset, $size ];
369 * Read the central directory at the given location
373 function readCentralDirectory( $offset, $size ) {
374 $block = $this->getBlock( $offset, $size );
377 'signature' => [ 'string', 4 ],
378 'version made by' => 2,
379 'version needed' => 2,
381 'compression method' => 2,
385 'compressed size' => 4,
386 'uncompressed size' => 4,
388 'extra field length' => 2,
389 'comment length' => 2,
390 'disk number start' => 2,
391 'internal attrs' => 2,
392 'external attrs' => 4,
393 'local header offset' => 4,
395 $fixedSize = $this->getStructSize( $fixedInfo );
398 while ( $pos < $size ) {
399 $data = $this->unpack( $block, $fixedInfo, $pos );
402 if ( $data['signature'] !== "PK\x01\x02" ) {
403 $this->error( 'zip-bad', 'Invalid signature found in directory entry' );
407 'name' => [ 'string', $data['name length'] ],
408 'extra field' => [ 'string', $data['extra field length'] ],
409 'comment' => [ 'string', $data['comment length'] ],
411 $data +
= $this->unpack( $block, $variableInfo, $pos );
412 $pos +
= $this->getStructSize( $variableInfo );
414 if ( $this->zip64
&& (
415 $data['compressed size'] == 0xffffffff
416 ||
$data['uncompressed size'] == 0xffffffff
417 ||
$data['local header offset'] == 0xffffffff )
419 $zip64Data = $this->unpackZip64Extra( $data['extra field'] );
421 $data = $zip64Data +
$data;
425 if ( $this->testBit( $data['general bits'], self
::GENERAL_CD_ENCRYPTED
) ) {
426 $this->error( 'zip-unsupported', 'central directory encryption is not supported' );
429 // Convert the timestamp into MediaWiki format
430 // For the format, please see the MS-DOS 2.0 Programmer's Reference,
431 // pages 3-5 and 3-6.
432 $time = $data['mod time'];
433 $date = $data['mod date'];
435 $year = 1980 +
( $date >> 9 );
436 $month = ( $date >> 5 ) & 15;
438 $hour = ( $time >> 11 ) & 31;
439 $minute = ( $time >> 5 ) & 63;
440 $second = ( $time & 31 ) * 2;
441 $timestamp = sprintf( "%04d%02d%02d%02d%02d%02d",
442 $year, $month, $day, $hour, $minute, $second );
444 // Convert the character set in the file name
445 if ( $this->testBit( $data['general bits'], self
::GENERAL_UTF8
) ) {
446 $name = $data['name'];
448 $name = iconv( 'CP437', 'UTF-8', $data['name'] );
451 // Compile a data array for the user, with a sensible format
454 'mtime' => $timestamp,
455 'size' => $data['uncompressed size'],
457 call_user_func( $this->callback
, $userData );
462 * Interpret ZIP64 "extra field" data and return an associative array.
463 * @param string $extraField
466 function unpackZip64Extra( $extraField ) {
471 $extraHeaderSize = $this->getStructSize( $extraHeaderInfo );
474 'uncompressed size' => 8,
475 'compressed size' => 8,
476 'local header offset' => 8,
477 'disk number start' => 4,
481 while ( $extraPos < strlen( $extraField ) ) {
482 $extra = $this->unpack( $extraField, $extraHeaderInfo, $extraPos );
483 $extraPos +
= $extraHeaderSize;
484 $extra +
= $this->unpack( $extraField,
485 [ 'data' => [ 'string', $extra['size'] ] ],
487 $extraPos +
= $extra['size'];
489 if ( $extra['id'] == self
::ZIP64_EXTRA_HEADER
) {
490 return $this->unpack( $extra['data'], $zip64ExtraInfo );
498 * Get the length of the file.
501 function getFileLength() {
502 if ( $this->fileLength
=== null ) {
503 $stat = fstat( $this->file
);
504 $this->fileLength
= $stat['size'];
507 return $this->fileLength
;
511 * Get the file contents from a given offset. If there are not enough bytes
512 * in the file to satisfy the request, an exception will be thrown.
514 * @param int $start The byte offset of the start of the block.
515 * @param int $length The number of bytes to return. If omitted, the remainder
516 * of the file will be returned.
520 function getBlock( $start, $length = null ) {
521 $fileLength = $this->getFileLength();
522 if ( $start >= $fileLength ) {
523 $this->error( 'zip-bad', "getBlock() requested position $start, " .
524 "file length is $fileLength" );
526 if ( $length === null ) {
527 $length = $fileLength - $start;
529 $end = $start +
$length;
530 if ( $end > $fileLength ) {
531 $this->error( 'zip-bad', "getBlock() requested end position $end, " .
532 "file length is $fileLength" );
534 $startSeg = floor( $start / self
::SEGSIZE
);
535 $endSeg = ceil( $end / self
::SEGSIZE
);
538 for ( $segIndex = $startSeg; $segIndex <= $endSeg; $segIndex++
) {
539 $block .= $this->getSegment( $segIndex );
542 $block = substr( $block,
543 $start - $startSeg * self
::SEGSIZE
,
546 if ( strlen( $block ) < $length ) {
547 $this->error( 'zip-bad', 'getBlock() returned an unexpectedly small amount of data' );
554 * Get a section of the file starting at position $segIndex * self::SEGSIZE,
555 * of length self::SEGSIZE. The result is cached. This is a helper function
558 * If there are not enough bytes in the file to satisfy the request, the
559 * return value will be truncated. If a request is made for a segment beyond
560 * the end of the file, an empty string will be returned.
562 * @param int $segIndex
566 function getSegment( $segIndex ) {
567 if ( !isset( $this->buffer
[$segIndex] ) ) {
568 $bytePos = $segIndex * self
::SEGSIZE
;
569 if ( $bytePos >= $this->getFileLength() ) {
570 $this->buffer
[$segIndex] = '';
574 if ( fseek( $this->file
, $bytePos ) ) {
575 $this->error( 'zip-bad', "seek to $bytePos failed" );
577 $seg = fread( $this->file
, self
::SEGSIZE
);
578 if ( $seg === false ) {
579 $this->error( 'zip-bad', "read from $bytePos failed" );
581 $this->buffer
[$segIndex] = $seg;
584 return $this->buffer
[$segIndex];
588 * Get the size of a structure in bytes. See unpack() for the format of $struct.
589 * @param array $struct
592 function getStructSize( $struct ) {
594 foreach ( $struct as $type ) {
595 if ( is_array( $type ) ) {
596 list( , $fieldSize ) = $type;
607 * Unpack a binary structure. This is like the built-in unpack() function
610 * @param string $string The binary data input
612 * @param array $struct An associative array giving structure members and their
613 * types. In the key is the field name. The value may be either an
614 * integer, in which case the field is a little-endian unsigned integer
615 * encoded in the given number of bytes, or an array, in which case the
616 * first element of the array is the type name, and the subsequent
617 * elements are type-dependent parameters. Only one such type is defined:
618 * - "string": The second array element gives the length of string.
619 * Not null terminated.
621 * @param int $offset The offset into the string at which to start unpacking.
623 * @throws MWException
624 * @return array Unpacked associative array. Note that large integers in the input
625 * may be represented as floating point numbers in the return value, so
626 * the use of weak comparison is advised.
628 function unpack( $string, $struct, $offset = 0 ) {
629 $size = $this->getStructSize( $struct );
630 if ( $offset +
$size > strlen( $string ) ) {
631 $this->error( 'zip-bad', 'unpack() would run past the end of the supplied string' );
636 foreach ( $struct as $key => $type ) {
637 if ( is_array( $type ) ) {
638 list( $typeName, $fieldSize ) = $type;
639 switch ( $typeName ) {
641 $data[$key] = substr( $string, $pos, $fieldSize );
645 throw new MWException( __METHOD__
. ": invalid type \"$typeName\"" );
648 // Unsigned little-endian integer
649 $length = intval( $type );
651 // Calculate the value. Use an algorithm which automatically
652 // upgrades the value to floating point if necessary.
654 for ( $i = $length - 1; $i >= 0; $i-- ) {
656 $value +
= ord( $string[$pos +
$i] );
659 // Throw an exception if there was loss of precision
660 if ( $value > pow( 2, 52 ) ) {
661 $this->error( 'zip-unsupported', 'number too large to be stored in a double. ' .
662 'This could happen if we tried to unpack a 64-bit structure ' .
663 'at an invalid location.' );
665 $data[$key] = $value;
674 * Returns a bit from a given position in an integer value, converted to
678 * @param int $bitIndex The index of the bit, where 0 is the LSB.
681 function testBit( $value, $bitIndex ) {
682 return (bool)( ( $value >> $bitIndex ) & 1 );
686 * Debugging helper function which dumps a string in hexdump -C format.
689 function hexDump( $s ) {
691 for ( $i = 0; $i < $n; $i +
= 16 ) {
692 printf( "%08X ", $i );
693 for ( $j = 0; $j < 16; $j++
) {
698 if ( $i +
$j >= $n ) {
701 printf( "%02X", ord( $s[$i +
$j] ) );
706 for ( $j = 0; $j < 16; $j++
) {
707 if ( $i +
$j >= $n ) {
709 } elseif ( ctype_print( $s[$i +
$j] ) ) {
721 * Internal exception class. Will be caught by private code.
723 class ZipDirectoryReaderError
extends Exception
{
724 protected $errorCode;
726 function __construct( $code ) {
727 $this->errorCode
= $code;
728 parent
::__construct( "ZipDirectoryReader error: $code" );
734 function getErrorCode() {
735 return $this->errorCode
;