storage_service_rackspace.php

См. документацию.

<?php
class CCloudStorageService_RackSpaceCloudFiles extends CCloudStorageService_OpenStackStorage
{
    public function GetObject()
    {
        return new CCloudStorageService_RackSpaceCloudFiles();
    }
 
    public function GetID()
    {
        return 'rackspace_storage';
    }
 
    public function GetName()
    {
        return 'Rackspace Cloud Files';
    }
 
    public function _GetToken($host, $user, $key)
    {
        global $APPLICATION;
 
        $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 = [];
            $this->errno = 0;
            $this->errstr = '';
            $this->result = '';
 
            $request = new Bitrix\Main\Web\HttpClient([
                '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 $headerKey => $headerValue)
            {
                $this->headers[$headerKey] = is_array($headerValue) ? $headerValue[0] : $headerValue;
            }
            $this->errstr = implode("\n", $request->getError());
            $this->errno = $this->errstr ? 255 : 0;
            $this->result = $request->getResult();
 
            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 = [];
                $this->errno = 0;
                $this->errstr = '';
                $this->result = '';
 
                $request = new Bitrix\Main\Web\HttpClient([
                    '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 $headerKey => $headerValue)
                {
                    $this->headers[$headerKey] = is_array($headerValue) ? $headerValue[0] : $headerValue;
                }
                $this->errstr = implode("\n", $request->getError());
                $this->errno = $this->errstr ? 255 : 0;
                $this->result = $request->getResult();
 
                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;
    }
 
    public function SendCDNRequest($settings, $verb, $bucket, $file_name='', $params='', $content=false, $additional_headers=[])
    {
        $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 ?: '') . $Urn . CCloudUtil::URLEncode('/' . $bucket . $file_name . $params, 'UTF-8');
        $this->headers = [];
        $this->errno = 0;
        $this->errstr = '';
        $this->result = '';
 
        $stime = 0;
        $logRequest = false;
        if (defined('BX_CLOUDS_TRACE') && $verb !== 'GET' && $verb !== 'HEAD')
        {
            $stime = microtime(1);
            $logRequest = [
                'request_id' => md5((string)mt_rand()),
                'portal' => $_SERVER['HTTP_HOST'],
                'verb' => $this->verb,
                'url' => $this->url,
            ];
            AddMessage2Log(json_encode($logRequest), 'clouds', 20);
        }
 
        $request = new Bitrix\Main\Web\HttpClient([
            '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] = is_array($value) ? $value[0] : $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;
    }
 
    public function CreateBucket($arBucket)
    {
        $this->SendRequest(
            $arBucket['SETTINGS'],
            'PUT',
            $arBucket['BUCKET']
        );
 
        //CDN Enable
        if ($this->status == 201)
        {
            $this->SendCDNRequest(
                $arBucket['SETTINGS'],
                'PUT',
                $arBucket['BUCKET'],
                '', //filename
                '', //params
                false, //content
                [
                    'X-CDN-Enabled' => 'True',
                ]
            );
        }
 
        return ($this->status == 201)/*Created*/ || ($this->status == 202) /*Accepted*/;
    }

    public function GetFileSRC($arBucket, $arFile, $encoded = true)
    {
        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 = [];
                    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;
            }
        }
 
        if ($encoded)
        {
            return $host . '/' . CCloudUtil::URLEncode($URI, 'UTF-8', true);
        }
        else
        {
            return $host . '/' . $URI;
        }
    }
}