blackteay/ufile-phpsdk
1
0
Fork 0
mirror of https://github.com/ufilesdk-dev/ufile-phpsdk.git synced 2025-04-06 04:00:05 +08:00
Code Issues Projects Releases Wiki Activity

新增head接口

Browse Source
This commit is contained in:
delex.xie 2020-07-07 20:00:42 +08:00
parent 0e4135d715
commit 1daed4cf76
4 changed files with 442 additions and 364 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

21
v1/demo/head.php Normal file
View File

@ -0,0 +1,21 @@
<?php
require_once("../ucloud/proxy.php");
//存储空间名
$bucket = "your bucket";
//上传至存储空间后的文件名称(请不要和API公私钥混淆)
$key = "your key";
list($header, $data, $err) = UCloud_Head($bucket, $key);
if ($err) {
echo "error: " . $err->ErrMsg . "\n";
echo "code: " . $err->Code . "\n";
exit;
}else{
echo "code: " . 200 ."\n";
}
print_r($header);
echo "head $bucket/$key success\n";

40
v1/ucloud/http.php
View File

@ -4,8 +4,8 @@ require_once("conf.php");
require_once("utils.php"); require_once("utils.php");
require_once("digest.php"); require_once("digest.php");
$CURL_TIMEOUT=30;
// -------------------------------------------------------------------------------- // --------------------------------------------------------------------------------
class HTTP_Request class HTTP_Request
{ {
public $URL; public $URL;
@ -129,13 +129,16 @@ function UCloud_Client_Do($req)
CURLOPT_TIMEOUT => $req->Timeout, CURLOPT_TIMEOUT => $req->Timeout,
CURLOPT_CONNECTTIMEOUT => $req->Timeout CURLOPT_CONNECTTIMEOUT => $req->Timeout
); );
if($req->METHOD =="HEAD"){
if($req->EncodedQuery() !== ""){ $options[CURLOPT_NOBODY]=true;
}
if($req->EncodedQuery() !== ""){
$options[CURLOPT_URL] = $url['host'] . "/" . $url['path'] . "?" . $req->EncodedQuery(); $options[CURLOPT_URL] = $url['host'] . "/" . $url['path'] . "?" . $req->EncodedQuery();
}else{ }else{
$options[CURLOPT_URL] = $url['host'] . "/" . $url['path']; $options[CURLOPT_URL] = $url['host'] . "/" . $url['path'];
} }
$httpHeader = $req->Header; $httpHeader = $req->Header;
if (!empty($httpHeader)) if (!empty($httpHeader))
{ {
@ -151,7 +154,9 @@ function UCloud_Client_Do($req)
} else { } else {
$options[CURLOPT_POSTFIELDS] = ""; $options[CURLOPT_POSTFIELDS] = "";
} }
curl_setopt_array($ch, $options); curl_setopt_array($ch, $options);
$result = curl_exec($ch); $result = curl_exec($ch);
$ret = curl_errno($ch); $ret = curl_errno($ch);
if ($ret !== 0) { if ($ret !== 0) {
@ -159,6 +164,7 @@ function UCloud_Client_Do($req)
curl_close($ch); curl_close($ch);
return array(null, $err); return array(null, $err);
} }
$code = curl_getinfo($ch, CURLINFO_HTTP_CODE); $code = curl_getinfo($ch, CURLINFO_HTTP_CODE);
$contentType = curl_getinfo($ch, CURLINFO_CONTENT_TYPE); $contentType = curl_getinfo($ch, CURLINFO_CONTENT_TYPE);
curl_close($ch); curl_close($ch);
@ -258,6 +264,7 @@ function UCloud_Client_Ret($resp)
}else{ }else{
$data['ETag'] = UCloud_Header_Get($resp->Header, 'Etag'); $data['ETag'] = UCloud_Header_Get($resp->Header, 'Etag');
} }
if (floor($code/100) == 2) { if (floor($code/100) == 2) {
return array($data, null); return array($data, null);
} }
@ -274,6 +281,33 @@ function UCloud_Client_Call($self, $req, $type = HEAD_FIELD_CHECK)
return UCloud_Client_Ret($resp); return UCloud_Client_Ret($resp);
} }
//@results: ($header,$data, $error)
function UCloud_Client_Call_ReHeader($self, $req, $type = HEAD_FIELD_CHECK)
{
list($resp, $err) = $self->RoundTrip($req, $type);
if ($err !== null) {
return array(null, null, $err);
}
$code = $resp->StatusCode;
$data = null;
if ($code >= 200 && $code <= 299) {
if ($resp->ContentLength !== 0 && UCloud_Header_Get($resp->Header, 'Content-Type') == 'application/json') {
$data = json_decode($resp->Body, true);
if ($data === null) {
$err = new UCloud_Error($code, 0, "");
return array($resp->Header, null, $err);
}
}
}
if (floor($code/100) == 2) {
return array($resp->Header, $data, null);
}
return array($resp->Header, $data, UCloud_ResponseError($resp));
}
//@results: $error //@results: $error
function UCloud_Client_CallNoRet($self, $req, $type = HEAD_FIELD_CHECK) function UCloud_Client_CallNoRet($self, $req, $type = HEAD_FIELD_CHECK)
{ {

743
v1/ucloud/proxy.php
View File

@ -1,361 +1,382 @@
<?php <?php
require_once("conf.php"); require_once("conf.php");
require_once("http.php"); require_once("http.php");
require_once("utils.php"); require_once("utils.php");
require_once("digest.php"); require_once("digest.php");
//------------------------------普通上传------------------------------ //------------------------------普通上传------------------------------
function UCloud_PutFile($bucket, $key, $file) function UCloud_PutFile($bucket, $key, $file)
{ {
$action_type = ActionType::PUTFILE; $action_type = ActionType::PUTFILE;
$err = CheckConfig(ActionType::PUTFILE); $err = CheckConfig(ActionType::PUTFILE);
if ($err != null) { if ($err != null) {
return array(null, $err); return array(null, $err);
} }
$f = @fopen($file, "r"); $f = @fopen($file, "r");
if (!$f) return array(null, new UCloud_Error(-1, -1, "open $file error")); if (!$f) return array(null, new UCloud_Error(-1, -1, "open $file error"));
global $UCLOUD_PROXY_SUFFIX; global $UCLOUD_PROXY_SUFFIX;
$host = $bucket . $UCLOUD_PROXY_SUFFIX; $host = $bucket . $UCLOUD_PROXY_SUFFIX;
$path = $key; $path = $key;
$content = @fread($f, filesize($file)); $content = @fread($f, filesize($file));
list($mimetype, $err) = GetFileMimeType($file); list($mimetype, $err) = GetFileMimeType($file);
if ($err) { if ($err) {
fclose($f); fclose($f);
return array("", $err); return array("", $err);
} }
$req = new HTTP_Request('PUT', array('host'=>$host, 'path'=>$path), $content, $bucket, $key, $action_type); $req = new HTTP_Request('PUT', array('host'=>$host, 'path'=>$path), $content, $bucket, $key, $action_type);
$req->Header['Expect'] = ''; $req->Header['Expect'] = '';
$req->Header['Content-Type'] = $mimetype; $req->Header['Content-Type'] = $mimetype;
$client = new UCloud_AuthHttpClient(null, $mimetype); $client = new UCloud_AuthHttpClient(null, $mimetype);
list($data, $err) = UCloud_Client_Call($client, $req); list($data, $err) = UCloud_Client_Call($client, $req);
fclose($f); fclose($f);
return array($data, $err); return array($data, $err);
} }
//------------------------------表单上传------------------------------ //------------------------------表单上传------------------------------
function UCloud_MultipartForm($bucket, $key, $file) function UCloud_MultipartForm($bucket, $key, $file)
{ {
$action_type = ActionType::POSTFILE; $action_type = ActionType::POSTFILE;
$err = CheckConfig(ActionType::POSTFILE); $err = CheckConfig(ActionType::POSTFILE);
if ($err != null) { if ($err != null) {
return array(null, $err); return array(null, $err);
} }
$f = @fopen($file, "r"); $f = @fopen($file, "r");
if (!$f) return array(null, new UCloud_Error(-1, -1, "open $file error")); if (!$f) return array(null, new UCloud_Error(-1, -1, "open $file error"));
global $UCLOUD_PROXY_SUFFIX; global $UCLOUD_PROXY_SUFFIX;
$host = $bucket . $UCLOUD_PROXY_SUFFIX; $host = $bucket . $UCLOUD_PROXY_SUFFIX;
$path = ""; $path = "";
$fsize = filesize($file); $fsize = filesize($file);
$content = ""; $content = "";
if ($fsize != 0) { if ($fsize != 0) {
$content = @fread($f, filesize($file)); $content = @fread($f, filesize($file));
if ($content == FALSE) { if ($content == FALSE) {
fclose($f); fclose($f);
return array(null, new UCloud_Error(0, -1, "read file error")); return array(null, new UCloud_Error(0, -1, "read file error"));
} }
} }
list($mimetype, $err) = GetFileMimeType($file); list($mimetype, $err) = GetFileMimeType($file);
if ($err) { if ($err) {
fclose($f); fclose($f);
return array("", $err); return array("", $err);
} }
$req = new HTTP_Request('POST', array('host'=>$host, 'path'=>$path), $content, $bucket, $key, $action_type); $req = new HTTP_Request('POST', array('host'=>$host, 'path'=>$path), $content, $bucket, $key, $action_type);
$req->Header['Expect'] = ''; $req->Header['Expect'] = '';
$token = UCloud_SignRequest(null, $req, $mimetype); $token = UCloud_SignRequest(null, $req, $mimetype);
$fields = array('Authorization'=>$token, 'FileName' => $key); $fields = array('Authorization'=>$token, 'FileName' => $key);
$files = array('files'=>array('file', $file, $content, $mimetype)); $files = array('files'=>array('file', $file, $content, $mimetype));
$client = new UCloud_AuthHttpClient(null, NO_AUTH_CHECK); $client = new UCloud_AuthHttpClient(null, NO_AUTH_CHECK);
list($data, $err) = UCloud_Client_CallWithMultipartForm($client, $req, $fields, $files); list($data, $err) = UCloud_Client_CallWithMultipartForm($client, $req, $fields, $files);
fclose($f); fclose($f);
return array($data, $err); return array($data, $err);
} }
//------------------------------分片上传------------------------------ //------------------------------分片上传------------------------------
function UCloud_MInit($bucket, $key) function UCloud_MInit($bucket, $key)
{ {
$err = CheckConfig(ActionType::MINIT); $err = CheckConfig(ActionType::MINIT);
if ($err != null) { if ($err != null) {
return array(null, $err); return array(null, $err);
} }
global $UCLOUD_PROXY_SUFFIX; global $UCLOUD_PROXY_SUFFIX;
$host = $bucket . $UCLOUD_PROXY_SUFFIX; $host = $bucket . $UCLOUD_PROXY_SUFFIX;
$path = $key; $path = $key;
$querys = array( $querys = array(
"uploads" => "" "uploads" => ""
); );
$req = new HTTP_Request('POST', array('host'=>$host, 'path'=>$path, 'query'=>$querys), null, $bucket, $key); $req = new HTTP_Request('POST', array('host'=>$host, 'path'=>$path, 'query'=>$querys), null, $bucket, $key);
$req->Header['Content-Type'] = 'application/x-www-form-urlencoded'; $req->Header['Content-Type'] = 'application/x-www-form-urlencoded';
$client = new UCloud_AuthHttpClient(null); $client = new UCloud_AuthHttpClient(null);
return UCloud_Client_Call($client, $req); return UCloud_Client_Call($client, $req);
} }
//@results: (tagList, err) //@results: (tagList, err)
function UCloud_MUpload($bucket, $key, $file, $uploadId, $blkSize, $partNumber=0) function UCloud_MUpload($bucket, $key, $file, $uploadId, $blkSize, $partNumber=0)
{ {
$err = CheckConfig(ActionType::MUPLOAD); $err = CheckConfig(ActionType::MUPLOAD);
if ($err != null) { if ($err != null) {
return array(null, $err); return array(null, $err);
} }
$f = @fopen($file, "r"); $f = @fopen($file, "r");
if (!$f) return array(null, new UCloud_Error(-1, -1, "open $file error")); if (!$f) return array(null, new UCloud_Error(-1, -1, "open $file error"));
global $UCLOUD_PROXY_SUFFIX; global $UCLOUD_PROXY_SUFFIX;
$etagList = array(); $etagList = array();
list($mimetype, $err) = GetFileMimeType($file); list($mimetype, $err) = GetFileMimeType($file);
if ($err) { if ($err) {
fclose($f); fclose($f);
return array("", $err); return array("", $err);
} }
$client = new UCloud_AuthHttpClient(null); $client = new UCloud_AuthHttpClient(null);
for(;;) { for(;;) {
$host = $bucket . $UCLOUD_PROXY_SUFFIX; $host = $bucket . $UCLOUD_PROXY_SUFFIX;
$path = $key; $path = $key;
if (@fseek($f, $blkSize*$partNumber, SEEK_SET) < 0) { if (@fseek($f, $blkSize*$partNumber, SEEK_SET) < 0) {
fclose($f); fclose($f);
return array(null, new UCloud_Error(0, -1, "fseek error")); return array(null, new UCloud_Error(0, -1, "fseek error"));
} }
$content = @fread($f, $blkSize); $content = @fread($f, $blkSize);
if ($content == FALSE) { if ($content == FALSE) {
if (feof($f)) break; if (feof($f)) break;
fclose($f); fclose($f);
return array(null, new UCloud_Error(0, -1, "read file error")); return array(null, new UCloud_Error(0, -1, "read file error"));
} }
$querys = array( $querys = array(
"uploadId" => $uploadId, "uploadId" => $uploadId,
"partNumber" => $partNumber "partNumber" => $partNumber
); );
$req = new HTTP_Request('PUT', array('host'=>$host, 'path'=>$path, 'query'=>$querys), $content, $bucket, $key); $req = new HTTP_Request('PUT', array('host'=>$host, 'path'=>$path, 'query'=>$querys), $content, $bucket, $key);
$req->Header['Content-Type'] = $mimetype; $req->Header['Content-Type'] = $mimetype;
$req->Header['Expect'] = ''; $req->Header['Expect'] = '';
list($data, $err) = UCloud_Client_Call($client, $req); list($data, $err) = UCloud_Client_Call($client, $req);
if ($err) { if ($err) {
fclose($f); fclose($f);
return array(null, $err); return array(null, $err);
} }
$etag = @$data['ETag']; $etag = @$data['ETag'];
$part = @$data['PartNumber']; $part = @$data['PartNumber'];
if ($part != $partNumber) { if ($part != $partNumber) {
fclose($f); fclose($f);
return array(null, new UCloud_Error(0, -1, "unmatch partnumber")); return array(null, new UCloud_Error(0, -1, "unmatch partnumber"));
} }
$etagList[] = $etag; $etagList[] = $etag;
$partNumber += 1; $partNumber += 1;
} }
fclose($f); fclose($f);
return array($etagList, null); return array($etagList, null);
} }
function UCloud_MFinish($bucket, $key, $uploadId, $etagList, $newKey = '') function UCloud_MFinish($bucket, $key, $uploadId, $etagList, $newKey = '')
{ {
$err = CheckConfig(ActionType::MFINISH); $err = CheckConfig(ActionType::MFINISH);
if ($err != null) { if ($err != null) {
return array(null, $err); return array(null, $err);
} }
global $UCLOUD_PROXY_SUFFIX; global $UCLOUD_PROXY_SUFFIX;
$host = $bucket . $UCLOUD_PROXY_SUFFIX; $host = $bucket . $UCLOUD_PROXY_SUFFIX;
$path = $key; $path = $key;
$querys = array( $querys = array(
'uploadId' => $uploadId, 'uploadId' => $uploadId,
'newKey' => $newKey, 'newKey' => $newKey,
); );
$body = @implode(',', $etagList); $body = @implode(',', $etagList);
$req = new HTTP_Request('POST', array('host'=>$host, 'path'=>$path, 'query'=>$querys), $body, $bucket, $key); $req = new HTTP_Request('POST', array('host'=>$host, 'path'=>$path, 'query'=>$querys), $body, $bucket, $key);
$req->Header['Content-Type'] = 'text/plain'; $req->Header['Content-Type'] = 'text/plain';
$client = new UCloud_AuthHttpClient(null); $client = new UCloud_AuthHttpClient(null);
return UCloud_Client_Call($client, $req); return UCloud_Client_Call($client, $req);
} }
function UCloud_MCancel($bucket, $key, $uploadId) function UCloud_MCancel($bucket, $key, $uploadId)
{ {
$err = CheckConfig(ActionType::MCANCEL); $err = CheckConfig(ActionType::MCANCEL);
if ($err != null) { if ($err != null) {
return array(null, $err); return array(null, $err);
} }
global $UCLOUD_PROXY_SUFFIX; global $UCLOUD_PROXY_SUFFIX;
$host = $bucket . $UCLOUD_PROXY_SUFFIX; $host = $bucket . $UCLOUD_PROXY_SUFFIX;
$path = $key; $path = $key;
$querys = array( $querys = array(
'uploadId' => $uploadId 'uploadId' => $uploadId
); );
$req = new HTTP_Request('DELETE', array('host'=>$host, 'path'=>$path, 'query'=>$querys), null, $bucket, $key); $req = new HTTP_Request('DELETE', array('host'=>$host, 'path'=>$path, 'query'=>$querys), null, $bucket, $key);
$req->Header['Content-Type'] = 'application/x-www-form-urlencoded'; $req->Header['Content-Type'] = 'application/x-www-form-urlencoded';
$client = new UCloud_AuthHttpClient(null); $client = new UCloud_AuthHttpClient(null);
return UCloud_Client_Call($client, $req); return UCloud_Client_Call($client, $req);
} }
//------------------------------秒传------------------------------ //------------------------------秒传------------------------------
function UCloud_UploadHit($bucket, $key, $file) function UCloud_UploadHit($bucket, $key, $file)
{ {
$err = CheckConfig(ActionType::UPLOADHIT); $err = CheckConfig(ActionType::UPLOADHIT);
if ($err != null) { if ($err != null) {
return array(null, $err); return array(null, $err);
} }
$f = @fopen($file, "r"); $f = @fopen($file, "r");
if (!$f) return array(null, new UCloud_Error(-1, -1, "open $file error")); if (!$f) return array(null, new UCloud_Error(-1, -1, "open $file error"));
$content = ""; $content = "";
$fileSize = filesize($file); $fileSize = filesize($file);
if ($fileSize != 0) { if ($fileSize != 0) {
$content = @fread($f, $fileSize); $content = @fread($f, $fileSize);
if ($content == FALSE) { if ($content == FALSE) {
fclose($f); fclose($f);
return array(null, new UCloud_Error(0, -1, "read file error")); return array(null, new UCloud_Error(0, -1, "read file error"));
} }
} }
list($fileHash, $err) = UCloud_FileHash($file); list($fileHash, $err) = UCloud_FileHash($file);
if ($err) { if ($err) {
fclose($f); fclose($f);
return array(null, $err); return array(null, $err);
} }
fclose($f); fclose($f);
global $UCLOUD_PROXY_SUFFIX; global $UCLOUD_PROXY_SUFFIX;
$host = $bucket . $UCLOUD_PROXY_SUFFIX; $host = $bucket . $UCLOUD_PROXY_SUFFIX;
$path = "uploadhit"; $path = "uploadhit";
$querys = array( $querys = array(
'Hash' => $fileHash, 'Hash' => $fileHash,
'FileName' => $key, 'FileName' => $key,
'FileSize' => $fileSize 'FileSize' => $fileSize
); );
$req = new HTTP_Request('POST', array('host'=>$host, 'path'=>$path, 'query'=>$querys), null, $bucket, $key); $req = new HTTP_Request('POST', array('host'=>$host, 'path'=>$path, 'query'=>$querys), null, $bucket, $key);
$req->Header['Content-Type'] = 'application/x-www-form-urlencoded'; $req->Header['Content-Type'] = 'application/x-www-form-urlencoded';
$client = new UCloud_AuthHttpClient(null); $client = new UCloud_AuthHttpClient(null);
return UCloud_Client_Call($client, $req); return UCloud_Client_Call($client, $req);
} }
//------------------------------删除文件------------------------------ //------------------------------删除文件------------------------------
function UCloud_Delete($bucket, $key) function UCloud_Delete($bucket, $key)
{ {
$err = CheckConfig(ActionType::DELETE); $err = CheckConfig(ActionType::DELETE);
if ($err != null) { if ($err != null) {
return array(null, $err); return array(null, $err);
} }
global $UCLOUD_PROXY_SUFFIX; global $UCLOUD_PROXY_SUFFIX;
$host = $bucket . $UCLOUD_PROXY_SUFFIX; $host = $bucket . $UCLOUD_PROXY_SUFFIX;
$path = "$key"; $path = "$key";
$req = new HTTP_Request('DELETE', array('host'=>$host, 'path'=>$path), null, $bucket, $key); $req = new HTTP_Request('DELETE', array('host'=>$host, 'path'=>$path), null, $bucket, $key);
$req->Header['Content-Type'] = 'application/x-www-form-urlencoded'; $req->Header['Content-Type'] = 'application/x-www-form-urlencoded';
$client = new UCloud_AuthHttpClient(null); $client = new UCloud_AuthHttpClient(null);
return UCloud_Client_Call($client, $req); return UCloud_Client_Call($client, $req);
} }
//------------------------------追加上传------------------------------ //------------------------------Head文件------------------------------
function UCloud_AppendFile($bucket, $key, $file, $position) function UCloud_Head($bucket, $key)
{ {
$action_type = ActionType::APPENDFILE;
$err = CheckConfig(ActionType::APPENDFILE); $err = CheckConfig(ActionType::HEAD);
if ($err != null) { if ($err != null) {
return array(null, $err); return array(null, $err);
} }
$f = @fopen($file, "r"); global $UCLOUD_PROXY_SUFFIX;
if (!$f) return array(null, new UCloud_Error(-1, -1, "open $file error")); $host = $bucket . $UCLOUD_PROXY_SUFFIX;
$path = "$key";
global $UCLOUD_PROXY_SUFFIX;
$host = $bucket . $UCLOUD_PROXY_SUFFIX; $req = new HTTP_Request('HEAD', array('host'=>$host, 'path'=>$path), null, $bucket, $key);
$key = $key . "?append&position=" . $position; $req->Header['Content-Type'] = 'application/x-www-form-urlencoded';
$path = $key;
$content = @fread($f, filesize($file)); $client = new UCloud_AuthHttpClient(null);
list($mimetype, $err) = GetFileMimeType($file); return UCloud_Client_Call_ReHeader($client, $req);
if ($err) { }
fclose($f);
return array("", $err);
} //------------------------------追加上传------------------------------
$req = new HTTP_Request('PUT', array('host'=>$host, 'path'=>$path), $content, $bucket, $key, $action_type); function UCloud_AppendFile($bucket, $key, $file, $position)
$req->Header['Expect'] = ''; {
$req->Header['Content-Type'] = $mimetype; $action_type = ActionType::APPENDFILE;
$err = CheckConfig(ActionType::APPENDFILE);
$client = new UCloud_AuthHttpClient(null, $mimetype); if ($err != null) {
list($data, $err) = UCloud_Client_Call($client, $req); return array(null, $err);
fclose($f); }
return array($data, $err);
} $f = @fopen($file, "r");
if (!$f) return array(null, new UCloud_Error(-1, -1, "open $file error"));
//------------------------------列表目录------------------------------
function UCloud_ListObjects($bucket, $path_prefix, $marker, $count, $delimiter) global $UCLOUD_PROXY_SUFFIX;
{ $host = $bucket . $UCLOUD_PROXY_SUFFIX;
$action_type = ActionType::LISTOBJECTS; $key = $key . "?append&position=" . $position;
$err = CheckConfig(ActionType::LISTOBJECTS); $path = $key;
if ($err != null) { $content = @fread($f, filesize($file));
return array(null, $err); list($mimetype, $err) = GetFileMimeType($file);
} if ($err) {
fclose($f);
global $UCLOUD_PROXY_SUFFIX; return array("", $err);
$host = $bucket . $UCLOUD_PROXY_SUFFIX; }
$path = "?listobjects&prefix=" . $path_prefix ."&marker=". $marker . "&max-keys=" . $count ."&delimiter=" .$delimiter; $req = new HTTP_Request('PUT', array('host'=>$host, 'path'=>$path), $content, $bucket, $key, $action_type);
$req->Header['Expect'] = '';
$req = new HTTP_Request('GET', array('host'=>$host, 'path'=>$path), null, $bucket, null, $action_type); $req->Header['Content-Type'] = $mimetype;
$req->Header['Content-Type'] = 'application/x-www-form-urlencoded';
$client = new UCloud_AuthHttpClient(null, $mimetype);
$client = new UCloud_AuthHttpClient(null); list($data, $err) = UCloud_Client_Call($client, $req);
list($data, $err) = UCloud_Client_Call($client, $req); fclose($f);
return array($data, $err); return array($data, $err);
} }
//------------------------------生成公有文件Url------------------------------ //------------------------------列表目录------------------------------
// @results: $url function UCloud_ListObjects($bucket, $path_prefix, $marker, $count, $delimiter)
function UCloud_MakePublicUrl($bucket, $key) {
{ $action_type = ActionType::LISTOBJECTS;
global $UCLOUD_PROXY_SUFFIX; $err = CheckConfig(ActionType::LISTOBJECTS);
return $bucket . $UCLOUD_PROXY_SUFFIX . "/" . rawurlencode($key); if ($err != null) {
} return array(null, $err);
//------------------------------生成私有文件Url------------------------------ }
// @results: $url
function UCloud_MakePrivateUrl($bucket, $key, $expires = 0) global $UCLOUD_PROXY_SUFFIX;
{ $host = $bucket . $UCLOUD_PROXY_SUFFIX;
$path = "?listobjects&prefix=" . $path_prefix ."&marker=". $marker . "&max-keys=" . $count ."&delimiter=" .$delimiter;
$err = CheckConfig(ActionType::GETFILE);
if ($err != null) { $req = new HTTP_Request('GET', array('host'=>$host, 'path'=>$path), null, $bucket, null, $action_type);
return array(null, $err); $req->Header['Content-Type'] = 'application/x-www-form-urlencoded';
}
$client = new UCloud_AuthHttpClient(null);
global $UCLOUD_PUBLIC_KEY; list($data, $err) = UCloud_Client_Call($client, $req);
return array($data, $err);
$public_url = UCloud_MakePublicUrl($bucket, $key); }
$req = new HTTP_Request('GET', array('path'=>$public_url), null, $bucket, $key);
if ($expires > 0) { //------------------------------生成公有文件Url------------------------------
$req->Header['Expires'] = $expires; // @results: $url
} function UCloud_MakePublicUrl($bucket, $key)
{
$client = new UCloud_AuthHttpClient(null); global $UCLOUD_PROXY_SUFFIX;
$temp = $client->Auth->SignRequest($req, null, QUERY_STRING_CHECK); return $bucket . $UCLOUD_PROXY_SUFFIX . "/" . rawurlencode($key);
$signature = substr($temp, -28, 28); }
$url = $public_url . "?UCloudPublicKey=" . rawurlencode($UCLOUD_PUBLIC_KEY) . "&Signature=" . rawurlencode($signature); //------------------------------生成私有文件Url------------------------------
if ('' != $expires) { // @results: $url
$url .= "&Expires=" . rawurlencode($expires); function UCloud_MakePrivateUrl($bucket, $key, $expires = 0)
} {
return $url;
} $err = CheckConfig(ActionType::GETFILE);
if ($err != null) {
return array(null, $err);
}
global $UCLOUD_PUBLIC_KEY;
$public_url = UCloud_MakePublicUrl($bucket, $key);
$req = new HTTP_Request('GET', array('path'=>$public_url), null, $bucket, $key);
if ($expires > 0) {
$req->Header['Expires'] = $expires;
}
$client = new UCloud_AuthHttpClient(null);
$temp = $client->Auth->SignRequest($req, null, QUERY_STRING_CHECK);
$signature = substr($temp, -28, 28);
$url = $public_url . "?UCloudPublicKey=" . rawurlencode($UCLOUD_PUBLIC_KEY) . "&Signature=" . rawurlencode($signature);
if ('' != $expires) {
$url .= "&Expires=" . rawurlencode($expires);
}
return $url;
}

2
v1/ucloud/utils.php
View File

@ -18,6 +18,7 @@ abstract class ActionType
const GETFILE = 8; const GETFILE = 8;
const APPENDFILE = 9; const APPENDFILE = 9;
const LISTOBJECTS = 10; const LISTOBJECTS = 10;
const HEAD = 11;
} }
class UCloud_Error class UCloud_Error
@ -127,6 +128,7 @@ function CheckConfig($action) {
case ActionType::DELETE: case ActionType::DELETE:
case ActionType::UPLOADHIT: case ActionType::UPLOADHIT:
case ActionType::LISTOBJECTS: case ActionType::LISTOBJECTS:
case ActionType::HEAD:
if ($UCLOUD_PROXY_SUFFIX == "") { if ($UCLOUD_PROXY_SUFFIX == "") {
return new UCloud_Error(400, -1, "no proxy suffix found in config"); return new UCloud_Error(400, -1, "no proxy suffix found in config");
} else if ($UCLOUD_PUBLIC_KEY == "" || strstr($UCLOUD_PUBLIC_KEY, " ") != FALSE) { } else if ($UCLOUD_PUBLIC_KEY == "" || strstr($UCLOUD_PUBLIC_KEY, " ") != FALSE) {