| Server IP : 37.220.80.31 / Your IP : 18.119.133.241 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 : |
<?
class CCloudStorageService_RackSpaceCloudFiles extends CCloudStorageService_OpenStackStorage
{
function GetObject()
{
return new CCloudStorageService_RackSpaceCloudFiles();
}
function GetID()
{
return "rackspace_storage";
}
function GetName()
{
return "Rackspace Cloud Files";
}
function _GetToken($host, $user, $key)
{
$result = false;
$cache_id = "v0|".$host."|".$user."|".$key;
$obCache = new CPHPCache;
if($obCache->InitCache(3600, $cache_id, "/"))
{
$result = $obCache->GetVars();
}
else
{
$this->status = 0;
$this->host = $host;
$this->verb = "GET";
$this->url = "http://".$host."/v1.0";
$this->headers = array();
$this->errno = 0;
$this->errstr = '';
$this->result = '';
$logRequest = false;
if (defined("BX_CLOUDS_TRACE") && $verb !== "GET" && $verb !== "HEAD")
{
$stime = microtime(1);
$logRequest = array(
"request_id" => md5((string)mt_rand()),
"portal" => (CModule::IncludeModule('replica')? getNameByDomain(): $_SERVER["HTTP_HOST"]),
"verb" => $this->verb,
"url" => $this->url,
);
AddMessage2Log(json_encode($logRequest), 'clouds', 20);
}
$request = new Bitrix\Main\Web\HttpClient(array(
"redirect" => false,
"streamTimeout" => $this->streamTimeout,
));
$request->setHeader("X-Auth-User", $user);
$request->setHeader("X-Auth-Key", $key);
$request->query($this->verb, $this->url);
$this->status = $request->getStatus();
foreach($request->getHeaders() as $key => $value)
{
$this->headers[$key] = $value;
}
$this->errstr = implode("\n", $request->getError());
$this->errno = $this->errstr? 255: 0;
$this->result = $request->getResult();
if ($logRequest)
{
$logRequest["status"] = $this->status;
$logRequest["time"] = round(microtime(true) - $stime, 6);
$logRequest["headers"] = $this->headers;
AddMessage2Log(json_encode($logRequest), 'clouds', 0);
}
if (
$this->status == 301
&& $this->headers["Location"] <> ''
&& preg_match("#^https://(.*?)(/.*)\$#", $this->headers["Location"], $arNewLocation)
)
{
$APPLICATION->ResetException();
$this->status = 0;
$this->host = $arNewLocation[1];
$this->verb = "GET";
$this->url = "https://".$arNewLocation[1]."/v1.0";
$this->headers = array();
$this->errno = 0;
$this->errstr = '';
$this->result = '';
$logRequest = false;
if (defined("BX_CLOUDS_TRACE") && $verb !== "GET" && $verb !== "HEAD")
{
$stime = microtime(1);
$logRequest = array(
"request_id" => md5((string)mt_rand()),
"portal" => (CModule::IncludeModule('replica')? getNameByDomain(): $_SERVER["HTTP_HOST"]),
"verb" => $this->verb,
"url" => $this->url,
);
AddMessage2Log(json_encode($logRequest), 'clouds', 20);
}
$request = new Bitrix\Main\Web\HttpClient(array(
"redirect" => false,
"streamTimeout" => $this->streamTimeout,
));
$request->setHeader("X-Auth-User", $user);
$request->setHeader("X-Auth-Key", $key);
$request->query($this->verb, $this->url);
$this->status = $request->getStatus();
foreach($request->getHeaders() as $key => $value)
{
$this->headers[$key] = $value;
}
$this->errstr = implode("\n", $request->getError());
$this->errno = $this->errstr? 255: 0;
$this->result = $request->getResult();
if ($logRequest)
{
$logRequest["status"] = $this->status;
$logRequest["time"] = round(microtime(true) - $stime, 6);
$logRequest["headers"] = $this->headers;
AddMessage2Log(json_encode($logRequest), 'clouds', 0);
}
if($this->status == 204)
{
if(preg_match("#^https://(.*?)(/.*)\$#", $this->headers["X-Storage-Url"], $arStorage))
{
$result = $this->headers;
$result["X-Storage-Host"] = $arStorage[1];
$result["X-Storage-Port"] = 443;
$result["X-Storage-Urn"] = $arStorage[2];
$result["X-Storage-Proto"] = "ssl://";
}
}
}
}
if(is_array($result))
{
if($obCache->StartDataCache())
$obCache->EndDataCache($result);
}
return $result;
}
function SendCDNRequest($settings, $verb, $bucket, $file_name='', $params='', $content=false, $additional_headers=array())
{
$arToken = $this->_GetToken($settings["HOST"], $settings["USER"], $settings["KEY"]);
if(!$arToken)
return false;
if(isset($arToken["X-CDN-Management-Url"]))
{
if(preg_match("#^http://(.*?)(|:\d+)(/.*)\$#", $arToken["X-CDN-Management-Url"], $arCDN))
{
$Host = $arCDN[1];
$Port = $arCDN[2];
$Urn = $arCDN[3];
$Proto = "http://";
}
elseif(preg_match("#^https://(.*?)(|:\d+)(/.*)\$#", $arToken["X-CDN-Management-Url"], $arCDN))
{
$Host = $arCDN[1];
$Port = $arCDN[2];
$Urn = $arCDN[3];
$Proto = "https://";
}
else
{
return false;
}
}
else
{
return false;
}
$this->status = 0;
$this->host = $Host;
$this->verb = $verb;
$this->url = $Proto.$Host.($Port? $Port: '').$Urn.CCloudUtil::URLEncode("/".$bucket.$file_name.$params, "UTF-8");
$this->headers = array();
$this->errno = 0;
$this->errstr = '';
$this->result = '';
$logRequest = false;
if (defined("BX_CLOUDS_TRACE") && $verb !== "GET" && $verb !== "HEAD")
{
$stime = microtime(1);
$logRequest = array(
"request_id" => md5((string)mt_rand()),
"portal" => (CModule::IncludeModule('replica')? getNameByDomain(): $_SERVER["HTTP_HOST"]),
"verb" => $this->verb,
"url" => $this->url,
);
AddMessage2Log(json_encode($logRequest), 'clouds', 20);
}
$request = new Bitrix\Main\Web\HttpClient(array(
"redirect" => false,
"streamTimeout" => $this->streamTimeout,
));
$request->setHeader("X-Auth-Token", $arToken["X-Auth-Token"]);
foreach($additional_headers as $key => $value)
{
$request->setHeader($key, $value);
}
$request->query($this->verb, $this->url);
$this->status = $request->getStatus();
foreach($request->getHeaders() as $key => $value)
{
$this->headers[$key] = $value;
}
$this->errstr = implode("\n", $request->getError());
$this->errno = $this->errstr? 255: 0;
$this->result = $request->getResult();
if ($logRequest)
{
$logRequest["status"] = $this->status;
$logRequest["time"] = round(microtime(true) - $stime, 6);
$logRequest["headers"] = $this->headers;
AddMessage2Log(json_encode($logRequest), 'clouds', 0);
}
return $request;
}
function CreateBucket($arBucket)
{
global $APPLICATION;
$obRequest = $this->SendRequest(
$arBucket["SETTINGS"],
"PUT",
$arBucket["BUCKET"]
);
//CDN Enable
if($this->status == 201)
{
$this->SendCDNRequest(
$arBucket["SETTINGS"],
"PUT",
$arBucket["BUCKET"],
'', //filename
'', //params
false, //content
array(
"X-CDN-Enabled" => "True",
)
);
}
return ($this->status == 201)/*Created*/ || ($this->status == 202) /*Accepted*/;
}
function GetFileSRC($arBucket, $arFile)
{
global $APPLICATION;
if ($arBucket["SETTINGS"]["FORCE_HTTP"] === "Y")
$proto = "http";
else
$proto = ($APPLICATION->IsHTTPS()? "https": "http");
if($arBucket["CNAME"])
{
$host = $proto."://".$arBucket["CNAME"];
}
else
{
$result = false;
$cache_id = md5(serialize($arBucket));
$obCache = new CPHPCache;
if($obCache->InitCache(3600, $cache_id, "/"))
{
$result = $obCache->GetVars();
}
else
{
$this->SendCDNRequest(
$arBucket["SETTINGS"],
"HEAD",
$arBucket["BUCKET"]
);
if($this->status == 204)
{
$result = array();
foreach($this->headers as $key => $value)
$result[mb_strtolower($key)] = $value;
}
}
if($obCache->StartDataCache())
$obCache->EndDataCache($result);
if(is_array($result))
$host = $result["x-cdn-uri"];
else
return "/404.php";
}
if(is_array($arFile))
$URI = ltrim($arFile["SUBDIR"]."/".$arFile["FILE_NAME"], "/");
else
$URI = ltrim($arFile, "/");
if($arBucket["PREFIX"])
{
if(mb_substr($URI, 0, mb_strlen($arBucket["PREFIX"]) + 1) !== $arBucket["PREFIX"]."/")
$URI = $arBucket["PREFIX"]."/".$URI;
}
return $host."/".CCloudUtil::URLEncode($URI, "UTF-8");
}
}
?>