@@ -86,7 +86,7 @@ discard block |
||
86 | 86 | * @throws \Exception 上传失败时,抛出异常 |
87 | 87 | */ |
88 | 88 | public function write($path, $content, $params = array(), $withAsyncProcess = false) { |
89 | - if(!$content) { |
|
89 | + if (!$content) { |
|
90 | 90 | throw new \Exception('write content can not be empty.'); |
91 | 91 | } |
92 | 92 | |
@@ -122,8 +122,8 @@ discard block |
||
122 | 122 | $params = Util::getHeaderParams($response->getHeaders()); |
123 | 123 | |
124 | 124 | |
125 | - if(! isset($params['x-upyun-list-iter'])) { |
|
126 | - if(is_resource($saveHandler)) { |
|
125 | + if (!isset($params['x-upyun-list-iter'])) { |
|
126 | + if (is_resource($saveHandler)) { |
|
127 | 127 | Psr7\copy_to_stream($response->getBody(), Psr7\stream_for($saveHandler)); |
128 | 128 | return true; |
129 | 129 | } else { |
@@ -150,9 +150,9 @@ discard block |
||
150 | 150 | try { |
151 | 151 | $req->request('HEAD', $path) |
152 | 152 | ->send(); |
153 | - } catch(GuzzleHttp\Exception\BadResponseException $e) { |
|
153 | + } catch (GuzzleHttp\Exception\BadResponseException $e) { |
|
154 | 154 | $statusCode = $e->getResponse()->getStatusCode(); |
155 | - if($statusCode === 404) { |
|
155 | + if ($statusCode === 404) { |
|
156 | 156 | return false; |
157 | 157 | } else { |
158 | 158 | throw $e; |
@@ -191,7 +191,7 @@ discard block |
||
191 | 191 | public function delete($path, $async = false) { |
192 | 192 | $req = new Rest($this->config); |
193 | 193 | $req->request('DELETE', $path); |
194 | - if($async) { |
|
194 | + if ($async) { |
|
195 | 195 | $req->withHeader('x-upyun-async', 'true'); |
196 | 196 | } |
197 | 197 | $res = $req->send(); |
@@ -207,7 +207,7 @@ discard block |
||
207 | 207 | * @throws \Exception |
208 | 208 | */ |
209 | 209 | public function createDir($path) { |
210 | - $path = rtrim($path, '/') . '/'; |
|
210 | + $path = rtrim($path, '/').'/'; |
|
211 | 211 | $req = new Rest($this->config); |
212 | 212 | $res = $req->request('POST', $path) |
213 | 213 | ->withHeader('folder', 'true') |
@@ -236,9 +236,9 @@ discard block |
||
236 | 236 | */ |
237 | 237 | public function usage($path = '/') { |
238 | 238 | |
239 | - $path = rtrim($path, '/') . '/'; |
|
239 | + $path = rtrim($path, '/').'/'; |
|
240 | 240 | $req = new Rest($this->config); |
241 | - $response = $req->request('GET', $path . '?usage') |
|
241 | + $response = $req->request('GET', $path.'?usage') |
|
242 | 242 | ->withHeader('folder', 'true') |
243 | 243 | ->send(); |
244 | 244 | |
@@ -254,7 +254,7 @@ discard block |
||
254 | 254 | */ |
255 | 255 | public function purge($urls) { |
256 | 256 | $urlString = $urls; |
257 | - if(is_array($urls)) { |
|
257 | + if (is_array($urls)) { |
|
258 | 258 | $urlString = implode("\n", $urls); |
259 | 259 | } |
260 | 260 |
@@ -87,7 +87,7 @@ |
||
87 | 87 | $callbackParams = array(); |
88 | 88 | foreach($callbackKeys as $key) { |
89 | 89 | if(isset($_POST[$key])) { |
90 | - $callbackParams[$key] = Util::trim($_POST[$key]); |
|
90 | + $callbackParams[$key] = Util::trim($_POST[$key]); |
|
91 | 91 | } |
92 | 92 | } |
93 | 93 |
@@ -32,7 +32,7 @@ discard block |
||
32 | 32 | $postParams |
33 | 33 | ); |
34 | 34 | |
35 | - if($response->status_code !== 200) { |
|
35 | + if ($response->status_code !== 200) { |
|
36 | 36 | $body = json_decode($response->body, true); |
37 | 37 | throw new \Exception(sprintf('%s, with x-request-id=%s', $body['msg'], $body['id']), $body['code']); |
38 | 38 | } |
@@ -48,7 +48,7 @@ discard block |
||
48 | 48 | if (count($taskIds) <= $limit) { |
49 | 49 | $taskIds = implode(',', $taskIds); |
50 | 50 | } else { |
51 | - throw new \Exception('can not query more than ' . $limit . ' tasks at one time!'); |
|
51 | + throw new \Exception('can not query more than '.$limit.' tasks at one time!'); |
|
52 | 52 | } |
53 | 53 | |
54 | 54 | $query['task_ids'] = $taskIds; |
@@ -65,7 +65,7 @@ discard block |
||
65 | 65 | $query |
66 | 66 | ); |
67 | 67 | |
68 | - if($response->status_code !== 200) { |
|
68 | + if ($response->status_code !== 200) { |
|
69 | 69 | $body = json_decode($response->body, true); |
70 | 70 | throw new \Exception(sprintf('%s, with x-request-id=%s', $body['msg'], $body['id']), $body['code']); |
71 | 71 | } |
@@ -5,7 +5,7 @@ discard block |
||
5 | 5 | use Upyun\Signature; |
6 | 6 | use GuzzleHttp\Client; |
7 | 7 | |
8 | -class Form extends Rest{ |
|
8 | +class Form extends Rest { |
|
9 | 9 | |
10 | 10 | public function upload($path, $stream, $params) { |
11 | 11 | $params['save-key'] = $path; |
@@ -21,7 +21,7 @@ discard block |
||
21 | 21 | 'timeout' => $this->config->timeout, |
22 | 22 | ]); |
23 | 23 | |
24 | - $url = ($this->config->useSsl ? 'https://' : 'http://') . $this->endpoint; |
|
24 | + $url = ($this->config->useSsl ? 'https://' : 'http://').$this->endpoint; |
|
25 | 25 | |
26 | 26 | $response = $client->request('POST', $url, array( |
27 | 27 | 'multipart' => array( |
@@ -3,7 +3,7 @@ discard block |
||
3 | 3 | class Util { |
4 | 4 | |
5 | 5 | public static function trim($str) { |
6 | - if(is_array($str)) { |
|
6 | + if (is_array($str)) { |
|
7 | 7 | return array_map(array('Util', 'trim'), $str); |
8 | 8 | } else { |
9 | 9 | return trim($str); |
@@ -14,7 +14,7 @@ discard block |
||
14 | 14 | $params = []; |
15 | 15 | foreach ($headers as $header => $value) { |
16 | 16 | $header = strtolower($header); |
17 | - if(strpos($header, 'x-upyun-') !== false) { |
|
17 | + if (strpos($header, 'x-upyun-') !== false) { |
|
18 | 18 | $params[$header] = $value[0]; |
19 | 19 | } |
20 | 20 | } |
@@ -23,12 +23,12 @@ discard block |
||
23 | 23 | |
24 | 24 | public static function parseDir($body) { |
25 | 25 | $files = array(); |
26 | - if(!$body) { |
|
26 | + if (!$body) { |
|
27 | 27 | return array('files' => $files, 'is_end' => true); |
28 | 28 | } |
29 | 29 | |
30 | 30 | $lines = explode("\n", $body); |
31 | - foreach($lines as $line) { |
|
31 | + foreach ($lines as $line) { |
|
32 | 32 | $file = []; |
33 | 33 | list($file['name'], $file['type'], $file['size'], $file['time']) = explode("\t", $line, 4); |
34 | 34 | $files[] = $file; |
@@ -10,15 +10,15 @@ discard block |
||
10 | 10 | /** |
11 | 11 | * 获取分块上传接口的签名 |
12 | 12 | */ |
13 | - const SIGN_MULTIPART = 1; |
|
13 | + const SIGN_MULTIPART = 1; |
|
14 | 14 | /** |
15 | 15 | * 生成视频处理接口的签名 |
16 | 16 | */ |
17 | - const SIGN_VIDEO = 2; |
|
17 | + const SIGN_VIDEO = 2; |
|
18 | 18 | /** |
19 | 19 | * 生成视频处理接口的签名(不需要操作员时使用) |
20 | 20 | */ |
21 | - const SIGN_VIDEO_NO_OPERATOR = 3; |
|
21 | + const SIGN_VIDEO_NO_OPERATOR = 3; |
|
22 | 22 | |
23 | 23 | /** |
24 | 24 | * 获取 RESET API 请求需要的签名头 |
@@ -32,14 +32,14 @@ discard block |
||
32 | 32 | */ |
33 | 33 | public static function getRestApiSignHeader($bucketConfig, $method, $remotePath, $contentLength) { |
34 | 34 | $gmtDate = gmdate('D, d M Y H:i:s \G\M\T'); |
35 | - $path = '/' . $bucketConfig->bucketName . '/' . ltrim($remotePath, '/'); |
|
35 | + $path = '/'.$bucketConfig->bucketName.'/'.ltrim($remotePath, '/'); |
|
36 | 36 | |
37 | 37 | $sign = md5("$method&$path&$gmtDate&$contentLength&{$bucketConfig->operatorPassword}"); |
38 | 38 | |
39 | 39 | $headers = array( |
40 | 40 | 'Authorization' => "UpYun {$bucketConfig->operatorName}:$sign", |
41 | 41 | 'Date' => $gmtDate, |
42 | - 'User-agent' => 'Php-Sdk/' . $bucketConfig->getVersion() . ' (rest api)' |
|
42 | + 'User-agent' => 'Php-Sdk/'.$bucketConfig->getVersion().' (rest api)' |
|
43 | 43 | ); |
44 | 44 | return $headers; |
45 | 45 | } |
@@ -58,21 +58,21 @@ discard block |
||
58 | 58 | return array( |
59 | 59 | 'Authorization' => "UpYun {$bucketConfig->bucketName}:{$bucketConfig->operatorName}:$sign", |
60 | 60 | 'Date' => $gmtDate, |
61 | - 'User-agent' => 'Php-Sdk/' . $bucketConfig->getVersion() . ' (purge api)' |
|
61 | + 'User-agent' => 'Php-Sdk/'.$bucketConfig->getVersion().' (purge api)' |
|
62 | 62 | ); |
63 | 63 | } |
64 | 64 | |
65 | 65 | public static function getFormSignature(Config $bucketConfig, $data) { |
66 | 66 | $data['bucket'] = $bucketConfig->bucketName; |
67 | 67 | $policy = Util::base64Json($data); |
68 | - $signature = md5($policy . '&' . $bucketConfig->getFormApiKey()); |
|
68 | + $signature = md5($policy.'&'.$bucketConfig->getFormApiKey()); |
|
69 | 69 | return array( |
70 | 70 | 'policy' => $policy, |
71 | 71 | 'signature' => $signature |
72 | 72 | ); |
73 | 73 | } |
74 | 74 | |
75 | - public static function getSignature( Config $bucketConfig, $data, $type, $tokenSecret = '') { |
|
75 | + public static function getSignature(Config $bucketConfig, $data, $type, $tokenSecret = '') { |
|
76 | 76 | if (is_array($data)) { |
77 | 77 | ksort($data); |
78 | 78 | $string = ''; |
@@ -87,7 +87,7 @@ discard block |
||
87 | 87 | $string .= $tokenSecret ? $tokenSecret : $bucketConfig->getFormApiKey(); |
88 | 88 | break; |
89 | 89 | case self::SIGN_VIDEO: |
90 | - $string = $bucketConfig->operatorName . $string . $bucketConfig->operatorPassword; |
|
90 | + $string = $bucketConfig->operatorName.$string.$bucketConfig->operatorPassword; |
|
91 | 91 | break; |
92 | 92 | case self::SIGN_VIDEO_NO_OPERATOR: |
93 | 93 | break; |