includes/upload/UploadFromChunks.php

   1 <?php
   2 /**
   3  * Backend for uploading files from chunks.
   4  *
   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.
   9  *
  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.
  14  *
  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
  19  *
  20  * @file
  21  * @ingroup Upload
  22  */
  23
  24 /**
  25  * Implements uploading from chunks
  26  *
  27  * @ingroup Upload
  28  * @author Michael Dale
  29  */
  30 class UploadFromChunks extends UploadFromFile {
  31         protected $mOffset;
  32         protected $mChunkIndex;
  33         protected $mFileKey;
  34         protected $mVirtualTempPath;
  35         /** @var LocalRepo */
  36         private $repo;
  37
  38         /**
  39          * Setup local pointers to stash, repo and user (similar to UploadFromStash)
  40          *
  41          * @param User|null $user Default: null
  42          * @param UploadStash|bool $stash Default: false
  43          * @param FileRepo|bool $repo Default: false
  44          */
  45         public function __construct( $user = null, $stash = false, $repo = false ) {
  46                 // user object. sometimes this won't exist, as when running from cron.
  47                 $this->user = $user;
  48
  49                 if ( $repo ) {
  50                         $this->repo = $repo;
  51                 } else {
  52                         $this->repo = RepoGroup::singleton()->getLocalRepo();
  53                 }
  54
  55                 if ( $stash ) {
  56                         $this->stash = $stash;
  57                 } else {
  58                         if ( $user ) {
  59                                 wfDebug( __METHOD__ . " creating new UploadFromChunks instance for " . $user->getId() . "\n" );
  60                         } else {
  61                                 wfDebug( __METHOD__ . " creating new UploadFromChunks instance with no user\n" );
  62                         }
  63                         $this->stash = new UploadStash( $this->repo, $this->user );
  64                 }
  65         }
  66
  67         /**
  68          * Calls the parent stashFile and updates the uploadsession table to handle "chunks"
  69          *
  70          * @param User|null $user
  71          * @return UploadStashFile Stashed file
  72          */
  73         public function stashFile( User $user = null ) {
  74                 // Stash file is the called on creating a new chunk session:
  75                 $this->mChunkIndex = 0;
  76                 $this->mOffset = 0;
  77
  78                 $this->verifyChunk();
  79                 // Create a local stash target
  80                 $this->mLocalFile = parent::stashFile( $user );
  81                 // Update the initial file offset (based on file size)
  82                 $this->mOffset = $this->mLocalFile->getSize();
  83                 $this->mFileKey = $this->mLocalFile->getFileKey();
  84
  85                 // Output a copy of this first to chunk 0 location:
  86                 $this->outputChunk( $this->mLocalFile->getPath() );
  87
  88                 // Update db table to reflect initial "chunk" state
  89                 $this->updateChunkStatus();
  90
  91                 return $this->mLocalFile;
  92         }
  93
  94         /**
  95          * Continue chunk uploading
  96          *
  97          * @param string $name
  98          * @param string $key
  99          * @param WebRequestUpload $webRequestUpload
 100          */
 101         public function continueChunks( $name, $key, $webRequestUpload ) {
 102                 $this->mFileKey = $key;
 103                 $this->mUpload = $webRequestUpload;
 104                 // Get the chunk status form the db:
 105                 $this->getChunkStatus();
 106
 107                 $metadata = $this->stash->getMetadata( $key );
 108                 $this->initializePathInfo( $name,
 109                         $this->getRealPath( $metadata['us_path'] ),
 110                         $metadata['us_size'],
 111                         false
 112                 );
 113         }
 114
 115         /**
 116          * Append the final chunk and ready file for parent::performUpload()
 117          * @return FileRepoStatus
 118          */
 119         public function concatenateChunks() {
 120                 $chunkIndex = $this->getChunkIndex();
 121                 wfDebug( __METHOD__ . " concatenate {$this->mChunkIndex} chunks:" .
 122                         $this->getOffset() . ' inx:' . $chunkIndex . "\n" );
 123
 124                 // Concatenate all the chunks to mVirtualTempPath
 125                 $fileList = [];
 126                 // The first chunk is stored at the mVirtualTempPath path so we start on "chunk 1"
 127                 for ( $i = 0; $i <= $chunkIndex; $i++ ) {
 128                         $fileList[] = $this->getVirtualChunkLocation( $i );
 129                 }
 130
 131                 // Get the file extension from the last chunk
 132                 $ext = FileBackend::extensionFromPath( $this->mVirtualTempPath );
 133                 // Get a 0-byte temp file to perform the concatenation at
 134                 $tmpFile = TempFSFile::factory( 'chunkedupload_', $ext );
 135                 $tmpPath = false; // fail in concatenate()
 136                 if ( $tmpFile ) {
 137                         // keep alive with $this
 138                         $tmpPath = $tmpFile->bind( $this )->getPath();
 139                 }
 140
 141                 // Concatenate the chunks at the temp file
 142                 $tStart = microtime( true );
 143                 $status = $this->repo->concatenate( $fileList, $tmpPath, FileRepo::DELETE_SOURCE );
 144                 $tAmount = microtime( true ) - $tStart;
 145                 if ( !$status->isOk() ) {
 146                         return $status;
 147                 }
 148
 149                 wfDebugLog( 'fileconcatenate', "Combined $i chunks in $tAmount seconds." );
 150
 151                 // File system path
 152                 $this->mTempPath = $tmpPath;
 153                 // Since this was set for the last chunk previously
 154                 $this->mFileSize = filesize( $this->mTempPath );
 155                 $ret = $this->verifyUpload();
 156                 if ( $ret['status'] !== UploadBase::OK ) {
 157                         wfDebugLog( 'fileconcatenate', "Verification failed for chunked upload" );
 158                         $status->fatal( $this->getVerificationErrorCode( $ret['status'] ) );
 159
 160                         return $status;
 161                 }
 162
 163                 // Update the mTempPath and mLocalFile
 164                 // (for FileUpload or normal Stash to take over)
 165                 $tStart = microtime( true );
 166                 $this->mLocalFile = parent::stashFile( $this->user );
 167                 $tAmount = microtime( true ) - $tStart;
 168                 $this->mLocalFile->setLocalReference( $tmpFile ); // reuse (e.g. for getImageInfo())
 169                 wfDebugLog( 'fileconcatenate', "Stashed combined file ($i chunks) in $tAmount seconds." );
 170
 171                 return $status;
 172         }
 173
 174         /**
 175          * Returns the virtual chunk location:
 176          * @param int $index
 177          * @return string
 178          */
 179         function getVirtualChunkLocation( $index ) {
 180                 return $this->repo->getVirtualUrl( 'temp' ) .
 181                         '/' .
 182                         $this->repo->getHashPath(
 183                                 $this->getChunkFileKey( $index )
 184                         ) .
 185                         $this->getChunkFileKey( $index );
 186         }
 187
 188         /**
 189          * Add a chunk to the temporary directory
 190          *
 191          * @param string $chunkPath Path to temporary chunk file
 192          * @param int $chunkSize Size of the current chunk
 193          * @param int $offset Offset of current chunk ( mutch match database chunk offset )
 194          * @return Status
 195          */
 196         public function addChunk( $chunkPath, $chunkSize, $offset ) {
 197                 // Get the offset before we add the chunk to the file system
 198                 $preAppendOffset = $this->getOffset();
 199
 200                 if ( $preAppendOffset + $chunkSize > $this->getMaxUploadSize() ) {
 201                         $status = Status::newFatal( 'file-too-large' );
 202                 } else {
 203                         // Make sure the client is uploading the correct chunk with a matching offset.
 204                         if ( $preAppendOffset == $offset ) {
 205                                 // Update local chunk index for the current chunk
 206                                 $this->mChunkIndex++;
 207                                 try {
 208                                         # For some reason mTempPath is set to first part
 209                                         $oldTemp = $this->mTempPath;
 210                                         $this->mTempPath = $chunkPath;
 211                                         $this->verifyChunk();
 212                                         $this->mTempPath = $oldTemp;
 213                                 } catch ( UploadChunkVerificationException $e ) {
 214                                         return Status::newFatal( $e->getMessage() );
 215                                 }
 216                                 $status = $this->outputChunk( $chunkPath );
 217                                 if ( $status->isGood() ) {
 218                                         // Update local offset:
 219                                         $this->mOffset = $preAppendOffset + $chunkSize;
 220                                         // Update chunk table status db
 221                                         $this->updateChunkStatus();
 222                                 }
 223                         } else {
 224                                 $status = Status::newFatal( 'invalid-chunk-offset' );
 225                         }
 226                 }
 227
 228                 return $status;
 229         }
 230
 231         /**
 232          * Update the chunk db table with the current status:
 233          */
 234         private function updateChunkStatus() {
 235                 wfDebug( __METHOD__ . " update chunk status for {$this->mFileKey} offset:" .
 236                         $this->getOffset() . ' inx:' . $this->getChunkIndex() . "\n" );
 237
 238                 $dbw = $this->repo->getMasterDb();
 239                 // Use a quick transaction since we will upload the full temp file into shared
 240                 // storage, which takes time for large files. We don't want to hold locks then.
 241                 $dbw->update(
 242                         'uploadstash',
 243                         [
 244                                 'us_status' => 'chunks',
 245                                 'us_chunk_inx' => $this->getChunkIndex(),
 246                                 'us_size' => $this->getOffset()
 247                         ],
 248                         [ 'us_key' => $this->mFileKey ],
 249                         __METHOD__
 250                 );
 251                 $dbw->commit( __METHOD__, 'flush' );
 252         }
 253
 254         /**
 255          * Get the chunk db state and populate update relevant local values
 256          */
 257         private function getChunkStatus() {
 258                 // get Master db to avoid race conditions.
 259                 // Otherwise, if chunk upload time < replag there will be spurious errors
 260                 $dbw = $this->repo->getMasterDb();
 261                 $row = $dbw->selectRow(
 262                         'uploadstash',
 263                         [
 264                                 'us_chunk_inx',
 265                                 'us_size',
 266                                 'us_path',
 267                         ],
 268                         [ 'us_key' => $this->mFileKey ],
 269                         __METHOD__
 270                 );
 271                 // Handle result:
 272                 if ( $row ) {
 273                         $this->mChunkIndex = $row->us_chunk_inx;
 274                         $this->mOffset = $row->us_size;
 275                         $this->mVirtualTempPath = $row->us_path;
 276                 }
 277         }
 278
 279         /**
 280          * Get the current Chunk index
 281          * @return int Index of the current chunk
 282          */
 283         private function getChunkIndex() {
 284                 if ( $this->mChunkIndex !== null ) {
 285                         return $this->mChunkIndex;
 286                 }
 287
 288                 return 0;
 289         }
 290
 291         /**
 292          * Get the offset at which the next uploaded chunk will be appended to
 293          * @return int Current byte offset of the chunk file set
 294          */
 295         public function getOffset() {
 296                 if ( $this->mOffset !== null ) {
 297                         return $this->mOffset;
 298                 }
 299
 300                 return 0;
 301         }
 302
 303         /**
 304          * Output the chunk to disk
 305          *
 306          * @param string $chunkPath
 307          * @throws UploadChunkFileException
 308          * @return FileRepoStatus
 309          */
 310         private function outputChunk( $chunkPath ) {
 311                 // Key is fileKey + chunk index
 312                 $fileKey = $this->getChunkFileKey();
 313
 314                 // Store the chunk per its indexed fileKey:
 315                 $hashPath = $this->repo->getHashPath( $fileKey );
 316                 $storeStatus = $this->repo->quickImport( $chunkPath,
 317                         $this->repo->getZonePath( 'temp' ) . "/{$hashPath}{$fileKey}" );
 318
 319                 // Check for error in stashing the chunk:
 320                 if ( !$storeStatus->isOK() ) {
 321                         $error = $storeStatus->getErrorsArray();
 322                         $error = reset( $error );
 323                         if ( !count( $error ) ) {
 324                                 $error = $storeStatus->getWarningsArray();
 325                                 $error = reset( $error );
 326                                 if ( !count( $error ) ) {
 327                                         $error = [ 'unknown', 'no error recorded' ];
 328                                 }
 329                         }
 330                         throw new UploadChunkFileException( "Error storing file in '$chunkPath': " .
 331                                 implode( '; ', $error ) );
 332                 }
 333
 334                 return $storeStatus;
 335         }
 336
 337         private function getChunkFileKey( $index = null ) {
 338                 if ( $index === null ) {
 339                         $index = $this->getChunkIndex();
 340                 }
 341
 342                 return $this->mFileKey . '.' . $index;
 343         }
 344
 345         /**
 346          * Verify that the chunk isn't really an evil html file
 347          *
 348          * @throws UploadChunkVerificationException
 349          */
 350         private function verifyChunk() {
 351                 // Rest mDesiredDestName here so we verify the name as if it were mFileKey
 352                 $oldDesiredDestName = $this->mDesiredDestName;
 353                 $this->mDesiredDestName = $this->mFileKey;
 354                 $this->mTitle = false;
 355                 $res = $this->verifyPartialFile();
 356                 $this->mDesiredDestName = $oldDesiredDestName;
 357                 $this->mTitle = false;
 358                 if ( is_array( $res ) ) {
 359                         throw new UploadChunkVerificationException( $res[0] );
 360                 }
 361         }
 362 }
 363
 364 class UploadChunkZeroLengthFileException extends MWException {
 365 }
 366
 367 class UploadChunkFileException extends MWException {
 368 }
 369
 370 class UploadChunkVerificationException extends MWException {
 371 }