<?php
namespace WPOSS;

if (is_file(__DIR__ . '/sdk/aliyun-oss-php-sdk/autoload.php')) {
    require_once __DIR__ . '/sdk/aliyun-oss-php-sdk/autoload.php';
}

use OSS\OssClient;
use OSS\Core\OssException;


class Api {

    private $options = array();
    private $client;
    private $errors = array();

    public function __construct($options = array()) {
        $this->options = $options;
        // 阿里云主账号AccessKey拥有所有API的访问权限，风险很高。
        // 强烈建议您创建并使用RAM账号进行API访问或日常运维，请登录 https://ram.console.aliyun.com 创建RAM账号。
        // Endpoint以杭州为例，其它Region请按实际情况填写。
        // 说明 使用自定义域名时，无法使用listBuckets方法。

        try {
            $this->client = new OssClient($this->options['accessKeyId'], $this->options['accessKeySecret'], $this->options['endpoint'], $this->options['cname']);
            if (!$this->client->doesBucketExist($this->options['bucket'])) {
                $this->client =  Null;
                $this->errors[] = "Bucket 不存在！";
            };
        } catch (OssException $e) {
            $this->errors[] = $e->getMessage();
        }
    }

    /**
     * 判断bucket是否存在
     * @param $accessKeyId : $accessKeyId
     * @param $accessKeySecret :
     * @param $endpoint :
     * @param $bucket : bucket name
     * @return array, 1 (存在), 0 (不存在), -1 (异常)
     */
    static public function does_bucket_exist($accessKeyId, $accessKeySecret, $endpoint, $bucket) {
        try {
            $client = new OssClient($accessKeyId, $accessKeySecret, $endpoint, False);
            if ($client->doesBucketExist($bucket)) {
                return array(
                    "status" => 1,
                    "msg" => "Bucket 存在!",
                );
            } else {
                return array(
                    "status" => 0,
                    "msg" => "Bucket 不存在!",
                );
            }
        } catch (OssException $e) {
            return array("status" => -1, "msg" => $e->getMessage(),);
        }
    }

    /**
     * 上传文件到OSS
     * @param $object : 文件名称
     * @param $filePath : 需要上传的文件路径，例如/users/local/my_file.txt
     */
    public function Upload($object, $filePath) {
        try{
            // 判读对象是否存在！
//            $exist = $this->client->doesObjectExist($this->options['bucket'], $object);
//            if (!$exist) {
            $this->client->uploadFile($this->options['bucket'], $object, $filePath);
//            } else {
//                $this->errors[] = "该object或object name已存在！";
//            }
        } catch(OssException $e) {
            $this->errors[] = $e->getMessage();
//            return;
        }
    }

    /**
     * 删除远程OSS对象
     * @param $objects
     */
    public function Delete($objects) {
        // object不存在时，也返回正常的响应
        $this->client->deleteObjects($this->options['bucket'], $objects);
    }


    /**
     * 远程OSS对象是否存在
     * @param $object
     * @return bool
     */
    public function hasExist($object) {
        try{
			return $this->client->doesObjectExist($this->options['bucket'], $object);
        } catch(OssException $e) {
            return False;
        }
    }
}