add video-pulp

Author: ankadada

examples/pulpvideo.php

@@ -0,0 +1,30 @@
+<?php
+
+require_once __DIR__ . '/../autoload.php';
+
+use Qiniu\Auth;
+use Qiniu\Http\Client;
+
+$accessKey = getenv('QINIU_ACCESS_KEY');
+$secretKey = getenv('QINIU_SECRET_KEY');
+$auth = new Auth($accessKey, $secretKey);
+$config = new \Qiniu\Config();
+$bucketManager = new \Qiniu\Storage\BucketManager($auth, $config);
+
+$reqBody = array();
+$reqBody['uri'] = "xxxxxxxx";
+$ops = array();
+$ops = array(
+    array(
+        'op' => 'pulp',
+    ),
+);
+
+$vid = "xxxx";
+list($ret, $err) = $bucketManager->pulpVideo($reqBody, $ops, $vid);
+
+if ($err !== null) {
+    var_dump($err);
+} else {
+    var_dump($ret);
+}

src/Qiniu/Config.php

@@ -12,6 +12,7 @@ final class Config
     const RS_HOST = 'rs.qiniu.com';      //RS Host
     const UC_HOST = 'https://api.qiniu.com';              //UC Host
     const RTCAPI_HOST = 'http://rtc.qiniuapi.com';
+    const ARGUS_HOST = 'argus.atlab.ai';
     const RTCAPI_VERSION = 'v3';
 
     // Zone 空间对应的机房

src/Qiniu/Storage/BucketManager.php

@@ -187,6 +187,30 @@ public function move($from_bucket, $from_key, $to_bucket, $to_key, $force = fals
         return $error;
     }
 
+    /**
+     * 将资源从一个空间到另一个空间
+     *
+     * @param $reqBody     待操作资源所在空间
+     * @param $from_key        待操作资源文件名
+     * @param $to_bucket       目标资源空间名
+     * @param $to_key          目标资源文件名
+     *
+     * @return mixed      成功返回NULL，失败返回对象Qiniu\Http\Error
+     * @link  https://developer.qiniu.com/dora/manual/4258/video-pulp
+     */
+    public function pulpVideo($reqBody, $ops, $vid, $params = null)
+    {
+        $path = '/v1/video/' . $vid;
+        $req = array();
+        $req['data'] = $reqBody;
+        $req['ops'] = $ops;
+        if (isset($params)) {
+            $req['params'] = $params;
+        }
+        $body = json_encode($req);
+        return $this->arPost($path, $body);
+    }
+
     /**
      * 主动修改指定资源的文件类型
      *
@@ -359,6 +383,15 @@ private function getRsHost()
         return $scheme . Config::RS_HOST;
     }
 
+    private function getArHost()
+    {
+        $scheme = "http://";
+        if ($this->config->useHTTPS == true) {
+            $scheme = "https://";
+        }
+        return $scheme . Config::ARGUS_HOST;
+    }
+
     private function getApiHost()
     {
         $scheme = "http://";
@@ -386,6 +419,12 @@ private function rsGet($path)
         return $this->get($url);
     }
 
+    private function arPost($path, $body = null)
+    {
+        $url = $this->getArHost() . $path;
+        return $this->pluPost($url, 'POST', $body);
+    }
+
     private function get($url)
     {
         $headers = $this->auth->authorization($url);
@@ -407,6 +446,19 @@ private function post($url, $body)
         return array($r, null);
     }
 
+    private function pluPost($url, $method, $body)
+    {
+        $headers = $this->auth->authorizationV2($url, $method, $body, 'application/json');
+        $headers['Content-Type']='application/json';
+        $ret = Client::post($url, $body, $headers);
+        if (!$ret->ok()) {
+            print($ret->statusCode);
+            return array(null, new Error($url, $ret));
+        }
+        $r = ($ret->body === null) ? array() : $ret->json();
+        return array($r, null);
+    }
+
     public static function buildBatchCopy($source_bucket, $key_pairs, $target_bucket, $force)
     {
         return self::twoKeyBatch('/copy', $source_bucket, $key_pairs, $target_bucket, $force);