* This file is part of AjaXplorer.
*
* AjaXplorer is free software: you can redistribute it and/or modify
* it under the terms of the GNU Affero General Public License as published by
* the Free Software Foundation, either version 3 of the License, or
* (at your option) any later version.
*
* AjaXplorer is distributed in the hope that it will be useful,
* but WITHOUT ANY WARRANTY; without even the implied warranty of
* MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the
* GNU Affero General Public License for more details.
*
* You should have received a copy of the GNU Affero General Public License
* along with AjaXplorer. If not, see .
*
* The latest code can be found at .
*/
defined('AJXP_EXEC') or die( 'Access not allowed');
/**
* @package info.ajaxplorer.plugins
* Processor for standard POST upload
*/
class SimpleUploadProcessor extends AJXP_Plugin {
public function getDropBg($action, $httpVars, $fileVars){
$lang = ConfService::getLanguage();
$img = AJXP_INSTALL_PATH."/plugins/uploader.html/i18n/$lang-dropzone.png";
if(!is_file($img)) $img = AJXP_INSTALL_PATH."/plugins/uploader.html/i18n/en-dropzone.png";
header("Content-Type: image/png; name=\"dropzone.png\"");
header("Content-Length: ".filesize($img));
header('Cache-Control: public');
readfile($img);
}
public function preProcess($action, &$httpVars, &$fileVars){
if(!isSet($httpVars["input_stream"])){
return false;
}
//AJXP_Logger::debug("SimpleUpload::preProcess", $httpVars);
$headersCheck = (
// basic checks
isset(
//$_SERVER['CONTENT_TYPE'],
$_SERVER['CONTENT_LENGTH'],
$_SERVER['HTTP_X_FILE_SIZE'],
$_SERVER['HTTP_X_FILE_NAME']
) &&
//$_SERVER['CONTENT_TYPE'] === 'multipart/form-data' &&
$_SERVER['CONTENT_LENGTH'] === $_SERVER['HTTP_X_FILE_SIZE']
);
$fileNameH = $_SERVER['HTTP_X_FILE_NAME'];
$fileSizeH = $_SERVER['HTTP_X_FILE_SIZE'];
if($headersCheck){
// create the object and assign property
$fileVars["userfile_0"] = array(
"input_upload" => true,
"name" => SystemTextEncoding::fromUTF8(basename($fileNameH)),
"size" => $fileSizeH
);
}else{
exit("Warning, missing headers!");
}
}
public function postProcess($action, $httpVars, $postProcessData){
if(!isSet($httpVars["simple_uploader"]) && !isSet($httpVars["xhr_uploader"])){
return false;
}
AJXP_Logger::debug("SimpleUploadProc is active");
$result = $postProcessData["processor_result"];
if(isSet($httpVars["simple_uploader"])){
print("");
}else{
if(isSet($result["ERROR"])){
$message = $result["ERROR"]["MESSAGE"]." (".$result["ERROR"]["CODE"].")";
exit($message);
}else{
exit("OK");
}
}
}
public function unifyChunks($action, $httpVars, $fileVars){
$repository = ConfService::getRepository();
if(!$repository->detectStreamWrapper(false)){
return false;
}
$plugin = AJXP_PluginsService::findPlugin("access", $repository->getAccessType());
$streamData = $plugin->detectStreamWrapper(true);
$dir = AJXP_Utils::decodeSecureMagic($httpVars["dir"]);
$destStreamURL = $streamData["protocol"]."://".$repository->getId().$dir."/";
$filename = AJXP_Utils::decodeSecureMagic($httpVars["file_name"]);
$chunks = array();
$index = 0;
while(isSet($httpVars["chunk_".$index])){
$chunks[] = AJXP_Utils::decodeSecureMagic($httpVars["chunk_".$index]);
$index++;
}
$newDest = fopen($destStreamURL.$filename, "w");
for ($i = 0; $i < count($chunks) ; $i++){
$part = fopen($destStreamURL.$chunks[$i], "r");
while(!feof($part)){
fwrite($newDest, fread($part, 4096));
}
fclose($part);
unlink($destStreamURL.$chunks[$i]);
}
fclose($newDest);
}
}
?>