| Server IP : 37.220.80.31 / Your IP : 3.135.200.4 Web Server : Apache/2.4.52 (Ubuntu) System : Linux 3051455-guretool.twc1.net 5.15.0-107-generic #117-Ubuntu SMP Fri Apr 26 12:26:49 UTC 2024 x86_64 User : www-root ( 1010) PHP Version : 7.4.33 Disable Function : pcntl_alarm,pcntl_fork,pcntl_waitpid,pcntl_wait,pcntl_wifexited,pcntl_wifstopped,pcntl_wifsignaled,pcntl_wexitstatus,pcntl_wtermsig,pcntl_wstopsig,pcntl_signal,pcntl_signal_dispatch,pcntl_get_last_error,pcntl_strerror,pcntl_sigprocmask,pcntl_sigwaitinfo,pcntl_sigtimedwait,pcntl_exec,pcntl_getpriority,pcntl_setpriority, MySQL : OFF | cURL : ON | WGET : OFF | Perl : OFF | Python : OFF | Sudo : OFF | Pkexec : OFF Directory : /var/www/www-root/data/www/dev.artlot24.ru/bitrix/modules/clouds/classes/general/ |
Upload File : |
<?php
/*.
require_module 'standard';
require_module 'pcre';
require_module 'hash';
require_module 'bitrix_main';
require_module 'bitrix_clouds_classes_storage_service';
require_module 'bitrix_clouds_classes_storage_bucket';
.*/
IncludeModuleLangFile(__FILE__);
class CCloudStorageUpload
{
protected /*.string.*/ $_filePath = "";
protected /*.string.*/ $_ID = "";
protected /*.CCloudStorageBucket.*/ $obBucket;
protected /*.int.*/ $_max_retries = 3;
protected /*.array[string]string.*/ $_cache = null;
/**
* @param string $filePath
* @return void
*/
function __construct($filePath)
{
$this->_filePath = $filePath;
$this->_ID = "1".mb_substr(md5($filePath), 1);
}
/**
* @return array[string]string
*/
public function GetArray()
{
global $DB;
if(!isset($this->_cache))
{
$rs = $DB->Query("
SELECT *
FROM b_clouds_file_upload
WHERE ID = '".$this->_ID."'
");
$this->_cache = $rs->Fetch();
}
return $this->_cache;
}
/**
* @return bool
*/
public function isStarted()
{
return is_array($this->GetArray());
}
/**
* @return void
*/
public function Delete()
{
global $DB;
//TODO: clean up temp files in Clodo
$DB->Query("DELETE FROM b_clouds_file_upload WHERE ID = '".$this->_ID."'");
unset($this->_cache);
}
/**
* @return void
*/
public function DeleteOld()
{
global $DB;
$DB->Query("DELETE FROM b_clouds_file_upload WHERE TIMESTAMP_X < ".$DB->CharToDateFunction(ConvertTimeStamp(time()-24*60*60)));
}
/**
* @param int $bucket_id
* @param float $fileSize
* @param string $ContentType
* @return bool
*/
function Start($bucket_id, $fileSize, $ContentType = 'binary/octet-stream', $tmpFileName = false)
{
global $DB;
if(is_object($bucket_id))
$obBucket = $bucket_id;
else
$obBucket = new CCloudStorageBucket(intval($bucket_id));
if(!$obBucket->Init())
return false;
if(!$this->isStarted())
{
$arUploadInfo = /*.(array[string]string).*/array();
$bStarted = $obBucket->GetService()->InitiateMultipartUpload(
$obBucket->GetBucketArray(),
$arUploadInfo,
$this->_filePath,
$fileSize,
$ContentType
);
if (!$bStarted && $obBucket->RenewToken())
{
$bStarted = $obBucket->GetService()->InitiateMultipartUpload(
$obBucket->GetBucketArray(),
$arUploadInfo,
$this->_filePath,
$fileSize,
$ContentType
);
}
if($bStarted)
{
$bAdded = $DB->Add("b_clouds_file_upload", array(
"ID" => $this->_ID,
"~TIMESTAMP_X" => $DB->CurrentTimeFunction(),
"FILE_PATH" => $this->_filePath,
"FILE_SIZE" => $fileSize,
"TMP_FILE" => $tmpFileName,
"BUCKET_ID" => intval($obBucket->ID),
"PART_SIZE" => $obBucket->GetService()->GetMinUploadPartSize(),
"PART_NO" => 0,
"PART_FAIL_COUNTER" => 0,
"NEXT_STEP" => serialize($arUploadInfo),
), array("NEXT_STEP"));
unset($this->_cache);
return $bAdded !== false;
}
}
return false;
}
/**
* @param string $data
* @return bool
*/
function Next($data, $obBucket = null)
{
global $APPLICATION;
if($this->isStarted())
{
$ar = $this->GetArray();
if($obBucket == null)
$obBucket = new CCloudStorageBucket(intval($ar["BUCKET_ID"]));
if(!$obBucket->Init())
{
$APPLICATION->ThrowException(GetMessage('CLO_STORAGE_UPLOAD_ERROR', array('#errno#'=>1)));
return false;
}
$arUploadInfo = unserialize($ar["NEXT_STEP"], ['allowed_classes' => false]);
$bSuccess = $obBucket->GetService()->UploadPart(
$obBucket->GetBucketArray(),
$arUploadInfo,
$data
);
if (!$this->UpdateProgress($arUploadInfo, $bSuccess))
{
$APPLICATION->ThrowException(GetMessage('CLO_STORAGE_UPLOAD_ERROR', array('#errno#'=>2)));
return false;
}
return $bSuccess;
}
return false;
}
/**
* @param string $data
* @param int $part_no
* @return bool
*/
function Part($data, $part_no, $obBucket = null)
{
global $APPLICATION;
if($this->isStarted())
{
$ar = $this->GetArray();
if($obBucket == null)
$obBucket = new CCloudStorageBucket(intval($ar["BUCKET_ID"]));
if(!$obBucket->Init())
{
$APPLICATION->ThrowException(GetMessage('CLO_STORAGE_UPLOAD_ERROR', array('#errno#'=>3)));
return false;
}
$service = $obBucket->GetService();
if (!is_callable(array($service, 'UploadPartNo')))
{
$APPLICATION->ThrowException(GetMessage('CLO_STORAGE_UPLOAD_ERROR', array('#errno#'=>4)));
return false;
}
$arUploadInfo = unserialize($ar["NEXT_STEP"], ['allowed_classes' => false]);
$bSuccess = $obBucket->GetService()->UploadPartNo(
$obBucket->GetBucketArray(),
$arUploadInfo,
$data,
$part_no
);
if (!$this->UpdateProgress($arUploadInfo, $bSuccess))
{
$APPLICATION->ThrowException(GetMessage('CLO_STORAGE_UPLOAD_ERROR', array('#errno#'=>5)));
return false;
}
return $bSuccess;
}
return false;
}
/**
* @return bool
*/
function Finish($obBucket = null)
{
if($this->isStarted())
{
$ar = $this->GetArray();
if($obBucket == null)
$obBucket = new CCloudStorageBucket(intval($ar["BUCKET_ID"]));
if(!$obBucket->Init())
return false;
$arUploadInfo = unserialize($ar["NEXT_STEP"], ['allowed_classes' => false]);
$bSuccess = $obBucket->GetService()->CompleteMultipartUpload(
$obBucket->GetBucketArray(),
$arUploadInfo
);
if ($bSuccess)
{
$this->Delete();
if ($obBucket->getQueueFlag())
{
CCloudFailover::queueCopy($obBucket, $this->_filePath);
}
foreach(GetModuleEvents("clouds", "OnAfterCompleteMultipartUpload", true) as $arEvent)
{
ExecuteModuleEventEx($arEvent, array($obBucket, array("size" => $ar["FILE_SIZE"]), $this->_filePath));
}
}
return $bSuccess;
}
return false;
}
/**
* @return int
*/
function GetPartCount()
{
$ar = $this->GetArray();
if(is_array($ar))
return intval($ar["PART_NO"]);
else
return 0;
}
/**
* @return float
*/
function GetPos()
{
$ar = $this->GetArray();
if(is_array($ar))
return intval($ar["PART_NO"])*doubleval($ar["PART_SIZE"]);
else
return 0;
}
/**
* @return int
*/
function getPartSize()
{
$ar = $this->GetArray();
if(is_array($ar))
return intval($ar["PART_SIZE"]);
else
return 0;
}
/**
* @return bool
*/
function hasRetries()
{
$ar = $this->GetArray();
return is_array($ar) && (intval($ar["PART_FAIL_COUNTER"]) < $this->_max_retries);
}
/**
* @return string
*/
function getTempFileName()
{
$ar = $this->GetArray();
if(is_array($ar))
return $ar["TMP_FILE"];
else
return "";
}
/**
* @param array $arUploadInfo
* @param boolean $bSuccess
* @return boolean
*/
protected function UpdateProgress($arUploadInfo, $bSuccess)
{
global $DB;
if ($bSuccess)
{
$arFields = array(
"NEXT_STEP" => serialize($arUploadInfo),
"~PART_NO" => "PART_NO + 1",
"PART_FAIL_COUNTER" => 0,
);
$arBinds = array(
"NEXT_STEP" => $arFields["NEXT_STEP"],
);
}
else
{
$arFields = array(
"~PART_FAIL_COUNTER" => "PART_FAIL_COUNTER + 1",
);
$arBinds = array(
);
}
$strUpdate = $DB->PrepareUpdate("b_clouds_file_upload", $arFields);
if ($strUpdate != "")
{
$strSql = "UPDATE b_clouds_file_upload SET ".$strUpdate." WHERE ID = '".$this->_ID."'";
if(!$DB->QueryBind($strSql, $arBinds))
{
unset($this->_cache);
return false;
}
}
unset($this->_cache);
return true;
}
public static function CleanUp($ID = '')
{
global $DB;
if ($ID)
{
$rs = $DB->Query("
SELECT ID, BUCKET_ID, NEXT_STEP
FROM b_clouds_file_upload
WHERE ID = '".$DB->ForSql($ID)."'
");
}
else
{
$days = COption::GetOptionInt("clouds", "multipart_upload_keep_days");
if ($days > 0)
{
$seconds = $days * 3600 * 24;
$delete_time = ConvertTimeStamp(time() - $seconds, 'FULL');
$rs = $DB->Query("
SELECT ID, BUCKET_ID, NEXT_STEP
FROM b_clouds_file_upload
WHERE TIMESTAMP_X < ".$DB->CharToDateFunction($delete_time)
);
}
}
while ($arBucket = $rs->Fetch())
{
$obBucket = new CCloudStorageBucket(intval($arBucket["BUCKET_ID"]));
if ($obBucket->Init())
{
$arUploadInfo = unserialize($arBucket["NEXT_STEP"], ['allowed_classes' => false]);
$service = $obBucket->GetService();
$service->CancelMultipartUpload($obBucket->GetBucketArray(), $arUploadInfo);
}
$DB->Query("DELETE FROM b_clouds_file_upload WHERE ID = '".$DB->ForSql($arBucket["ID"])."'");
}
}
}