upload/sdk/Sina/Storage.php

<?php

namespace sinacloud\sae;

/**
 * 新浪云 Storage PHP 客户端
 *
 * @copyright Copyright (c) 2015, SINA, All rights reserved.
 *
 * ```php
 * <?php
 * use sinacloud\sae\Storage as Storage;
 *
 * **类初始化**
 *
 * // 方法一：在新浪云运行环境中时可以不传认证信息，默认会从应用的环境变量中取
 * $s = new Storage();
 *
 * // 方法二：如果不在新浪云运行环境或者要连非本应用的 storage，需要传入所连应用的"应用名：应用 AccessKey"和"应用 SecretKey"
 * $s = new Storage("$AppName:$AccessKey", $SecretKey);
 *
 * **Bucket 操作**
 *
 * // 创建一个 Bucket test
 * $s->putBucket("test");
 *
 * // 获取 Bucket 列表
 * $s->listBuckets();
 *
 * // 获取 Bucket 列表及 Bucket 中 Object 数量和 Bucket 的大小
 * $s->listBuckets(true);
 *
 * // 获取 test 这个 Bucket 中的 Object 对象列表，默认返回前 1000 个，如果需要返回大于 1000 个 Object 的列表，可以通过 limit 参数来指定。
 * $s->getBucket("test");
 *
 * // 获取 test 这个 Bucket 中所有以 a/ 为前缀的 Objects 列表
 * $s->getBucket("test", 'a/');
 *
 * // 获取 test 这个 Bucket 中所有以 a/ 为前缀的 Objects 列表，只显示 a/N 这个 Object 之后的列表（不包含 a/N 这个 Object）。
 * $s->getBucket("test", 'a/', 'a/N');
 *
 * // Storage 也可以当成一个伪文件系统来使用，比如获取 a/ 目录下的 Object（不显示其下的子目录的具体 Object 名称，只显示目录名）
 * $s->getBucket("test", 'a/', null, 10000, '/');
 *
 * // 删除一个空的 Bucket test
 * $s->deleteBucket("test");
 *
 * **Object 上传操作**
 *
 * // 把 $_FILES 全局变量中的缓存文件上传到 test 这个 Bucket，设置此 Object 名为 1.txt
 * $s->putObjectFile($_FILES['uploaded']['tmp_name'], "test", "1.txt");
 *
 * // 把 $_FILES 全局变量中的缓存文件上传到 test 这个 Bucket，设置此 Object 名为 sae/1.txt
 * $s->putObjectFile($_FILES['uploaded']['tmp_name'], "test", "sae/1.txt");
 *
 * // 上传一个字符串到 test 这个 Bucket 中，设置此 Object 名为 string.txt，并且设置其 Content-type
 * $s->putObject("This is string.", "test", "string.txt", array(), array('Content-Type' => 'text/plain'));
 *
 * // 上传一个文件句柄（必须是 buffer 或者一个文件，文件会被自动 fclose 掉）到 test 这个 Bucket 中，设置此 Object 名为 file.txt
 * $s->putObject(Storage::inputResource(fopen($_FILES['uploaded']['tmp_name'], 'rb'), filesize($_FILES['uploaded']['tmp_name']), "test", "file.txt", Storage::ACL_PUBLIC_READ);
 *
 * **Object 下载操作**
 *
 * // 从 test 这个 Bucket 读取 Object 1.txt，输出为此次请求的详细信息，包括状态码和 1.txt 的内容等
 * var_dump($s->getObject("test", "1.txt"));
 *
 * // 从 test 这个 Bucket 读取 Object 1.txt，把 1.txt 的内容保存在 SAE_TMP_PATH 变量指定的 TmpFS 中，savefile.txt 为保存的文件名；SAE_TMP_PATH 路径具有写权限，用户可以往这个目录下写文件，但文件的生存周期等同于 PHP 请求，也就是当该 PHP 请求完成执行时，所有写入 SAE_TMP_PATH 的文件都会被销毁
 * $s->getObject("test", "1.txt", SAE_TMP_PATH."savefile.txt");
 *
 * // 从 test 这个 Bucket 读取 Object 1.txt，把 1.txt 的内容保存在打开的文件句柄中
 * $s->getObject("test", "1.txt", fopen(SAE_TMP_PATH."savefile.txt", 'wb'));
 *
 * **Object 删除操作**
 *
 * // 从 test 这个 Bucket 删除 Object 1.txt
 * $s->deleteObject("test", "1.txt");
 *
 * **Object 复制操作**
 *
 * // 把 test 这个 Bucket 的 Object 1.txt 内容复制到 newtest 这个 Bucket 的 Object 1.txt
 * $s->copyObject("test", "1.txt", "newtest", "1.txt");
 *
 * // 把 test 这个 Bucket 的 Object 1.txt 内容复制到 newtest 这个 Bucket 的 Object 1.txt，并设置 Object 的浏览器缓存过期时间为 10s 和 Content-Type 为 text/plain
 * $s->copyObject("test", "1.txt", "newtest", "1.txt", array('expires' => '10s'), array('Content-Type' => 'text/plain'));
 *
 * **生成一个外网能够访问的 url**
 *
 * // 为私有 Bucket test 中的 Object 1.txt 生成一个能够在外网用 GET 方法临时访问的 URL，次 URL 过期时间为 600s
 * $s->getTempUrl("test", "1.txt", "GET", 600);
 *
 * // 为 test 这个 Bucket 中的 Object 1.txt 生成一个能用 CDN 访问的 URL
 * $s->getCdnUrl("test", "1.txt");
 *
 * **调试模式**
 *
 * // 开启调试模式，出问题的时候方便定位问题，设置为 true 后遇到错误的时候会抛出异常而不是写一条 warning 信息到日志。
 * $s->setExceptions(true);
 * ?>
 * ```
 */

if (defined('SAE_APPNAME')) {
    define('DEFAULT_STORAGE_ENDPOINT', 'api.i.sinas3.com:81');
    define('DEFAULT_USE_SSL', false);
} else {
    define('DEFAULT_STORAGE_ENDPOINT', 'api.sinas3.com');
    define('DEFAULT_USE_SSL', true);
}

class Storage
{
    // ACL flags
    const ACL_PRIVATE = '';
    const ACL_PUBLIC_READ = '.r:*';

    private static $__accessKey = null;
    private static $__secretKey = null;
    private static $__account = null;

    /**
     * 默认使用的分隔符，getBucket() 等用到
     *
     * @var string
     * @access public
     * @static
     */
    public static $defDelimiter = null;

    public static $endpoint = DEFAULT_STORAGE_ENDPOINT;

    public static $proxy = null;

    /**
     * 使用 SSL 连接？
     *
     * @var bool
     * @access public
     * @static
     */
    public static $useSSL = DEFAULT_USE_SSL;

    /**
     * 是否验证 SSL 证书
     *
     * @var bool
     * @access public
     * @static
     */
    public static $useSSLValidation = false;

    /**
     * 使用的 SSL 版本
     *
     * @var const
     * @access public
     * @static
     */
    public static $useSSLVersion = 1;

    /**
     * 出现错误的时候是否使用 PHP Exception（默认使用 trigger_error 纪录错误）
     *
     * @var bool
     * @access public
     * @static
     */
    public static $useExceptions = false;

    /**
     * 构造函数
     *
     * @param string $accessKey 此处需要使用"应用名:Accesskey"
     * @param string $secretKey 应用 Secretkey
     * @param boolean $useSSL 是否使用 SSL
     * @param string $endpoint 新浪云 Storage 的 endpoint
     * @return void
     */
    public function __construct($accessKey = null, $secretKey = null,
            $useSSL = DEFAULT_USE_SSL, $endpoint = DEFAULT_STORAGE_ENDPOINT)
    {
        if ($accessKey !== null && $secretKey !== null) {
            self::setAuth($accessKey, $secretKey);
        } else if (defined('SAE_APPNAME')) {
            // We are in 新浪云运行环境
            self::setAuth(SAE_APPNAME.':'.SAE_ACCESSKEY, SAE_SECRETKEY);
        }
        self::$useSSL = $useSSL;
        self::$endpoint = $endpoint;
    }


    /**
     * 设置新浪云的 Storage 的 endpoint
     *
     * @param string $host 新浪云 Storage 的 hostname
     * @return void
     */
    public function setEndpoint($host)
    {
        self::$endpoint = $host;
    }


    /**
     * 设置访问的 Accesskey 和 Secretkey
     *
     * @param string $accessKey 此处需要使用"应用名：应用 Accesskey"
     * @param string $secretKey 应用 Secretkey
     * @return void
     */
    public static function setAuth($accessKey, $secretKey)
    {
        $e = explode(':', $accessKey);
        self::$__account = $e[0];
        self::$__accessKey = $e[1];
        self::$__secretKey = $secretKey;
    }


    public static function hasAuth() {
        return (self::$__accessKey !== null && self::$__secretKey !== null);
    }


    /**
     * 开启或者关闭 SSL
     *
     * @param boolean $enabled 是否启用 SSL
     * @param boolean $validate 是否验证 SSL 证书
     * @return void
     */
    public static function setSSL($enabled, $validate = true)
    {
        self::$useSSL = $enabled;
        self::$useSSLValidation = $validate;
    }


    /**
     * 设置代理信息
     *
     * @param string $host 代理的 hostname 和端口 (localhost:1234)
     * @param string $user 代理的 username
     * @param string $pass 代理的 password
     * @param constant $type CURL 代理类型
     * @return void
     */
    public static function setProxy($host, $user = null, $pass = null, $type = CURLPROXY_SOCKS5)
    {
        self::$proxy = array('host' => $host, 'type' => $type, 'user' => $user, 'pass' => $pass);
    }


    /**
     * 设置是否使用 PHP Exception，默认使用 trigger_error
     *
     * @param boolean $enabled Enable exceptions
     * @return void
     */
    public static function setExceptions($enabled = true)
    {
        self::$useExceptions = $enabled;
    }


    private static function __triggerError($message, $file, $line, $code = 0)
    {
        if (self::$useExceptions)
            throw new StorageException($message, $file, $line, $code);
        else
            trigger_error($message, E_USER_WARNING);
    }


    /**
     * 获取 bucket 列表
     *
     * @param boolean $detailed 设置为 true 时返回 bucket 的详细信息
     * @return array | false
     */
    public static function listBuckets($detailed = false)
    {
        $rest = new StorageRequest('GET', self::$__account, '', '', self::$endpoint);
        $rest->setParameter('format', 'json');
        $rest = $rest->getResponse();
        if ($rest->error === false && $rest->code !== 200)
            $rest->error = array('code' => $rest->code, 'message' => 'Unexpected HTTP status');
        if ($rest->error !== false)
        {
            self::__triggerError(sprintf("Storage::listBuckets(): [%s] %s", $rest->error['code'],
                $rest->error['message']), __FILE__, __LINE__);
            return false;
        }
        $buckets = json_decode($rest->body, True);
        if ($buckets === False) {
            self::__triggerError(sprintf("Storage::listBuckets(): invalid body: %s", $rest->body),
                __FILE__, __LINE__);
            return false;
        }

        if ($detailed) {
            return $buckets;
        }

        $results = array();
        foreach ($buckets as $b) $results[] = (string)$b['name'];
        return $results;
    }


    /**
     * 获取 bucket 中的 object 列表
     *
     * @param string $bucket Bucket 名称
     * @param string $prefix Object 名称的前缀
     * @param string $marker Marker （返回 marker 之后的 object 列表，不包含 marker）
     * @param string $limit 最大返回的 Object 数目
     * @param string $delimiter 分隔符
     * @return array | false
     */
    public static function getBucket($bucket, $prefix = null, $marker = null, $limit = 1000, $delimiter = null, $keyword = null)
    {
        $result = array();

        do {
            $rest = new StorageRequest('GET', self::$__account, $bucket, '', self::$endpoint);
            $rest->setParameter('format', 'json');
            if ($prefix !== null && $prefix !== '') $rest->setParameter('prefix', $prefix);
            if ($marker !== null && $marker !== '') $rest->setParameter('marker', $marker);
            if ($delimiter !== null && $delimiter !== '') $rest->setParameter('delimiter', $delimiter);
            if ($keyword !== null && $keyword !== '') $rest->setParameter('keyword', $keyword);
            else if (!empty(self::$defDelimiter)) $rest->setParameter('delimiter', self::$defDelimiter);
            if ($limit > 1000) {
                $max_keys = 1000;
            } else {
                $max_keys = $limit;
            }
            $rest->setParameter("limit", $max_keys);
            $limit -= 1000;
            $response = $rest->getResponse();
            if ($response->error === false && $response->code !== 200)
                $response->error = array('code' => $response->code, 'message' => 'Unexpected HTTP status');
            if ($response->error !== false)
            {
                self::__triggerError(sprintf("Storage::getBucket(): [%s] %s", $response->error['code'],
                    $response->error['message']), __FILE__, __LINE__);
                return false;
            }

            $objects = json_decode($response->body, True);
            if ($objects === False) {
                self::__triggerError(sprintf("Storage::getBucket(): invalid body: %s", $response->body),
                    __FILE__, __LINE__);
                return false;
            }

            if ($objects) {
                $result = array_merge($result, $objects);
                $marker = end($objects);
                $marker = $marker['name'];
            }
        } while ($objects && count($objects) == $max_keys && $limit > 0);

        return $result;
    }


    /**
     * 创建一个 Bucket
     *
     * @param string $bucket Bucket 名称
     * @param constant $acl Bucket 的 ACL
     * @param array $metaHeaders x-sws-container-meta-* header 数组
     * @return boolean
     */
    public static function putBucket($bucket, $acl = self::ACL_PRIVATE, $metaHeaders=array())
    {
        $rest = new StorageRequest('PUT', self::$__account, $bucket, '', self::$endpoint);
        if ($acl) {
            $rest->setSwsHeader('x-sws-container-read', $acl);
        }
        foreach ($metaHeaders as $k => $v) {
            $rest->setSwsHeader('x-sws-container-meta-'.$k, $v);
        }

        $rest = $rest->getResponse();

        if ($rest->error === false && ($rest->code !== 201 && $rest->code != 202 && $rest->code !== 204))
            $rest->error = array('code' => $rest->code, 'message' => 'Unexpected HTTP status');
        if ($rest->error !== false)
        {
            self::__triggerError(sprintf("Storage::putBucket({$bucket}, {$acl}): [%s] %s",
                $rest->error['code'], $rest->error['message']), __FILE__, __LINE__);
            return false;
        }
        return true;
    }

    /**
     * 获取一个 Bucket 的属性
     * @param string $bucket Bucket 名称
     * @param boolean $returnInfo 是否返回 Bucket 的信息
     * @return mixed
     */
    public static function getBucketInfo($bucket, $returnInfo=True) {
        $rest = new StorageRequest('HEAD', self::$__account, $bucket, '', self::$endpoint);
        $rest = $rest->getResponse();
        if ($rest->error === false && ($rest->code !== 204 && $rest->code !== 404))
            $rest->error = array('code' => $rest->code, 'message' => 'Unexpected HTTP status');
        if ($rest->error !== false)
        {
            self::__triggerError(sprintf("Storage::getBucketInfo({$bucket}): [%s] %s",
                $rest->error['code'], $rest->error['message']), __FILE__, __LINE__);
            return false;
        }
        return $rest->code !== 404 ? $returnInfo ? $rest->headers : true : false;
    }

    /**
     * 修改一个 Bucket 的属性
     *
     * @param string $bucket Bucket 名称
     * @param constant $acl Bucket 的 ACL，null 表示不变
     * @param array $metaHeaders x-sws-container-meta-* header 数组
     * @return boolean
     */
    public static function postBucket($bucket, $acl = null, $metaHeaders=array())
    {
        $rest = new StorageRequest('POST', self::$__account, $bucket, '', self::$endpoint);
        if ($acl) {
            $rest->setSwsHeader('x-sws-container-read', $acl);
        }
        foreach ($metaHeaders as $k => $v) {
            $rest->setSwsHeader('x-sws-container-meta-'.$k, $v);
        }

        $rest = $rest->getResponse();

        if ($rest->error === false && ($rest->code !== 201 && $rest->code !== 204))
            $rest->error = array('code' => $rest->code, 'message' => 'Unexpected HTTP status');
        if ($rest->error !== false)
        {
            self::__triggerError(sprintf("Storage::postBucket({$bucket}, {$acl}): [%s] %s",
                $rest->error['code'], $rest->error['message']), __FILE__, __LINE__);
            return false;
        }
        return true;
    }

    /**
     * 删除一个空的 Bucket
     *
     * @param string $bucket Bucket 名称
     * @return boolean
     */
    public static function deleteBucket($bucket)
    {
        $rest = new StorageRequest('DELETE', self::$__account, $bucket, '', self::$endpoint);
        $rest = $rest->getResponse();
        if ($rest->error === false && $rest->code !== 204)
            $rest->error = array('code' => $rest->code, 'message' => 'Unexpected HTTP status');
        if ($rest->error !== false)
        {
            self::__triggerError(sprintf("Storage::deleteBucket({$bucket}): [%s] %s",
                $rest->error['code'], $rest->error['message']), __FILE__, __LINE__);
            return false;
        }
        return true;
    }


    /**
     * 为本地文件路径创建一个可以用于 putObject() 上传的 array
     *
     * @param string $file 文件路径
     * @param mixed $md5sum Use MD5 hash (supply a string if you want to use your own)
     * @return array | false
     */
    public static function inputFile($file, $md5sum = false)
    {
        if (!file_exists($file) || !is_file($file) || !is_readable($file))
        {
            self::__triggerError('Storage::inputFile(): Unable to open input file: '.$file, __FILE__, __LINE__);
            return false;
        }
        clearstatcache(false, $file);
        return array('file' => $file, 'size' => filesize($file), 'md5sum' => $md5sum !== false ?
            (is_string($md5sum) ? $md5sum : base64_encode(md5_file($file, true))) : '');
    }


    /**
     * 为打开的文件句柄创建一个可以用于 putObject() 上传的 array
     *
     * @param string $resource Input resource to read from
     * @param integer $bufferSize Input byte size
     * @param string $md5sum MD5 hash to send (optional)
     * @return array | false
     */
    public static function inputResource(&$resource, $bufferSize = false, $md5sum = '')
    {
        if (!is_resource($resource) || (int)$bufferSize < 0)
        {
            self::__triggerError('Storage::inputResource(): Invalid resource or buffer size', __FILE__, __LINE__);
            return false;
        }

        // Try to figure out the bytesize
        if ($bufferSize === false)
        {
            if (fseek($resource, 0, SEEK_END) < 0 || ($bufferSize = ftell($resource)) === false)
            {
                self::__triggerError('Storage::inputResource(): Unable to obtain resource size', __FILE__, __LINE__);
                return false;
            }
            fseek($resource, 0);
        }

        $input = array('size' => $bufferSize, 'md5sum' => $md5sum);
        $input['fp'] =& $resource;
        return $input;
    }


    /**
     * 上传一个 object
     *
     * @param mixed $input Input data
     * @param string $bucket Bucket name
     * @param string $uri Object URI
     * @param array $metaHeaders x-sws-object-meta-* header 数组
     * @param array $requestHeaders Array of request headers or content type as a string
     * @return boolean
     */
    public static function putObject($input, $bucket, $uri, $metaHeaders = array(), $requestHeaders = array())
    {
        if ($input === false) return false;
        $rest = new StorageRequest('PUT', self::$__account, $bucket, $uri, self::$endpoint);

        if (!is_array($input)) $input = array(
            'data' => $input, 'size' => strlen($input),
            'md5sum' => base64_encode(md5($input, true))
        );

        // Data
        if (isset($input['fp']))
            $rest->fp =& $input['fp'];
        elseif (isset($input['file']))
            $rest->fp = @fopen($input['file'], 'rb');
        elseif (isset($input['data']))
            $rest->data = $input['data'];

        // Content-Length (required)
        if (isset($input['size']) && $input['size'] >= 0)
            $rest->size = $input['size'];
        else {
            if (isset($input['file'])) {
                clearstatcache(false, $input['file']);
                $rest->size = filesize($input['file']);
            }
            elseif (isset($input['data']))
                $rest->size = strlen($input['data']);
        }

        // Custom request headers (Content-Type, Content-Disposition, Content-Encoding)
        if (is_array($requestHeaders))
            foreach ($requestHeaders as $h => $v)
                strpos($h, 'x-') === 0 ? $rest->setSwsHeader($h, $v) : $rest->setHeader($h, $v);

        if (is_string($requestHeaders)) // Support for legacy contentType parameter
            $rest->setHeader('content-type', $requestHeaders);
        else if (!isset($requestHeaders['content-type']) && !isset($requestHeaders['Content-Type']))
            $rest->setHeader('content-type', self::__getMIMEType($uri));

        // We need to post with Content-Length and Content-Type, MD5 is optional
        if ($rest->size >= 0 && ($rest->fp !== false || $rest->data !== false))
        {
            if (isset($input['md5sum'])) $rest->setHeader('Content-MD5', $input['md5sum']);

            foreach ($metaHeaders as $h => $v) $rest->setSwsHeader('x-sws-object-meta-'.$h, $v);
            $rest->getResponse();
        } else
            $rest->response->error = array('code' => 0, 'message' => 'Missing input parameters');

        if ($rest->response->error === false && $rest->response->code !== 201)
            $rest->response->error = array('code' => $rest->response->code, 'message' => 'Unexpected HTTP status');
        if ($rest->response->error !== false)
        {
            self::__triggerError(sprintf("Storage::putObject(): [%s] %s",
                $rest->response->error['code'], $rest->response->error['message']), __FILE__, __LINE__);
            return false;
        }
        return true;
    }


    /**
     * Put an object from a file (legacy function)
     *
     * @param string $file Input file path
     * @param string $bucket Bucket name
     * @param string $uri Object URI
     * @param constant $acl ACL constant
     * @param array $metaHeaders Array of x-meta-* headers
     * @param string $contentType Content type
     * @return boolean
     */
    public static function putObjectFile($file, $bucket, $uri, $metaHeaders = array(), $contentType = null)
    {
        return self::putObject(self::inputFile($file), $bucket, $uri, $metaHeaders, $contentType);
    }


    /**
     * Put an object from a string (legacy function)
     *
     * @param string $string Input data
     * @param string $bucket Bucket name
     * @param string $uri Object URI
     * @param constant $acl ACL constant
     * @param array $metaHeaders Array of x-sws-meta-* headers
     * @param string $contentType Content type
     * @return boolean
     */
    public static function putObjectString($string, $bucket, $uri, $metaHeaders = array(), $contentType = false)
    {
        return self::putObject($string, $bucket, $uri, $metaHeaders, $contentType);
    }

    /**
     * 修改一个 Object 的属性
     *
     * @param string $bucket Bucket 名称
     * @param constant $uri Object 名称
     * @param array $metaHeaders x-sws-container-meta-* header 数组
     * @param array $requestHeaders 其它 header 属性
     * @return boolean
     */
    public static function postObject($bucket, $uri, $metaHeaders=array(), $requestHeaders=Array())
    {
        $rest = new StorageRequest('POST', self::$__account, $bucket, $uri, self::$endpoint);
        foreach ($metaHeaders as $k => $v) {
            $rest->setSwsHeader('x-sws-object-meta-'.$k, $v);
        }
        foreach ($requestHeaders as $k => $v) {
            $rest->setHeader('x-sws-object-meta-'.$k, $v);
        }

        $rest = $rest->getResponse();

        if ($rest->error === false && ($rest->code !== 202))
            $rest->error = array('code' => $rest->code, 'message' => 'Unexpected HTTP status');
        if ($rest->error !== false)
        {
            self::__triggerError(sprintf("Storage::postObject({$bucket}, {$uri}): [%s] %s",
                $rest->error['code'], $rest->error['message']), __FILE__, __LINE__);
            return false;
        }
        return true;
    }

    /**
     * 获取一个 Object 的内容
     *
     * @param string $bucket Bucket 名称
     * @param string $uri Object 名称
     * @param mixed $saveTo 文件保存到的文件名或者句柄
     * @return mixed 返回服务端返回的 response，其中 headers 为 Object 的属性信息，body 为 Object 的内容
     */
    public static function getObject($bucket, $uri, $saveTo = false)
    {
        $rest = new StorageRequest('GET', self::$__account, $bucket, $uri, self::$endpoint);
        if ($saveTo !== false)
        {
            if (is_resource($saveTo))
                $rest->fp =& $saveTo;
            else
                if (($rest->fp = @fopen($saveTo, 'wb')) !== false)
                    $rest->file = realpath($saveTo);
                else
                    $rest->response->error = array('code' => 0, 'message' => 'Unable to open save file for writing: '.$saveTo);
        }
        if ($rest->response->error === false) $rest->getResponse();

        if ($rest->response->error === false && $rest->response->code !== 200)
            $rest->response->error = array('code' => $rest->response->code, 'message' => 'Unexpected HTTP status');
        if ($rest->response->error !== false)
        {
            self::__triggerError(sprintf("Storage::getObject({$bucket}, {$uri}): [%s] %s",
                $rest->response->error['code'], $rest->response->error['message']), __FILE__, __LINE__);
            return false;
        }
        return $rest->response;
    }


    /**
     * 获取一个 Object 的信息
     *
     * @param string $bucket Bucket 名称
     * @param string $uri Object 名称
     * @param boolean $returnInfo 是否返回 Object 的详细信息
     * @return mixed | false
     */
    public static function getObjectInfo($bucket, $uri, $returnInfo = true)
    {
        $rest = new StorageRequest('HEAD', self::$__account, $bucket, $uri, self::$endpoint);
        $rest = $rest->getResponse();
        if ($rest->error === false && ($rest->code !== 200 && $rest->code !== 404))
            $rest->error = array('code' => $rest->code, 'message' => 'Unexpected HTTP status');
        if ($rest->error !== false)
        {
            self::__triggerError(sprintf("Storage::getObjectInfo({$bucket}, {$uri}): [%s] %s",
                $rest->error['code'], $rest->error['message']), __FILE__, __LINE__);
            return false;
        }
        return $rest->code == 200 ? $returnInfo ? $rest->headers : true : false;
    }


    /**
     * 从一个 Bucket 复制一个 Object 到另一个 Bucket
     *
     * @param string $srcBucket 源 Bucket 名称
     * @param string $srcUri 源 Object 名称
     * @param string $bucket 目标 Bucket 名称
     * @param string $uri 目标 Object 名称
     * @param array $metaHeaders Optional array of x-sws-meta-* headers
     * @param array $requestHeaders Optional array of request headers (content type, disposition, etc.)
     * @return mixed | false
     */
    public static function copyObject($srcBucket, $srcUri, $bucket, $uri, $metaHeaders = array(), $requestHeaders = array())
    {
        $rest = new StorageRequest('PUT', self::$__account, $bucket, $uri, self::$endpoint);
        $rest->setHeader('Content-Length', 0);
        foreach ($requestHeaders as $h => $v)
            strpos($h, 'x-sws-') === 0 ? $rest->setSwsHeader($h, $v) : $rest->setHeader($h, $v);
        foreach ($metaHeaders as $h => $v) $rest->setSwsHeader('x-sws-object-meta-'.$h, $v);
        $rest->setSwsHeader('x-sws-copy-from', sprintf('/%s/%s', $srcBucket, rawurlencode($srcUri)));
        $rest->setSwsHeader('x-sws-newest', '1');

        $rest = $rest->getResponse();
        if ($rest->error === false && $rest->code !== 201)
            $rest->error = array('code' => $rest->code, 'message' => 'Unexpected HTTP status');
        if ($rest->error !== false)
        {
            self::__triggerError(sprintf("Storage::copyObject({$srcBucket}, {$srcUri}, {$bucket}, {$uri}): [%s] %s",
                $rest->error['code'], $rest->error['message']), __FILE__, __LINE__);
            return false;
        }
        return isset($rest->headers['time'], $rest->headers['hash']) ? $rest->headers : false;
    }


    /**
     * Set object or bucket Access Control Policy
     *
     * @param string $bucket Bucket name
     * @param string $uri Object URI
     * @param array $acp Access Control Policy Data (same as the data returned from getAccessControlPolicy)
     * @return boolean
     */
    public static function setAccessControlPolicy($bucket, $uri = '', $acp = array())
    {
    }


    /**
     * 删除一个 Object
     *
     * @param string $bucket Bucket 名称
     * @param string $uri Object 名称
     * @return boolean
     */
    public static function deleteObject($bucket, $uri)
    {
        $rest = new StorageRequest('DELETE', self::$__account, $bucket, $uri, self::$endpoint);
        $rest = $rest->getResponse();
        if ($rest->error === false && $rest->code !== 204)
            $rest->error = array('code' => $rest->code, 'message' => 'Unexpected HTTP status');
        if ($rest->error !== false)
        {
            self::__triggerError(sprintf("Storage::deleteObject(): [%s] %s",
                $rest->error['code'], $rest->error['message']), __FILE__, __LINE__);
            return false;
        }
        return true;
    }


    /**
     * 获取一个 Object 的外网直接访问 URL
     *
     * @param string $bucket Bucket 名称
     * @param string $uri Object 名称
     * @return string
     */
    public static function getUrl($bucket, $uri)
    {
        return "http://" . self::$__account . '-' . $bucket . '.stor.sinaapp.com/' . self::__encodeURI($uri);
    }

     /**
     * 获取一个 Object 的外网临时访问 URL
     *
     * @param string $bucket Bucket 名称
     * @param string $uri Object 名称
     * @param string $method Http 请求的方法，有 GET, PUT, DELETE 等
     * @param int    $seconds 设置这个此 URL 的过期时间，单位是秒
     */
    public static function getTempUrl($bucket, $uri, $method, $seconds)
    {
        $expires = (int)(time() + $seconds);
        $path = "/v1/SAE_" . self::$__account . "/" . $bucket . "/" . $uri;
        $hmac_body = $method . "\n" . $expires . "\n" . $path;
        $sig = hash_hmac('sha1', $hmac_body, self::$__secretKey);
        $parameter = http_build_query(array("temp_url_sig" => $sig, "temp_url_expires" => $expires));
        return "http://" . self::$__account . '-' . $bucket . '.stor.sinaapp.com/' . self::__encodeURI($uri) . "?" . $parameter;
    }

    /**
     * 获取一个 Object 的 CDN 访问 URL
     * @param string $bucket Bucket 名称
     * @param string $uri Object 名称
     * @return string
     */
    public static function getCdnUrl($bucket, $uri)
    {
        return "http://". self::$__account . '.sae.sinacn.com/.app-stor/' . $bucket . '/' . self::__encodeURI($uri);
    }

    /**
     * 修改账户的属性（for internal use onley）
     *
     * @param array $metaHeaders x-sws-account-meta-* header 数组
     * @return boolean
     */
    public static function postAccount($metaHeaders=array())
    {
        $rest = new StorageRequest('POST', self::$__account, '', '', self::$endpoint);
        foreach ($metaHeaders as $k => $v) {
            $rest->setSwsHeader('x-sws-account-meta-'.$k, $v);
        }

        $rest = $rest->getResponse();

        if ($rest->error === false && ($rest->code !== 201 && $rest->code !== 204))
            $rest->error = array('code' => $rest->code, 'message' => 'Unexpected HTTP status');
        if ($rest->error !== false)
        {
            self::__triggerError(sprintf("Storage::postAccount({$bucket}, {$acl}): [%s] %s",
                $rest->error['code'], $rest->error['message']), __FILE__, __LINE__);
            return false;
        }
        return true;
    }

    /**
     * 获取账户的属性（for internal use only）
     *
     * @param string $bucket Bucket 名称
     * @return mixed
     */
    public static function getAccountInfo() {
        $rest = new StorageRequest('HEAD', self::$__account, '', '', self::$endpoint);
        $rest = $rest->getResponse();
        if ($rest->error === false && ($rest->code !== 204 && $rest->code !== 404))
            $rest->error = array('code' => $rest->code, 'message' => 'Unexpected HTTP status');
        if ($rest->error !== false)
        {
            self::__triggerError(sprintf("Storage::getAccountInfo({$bucket}): [%s] %s",
                $rest->error['code'], $rest->error['message']), __FILE__, __LINE__);
            return false;
        }
        return $rest->code !== 404 ? $rest->headers : false;
    }


    private static function __getMIMEType(&$file)
    {
        static $exts = array(
            'jpg' => 'image/jpeg', 'jpeg' => 'image/jpeg', 'gif' => 'image/gif',
            'png' => 'image/png', 'ico' => 'image/x-icon', 'pdf' => 'application/pdf',
            'tif' => 'image/tiff', 'tiff' => 'image/tiff', 'svg' => 'image/svg+xml',
            'svgz' => 'image/svg+xml', 'swf' => 'application/x-shockwave-flash',
            'zip' => 'application/zip', 'gz' => 'application/x-gzip',
            'tar' => 'application/x-tar', 'bz' => 'application/x-bzip',
            'bz2' => 'application/x-bzip2',  'rar' => 'application/x-rar-compressed',
            'exe' => 'application/x-msdownload', 'msi' => 'application/x-msdownload',
            'cab' => 'application/vnd.ms-cab-compressed', 'txt' => 'text/plain',
            'asc' => 'text/plain', 'htm' => 'text/html', 'html' => 'text/html',
            'css' => 'text/css', 'js' => 'text/javascript',
            'xml' => 'text/xml', 'xsl' => 'application/xsl+xml',
            'ogg' => 'application/ogg', 'mp3' => 'audio/mpeg', 'wav' => 'audio/x-wav',
            'avi' => 'video/x-msvideo', 'mpg' => 'video/mpeg', 'mpeg' => 'video/mpeg',
            'mov' => 'video/quicktime', 'flv' => 'video/x-flv', 'php' => 'text/x-php'
        );

        $ext = strtolower(pathinfo($file, PATHINFO_EXTENSION));
        if (isset($exts[$ext])) return $exts[$ext];

        // Use fileinfo if available
        if (extension_loaded('fileinfo') && isset($_ENV['MAGIC']) &&
            ($finfo = finfo_open(FILEINFO_MIME, $_ENV['MAGIC'])) !== false)
        {
            if (($type = finfo_file($finfo, $file)) !== false)
            {
                // Remove the charset and grab the last content-type
                $type = explode(' ', str_replace('; charset=', ';charset=', $type));
                $type = array_pop($type);
                $type = explode(';', $type);
                $type = trim(array_shift($type));
            }
            finfo_close($finfo);
            if ($type !== false && strlen($type) > 0) return $type;
        }

        return 'application/octet-stream';
    }

    private static function __encodeURI($uri)
    {
        return str_replace('%2F', '/', rawurlencode($uri));
    }

    public static function __getTime()
    {
        return time() + self::$__timeOffset;
    }


    public static function __getSignature($string)
    {
        //var_dump("sign:", $string);
        return 'SWS '.self::$__accessKey.':'.self::__getHash($string);
    }


    private static function __getHash($string)
    {
        return base64_encode(extension_loaded('hash') ?
            hash_hmac('sha1', $string, self::$__secretKey, true) : pack('H*', sha1(
                (str_pad(self::$__secretKey, 64, chr(0x00)) ^ (str_repeat(chr(0x5c), 64))) .
                pack('H*', sha1((str_pad(self::$__secretKey, 64, chr(0x00)) ^
                (str_repeat(chr(0x36), 64))) . $string)))));
    }

}

/**
 * @ignore
 */
final class StorageRequest
{
    private $endpoint;
    private $verb;
    private $uri;
    private $parameters = array();
    private $swsHeaders = array();
    private $headers = array(
        'Host' => '', 'Date' => '', 'Content-MD5' => ''
    );

    public $fp = false;
    public $size = 0;
    public $data = false;

    public $response;


    function __construct($verb, $account, $bucket = '', $uri = '', $endpoint = DEFAULT_STORAGE_ENDPOINT)
    {
        $this->endpoint = $endpoint;
        $this->verb = $verb;

        $this->uri = "/v1/SAE_" . rawurlencode($account);
        $this->resource = "/$account";
        if ($bucket !== '') {
            $this->uri = $this->uri . '/' . rawurlencode($bucket);
            $this->resource = $this->resource . '/'. $bucket;
        }
        if ($uri !== '') {
            $this->uri .= '/'.str_replace('%2F', '/', rawurlencode($uri));
            $this->resource = $this->resource . '/'. str_replace(' ', '%20', $uri);
        }

        $this->headers['Host'] = $this->endpoint;
        $this->headers['Date'] = gmdate('D, d M Y H:i:s T');
        $this->response = new \STDClass;
        $this->response->error = false;
        $this->response->body = null;
        $this->response->headers = array();
    }


    public function setParameter($key, $value)
    {
        $this->parameters[$key] = $value;
    }


    public function setHeader($key, $value)
    {
        $this->headers[$key] = $value;
    }


    public function setSwsHeader($key, $value)
    {
        $this->swsHeaders[$key] = $value;
    }


    public function getResponse()
    {
        $query = '';
        if (sizeof($this->parameters) > 0)
        {
            $query = substr($this->uri, -1) !== '?' ? '?' : '&';
            foreach ($this->parameters as $var => $value)
                if ($value == null || $value == '') $query .= $var.'&';
                else $query .= $var.'='.rawurlencode($value).'&';
            $query = substr($query, 0, -1);
            $this->uri .= $query;
            $this->resource .= $query;
        }
        $url = (Storage::$useSSL ? 'https://' : 'http://') . ($this->headers['Host'] !== '' ? $this->headers['Host'] : $this->endpoint) . $this->uri;

        //var_dump('uri: ' . $this->uri, 'url: ' . $url, 'resource: ' . $this->resource);

        // Basic setup
        $curl = curl_init();
        curl_setopt($curl, CURLOPT_USERAGENT, 'Storage/php');

        if (Storage::$useSSL)
        {
            // Set protocol version
            curl_setopt($curl, CURLOPT_SSLVERSION, Storage::$useSSLVersion);

            // SSL Validation can now be optional for those with broken OpenSSL installations
            curl_setopt($curl, CURLOPT_SSL_VERIFYHOST, Storage::$useSSLValidation ? 2 : 0);
            curl_setopt($curl, CURLOPT_SSL_VERIFYPEER, Storage::$useSSLValidation ? 1 : 0);
        }

        curl_setopt($curl, CURLOPT_URL, $url);

        if (Storage::$proxy != null && isset(Storage::$proxy['host']))
        {
            curl_setopt($curl, CURLOPT_PROXY, Storage::$proxy['host']);
            curl_setopt($curl, CURLOPT_PROXYTYPE, Storage::$proxy['type']);
            if (isset(Storage::$proxy['user'], Storage::$proxy['pass']) && Storage::$proxy['user'] != null && Storage::$proxy['pass'] != null)
                curl_setopt($curl, CURLOPT_PROXYUSERPWD, sprintf('%s:%s', Storage::$proxy['user'], Storage::$proxy['pass']));
        }

        // Headers
        $headers = array(); $sae = array();
        foreach ($this->swsHeaders as $header => $value)
            if (strlen($value) > 0) $headers[] = $header.': '.$value;
        foreach ($this->headers as $header => $value)
            if (strlen($value) > 0) $headers[] = $header.': '.$value;

        foreach ($this->swsHeaders as $header => $value)
            if (strlen($value) > 0) $sae[] = strtolower($header).':'.$value;

        if (sizeof($sae) > 0)
        {
            usort($sae, array(&$this, '__sortMetaHeadersCmp'));
            $sae= "\n".implode("\n", $sae);
        } else $sae = '';

        if (Storage::hasAuth())
        {
            $headers[] = 'Authorization: ' . Storage::__getSignature(
                $this->verb."\n".
                $this->headers['Date'].$sae."\n".
                $this->resource
            );
        }

        //var_dump("headers:", $headers);

        curl_setopt($curl, CURLOPT_HTTPHEADER, $headers);
        curl_setopt($curl, CURLOPT_HEADER, false);
        curl_setopt($curl, CURLOPT_RETURNTRANSFER, false);
        curl_setopt($curl, CURLOPT_WRITEFUNCTION, array(&$this, '__responseWriteCallback'));
        curl_setopt($curl, CURLOPT_HEADERFUNCTION, array(&$this, '__responseHeaderCallback'));

        // Request types
        switch ($this->verb)
        {
        case 'GET': break;
        case 'PUT': case 'POST':
            if ($this->fp !== false)
            {
                curl_setopt($curl, CURLOPT_PUT, true);
                curl_setopt($curl, CURLOPT_INFILE, $this->fp);
                if ($this->size >= 0)
                    curl_setopt($curl, CURLOPT_INFILESIZE, $this->size);
            }
            elseif ($this->data !== false)
            {
                curl_setopt($curl, CURLOPT_CUSTOMREQUEST, $this->verb);
                curl_setopt($curl, CURLOPT_POSTFIELDS, $this->data);
            }
            else
                curl_setopt($curl, CURLOPT_CUSTOMREQUEST, $this->verb);
            break;
        case 'HEAD':
            curl_setopt($curl, CURLOPT_CUSTOMREQUEST, 'HEAD');
            curl_setopt($curl, CURLOPT_NOBODY, true);
            break;
        case 'DELETE':
            curl_setopt($curl, CURLOPT_CUSTOMREQUEST, 'DELETE');
            break;
        default: break;
        }

        // Execute, grab errors
        if (curl_exec($curl))
            $this->response->code = curl_getinfo($curl, CURLINFO_HTTP_CODE);
        else
            $this->response->error = array(
                'code' => curl_errno($curl),
                'message' => curl_error($curl),
            );

        @curl_close($curl);

        // Clean up file resources
        if ($this->fp !== false && is_resource($this->fp)) fclose($this->fp);

        //var_dump("response:", $this->response);
        return $this->response;
    }


    private function __sortMetaHeadersCmp($a, $b)
    {
        $lenA = strpos($a, ':');
        $lenB = strpos($b, ':');
        $minLen = min($lenA, $lenB);
        $ncmp = strncmp($a, $b, $minLen);
        if ($lenA == $lenB) return $ncmp;
        if (0 == $ncmp) return $lenA < $lenB ? -1 : 1;
        return $ncmp;
    }


    private function __responseWriteCallback(&$curl, &$data)
    {
        if (in_array($this->response->code, array(200, 206)) && $this->fp !== false)
            return fwrite($this->fp, $data);
        else
            $this->response->body .= $data;
        return strlen($data);
    }


    private function __responseHeaderCallback($curl, $data)
    {
        if (($strlen = strlen($data)) <= 2) return $strlen;
        if (substr($data, 0, 4) == 'HTTP')
            $this->response->code = (int)substr($data, 9, 3);
        else
        {
            $data = trim($data);
            if (strpos($data, ': ') === false) return $strlen;
            list($header, $value) = explode(': ', $data, 2);
            if ($header == 'Last-Modified')
                $this->response->headers['time'] = strtotime($value);
            elseif ($header == 'Date')
                $this->response->headers['date'] = strtotime($value);
            elseif ($header == 'Content-Length')
                $this->response->headers['size'] = (int)$value;
            elseif ($header == 'Content-Type')
                $this->response->headers['type'] = $value;
            elseif ($header == 'ETag' || $header == 'Etag')
                $this->response->headers['hash'] = $value{0} == '"' ? substr($value, 1, -1) : $value;
            elseif (preg_match('/^x-sws-(?:account|container|object)-read$/i', $header))
                $this->response->headers['acl'] = $value;
            elseif (preg_match('/^x-sws-(?:account|container|object)-meta-(.*)$/i', $header))
                $this->response->headers[strtolower($header)] = $value;
            elseif (preg_match('/^x-sws-(?:account|container|object)-(.*)$/i', $header, $m))
                $this->response->headers[strtolower($m[1])] = $value;
        }
        return $strlen;
    }

}

/**
 * Storage 异常类
 */
class StorageException extends \Exception {
    /**
     * 构造函数
     *
     * @param string $message 异常信息
     * @param string $file 抛出异常的文件
     * @param string $line 抛出异常的代码行
     * @param int $code 异常码
     */
    function __construct($message, $file, $line, $code = 0)
    {
        parent::__construct($message, $code);
        $this->file = $file;
        $this->line = $line;
    }
}

/**
 * A PHP wrapper for Storage
 *
 * @ignore
 */
final class StorageWrapper extends Storage {
    private $position = 0, $mode = '', $buffer;

    public function url_stat($path, $flags) {
        self::__getURL($path);
        return (($info = self::getObjectInfo($this->url['host'], $this->url['path'])) !== false) ?
            array('size' => $info['size'], 'mtime' => $info['time'], 'ctime' => $info['time']) : false;
    }

    public function unlink($path) {
        self::__getURL($path);
        return self::deleteObject($this->url['host'], $this->url['path']);
    }

    public function mkdir($path, $mode, $options) {
        self::__getURL($path);
        return self::putBucket($this->url['host'], self::__translateMode($mode));
    }

    public function rmdir($path) {
        self::__getURL($path);
        return self::deleteBucket($this->url['host']);
    }

    public function dir_opendir($path, $options) {
        self::__getURL($path);
        if (($contents = self::getBucket($this->url['host'], $this->url['path'])) !== false) {
            $pathlen = strlen($this->url['path']);
            if (substr($this->url['path'], -1) == '/') $pathlen++;
            $this->buffer = array();
            foreach ($contents as $file) {
                if ($pathlen > 0) $file['name'] = substr($file['name'], $pathlen);
                $this->buffer[] = $file;
            }
            return true;
        }
        return false;
    }

    public function dir_readdir() {
        return (isset($this->buffer[$this->position])) ? $this->buffer[$this->position++]['name'] : false;
    }

    public function dir_rewinddir() {
        $this->position = 0;
    }

    public function dir_closedir() {
        $this->position = 0;
        unset($this->buffer);
    }

    public function stream_close() {
        if ($this->mode == 'w') {
            self::putObject($this->buffer, $this->url['host'], $this->url['path']);
        }
        $this->position = 0;
        unset($this->buffer);
    }

    public function stream_stat() {
        if (is_object($this->buffer) && isset($this->buffer->headers))
            return array(
                'size' => $this->buffer->headers['size'],
                'mtime' => $this->buffer->headers['time'],
                'ctime' => $this->buffer->headers['time']
            );
        elseif (($info = self::getObjectInfo($this->url['host'], $this->url['path'])) !== false)
            return array('size' => $info['size'], 'mtime' => $info['time'], 'ctime' => $info['time']);
        return false;
    }

    public function stream_flush() {
        $this->position = 0;
        return true;
    }

    public function stream_open($path, $mode, $options, &$opened_path) {
        if (!in_array($mode, array('r', 'rb', 'w', 'wb'))) return false; // Mode not supported
        $this->mode = substr($mode, 0, 1);
        self::__getURL($path);
        $this->position = 0;
        if ($this->mode == 'r') {
            if (($this->buffer = self::getObject($this->url['host'], $this->url['path'])) !== false) {
                if (is_object($this->buffer->body)) $this->buffer->body = (string)$this->buffer->body;
            } else return false;
        }
        return true;
    }

    public function stream_read($count) {
        if ($this->mode !== 'r' && $this->buffer !== false) return false;
        $data = substr(is_object($this->buffer) ? $this->buffer->body : $this->buffer, $this->position, $count);
        $this->position += strlen($data);
        return $data;
    }

    public function stream_write($data) {
        if ($this->mode !== 'w') return 0;
        $left = substr($this->buffer, 0, $this->position);
        $right = substr($this->buffer, $this->position + strlen($data));
        $this->buffer = $left . $data . $right;
        $this->position += strlen($data);
        return strlen($data);
    }

    public function stream_tell() {
        return $this->position;
    }

    public function stream_eof() {
        return $this->position >= strlen(is_object($this->buffer) ? $this->buffer->body : $this->buffer);
    }

    public function stream_seek($offset, $whence) {
        switch ($whence) {
        case SEEK_SET:
            if ($offset < strlen($this->buffer->body) && $offset >= 0) {
                $this->position = $offset;
                return true;
            } else return false;
            break;
        case SEEK_CUR:
            if ($offset >= 0) {
                $this->position += $offset;
                return true;
            } else return false;
            break;
        case SEEK_END:
            $bytes = strlen($this->buffer->body);
            if ($bytes + $offset >= 0) {
                $this->position = $bytes + $offset;
                return true;
            } else return false;
            break;
        default: return false;
        }
    }

    private function __getURL($path) {
        $this->url = parse_url($path);
        if (!isset($this->url['scheme']) || $this->url['scheme'] !== 'storage') return $this->url;
        if (isset($this->url['user'], $this->url['pass'])) self::setAuth($this->url['user'], $this->url['pass']);
        $this->url['path'] = isset($this->url['path']) ? substr($this->url['path'], 1) : '';
    }

    private function __translateMode($mode) {
        $acl = self::ACL_PRIVATE;
        if (($mode & 0x0020) || ($mode & 0x0004))
            $acl = self::ACL_PUBLIC_READ;
        // You probably don't want to enable public write access
        if (($mode & 0x0010) || ($mode & 0x0008) || ($mode & 0x0002) || ($mode & 0x0001))
            $acl = self::ACL_PUBLIC_READ; //$acl = self::ACL_PUBLIC_READ_WRITE;
        return $acl;
    }
} stream_wrapper_register('storage', 'sinacloud\sae\StorageWrapper');