PHPSessionHandler: Implement SessionHandlerInterface
[mediawiki.git] / includes / api / ApiUpload.php
blob82f66a8c673b1aaeb544483104109f13a48cccae
1 <?php
2 /**
5 * Created on Aug 21, 2008
7 * Copyright © 2008 - 2010 Bryan Tong Minh <Bryan.TongMinh@Gmail.com>
9 * This program is free software; you can redistribute it and/or modify
10 * it under the terms of the GNU General Public License as published by
11 * the Free Software Foundation; either version 2 of the License, or
12 * (at your option) any later version.
14 * This program is distributed in the hope that it will be useful,
15 * but WITHOUT ANY WARRANTY; without even the implied warranty of
16 * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the
17 * GNU General Public License for more details.
19 * You should have received a copy of the GNU General Public License along
20 * with this program; if not, write to the Free Software Foundation, Inc.,
21 * 51 Franklin Street, Fifth Floor, Boston, MA 02110-1301, USA.
22 * http://www.gnu.org/copyleft/gpl.html
24 * @file
27 /**
28 * @ingroup API
30 class ApiUpload extends ApiBase {
31 /** @var UploadBase|UploadFromChunks */
32 protected $mUpload = null;
34 protected $mParams;
36 public function execute() {
37 // Check whether upload is enabled
38 if ( !UploadBase::isEnabled() ) {
39 $this->dieUsageMsg( 'uploaddisabled' );
42 $user = $this->getUser();
44 // Parameter handling
45 $this->mParams = $this->extractRequestParams();
46 $request = $this->getMain()->getRequest();
47 // Check if async mode is actually supported (jobs done in cli mode)
48 $this->mParams['async'] = ( $this->mParams['async'] &&
49 $this->getConfig()->get( 'EnableAsyncUploads' ) );
50 // Add the uploaded file to the params array
51 $this->mParams['file'] = $request->getFileName( 'file' );
52 $this->mParams['chunk'] = $request->getFileName( 'chunk' );
54 // Copy the session key to the file key, for backward compatibility.
55 if ( !$this->mParams['filekey'] && $this->mParams['sessionkey'] ) {
56 $this->mParams['filekey'] = $this->mParams['sessionkey'];
59 // Select an upload module
60 try {
61 if ( !$this->selectUploadModule() ) {
62 return; // not a true upload, but a status request or similar
63 } elseif ( !isset( $this->mUpload ) ) {
64 $this->dieUsage( 'No upload module set', 'nomodule' );
66 } catch ( UploadStashException $e ) { // XXX: don't spam exception log
67 $this->handleStashException( $e );
70 // First check permission to upload
71 $this->checkPermissions( $user );
73 // Fetch the file (usually a no-op)
74 /** @var $status Status */
75 $status = $this->mUpload->fetchFile();
76 if ( !$status->isGood() ) {
77 $errors = $status->getErrorsArray();
78 $error = array_shift( $errors[0] );
79 $this->dieUsage( 'Error fetching file from remote source', $error, 0, $errors[0] );
82 // Check if the uploaded file is sane
83 if ( $this->mParams['chunk'] ) {
84 $maxSize = UploadBase::getMaxUploadSize();
85 if ( $this->mParams['filesize'] > $maxSize ) {
86 $this->dieUsage( 'The file you submitted was too large', 'file-too-large' );
88 if ( !$this->mUpload->getTitle() ) {
89 $this->dieUsage( 'Invalid file title supplied', 'internal-error' );
91 } elseif ( $this->mParams['async'] && $this->mParams['filekey'] ) {
92 // defer verification to background process
93 } else {
94 wfDebug( __METHOD__ . " about to verify\n" );
95 $this->verifyUpload();
98 // Check if the user has the rights to modify or overwrite the requested title
99 // (This check is irrelevant if stashing is already requested, since the errors
100 // can always be fixed by changing the title)
101 if ( !$this->mParams['stash'] ) {
102 $permErrors = $this->mUpload->verifyTitlePermissions( $user );
103 if ( $permErrors !== true ) {
104 $this->dieRecoverableError( $permErrors[0], 'filename' );
108 // Get the result based on the current upload context:
109 try {
110 $result = $this->getContextResult();
111 if ( $result['result'] === 'Success' ) {
112 $result['imageinfo'] = $this->mUpload->getImageInfo( $this->getResult() );
114 } catch ( UploadStashException $e ) { // XXX: don't spam exception log
115 $this->handleStashException( $e );
118 $this->getResult()->addValue( null, $this->getModuleName(), $result );
120 // Cleanup any temporary mess
121 $this->mUpload->cleanupTempFile();
125 * Get an upload result based on upload context
126 * @return array
128 private function getContextResult() {
129 $warnings = $this->getApiWarnings();
130 if ( $warnings && !$this->mParams['ignorewarnings'] ) {
131 // Get warnings formatted in result array format
132 return $this->getWarningsResult( $warnings );
133 } elseif ( $this->mParams['chunk'] ) {
134 // Add chunk, and get result
135 return $this->getChunkResult( $warnings );
136 } elseif ( $this->mParams['stash'] ) {
137 // Stash the file and get stash result
138 return $this->getStashResult( $warnings );
141 // Check throttle after we've handled warnings
142 if ( UploadBase::isThrottled( $this->getUser() )
144 $this->dieUsageMsg( 'actionthrottledtext' );
147 // This is the most common case -- a normal upload with no warnings
148 // performUpload will return a formatted properly for the API with status
149 return $this->performUpload( $warnings );
153 * Get Stash Result, throws an exception if the file could not be stashed.
154 * @param array $warnings Array of Api upload warnings
155 * @return array
157 private function getStashResult( $warnings ) {
158 $result = array();
159 // Some uploads can request they be stashed, so as not to publish them immediately.
160 // In this case, a failure to stash ought to be fatal
161 try {
162 $result['result'] = 'Success';
163 $result['filekey'] = $this->performStash();
164 $result['sessionkey'] = $result['filekey']; // backwards compatibility
165 if ( $warnings && count( $warnings ) > 0 ) {
166 $result['warnings'] = $warnings;
168 } catch ( UploadStashException $e ) {
169 $this->handleStashException( $e );
170 } catch ( Exception $e ) {
171 $this->dieUsage( $e->getMessage(), 'stashfailed' );
174 return $result;
178 * Get Warnings Result
179 * @param array $warnings Array of Api upload warnings
180 * @return array
182 private function getWarningsResult( $warnings ) {
183 $result = array();
184 $result['result'] = 'Warning';
185 $result['warnings'] = $warnings;
186 // in case the warnings can be fixed with some further user action, let's stash this upload
187 // and return a key they can use to restart it
188 try {
189 $result['filekey'] = $this->performStash();
190 $result['sessionkey'] = $result['filekey']; // backwards compatibility
191 } catch ( Exception $e ) {
192 $result['warnings']['stashfailed'] = $e->getMessage();
195 return $result;
199 * Get the result of a chunk upload.
200 * @param array $warnings Array of Api upload warnings
201 * @return array
203 private function getChunkResult( $warnings ) {
204 $result = array();
206 if ( $warnings && count( $warnings ) > 0 ) {
207 $result['warnings'] = $warnings;
210 $request = $this->getMain()->getRequest();
211 $chunkPath = $request->getFileTempname( 'chunk' );
212 $chunkSize = $request->getUpload( 'chunk' )->getSize();
213 $totalSoFar = $this->mParams['offset'] + $chunkSize;
214 $minChunkSize = $this->getConfig()->get( 'MinUploadChunkSize' );
216 // Sanity check sizing
217 if ( $totalSoFar > $this->mParams['filesize'] ) {
218 $this->dieUsage(
219 'Offset plus current chunk is greater than claimed file size', 'invalid-chunk'
223 // Enforce minimum chunk size
224 if ( $totalSoFar != $this->mParams['filesize'] && $chunkSize < $minChunkSize ) {
225 $this->dieUsage(
226 "Minimum chunk size is $minChunkSize bytes for non-final chunks", 'chunk-too-small'
230 if ( $this->mParams['offset'] == 0 ) {
231 try {
232 $filekey = $this->performStash();
233 } catch ( UploadStashException $e ) {
234 $this->handleStashException( $e );
235 } catch ( Exception $e ) {
236 // FIXME: Error handling here is wrong/different from rest of this
237 $this->dieUsage( $e->getMessage(), 'stashfailed' );
239 } else {
240 $filekey = $this->mParams['filekey'];
242 // Don't allow further uploads to an already-completed session
243 $progress = UploadBase::getSessionStatus( $this->getUser(), $filekey );
244 if ( !$progress ) {
245 // Probably can't get here, but check anyway just in case
246 $this->dieUsage( 'No chunked upload session with this key', 'stashfailed' );
247 } elseif ( $progress['result'] !== 'Continue' || $progress['stage'] !== 'uploading' ) {
248 $this->dieUsage(
249 'Chunked upload is already completed, check status for details', 'stashfailed'
253 $status = $this->mUpload->addChunk(
254 $chunkPath, $chunkSize, $this->mParams['offset'] );
255 if ( !$status->isGood() ) {
256 $extradata = array(
257 'offset' => $this->mUpload->getOffset(),
260 $this->dieUsage( $status->getWikiText(), 'stashfailed', 0, $extradata );
264 // Check we added the last chunk:
265 if ( $totalSoFar == $this->mParams['filesize'] ) {
266 if ( $this->mParams['async'] ) {
267 UploadBase::setSessionStatus(
268 $this->getUser(),
269 $filekey,
270 array( 'result' => 'Poll',
271 'stage' => 'queued', 'status' => Status::newGood() )
273 JobQueueGroup::singleton()->push( new AssembleUploadChunksJob(
274 Title::makeTitle( NS_FILE, $filekey ),
275 array(
276 'filename' => $this->mParams['filename'],
277 'filekey' => $filekey,
278 'session' => $this->getContext()->exportSession()
280 ) );
281 $result['result'] = 'Poll';
282 $result['stage'] = 'queued';
283 } else {
284 $status = $this->mUpload->concatenateChunks();
285 if ( !$status->isGood() ) {
286 UploadBase::setSessionStatus(
287 $this->getUser(),
288 $filekey,
289 array( 'result' => 'Failure', 'stage' => 'assembling', 'status' => $status )
291 $this->dieUsage( $status->getWikiText(), 'stashfailed' );
294 // The fully concatenated file has a new filekey. So remove
295 // the old filekey and fetch the new one.
296 UploadBase::setSessionStatus( $this->getUser(), $filekey, false );
297 $this->mUpload->stash->removeFile( $filekey );
298 $filekey = $this->mUpload->getLocalFile()->getFileKey();
300 $result['result'] = 'Success';
302 } else {
303 UploadBase::setSessionStatus(
304 $this->getUser(),
305 $filekey,
306 array(
307 'result' => 'Continue',
308 'stage' => 'uploading',
309 'offset' => $totalSoFar,
310 'status' => Status::newGood(),
313 $result['result'] = 'Continue';
314 $result['offset'] = $totalSoFar;
317 $result['filekey'] = $filekey;
319 return $result;
323 * Stash the file and return the file key
324 * Also re-raises exceptions with slightly more informative message strings (useful for API)
325 * @throws MWException
326 * @return string File key
328 private function performStash() {
329 try {
330 $stashFile = $this->mUpload->stashFile( $this->getUser() );
332 if ( !$stashFile ) {
333 throw new MWException( 'Invalid stashed file' );
335 $fileKey = $stashFile->getFileKey();
336 } catch ( Exception $e ) {
337 $message = 'Stashing temporary file failed: ' . get_class( $e ) . ' ' . $e->getMessage();
338 wfDebug( __METHOD__ . ' ' . $message . "\n" );
339 $className = get_class( $e );
340 throw new $className( $message );
343 return $fileKey;
347 * Throw an error that the user can recover from by providing a better
348 * value for $parameter
350 * @param array $error Error array suitable for passing to dieUsageMsg()
351 * @param string $parameter Parameter that needs revising
352 * @param array $data Optional extra data to pass to the user
353 * @throws UsageException
355 private function dieRecoverableError( $error, $parameter, $data = array() ) {
356 try {
357 $data['filekey'] = $this->performStash();
358 $data['sessionkey'] = $data['filekey'];
359 } catch ( Exception $e ) {
360 $data['stashfailed'] = $e->getMessage();
362 $data['invalidparameter'] = $parameter;
364 $parsed = $this->parseMsg( $error );
365 if ( isset( $parsed['data'] ) ) {
366 $data = array_merge( $data, $parsed['data'] );
369 $this->dieUsage( $parsed['info'], $parsed['code'], 0, $data );
373 * Select an upload module and set it to mUpload. Dies on failure. If the
374 * request was a status request and not a true upload, returns false;
375 * otherwise true
377 * @return bool
379 protected function selectUploadModule() {
380 $request = $this->getMain()->getRequest();
382 // chunk or one and only one of the following parameters is needed
383 if ( !$this->mParams['chunk'] ) {
384 $this->requireOnlyOneParameter( $this->mParams,
385 'filekey', 'file', 'url' );
388 // Status report for "upload to stash"/"upload from stash"
389 if ( $this->mParams['filekey'] && $this->mParams['checkstatus'] ) {
390 $progress = UploadBase::getSessionStatus( $this->getUser(), $this->mParams['filekey'] );
391 if ( !$progress ) {
392 $this->dieUsage( 'No result in status data', 'missingresult' );
393 } elseif ( !$progress['status']->isGood() ) {
394 $this->dieUsage( $progress['status']->getWikiText(), 'stashfailed' );
396 if ( isset( $progress['status']->value['verification'] ) ) {
397 $this->checkVerification( $progress['status']->value['verification'] );
399 unset( $progress['status'] ); // remove Status object
400 $this->getResult()->addValue( null, $this->getModuleName(), $progress );
402 return false;
405 // The following modules all require the filename parameter to be set
406 if ( is_null( $this->mParams['filename'] ) ) {
407 $this->dieUsageMsg( array( 'missingparam', 'filename' ) );
410 if ( $this->mParams['chunk'] ) {
411 // Chunk upload
412 $this->mUpload = new UploadFromChunks();
413 if ( isset( $this->mParams['filekey'] ) ) {
414 if ( $this->mParams['offset'] === 0 ) {
415 $this->dieUsage( 'Cannot supply a filekey when offset is 0', 'badparams' );
418 // handle new chunk
419 $this->mUpload->continueChunks(
420 $this->mParams['filename'],
421 $this->mParams['filekey'],
422 $request->getUpload( 'chunk' )
424 } else {
425 if ( $this->mParams['offset'] !== 0 ) {
426 $this->dieUsage( 'Must supply a filekey when offset is non-zero', 'badparams' );
429 // handle first chunk
430 $this->mUpload->initialize(
431 $this->mParams['filename'],
432 $request->getUpload( 'chunk' )
435 } elseif ( isset( $this->mParams['filekey'] ) ) {
436 // Upload stashed in a previous request
437 if ( !UploadFromStash::isValidKey( $this->mParams['filekey'] ) ) {
438 $this->dieUsageMsg( 'invalid-file-key' );
441 $this->mUpload = new UploadFromStash( $this->getUser() );
442 // This will not download the temp file in initialize() in async mode.
443 // We still have enough information to call checkWarnings() and such.
444 $this->mUpload->initialize(
445 $this->mParams['filekey'], $this->mParams['filename'], !$this->mParams['async']
447 } elseif ( isset( $this->mParams['file'] ) ) {
448 $this->mUpload = new UploadFromFile();
449 $this->mUpload->initialize(
450 $this->mParams['filename'],
451 $request->getUpload( 'file' )
453 } elseif ( isset( $this->mParams['url'] ) ) {
454 // Make sure upload by URL is enabled:
455 if ( !UploadFromUrl::isEnabled() ) {
456 $this->dieUsageMsg( 'copyuploaddisabled' );
459 if ( !UploadFromUrl::isAllowedHost( $this->mParams['url'] ) ) {
460 $this->dieUsageMsg( 'copyuploadbaddomain' );
463 if ( !UploadFromUrl::isAllowedUrl( $this->mParams['url'] ) ) {
464 $this->dieUsageMsg( 'copyuploadbadurl' );
467 $this->mUpload = new UploadFromUrl;
468 $this->mUpload->initialize( $this->mParams['filename'],
469 $this->mParams['url'] );
472 return true;
476 * Checks that the user has permissions to perform this upload.
477 * Dies with usage message on inadequate permissions.
478 * @param User $user The user to check.
480 protected function checkPermissions( $user ) {
481 // Check whether the user has the appropriate permissions to upload anyway
482 $permission = $this->mUpload->isAllowed( $user );
484 if ( $permission !== true ) {
485 if ( !$user->isLoggedIn() ) {
486 $this->dieUsageMsg( array( 'mustbeloggedin', 'upload' ) );
489 $this->dieUsageMsg( 'badaccess-groups' );
494 * Performs file verification, dies on error.
496 protected function verifyUpload() {
497 $verification = $this->mUpload->verifyUpload();
498 if ( $verification['status'] === UploadBase::OK ) {
499 return;
502 $this->checkVerification( $verification );
506 * Performs file verification, dies on error.
507 * @param array $verification
509 protected function checkVerification( array $verification ) {
510 // @todo Move them to ApiBase's message map
511 switch ( $verification['status'] ) {
512 // Recoverable errors
513 case UploadBase::MIN_LENGTH_PARTNAME:
514 $this->dieRecoverableError( 'filename-tooshort', 'filename' );
515 break;
516 case UploadBase::ILLEGAL_FILENAME:
517 $this->dieRecoverableError( 'illegal-filename', 'filename',
518 array( 'filename' => $verification['filtered'] ) );
519 break;
520 case UploadBase::FILENAME_TOO_LONG:
521 $this->dieRecoverableError( 'filename-toolong', 'filename' );
522 break;
523 case UploadBase::FILETYPE_MISSING:
524 $this->dieRecoverableError( 'filetype-missing', 'filename' );
525 break;
526 case UploadBase::WINDOWS_NONASCII_FILENAME:
527 $this->dieRecoverableError( 'windows-nonascii-filename', 'filename' );
528 break;
530 // Unrecoverable errors
531 case UploadBase::EMPTY_FILE:
532 $this->dieUsage( 'The file you submitted was empty', 'empty-file' );
533 break;
534 case UploadBase::FILE_TOO_LARGE:
535 $this->dieUsage( 'The file you submitted was too large', 'file-too-large' );
536 break;
538 case UploadBase::FILETYPE_BADTYPE:
539 $extradata = array(
540 'filetype' => $verification['finalExt'],
541 'allowed' => array_values( array_unique( $this->getConfig()->get( 'FileExtensions' ) ) )
543 ApiResult::setIndexedTagName( $extradata['allowed'], 'ext' );
545 $msg = "Filetype not permitted: ";
546 if ( isset( $verification['blacklistedExt'] ) ) {
547 $msg .= join( ', ', $verification['blacklistedExt'] );
548 $extradata['blacklisted'] = array_values( $verification['blacklistedExt'] );
549 ApiResult::setIndexedTagName( $extradata['blacklisted'], 'ext' );
550 } else {
551 $msg .= $verification['finalExt'];
553 $this->dieUsage( $msg, 'filetype-banned', 0, $extradata );
554 break;
555 case UploadBase::VERIFICATION_ERROR:
556 $params = $verification['details'];
557 $key = array_shift( $params );
558 $msg = $this->msg( $key, $params )->inLanguage( 'en' )->useDatabase( false )->text();
559 ApiResult::setIndexedTagName( $verification['details'], 'detail' );
560 $this->dieUsage( "This file did not pass file verification: $msg", 'verification-error',
561 0, array( 'details' => $verification['details'] ) );
562 break;
563 case UploadBase::HOOK_ABORTED:
564 if ( is_array( $verification['error'] ) ) {
565 $params = $verification['error'];
566 } elseif ( $verification['error'] !== '' ) {
567 $params = array( $verification['error'] );
568 } else {
569 $params = array( 'hookaborted' );
571 $key = array_shift( $params );
572 $msg = $this->msg( $key, $params )->inLanguage( 'en' )->useDatabase( false )->text();
573 $this->dieUsage( $msg, 'hookaborted', 0, array( 'details' => $verification['error'] ) );
574 break;
575 default:
576 $this->dieUsage( 'An unknown error occurred', 'unknown-error',
577 0, array( 'details' => array( 'code' => $verification['status'] ) ) );
578 break;
583 * Check warnings.
584 * Returns a suitable array for inclusion into API results if there were warnings
585 * Returns the empty array if there were no warnings
587 * @return array
589 protected function getApiWarnings() {
590 $warnings = $this->mUpload->checkWarnings();
592 return $this->transformWarnings( $warnings );
595 protected function transformWarnings( $warnings ) {
596 if ( $warnings ) {
597 // Add indices
598 ApiResult::setIndexedTagName( $warnings, 'warning' );
600 if ( isset( $warnings['duplicate'] ) ) {
601 $dupes = array();
602 /** @var File $dupe */
603 foreach ( $warnings['duplicate'] as $dupe ) {
604 $dupes[] = $dupe->getName();
606 ApiResult::setIndexedTagName( $dupes, 'duplicate' );
607 $warnings['duplicate'] = $dupes;
610 if ( isset( $warnings['exists'] ) ) {
611 $warning = $warnings['exists'];
612 unset( $warnings['exists'] );
613 /** @var LocalFile $localFile */
614 $localFile = isset( $warning['normalizedFile'] )
615 ? $warning['normalizedFile']
616 : $warning['file'];
617 $warnings[$warning['warning']] = $localFile->getName();
621 return $warnings;
625 * Handles a stash exception, giving a useful error to the user.
626 * @param Exception $e The exception we encountered.
628 protected function handleStashException( $e ) {
629 $exceptionType = get_class( $e );
631 switch ( $exceptionType ) {
632 case 'UploadStashFileNotFoundException':
633 $this->dieUsage(
634 'Could not find the file in the stash: ' . $e->getMessage(),
635 'stashedfilenotfound'
637 break;
638 case 'UploadStashBadPathException':
639 $this->dieUsage(
640 'File key of improper format or otherwise invalid: ' . $e->getMessage(),
641 'stashpathinvalid'
643 break;
644 case 'UploadStashFileException':
645 $this->dieUsage(
646 'Could not store upload in the stash: ' . $e->getMessage(),
647 'stashfilestorage'
649 break;
650 case 'UploadStashZeroLengthFileException':
651 $this->dieUsage(
652 'File is of zero length, and could not be stored in the stash: ' .
653 $e->getMessage(),
654 'stashzerolength'
656 break;
657 case 'UploadStashNotLoggedInException':
658 $this->dieUsage( 'Not logged in: ' . $e->getMessage(), 'stashnotloggedin' );
659 break;
660 case 'UploadStashWrongOwnerException':
661 $this->dieUsage( 'Wrong owner: ' . $e->getMessage(), 'stashwrongowner' );
662 break;
663 case 'UploadStashNoSuchKeyException':
664 $this->dieUsage( 'No such filekey: ' . $e->getMessage(), 'stashnosuchfilekey' );
665 break;
666 default:
667 $this->dieUsage( $exceptionType . ": " . $e->getMessage(), 'stasherror' );
668 break;
673 * Perform the actual upload. Returns a suitable result array on success;
674 * dies on failure.
676 * @param array $warnings Array of Api upload warnings
677 * @return array
679 protected function performUpload( $warnings ) {
680 // Use comment as initial page text by default
681 if ( is_null( $this->mParams['text'] ) ) {
682 $this->mParams['text'] = $this->mParams['comment'];
685 /** @var $file File */
686 $file = $this->mUpload->getLocalFile();
688 // For preferences mode, we want to watch if 'watchdefault' is set or
689 // if the *file* doesn't exist and 'watchcreations' is set. But
690 // getWatchlistValue()'s automatic handling checks if the *title*
691 // exists or not, so we need to check both prefs manually.
692 $watch = $this->getWatchlistValue(
693 $this->mParams['watchlist'], $file->getTitle(), 'watchdefault'
695 if ( !$watch && $this->mParams['watchlist'] == 'preferences' && !$file->exists() ) {
696 $watch = $this->getWatchlistValue(
697 $this->mParams['watchlist'], $file->getTitle(), 'watchcreations'
701 // Deprecated parameters
702 if ( $this->mParams['watch'] ) {
703 $watch = true;
706 // No errors, no warnings: do the upload
707 if ( $this->mParams['async'] ) {
708 $progress = UploadBase::getSessionStatus( $this->getUser(), $this->mParams['filekey'] );
709 if ( $progress && $progress['result'] === 'Poll' ) {
710 $this->dieUsage( "Upload from stash already in progress.", 'publishfailed' );
712 UploadBase::setSessionStatus(
713 $this->getUser(),
714 $this->mParams['filekey'],
715 array( 'result' => 'Poll', 'stage' => 'queued', 'status' => Status::newGood() )
717 JobQueueGroup::singleton()->push( new PublishStashedFileJob(
718 Title::makeTitle( NS_FILE, $this->mParams['filename'] ),
719 array(
720 'filename' => $this->mParams['filename'],
721 'filekey' => $this->mParams['filekey'],
722 'comment' => $this->mParams['comment'],
723 'text' => $this->mParams['text'],
724 'watch' => $watch,
725 'session' => $this->getContext()->exportSession()
727 ) );
728 $result['result'] = 'Poll';
729 $result['stage'] = 'queued';
730 } else {
731 /** @var $status Status */
732 $status = $this->mUpload->performUpload( $this->mParams['comment'],
733 $this->mParams['text'], $watch, $this->getUser() );
735 if ( !$status->isGood() ) {
736 $error = $status->getErrorsArray();
737 ApiResult::setIndexedTagName( $error, 'error' );
738 $this->dieUsage( 'An internal error occurred', 'internal-error', 0, $error );
740 $result['result'] = 'Success';
743 $result['filename'] = $file->getName();
744 if ( $warnings && count( $warnings ) > 0 ) {
745 $result['warnings'] = $warnings;
748 return $result;
751 public function mustBePosted() {
752 return true;
755 public function isWriteMode() {
756 return true;
759 public function getAllowedParams() {
760 $params = array(
761 'filename' => array(
762 ApiBase::PARAM_TYPE => 'string',
764 'comment' => array(
765 ApiBase::PARAM_DFLT => ''
767 'text' => array(
768 ApiBase::PARAM_TYPE => 'text',
770 'watch' => array(
771 ApiBase::PARAM_DFLT => false,
772 ApiBase::PARAM_DEPRECATED => true,
774 'watchlist' => array(
775 ApiBase::PARAM_DFLT => 'preferences',
776 ApiBase::PARAM_TYPE => array(
777 'watch',
778 'preferences',
779 'nochange'
782 'ignorewarnings' => false,
783 'file' => array(
784 ApiBase::PARAM_TYPE => 'upload',
786 'url' => null,
787 'filekey' => null,
788 'sessionkey' => array(
789 ApiBase::PARAM_DEPRECATED => true,
791 'stash' => false,
793 'filesize' => array(
794 ApiBase::PARAM_TYPE => 'integer',
795 ApiBase::PARAM_MIN => 0,
796 ApiBase::PARAM_MAX => UploadBase::getMaxUploadSize(),
798 'offset' => array(
799 ApiBase::PARAM_TYPE => 'integer',
800 ApiBase::PARAM_MIN => 0,
802 'chunk' => array(
803 ApiBase::PARAM_TYPE => 'upload',
806 'async' => false,
807 'checkstatus' => false,
810 return $params;
813 public function needsToken() {
814 return 'csrf';
817 protected function getExamplesMessages() {
818 return array(
819 'action=upload&filename=Wiki.png' .
820 '&url=http%3A//upload.wikimedia.org/wikipedia/en/b/bc/Wiki.png&token=123ABC'
821 => 'apihelp-upload-example-url',
822 'action=upload&filename=Wiki.png&filekey=filekey&ignorewarnings=1&token=123ABC'
823 => 'apihelp-upload-example-filekey',
827 public function getHelpUrls() {
828 return 'https://www.mediawiki.org/wiki/API:Upload';