Merge pull request #43 from dtynn/wanglin/persistentOps

Wanglin/persistent ops

Author: xushiwei

docs/README.md

@@ -250,14 +250,18 @@ SDK源码地址：<https://github.com/qiniu/php-sdk/tags>
 		public $AsyncOps;			// 可选
 		public $EndUser;			// 可选
 		public $Expires;			// 可选。默认是 3600 秒
+		public $PersistentOps;		// 可选。
+		public $PersistentNotifyUrl;	// 如果设置了PersistentOps，必须同时设置此项。
 	}
 
 * `scope` 限定客户端的权限。如果 `scope` 是 bucket，则客户端只能新增文件到指定的 bucket，不能修改文件。如果 `scope` 为 bucket:key，则客户端可以修改指定的文件。**注意： key必须采用utf8编码，如使用非utf8编码访问七牛云存储将反馈错误**
 * `callbackUrl` 设定业务服务器的回调地址，这样业务服务器才能感知到上传行为的发生。
 * `callbackBody` 设定业务服务器的回调信息。文件上传成功后，七牛向业务服务器的callbackUrl发送的POST请求携带的数据。支持 [魔法变量](http://docs.qiniu.com/api/put.html#MagicVariables) 和 [自定义变量](http://docs.qiniu.com/api/put.html#xVariables)。
 * `returnUrl` 设置用于浏览器端文件上传成功后，浏览器执行301跳转的URL，一般为 HTML Form 上传时使用。文件上传成功后浏览器会自动跳转到 `returnUrl?upload_ret=returnBody`。
 * `returnBody` 可调整返回给客户端的数据包，支持 [魔法变量](http://docs.qiniu.com/api/put.html#MagicVariables) 和 [自定义变量](http://docs.qiniu.com/api/put.html#xVariables)。`returnBody` 只在没有 `callbackUrl` 时有效（否则直接返回 `callbackUrl` 返回的结果）。不同情形下默认返回的 `returnBody` 并不相同。在一般情况下返回的是文件内容的 `hash`，也就是下载该文件时的 `etag`；但指定 `returnUrl` 时默认的 `returnBody` 会带上更多的信息。
-* `asyncOps` 可指定上传完成后，需要自动执行哪些数据处理。这是因为有些数据处理操作（比如音视频转码）比较慢，如果不进行预转可能第一次访问的时候效果不理想，预转可以很大程度改善这一点。
+* `asyncOps` 可指定上传完成后，需要自动执行哪些数据处理。这是因为有些数据处理操作（比如音视频转码）比较慢，如果不进行预转可能第一次访问的时候效果不理想，预转可以很大程度改善这一点。  
+* `persistentOps` 可指定音视频文件上传完成后，需要进行的转码持久化操作。asyncOps的处理结果保存在缓存当中，有可能失效。而persistentOps的处理结果以文件形式保存在bucket中，体验更佳。[数据处理(持久化)](http://docs.qiniu.com/api/persistent-ops.html)  
+* `persistentNotifyUrl` 音视频转码持久化完成后，七牛的服务器会向用户发送处理结果通知。这里指定的url就是用于接收通知的接口。设置了`persistentOps`,则需要同时设置此字段。
 
 关于上传策略更完整的说明，请参考 [uptoken](http://docs.qiniu.com/api/put.html#uploadToken)。
 

qiniu/rs.php

@@ -49,6 +49,8 @@ class Qiniu_RS_PutPolicy
 	public $AsyncOps;
 	public $EndUser;
 	public $Expires;
+	public $PersistentOps;
+	public $PersistentNotifyUrl;
 
 	public function __construct($scope)
 	{
@@ -82,6 +84,12 @@ public function Token($mac) // => $token
 		if (!empty($this->EndUser)) {
 			$policy['endUser'] = $this->EndUser;
 		}
+		if (!empty($this->PersistentOps)) {
+			$policy['persistentOps'] = $this->PersistentOps;
+		}
+		if (!empty($this->PersistentNotifyUrl)) {
+			$policy['persistentNotifyUrl'] = $this->PersistentNotifyUrl;
+		}
 
 		$b = json_encode($policy);
 		return Qiniu_SignWithData($mac, $b);

tests/PersistentTest.php

@@ -0,0 +1,65 @@
+<?php
+
+require_once("bootstrap.php");
+
+class PersistentTest extends PHPUnit_Framework_TestCase
+{
+	public $bucket;
+	public $client;
+
+	public function setUp()
+	{
+		initKeys();
+		$this->client = new Qiniu_MacHttpClient(null);
+		$this->bucket = getenv("QINIU_BUCKET_NAME");
+	}
+
+	public function testPutFileWithPersistentOps()
+	{
+		$key = 'testPutFileWithPersistentOps' . getTid();
+		$err = Qiniu_RS_Delete($this->client, $this->bucket, $key);
+
+		$putPolicy = new Qiniu_RS_PutPolicy($this->bucket);
+		$putPolicy->PersistentOps = 'avthumb/mp3';
+		$putPolicy->PersistentNotifyUrl = 'http://someurl/abc';
+		$upToken = $putPolicy->Token(null);
+		$putExtra = new Qiniu_PutExtra();
+		$putExtra->CheckCrc = 1;
+		list($ret, $err) = Qiniu_PutFile($upToken, $key, __file__, $putExtra);
+		$this->assertNull($err);
+		$this->assertArrayHasKey('hash', $ret);
+		$this->assertArrayHasKey('persistentId', $ret);
+		var_dump($ret);
+
+		list($ret, $err) = Qiniu_RS_Stat($this->client, $this->bucket, $key);
+		$this->assertNull($err);
+		var_dump($ret);
+
+		$err = Qiniu_RS_Delete($this->client, $this->bucket, $key);
+		$this->assertNull($err);
+	}
+
+	public function testPutWithPersistentOps()
+	{
+		$key = 'testPutWithPersistentOps' . getTid();
+		$err = Qiniu_RS_Delete($this->client, $this->bucket, $key);
+
+		$putPolicy = new Qiniu_RS_PutPolicy($this->bucket);
+		$putPolicy->PersistentOps = 'avthumb/mp3';
+		$putPolicy->PersistentNotifyUrl = 'http://someurl/abc';
+		$upToken = $putPolicy->Token(null);
+		list($ret, $err) = Qiniu_Put($upToken, $key, "hello world!", null);
+		$this->assertNull($err);
+		$this->assertArrayHasKey('hash', $ret);
+		$this->assertArrayHasKey('persistentId', $ret);
+		var_dump($ret);
+
+		list($ret, $err) = Qiniu_RS_Stat($this->client, $this->bucket, $key);
+		$this->assertNull($err);
+		var_dump($ret);
+
+		$err = Qiniu_RS_Delete($this->client, $this->bucket, $key);
+		$this->assertNull($err);
+	}
+}
+