add fop

Author: longbai

src/Qiniu/Processing/Operation.php

@@ -0,0 +1,27 @@
+<?php
+namespace Qiniu\Processing;
+
+final class Operation
+{
+    public static function buildOp($cmd, $first_arg, array $args)
+    {
+        $op = array($cmd);
+        if (!empty($first_arg)) {
+            array_push($op, $first_arg);
+        }
+        foreach ($args as $key => $value) {
+            array_push($op, "$key/$value");
+        }
+        return implode('/', $op);
+    }
+
+    public static function pipeCmd($cmds)
+    {
+        return implode('|', $cmds);
+    }
+
+    public static function saveas($op, $bucket, $key)
+    {
+        return self::pipeCmd(array($op, 'saveas/' . \Qiniu\entry($bucket, $key)));
+    }
+}

src/Qiniu/Processing/PersistentFop.php

@@ -0,0 +1,58 @@
+<?php
+namespace Qiniu\Processing;
+
+use Qiniu\Config;
+use Qiniu\Http\Client;
+use Qiniu\Http\Error;
+
+final class PersistentFop
+{
+    private $auth;
+            private $bucket;
+        private $pipeline;
+        private $notify_url;
+
+    public function __construct($auth, $bucket, $pipeline = null, $notify_url = null)
+    {
+        $this->auth = $auth;
+        $this->bucket = $bucket;
+        $this->pipeline = $pipeline;
+        $this->notify_url = $notify_url;
+    }
+
+    public function execute($key, array $fops, $force = false)
+    {
+        $ops = implode(';', $fops);
+        $params = array('bucket' => $this->bucket, 'key' => $key, 'fops' => $ops);
+        if (!empty($this->pipeline)) {
+            $params['pipeline'] = $this->pipeline;
+        }
+        if (!empty($this->notify_url)){
+            $params['notifyURL'] = $this->notify_url;
+        }
+        if ($force) {
+            $params['force'] = 1;
+        }
+        $data = http_build_query($params);
+        $url = Config::API_HOST . '/pfop/';
+        $headers = $this->auth->authorization($url, $data, 'application/x-www-form-urlencoded');
+        $headers['Content-Type'] = 'application/x-www-form-urlencoded';
+        $response = Client::post($url, $data, $headers);
+        if ($response->statusCode != 200) {
+            return array(null, new Error($url, $response));
+        }
+        $r = $response->json();
+        $id = $r['persistentId'];
+        return array($id, null);
+    }
+
+    public static function status($id)
+    {
+        $url = Config::API_HOST . "/status/get/prefop?id=$id";
+        $response = Client::get($url);
+        if ($response->statusCode != 200) {
+            return array(null, new Error($url, $response));
+        }
+        return array($response->json(), null);
+    }
+}

src/Qiniu/Processing/Pfop.php

@@ -0,0 +1,25 @@
+<?php
+namespace Qiniu\Tests;
+
+use Qiniu\Http\Client;
+
+class DownloadTest extends \PHPUnit_Framework_TestCase
+{
+    public function test()
+    {
+        global $testAuth;
+        $base_url = 'http://private-res.qiniudn.com/gogopher.jpg';
+        $private_url = $testAuth->privateDownloadUrl($base_url);
+        $response = Client::get($private_url);
+        $this->assertEquals(200, $response->statusCode);
+    }
+
+    public function testFop()
+    {
+        global $testAuth;
+        $base_url = 'http://private-res.qiniudn.com/gogopher.jpg?exif';
+        $private_url = $testAuth->privateDownloadUrl($base_url);
+        $response = Client::get($private_url);
+        $this->assertEquals(200, $response->statusCode);
+    }
+}

tests/Qiniu/Tests/DownloadTest.php

@@ -0,0 +1,22 @@
+<?php
+namespace Qiniu\Tests;
+
+use Qiniu\Processing\Operation;
+use Qiniu\Processing\PersistentFop;
+
+class PfopTest extends \PHPUnit_Framework_TestCase
+{
+    public function test()
+    {
+        global $testAuth;
+        $pfop = new PersistentFop($testAuth, 'testres', 'sdktest');
+        $op = Operation::saveas('avthumb/m3u8/segtime/10/vcodec/libx264/s/320x240', 'phpsdk', 'pfoptest');
+        $ops = array();
+        array_push($ops, $op);
+        list($id, $error) = $pfop->execute('sintel_trailer.mp4', $ops, true);
+        $this->assertNull($error);
+        list($status, $error) = PersistentFop::status($id);
+        $this->assertNotNull($status);
+        $this->assertNull($error);
+    }
+}