/**
* Entry point for API upload
- *
+ *
* @param $name string
* @param $url string
- * @param $async mixed Whether the download should be performed
+ * @param $async mixed Whether the download should be performed
* asynchronous. False for synchronous, async or async-leavemessage for
* asynchronous download.
*/
public function initialize( $name, $url, $async = false ) {
global $wgAllowAsyncCopyUploads;
-
+
$this->mUrl = $url;
$this->mAsync = $wgAllowAsyncCopyUploads ? $async : false;
-
+
$tempPath = $this->mAsync ? null : $this->makeTemporaryFile();
# File size and removeTempFile will be filled in later
$this->initializePathInfo( $name, $tempPath, 0, false );
&& Http::isValidURI( $url )
&& $wgUser->isAllowed( 'upload_by_url' );
}
-
+
public function fetchFile() {
if ( !Http::isValidURI( $this->mUrl ) ) {
return Status::newFatal( 'http-invalid-url' );
}
-
+
if ( !$this->mAsync ) {
return $this->reallyFetchFile();
}
}
/**
* Create a new temporary file in the URL subdirectory of wfTempDir().
- *
+ *
* @return string Path to the file
*/
protected function makeTemporaryFile() {
}
/**
* Save the result of a HTTP request to the temporary file
- *
- * @param $req MWHttpRequest
+ *
+ * @param $req MWHttpRequest
* @return Status
*/
private function saveTempFile( $req ) {
}
/**
- * Wrapper around the parent function in order to defer verifying the
+ * Wrapper around the parent function in order to defer verifying the
* upload until the file really has been fetched.
*/
public function verifyUpload() {
}
return parent::checkWarnings();
}
-
+
/**
* Wrapper around the parent function in order to defer checking protection
* until we are sure that the file can actually be uploaded
}
return parent::verifyPermissions( $user );
}
-
+
/**
* Wrapper around the parent function in order to defer uploading to the
* job queue for asynchronous uploads
public function performUpload( $comment, $pageText, $watch, $user ) {
if ( $this->mAsync ) {
$sessionKey = $this->insertJob( $comment, $pageText, $watch, $user );
-
+
$status = new Status;
$status->error( 'async', $sessionKey );
return $status;
}
-
+
return parent::performUpload( $comment, $pageText, $watch, $user );
}
-
+
protected function insertJob( $comment, $pageText, $watch, $user ) {
- $sessionKey = $this->getSessionKey();
+ $sessionKey = $this->stashSession();
$job = new UploadFromUrlJob( $this->getTitle(), array(
'url' => $this->mUrl,
'comment' => $comment,
$job->insert();
return $sessionKey;
}
-
+
}