storage_service.php

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

<?php
IncludeModuleLangFile(__FILE__);
 
abstract class CCloudStorageService
{
    protected $verb = '';
    protected $host = '';
    protected $url = '';
 
    protected $errno = 0;
    protected $errstr = '';
 
    protected $status = 0;
    protected $headers = /*.(array[string]string).*/[];
    protected $result = '';
 
    public $tokenHasExpired = false;
    protected $streamTimeout = 0;

    abstract public function GetObject();

    abstract public function GetID();

    abstract public function GetName();

    abstract public function GetLocationList();

    abstract public function GetSettingsHTML($arBucket, $bServiceSet, $cur_SERVICE_ID, $bVarsFromForm);

    abstract public function CheckSettings($arBucket, &$arSettings);

    abstract public function CreateBucket($arBucket);

    abstract public function DeleteBucket($arBucket);

    abstract public function IsEmptyBucket($arBucket);

    public function GetFileSRC($arBucket, $arFile, $encoded = true)
    {
        return '';
    }

    abstract public function FileExists($arBucket, $filePath);

    abstract public function FileCopy($arBucket, $arFile, $filePath);

    public function DownloadToFile($arBucket, $arFile, $filePath)
    {
        $url = $this->GetFileSRC($arBucket, $arFile);
        $request = new Bitrix\Main\Web\HttpClient([
            'streamTimeout' => $this->streamTimeout,
        ]);
        $result = $request->download($url, $filePath);
        if ($request->getStatus() == 404 || $request->getStatus() == 403)
        {
            return false;
        }
        return $result;
    }

    abstract public function DeleteFile($arBucket, $filePath);

    abstract public function SaveFile($arBucket, $filePath, $arFile);

    abstract public function ListFiles($arBucket, $filePath, $bRecursive = false);

    public function GetFileInfo($arBucket, $filePath)
    {
        return null; // not implemented
    }

    public function FileRename($arBucket, $sourcePath, $targetPath, $overwrite = true)
    {
        if ($this->FileExists($arBucket, $sourcePath))
        {
            $contentType = $this->headers['Content-Type'];
        }
        else
        {
            return false;
        }
 
        if ($this->FileExists($arBucket, $targetPath))
        {
            if (!$overwrite)
            {
                return false;
            }
 
            if (!$this->DeleteFile($arBucket, $targetPath))
            {
                return false;
            }
        }
 
        $arFile = [
            'SUBDIR' => '',
            'FILE_NAME' => ltrim($sourcePath, '/'),
            'CONTENT_TYPE' => $contentType,
        ];
 
        if (!$this->FileCopy($arBucket, $arFile, $targetPath))
        {
            return false;
        }
 
        if (!$this->DeleteFile($arBucket, $sourcePath))
        {
            return false;
        }
 
        return true;
    }

    abstract public function InitiateMultipartUpload($arBucket, &$NS, $filePath, $fileSize, $ContentType);

    abstract public function GetMinUploadPartSize();

    abstract public function UploadPart($arBucket, &$NS, $data);

    public function UploadPartNo($arBucket, &$NS, $data, $part_no)
    {
        return false;
    }

    abstract public function CompleteMultipartUpload($arBucket, &$NS);

    public function CancelMultipartUpload($arBucket, &$NS)
    {
    }

    public function SetHeader($name, $value)
    {
    }

    public function UnsetHeader($name)
    {
    }

    public function SetPublic($state = true)
    {
    }

    public function getHeaders()
    {
        return $this->headers;
    }

    public function GetLastRequestStatus()
    {
        return $this->status;
    }

    public function GetLastRequestHeader($headerName)
    {
        $loweredName = mb_strtolower($headerName);
        foreach ($this->headers as $name => $value)
        {
            if (mb_strtolower($name) === $loweredName)
            {
                return $value;
            }
        }
        return '';
    }

    public static function GetObjectInstance()
    {
        return new static();
    }
 
    public function formatError()
    {
        if ($this->errno > 0)
        {
            return GetMessage('CLO_STORAGE_HTTP_ERROR', [
                '#verb#' => $this->verb,
                '#url#' => $this->url,
                '#errno#' => $this->errno,
                '#errstr#' => $this->errstr,
            ]);
        }
        return '';
    }
}