storage_service_amazon.php

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

<?php
IncludeModuleLangFile(__FILE__);
 
class CCloudStorageService_AmazonS3 extends CCloudStorageService_S3
{
    public function GetObject()
    {
        return new CCloudStorageService_AmazonS3();
    }

    public function GetID()
    {
        return 'amazon_s3';
    }

    public function GetName()
    {
        return 'Amazon Simple Storage Service';
    }

    public function GetLocationList()
    {
        // http://docs.aws.amazon.com/general/latest/gr/rande.html#s3_region
        return [
            '' => 'US Standard',
            'us-east-2' => 'US East (Ohio)',
            'us-east-1' => 'US East (N. Virginia)',
            'us-west-1' => 'US West (N. California)',
            'us-west-2' => 'US West (Oregon)',
            'af-south-1' => 'Africa (Cape Town)',
            'ap-east-1' => 'Asia Pacific (Hong Kong)',
            'ap-south-2' => 'Asia Pacific (Hyderabad)',
            'ap-southeast-3' => 'Asia Pacific (Jakarta)',
            'ap-southeast-4' => 'Asia Pacific (Melbourne)',
            'ap-south-1' => 'Asia Pacific (Mumbai)',
            'ap-northeast-3' => 'Asia Pacific (Osaka-Local)',
            'ap-northeast-2' => 'Asia Pacific (Seoul)',
            'ap-southeast-1' => 'Asia Pacific (Singapore)',
            'ap-southeast-2' => 'Asia Pacific (Sydney)',
            'ap-northeast-1' => 'Asia Pacific (Tokyo)',
            'ca-central-1' => 'Canada (Central)',
            'ca-west-1' => 'Canada West (Calgary)',
            'eu-central-1' => 'Europe (Frankfurt)',
            'eu-west-1' => 'Europe (Ireland)',
            'eu-west-2' => 'Europe (London)',
            'eu-south-1' => 'Europe (Milan)',
            'eu-west-3' => 'Europe (Paris)',
            'eu-south-2' => 'Europe (Spain)',
            'eu-north-1' => 'Europe (Stockholm)',
            'eu-central-2' => 'Europe (Zurich)',
            'il-central-1' => 'Israel (Tel Aviv)',
            'me-south-1' => 'Middle East (Bahrain)',
            'me-central-1' => 'Middle East (UAE)',
            'sa-east-1' => 'South America (Sao Paulo)',
            'us-gov-east-1' => 'AWS GovCloud (US-East)',
            'us-gov-west-1' => 'AWS GovCloud (US-West)',
        ];
    }

    public function GetAPList()
    {
        // https://docs.aws.amazon.com/general/latest/gr/s3.html
        return [
            '' => 's3.amazonaws.com',
            'us-east-2' => 's3.us-east-2.amazonaws.com',
            'us-east-1' => 's3.us-east-1.amazonaws.com',
            'us-west-1' => 's3.us-west-1.amazonaws.com',
            'us-west-2' => 's3.us-west-2.amazonaws.com',
            'af-south-1' => 's3.af-south-1.amazonaws.com',
            'ap-east-1' => 's3.ap-east-1.amazonaws.com',
            'ap-south-2' => 's3.ap-south-2.amazonaws.com',
            'ap-southeast-3' => 's3.ap-southeast-3.amazonaws.com',
            'ap-southeast-4' => 's3.ap-southeast-4.amazonaws.com',
            'ap-south-1' => 's3.ap-south-1.amazonaws.com',
            'ap-northeast-3' => 's3.ap-northeast-3.amazonaws.com',
            'ap-northeast-2' => 's3.ap-northeast-2.amazonaws.com',
            'ap-southeast-1' => 's3.ap-southeast-1.amazonaws.com',
            'ap-southeast-2' => 's3.ap-southeast-2.amazonaws.com',
            'ap-northeast-1' => 's3.ap-northeast-1.amazonaws.com',
            'ca-central-1' => 's3.ca-central-1.amazonaws.com',
            'ca-west-1' => 's3.ca-west-1.amazonaws.com',
            'eu-central-1' => 's3.eu-central-1.amazonaws.com',
            'eu-west-1' => 's3.eu-west-1.amazonaws.com',
            'eu-west-2' => 's3.eu-west-2.amazonaws.com',
            'eu-south-1' => 's3.eu-south-1.amazonaws.com',
            'eu-west-3' => 's3.eu-west-3.amazonaws.com',
            'eu-south-2' => 's3.eu-south-2.amazonaws.com',
            'eu-north-1' => 's3.eu-north-1.amazonaws.com',
            'eu-central-2' => 's3.eu-central-2.amazonaws.com',
            'il-central-1' => 's3.il-central-1.amazonaws.com',
            'me-south-1' => 's3.me-south-1.amazonaws.com',
            'me-central-1' => 's3.me-central-1.amazonaws.com',
            'sa-east-1' => 's3.sa-east-1.amazonaws.com',
            'us-gov-east-1' => 's3.us-gov-east-1.amazonaws.com',
            'us-gov-west-1' => 's3.us-gov-west-1.amazonaws.com',
        ];
    }

    public function GetSettingsHTML($arBucket, $bServiceSet, $cur_SERVICE_ID, $bVarsFromForm)
    {
        if ($bVarsFromForm)
        {
            $arSettings = $_POST['SETTINGS'][$this->GetID()];
        }
        else
        {
            $arSettings = unserialize($arBucket['SETTINGS'], ['allowed_classes' => false]);
        }
 
        if (!is_array($arSettings))
        {
            $arSettings = ['ACCESS_KEY' => '', 'SECRET_KEY' => ''];
        }
 
        $htmlID = htmlspecialcharsbx($this->GetID());
        $show = (($cur_SERVICE_ID === $this->GetID()) || !$bServiceSet) ? '' : 'none';
        $useHttps = $arSettings['USE_HTTPS'] ?? 'N';
 
        $result = '
        <tr id="SETTINGS_0_' . $htmlID . '" style="display:' . $show . '" class="settings-tr adm-detail-required-field">
            <td>' . GetMessage('CLO_STORAGE_AMAZON_EDIT_ACCESS_KEY') . ':</td>
            <td><input type="hidden" name="SETTINGS[' . $htmlID . '][ACCESS_KEY]" id="' . $htmlID . 'ACCESS_KEY" value="' . htmlspecialcharsbx($arSettings['ACCESS_KEY']) . '"><input type="text" size="55" name="' . $htmlID . 'INP_ACCESS_KEY" id="' . $htmlID . 'INP_ACCESS_KEY" value="' . htmlspecialcharsbx($arSettings['ACCESS_KEY']) . '" ' . ($arBucket['READ_ONLY'] === 'Y' ? '"disabled"' : '') . ' onchange="BX(\'' . $htmlID . 'ACCESS_KEY\').value = this.value"></td>
        </tr>
        <tr id="SETTINGS_1_' . $htmlID . '" style="display:' . $show . '" class="settings-tr adm-detail-required-field">
            <td>' . GetMessage('CLO_STORAGE_AMAZON_EDIT_SECRET_KEY') . ':</td>
            <td><input type="hidden" name="SETTINGS[' . $htmlID . '][SECRET_KEY]" id="' . $htmlID . 'SECRET_KEY" value="' . htmlspecialcharsbx($arSettings['SECRET_KEY']) . '"><input type="text" size="55" name="' . $htmlID . 'INP_SECRET_KEY" id="' . $htmlID . 'INP_SECRET_KEY" value="' . htmlspecialcharsbx($arSettings['SECRET_KEY']) . '" autocomplete="off" ' . ($arBucket['READ_ONLY'] === 'Y' ? '"disabled"' : '') . ' onchange="BX(\'' . $htmlID . 'SECRET_KEY\').value = this.value">' . (
                array_key_exists('SESSION_TOKEN', $arSettings) ?
                '<input type="hidden" name="SETTINGS[' . $htmlID . '][SESSION_TOKEN]" id="' . $htmlID . 'SESSION_TOKEN" value="' . htmlspecialcharsbx($arSettings['SESSION_TOKEN']) . '">' :
                ''
            ) . '</td>
        </tr>
        <tr id="SETTINGS_3_' . $htmlID . '" style="display:' . $show . '" class="settings-tr">
            <td nowrap>' . GetMessage('CLO_STORAGE_AMAZON_EDIT_USE_HTTPS') . ':</td>
            <td><input type="hidden" name="SETTINGS[' . $htmlID . '][USE_HTTPS]" id="' . $htmlID . 'KEY" value="N"><input type="checkbox" name="SETTINGS[' . $htmlID . '][USE_HTTPS]" id="' . $htmlID . 'USE_HTTPS" value="Y" ' . ($useHttps == 'Y' ? 'checked="checked"' : '') . '></td>
        </tr><tr id="SETTINGS_2_' . $htmlID . '" style="display:' . $show . '" class="settings-tr">
            <td>&nbsp;</td>
            <td>' . BeginNote() . GetMessage('CLO_STORAGE_AMAZON_EDIT_HELP') . EndNote() . '</td>
        </tr>
        ';
 
        return $result;
    }

    public function CheckSettings($arBucket, &$arSettings)
    {
        global $APPLICATION;
        $aMsg = /*.(array[int][string]string).*/[];
 
        $result = [
            'ACCESS_KEY' => is_array($arSettings) ? trim($arSettings['ACCESS_KEY']) : '',
            'SECRET_KEY' => is_array($arSettings) ? trim($arSettings['SECRET_KEY']) : '',
        ];
        if (is_array($arSettings) && array_key_exists('SESSION_TOKEN', $arSettings))
        {
            $result['SESSION_TOKEN'] = trim($arSettings['SESSION_TOKEN']);
        }
 
        if ($arBucket['READ_ONLY'] !== 'Y' && $result['ACCESS_KEY'] === '')
        {
            $aMsg[] = [
                'id' => $this->GetID() . 'INP_ACCESS_KEY',
                'text' => GetMessage('CLO_STORAGE_AMAZON_EMPTY_ACCESS_KEY'),
            ];
        }
 
        if ($arBucket['READ_ONLY'] !== 'Y' && $result['SECRET_KEY'] === '')
        {
            $aMsg[] = [
                'id' => $this->GetID() . 'INP_SECRET_KEY',
                'text' => GetMessage('CLO_STORAGE_AMAZON_EMPTY_SECRET_KEY'),
            ];
        }
 
        if (!empty($aMsg))
        {
            $e = new CAdminException($aMsg);
            $APPLICATION->ThrowException($e);
            return false;
        }
        else
        {
            $arSettings = $result;
        }
 
        return true;
    }

    protected function GetRequestHost($bucket, $arSettings)
    {
        if (
            $this->new_end_point != ''
            && preg_match('#^(http|https)://' . preg_quote($bucket, '#') . '(.+?)/#', $this->new_end_point, $match) > 0
        )
        {
            return $bucket . $match[2];
        }
        elseif ($this->location)
        {
            if ($bucket !== '')
            {
                return $bucket . '.s3.' . $this->location . '.amazonaws.com';
            }
            else
            {
                return 's3.' . $this->location . '.amazonaws.com';
            }
        }
        else
        {
            if ($bucket !== '')
            {
                return $bucket . '.s3.amazonaws.com';
            }
            else
            {
                return 's3.amazonaws.com';
            }
        }
    }

    public function GetFileSRC($arBucket, $arFile, $encoded = true)
    {
        /* @var \Bitrix\Main\HttpRequest $request */
        $request = \Bitrix\Main\Context::getCurrent()->getRequest();
        $proto = $request->isHttps() ? 'https' : 'http';
 
        static $aps = null;
        if (!$aps)
        {
            $aps = $this->GetAPList();
        }
 
        if ($arBucket['CNAME'] != '')
        {
            $host = $arBucket['CNAME'];
            $pref = '';
        }
        elseif ($proto === 'https' && strpos($arBucket['BUCKET'], '.') !== false)
        {
            if (isset($aps[$arBucket['LOCATION']]))
            {
                $host = $aps[$arBucket['LOCATION']];
            }
            else
            {
                $host = $aps[''];
            }
 
            $pref = $arBucket['BUCKET'];
        }
        else
        {
            if (isset($aps[$arBucket['LOCATION']]))
            {
                $host = $arBucket['BUCKET'] . '.' . $aps[$arBucket['LOCATION']];
            }
            else
            {
                $host = $aps[''];
            }
 
            $pref = '';
        }
 
        if (is_array($arFile))
        {
            $URI = ltrim($arFile['SUBDIR'] . '/' . $arFile['FILE_NAME'], '/');
        }
        else
        {
            $URI = ltrim($arFile, '/');
        }
 
        if ($arBucket['PREFIX'] != '')
        {
            if (substr($URI, 0, strlen($arBucket['PREFIX']) + 1) !== $arBucket['PREFIX'] . '/')
            {
                $URI = $arBucket['PREFIX'] . '/' . $URI;
            }
        }
 
        if ($pref !== '')
        {
            $URI = $pref . '/' . $URI;
        }
 
        if ($encoded)
        {
            return $proto . '://' . $host . '/' . CCloudUtil::URLEncode($URI, 'UTF-8', true);
        }
        else
        {
            return $proto . '://' . $host . '/' . $URI;
        }
    }

    public function CreateBucket($arBucket)
    {
        global $APPLICATION;
 
        $arFiles = $this->ListFiles($arBucket, '/', false, 1);
        if (is_array($arFiles))
        {
            return true;
        }
 
        // The bucket already exists and user has specified wrong location
        if (
            $this->status == 301
            && $arBucket['LOCATION'] != ''
            && $this->GetLastRequestHeader('x-amz-bucket-region') !== ''
            && $this->GetLastRequestHeader('x-amz-bucket-region') !== $arBucket['LOCATION']
        )
        {
            return false;
        }
 
        if ($arBucket['LOCATION'] != '' && $arBucket['LOCATION'] !== 'us-east-1')
        {
            $content =
                '<CreateBucketConfiguration xmlns="http://s3.amazonaws.com/doc/2006-03-01/">'
                . '<LocationConstraint>' . $arBucket['LOCATION'] . '</LocationConstraint>'
                . '</CreateBucketConfiguration>';
        }
        else
        {
            $content = '';
        }
 
        $this->SetLocation($arBucket['LOCATION']);
        $response = $this->SendRequest(
            $arBucket['SETTINGS'],
            'PUT',
            $arBucket['BUCKET'],
            '/',
            '',
            $content,
            ['x-amz-object-ownership' => 'ObjectWriter']
        );
 
        if ($this->status == 409/*Already exists*/)
        {
            $APPLICATION->ResetException();
            return true;
        }
        elseif ($this->status == 200)
        {
            $response = $this->SendRequest(
                $arBucket['SETTINGS'],
                'DELETE',
                $arBucket['BUCKET'],
                '/',
                '?publicAccessBlock='
            );
            if ($this->status == 204)
            {
                return true;
            }
 
            if (defined('BX_CLOUDS_ERROR_DEBUG'))
            {
                AddMessage2Log($this);
            }
            return false;
        }
        elseif (is_array($response))
        {
            return true;
        }
        else
        {
            if (defined('BX_CLOUDS_ERROR_DEBUG'))
            {
                AddMessage2Log($this);
            }
            return false;
        }
    }
}