12345678910111213141516171819202122232425262728293031323334353637383940414243444546474849505152535455565758596061626364656667686970717273747576777879808182838485868788899091929394959697989910010110210310410510610710810911011111211311411511611711811912012112212312412512612712812913013113213313413513613713813914014114214314414514614714814915015115215315415515615715815916016116216316416516616716816917017117217317417517617717817918018118218318418518618718818919019119219319419519619719819920020120220320420520620720820921021121221321421521621721821922022122222322422522622722822923023123223323423523623723823924024124224324424524624724824925025125225325425525625725825926026126226326426526626726826927027127227327427527627727827928028128228328428528628728828929029129229329429529629729829930030130230330430530630730830931031131231331431531631731831932032132232332432532632732832933033133233333433533633733833934034134234334434534634734834935035135235335435535635735835936036136236336436536636736836937037137237337437537637737837938038138238338438538638738838939039139239339439539639739839940040140240340440540640740840941041141241341441541641741841942042142242342442542642742842943043143243343443543643743843944044144244344444544644744844945045145245345445545645745845946046146246346446546646746846947047147247347447547647747847948048148248348448548648748848949049149249349449549649749849950050150250350450550650750850951051151251351451551651751851952052152252352452552652752852953053153253353453553653753853954054154254354454554654754854955055155255355455555655755855956056156256356456556656756856957057157257357457557657757857958058158258358458558658758858959059159259359459559659759859960060160260360460560660760860961061161261361461561661761861962062162262362462562662762862963063163263363463563663763863964064164264364464564664764864965065165265365465565665765865966066166266366466566666766866967067167267367467567667767867968068168268368468568668768868969069169269369469569669769869970070170270370470570670770870971071171271371471571671771871972072172272372472572672772872973073173273373473573673773873974074174274374474574674774874975075175275375475575675775875976076176276376476576676776876977077177277377477577677777877978078178278378478578678778878979079179279379479579679779879980080180280380480580680780880981081181281381481581681781881982082182282382482582682782882983083183283383483583683783883984084184284384484584684784884985085185285385485585685785885986086186286386486586686786886987087187287387487587687787887988088188288388488588688788888989089189289389489589689789889990090190290390490590690790890991091191291391491591691791891992092192292392492592692792892993093193293393493593693793893994094194294394494594694794894995095195295395495595695795895996096196296396496596696796896997097197297397497597697797897998098198298398498598698798898999099199299399499599699799899910001001100210031004100510061007100810091010101110121013101410151016101710181019102010211022102310241025102610271028102910301031103210331034103510361037103810391040104110421043104410451046104710481049105010511052105310541055105610571058105910601061106210631064106510661067106810691070107110721073107410751076107710781079108010811082108310841085108610871088108910901091109210931094109510961097109810991100110111021103110411051106110711081109111011111112111311141115111611171118111911201121112211231124112511261127112811291130113111321133113411351136113711381139114011411142114311441145114611471148114911501151115211531154115511561157115811591160116111621163116411651166116711681169117011711172117311741175117611771178117911801181118211831184118511861187118811891190119111921193119411951196119711981199120012011202120312041205120612071208120912101211121212131214121512161217121812191220122112221223122412251226122712281229123012311232123312341235123612371238123912401241124212431244124512461247124812491250125112521253125412551256125712581259126012611262126312641265126612671268126912701271127212731274127512761277127812791280128112821283128412851286128712881289129012911292129312941295129612971298129913001301130213031304130513061307130813091310131113121313131413151316131713181319132013211322132313241325132613271328132913301331133213331334133513361337133813391340134113421343134413451346134713481349135013511352135313541355135613571358135913601361136213631364136513661367136813691370137113721373137413751376137713781379138013811382138313841385138613871388138913901391139213931394139513961397139813991400140114021403140414051406140714081409141014111412141314141415141614171418141914201421142214231424142514261427142814291430143114321433143414351436143714381439144014411442144314441445144614471448144914501451145214531454145514561457145814591460146114621463146414651466146714681469147014711472147314741475147614771478147914801481148214831484148514861487148814891490149114921493149414951496149714981499150015011502150315041505150615071508150915101511151215131514151515161517151815191520152115221523152415251526152715281529153015311532153315341535153615371538153915401541154215431544154515461547154815491550155115521553155415551556155715581559156015611562156315641565156615671568156915701571157215731574157515761577157815791580158115821583158415851586158715881589159015911592159315941595159615971598159916001601160216031604160516061607160816091610161116121613161416151616161716181619162016211622162316241625162616271628162916301631163216331634163516361637163816391640164116421643164416451646164716481649165016511652165316541655165616571658165916601661166216631664166516661667166816691670167116721673167416751676167716781679168016811682168316841685168616871688168916901691169216931694169516961697169816991700170117021703170417051706170717081709171017111712171317141715171617171718171917201721172217231724172517261727172817291730173117321733173417351736173717381739174017411742174317441745174617471748174917501751175217531754175517561757175817591760176117621763176417651766176717681769177017711772177317741775177617771778177917801781178217831784178517861787178817891790179117921793179417951796179717981799180018011802180318041805180618071808180918101811181218131814181518161817181818191820182118221823182418251826182718281829183018311832183318341835183618371838183918401841184218431844184518461847184818491850185118521853185418551856185718581859186018611862186318641865186618671868186918701871187218731874187518761877187818791880188118821883188418851886188718881889189018911892189318941895189618971898189919001901190219031904190519061907190819091910191119121913191419151916191719181919192019211922192319241925192619271928192919301931193219331934193519361937193819391940194119421943194419451946194719481949195019511952195319541955195619571958195919601961196219631964196519661967196819691970197119721973197419751976197719781979198019811982198319841985198619871988198919901991199219931994199519961997199819992000200120022003200420052006200720082009201020112012201320142015201620172018201920202021202220232024202520262027202820292030203120322033203420352036203720382039204020412042204320442045204620472048204920502051205220532054205520562057205820592060206120622063206420652066206720682069207020712072207320742075207620772078207920802081208220832084208520862087208820892090209120922093209420952096209720982099210021012102210321042105210621072108210921102111211221132114211521162117211821192120212121222123212421252126212721282129213021312132213321342135213621372138213921402141214221432144214521462147214821492150215121522153215421552156215721582159216021612162216321642165216621672168216921702171217221732174217521762177217821792180218121822183218421852186218721882189219021912192219321942195219621972198219922002201220222032204220522062207220822092210221122122213221422152216221722182219222022212222222322242225222622272228222922302231223222332234223522362237223822392240224122422243224422452246224722482249225022512252225322542255225622572258225922602261226222632264226522662267226822692270 |
- // Bucket test
- package oss
- import (
- "bytes"
- "encoding/base64"
- "errors"
- "fmt"
- "io"
- "io/ioutil"
- "math/rand"
- "net/http"
- "os"
- "path/filepath"
- "strconv"
- "strings"
- "time"
- "github.com/baiyubin/aliyun-sts-go-sdk/sts"
- . "gopkg.in/check.v1"
- )
- type OssBucketSuite struct {
- client *Client
- bucket *Bucket
- archiveBucket *Bucket
- }
- var _ = Suite(&OssBucketSuite{})
- var (
- pastDate = time.Date(2009, time.November, 10, 23, 0, 0, 0, time.UTC)
- futureDate = time.Date(2049, time.January, 10, 23, 0, 0, 0, time.UTC)
- )
- // SetUpSuite runs once when the suite starts running.
- func (s *OssBucketSuite) SetUpSuite(c *C) {
- client, err := New(endpoint, accessID, accessKey)
- c.Assert(err, IsNil)
- s.client = client
- s.client.CreateBucket(bucketName)
- err = s.client.CreateBucket(archiveBucketName, StorageClass(StorageArchive))
- c.Assert(err, IsNil)
- time.Sleep(5 * time.Second)
- bucket, err := s.client.Bucket(bucketName)
- c.Assert(err, IsNil)
- s.bucket = bucket
- archiveBucket, err := s.client.Bucket(archiveBucketName)
- c.Assert(err, IsNil)
- s.archiveBucket = archiveBucket
- testLogger.Println("test bucket started")
- }
- // TearDownSuite runs before each test or benchmark starts running.
- func (s *OssBucketSuite) TearDownSuite(c *C) {
- for _, bucket := range []*Bucket{s.bucket, s.archiveBucket} {
- // Delete multipart
- lmu, err := bucket.ListMultipartUploads()
- c.Assert(err, IsNil)
- for _, upload := range lmu.Uploads {
- imur := InitiateMultipartUploadResult{Bucket: bucketName, Key: upload.Key, UploadID: upload.UploadID}
- err = bucket.AbortMultipartUpload(imur)
- c.Assert(err, IsNil)
- }
- // Delete objects
- lor, err := bucket.ListObjects()
- c.Assert(err, IsNil)
- for _, object := range lor.Objects {
- err = bucket.DeleteObject(object.Key)
- c.Assert(err, IsNil)
- }
- }
- testLogger.Println("test bucket completed")
- }
- // SetUpTest runs after each test or benchmark runs.
- func (s *OssBucketSuite) SetUpTest(c *C) {
- err := removeTempFiles("../oss", ".jpg")
- c.Assert(err, IsNil)
- }
- // TearDownTest runs once after all tests or benchmarks have finished running.
- func (s *OssBucketSuite) TearDownTest(c *C) {
- err := removeTempFiles("../oss", ".jpg")
- c.Assert(err, IsNil)
- err = removeTempFiles("../oss", ".txt")
- c.Assert(err, IsNil)
- err = removeTempFiles("../oss", ".temp")
- c.Assert(err, IsNil)
- err = removeTempFiles("../oss", ".txt1")
- c.Assert(err, IsNil)
- err = removeTempFiles("../oss", ".txt2")
- c.Assert(err, IsNil)
- }
- // TestPutObject
- func (s *OssBucketSuite) TestPutObject(c *C) {
- objectName := objectNamePrefix + "tpo"
- objectValue := "大江东去,浪淘尽,千古风流人物。 故垒西边,人道是、三国周郎赤壁。 乱石穿空,惊涛拍岸,卷起千堆雪。 江山如画,一时多少豪杰。" +
- "遥想公谨当年,小乔初嫁了,雄姿英发。 羽扇纶巾,谈笑间、樯橹灰飞烟灭。故国神游,多情应笑我,早生华发,人生如梦,一尊还酹江月。"
- // Put string
- err := s.bucket.PutObject(objectName, strings.NewReader(objectValue))
- c.Assert(err, IsNil)
- // Check
- body, err := s.bucket.GetObject(objectName)
- c.Assert(err, IsNil)
- str, err := readBody(body)
- c.Assert(err, IsNil)
- c.Assert(str, Equals, objectValue)
- acl, err := s.bucket.GetObjectACL(objectName)
- c.Assert(err, IsNil)
- testLogger.Println("aclRes:", acl)
- c.Assert(acl.ACL, Equals, "default")
- err = s.bucket.DeleteObject(objectName)
- c.Assert(err, IsNil)
- // Put bytes
- err = s.bucket.PutObject(objectName, bytes.NewReader([]byte(objectValue)))
- c.Assert(err, IsNil)
- // Check
- body, err = s.bucket.GetObject(objectName)
- c.Assert(err, IsNil)
- str, err = readBody(body)
- c.Assert(err, IsNil)
- c.Assert(str, Equals, objectValue)
- err = s.bucket.DeleteObject(objectName)
- c.Assert(err, IsNil)
- // Put file
- err = createFileAndWrite(objectName+".txt", []byte(objectValue))
- c.Assert(err, IsNil)
- fd, err := os.Open(objectName + ".txt")
- c.Assert(err, IsNil)
- err = s.bucket.PutObject(objectName, fd)
- c.Assert(err, IsNil)
- os.Remove(objectName + ".txt")
- // Check
- body, err = s.bucket.GetObject(objectName)
- c.Assert(err, IsNil)
- str, err = readBody(body)
- c.Assert(err, IsNil)
- c.Assert(str, Equals, objectValue)
- err = s.bucket.DeleteObject(objectName)
- c.Assert(err, IsNil)
- // Put with properties
- objectName = objectNamePrefix + "tpox"
- options := []Option{
- Expires(futureDate),
- ObjectACL(ACLPublicRead),
- Meta("myprop", "mypropval"),
- }
- err = s.bucket.PutObject(objectName, strings.NewReader(objectValue), options...)
- c.Assert(err, IsNil)
- // Check
- body, err = s.bucket.GetObject(objectName)
- c.Assert(err, IsNil)
- str, err = readBody(body)
- c.Assert(err, IsNil)
- c.Assert(str, Equals, objectValue)
- acl, err = s.bucket.GetObjectACL(objectName)
- c.Assert(err, IsNil)
- testLogger.Println("GetObjectACL:", acl)
- c.Assert(acl.ACL, Equals, string(ACLPublicRead))
- meta, err := s.bucket.GetObjectDetailedMeta(objectName)
- c.Assert(err, IsNil)
- testLogger.Println("GetObjectDetailedMeta:", meta)
- c.Assert(meta.Get("X-Oss-Meta-Myprop"), Equals, "mypropval")
- err = s.bucket.DeleteObject(objectName)
- c.Assert(err, IsNil)
- }
- func (s *OssBucketSuite) TestSignURL(c *C) {
- objectName := objectNamePrefix + randStr(5)
- objectValue := randStr(20)
- filePath := randLowStr(10)
- content := "复写object"
- createFile(filePath, content, c)
- notExistfilePath := randLowStr(10)
- os.Remove(notExistfilePath)
- // Sign URL for put
- str, err := s.bucket.SignURL(objectName, HTTPPut, 60)
- c.Assert(err, IsNil)
- c.Assert(strings.Contains(str, HTTPParamExpires+"="), Equals, true)
- c.Assert(strings.Contains(str, HTTPParamAccessKeyID+"="), Equals, true)
- c.Assert(strings.Contains(str, HTTPParamSignature+"="), Equals, true)
- // Error put object with URL
- err = s.bucket.PutObjectWithURL(str, strings.NewReader(objectValue), ContentType("image/tiff"))
- c.Assert(err, NotNil)
- c.Assert(err.(ServiceError).Code, Equals, "SignatureDoesNotMatch")
- err = s.bucket.PutObjectFromFileWithURL(str, filePath, ContentType("image/tiff"))
- c.Assert(err, NotNil)
- c.Assert(err.(ServiceError).Code, Equals, "SignatureDoesNotMatch")
- // Put object with URL
- err = s.bucket.PutObjectWithURL(str, strings.NewReader(objectValue))
- c.Assert(err, IsNil)
- acl, err := s.bucket.GetObjectACL(objectName)
- c.Assert(err, IsNil)
- c.Assert(acl.ACL, Equals, "default")
- // Get object meta
- meta, err := s.bucket.GetObjectDetailedMeta(objectName)
- c.Assert(err, IsNil)
- c.Assert(meta.Get(HTTPHeaderContentType), Equals, "application/octet-stream")
- c.Assert(meta.Get("X-Oss-Meta-Myprop"), Equals, "")
- // Sign URL for function GetObjectWithURL
- str, err = s.bucket.SignURL(objectName, HTTPGet, 60)
- c.Assert(err, IsNil)
- c.Assert(strings.Contains(str, HTTPParamExpires+"="), Equals, true)
- c.Assert(strings.Contains(str, HTTPParamAccessKeyID+"="), Equals, true)
- c.Assert(strings.Contains(str, HTTPParamSignature+"="), Equals, true)
- // Get object with URL
- body, err := s.bucket.GetObjectWithURL(str)
- c.Assert(err, IsNil)
- str, err = readBody(body)
- c.Assert(err, IsNil)
- c.Assert(str, Equals, objectValue)
- // Sign URL for function PutObjectWithURL
- options := []Option{
- ObjectACL(ACLPublicRead),
- Meta("myprop", "mypropval"),
- ContentType("image/tiff"),
- ResponseContentEncoding("deflate"),
- }
- str, err = s.bucket.SignURL(objectName, HTTPPut, 60, options...)
- c.Assert(err, IsNil)
- c.Assert(strings.Contains(str, HTTPParamExpires+"="), Equals, true)
- c.Assert(strings.Contains(str, HTTPParamAccessKeyID+"="), Equals, true)
- c.Assert(strings.Contains(str, HTTPParamSignature+"="), Equals, true)
- // Put object with URL from file
- // Without option, error
- err = s.bucket.PutObjectWithURL(str, strings.NewReader(objectValue))
- c.Assert(err, NotNil)
- c.Assert(err.(ServiceError).Code, Equals, "SignatureDoesNotMatch")
- err = s.bucket.PutObjectFromFileWithURL(str, filePath)
- c.Assert(err, NotNil)
- c.Assert(err.(ServiceError).Code, Equals, "SignatureDoesNotMatch")
- // With option, error file
- err = s.bucket.PutObjectFromFileWithURL(str, notExistfilePath, options...)
- c.Assert(err, NotNil)
- // With option
- err = s.bucket.PutObjectFromFileWithURL(str, filePath, options...)
- c.Assert(err, IsNil)
- // Get object meta
- meta, err = s.bucket.GetObjectDetailedMeta(objectName)
- c.Assert(err, IsNil)
- c.Assert(meta.Get("X-Oss-Meta-Myprop"), Equals, "mypropval")
- c.Assert(meta.Get(HTTPHeaderContentType), Equals, "image/tiff")
- acl, err = s.bucket.GetObjectACL(objectName)
- c.Assert(err, IsNil)
- c.Assert(acl.ACL, Equals, string(ACLPublicRead))
- // Sign URL for function GetObjectToFileWithURL
- str, err = s.bucket.SignURL(objectName, HTTPGet, 60)
- c.Assert(err, IsNil)
- // Get object to file with URL
- newFile := randStr(10)
- err = s.bucket.GetObjectToFileWithURL(str, newFile)
- c.Assert(err, IsNil)
- eq, err := compareFiles(filePath, newFile)
- c.Assert(err, IsNil)
- c.Assert(eq, Equals, true)
- os.Remove(newFile)
- // Get object to file error
- err = s.bucket.GetObjectToFileWithURL(str, newFile, options...)
- c.Assert(err, NotNil)
- c.Assert(err.(ServiceError).Code, Equals, "SignatureDoesNotMatch")
- _, err = os.Stat(newFile)
- c.Assert(err, NotNil)
- // Get object error
- body, err = s.bucket.GetObjectWithURL(str, options...)
- c.Assert(err, NotNil)
- c.Assert(err.(ServiceError).Code, Equals, "SignatureDoesNotMatch")
- c.Assert(body, IsNil)
- // Sign URL for function GetObjectToFileWithURL
- options = []Option{
- Expires(futureDate),
- ObjectACL(ACLPublicRead),
- Meta("myprop", "mypropval"),
- ContentType("image/tiff"),
- ResponseContentEncoding("deflate"),
- }
- str, err = s.bucket.SignURL(objectName, HTTPGet, 60, options...)
- c.Assert(err, IsNil)
- // Get object to file with URL and options
- err = s.bucket.GetObjectToFileWithURL(str, newFile, options...)
- c.Assert(err, IsNil)
- eq, err = compareFiles(filePath, newFile)
- c.Assert(err, IsNil)
- c.Assert(eq, Equals, true)
- os.Remove(newFile)
- // Get object to file error
- err = s.bucket.GetObjectToFileWithURL(str, newFile)
- c.Assert(err, NotNil)
- c.Assert(err.(ServiceError).Code, Equals, "SignatureDoesNotMatch")
- _, err = os.Stat(newFile)
- c.Assert(err, NotNil)
- // Get object error
- body, err = s.bucket.GetObjectWithURL(str)
- c.Assert(err, NotNil)
- c.Assert(err.(ServiceError).Code, Equals, "SignatureDoesNotMatch")
- c.Assert(body, IsNil)
- err = s.bucket.PutObjectFromFile(objectName, "../sample/The Go Programming Language.html")
- c.Assert(err, IsNil)
- str, err = s.bucket.SignURL(objectName, HTTPGet, 3600, AcceptEncoding("gzip"))
- c.Assert(err, IsNil)
- s.bucket.GetObjectToFileWithURL(str, newFile)
- c.Assert(err, IsNil)
- os.Remove(filePath)
- os.Remove(newFile)
- // Sign URL error
- str, err = s.bucket.SignURL(objectName, HTTPGet, -1)
- c.Assert(err, NotNil)
- err = s.bucket.DeleteObject(objectName)
- c.Assert(err, IsNil)
- // Invalid URL parse
- str = randStr(20)
- err = s.bucket.PutObjectWithURL(str, strings.NewReader(objectValue))
- c.Assert(err, NotNil)
- err = s.bucket.GetObjectToFileWithURL(str, newFile)
- c.Assert(err, NotNil)
- }
- func (s *OssBucketSuite) TestSignURLWithEscapedKey(c *C) {
- // Key with '/'
- objectName := "zyimg/86/e8/653b5dc97bb0022051a84c632bc4"
- objectValue := "弃我去者,昨日之日不可留;乱我心者,今日之日多烦忧。长风万里送秋雁,对此可以酣高楼。蓬莱文章建安骨,中间小谢又清发。" +
- "俱怀逸兴壮思飞,欲上青天揽明月。抽刀断水水更流,举杯销愁愁更愁。人生在世不称意,明朝散发弄扁舟。"
- // Sign URL for function PutObjectWithURL
- str, err := s.bucket.SignURL(objectName, HTTPPut, 60)
- c.Assert(err, IsNil)
- c.Assert(strings.Contains(str, HTTPParamExpires+"="), Equals, true)
- c.Assert(strings.Contains(str, HTTPParamAccessKeyID+"="), Equals, true)
- c.Assert(strings.Contains(str, HTTPParamSignature+"="), Equals, true)
- // Put object with URL
- err = s.bucket.PutObjectWithURL(str, strings.NewReader(objectValue))
- c.Assert(err, IsNil)
- // Sign URL for function GetObjectWithURL
- str, err = s.bucket.SignURL(objectName, HTTPGet, 60)
- c.Assert(err, IsNil)
- c.Assert(strings.Contains(str, HTTPParamExpires+"="), Equals, true)
- c.Assert(strings.Contains(str, HTTPParamAccessKeyID+"="), Equals, true)
- c.Assert(strings.Contains(str, HTTPParamSignature+"="), Equals, true)
- // Get object with URL
- body, err := s.bucket.GetObjectWithURL(str)
- c.Assert(err, IsNil)
- str, err = readBody(body)
- c.Assert(err, IsNil)
- c.Assert(str, Equals, objectValue)
- // Key with escaped chars
- objectName = "<>[]()`?.,!@#$%^&'/*-_=+~:;"
- // Sign URL for funciton PutObjectWithURL
- str, err = s.bucket.SignURL(objectName, HTTPPut, 60)
- c.Assert(err, IsNil)
- c.Assert(strings.Contains(str, HTTPParamExpires+"="), Equals, true)
- c.Assert(strings.Contains(str, HTTPParamAccessKeyID+"="), Equals, true)
- c.Assert(strings.Contains(str, HTTPParamSignature+"="), Equals, true)
- // Put object with URL
- err = s.bucket.PutObjectWithURL(str, strings.NewReader(objectValue))
- c.Assert(err, IsNil)
- // Sign URL for function GetObjectWithURL
- str, err = s.bucket.SignURL(objectName, HTTPGet, 60)
- c.Assert(err, IsNil)
- c.Assert(strings.Contains(str, HTTPParamExpires+"="), Equals, true)
- c.Assert(strings.Contains(str, HTTPParamAccessKeyID+"="), Equals, true)
- c.Assert(strings.Contains(str, HTTPParamSignature+"="), Equals, true)
- // Get object with URL
- body, err = s.bucket.GetObjectWithURL(str)
- c.Assert(err, IsNil)
- str, err = readBody(body)
- c.Assert(err, IsNil)
- c.Assert(str, Equals, objectValue)
- // Key with Chinese chars
- objectName = "风吹柳花满店香,吴姬压酒劝客尝。金陵子弟来相送,欲行不行各尽觞。请君试问东流水,别意与之谁短长。"
- // Sign URL for function PutObjectWithURL
- str, err = s.bucket.SignURL(objectName, HTTPPut, 60)
- c.Assert(err, IsNil)
- c.Assert(strings.Contains(str, HTTPParamExpires+"="), Equals, true)
- c.Assert(strings.Contains(str, HTTPParamAccessKeyID+"="), Equals, true)
- c.Assert(strings.Contains(str, HTTPParamSignature+"="), Equals, true)
- // Put object with URL
- err = s.bucket.PutObjectWithURL(str, strings.NewReader(objectValue))
- c.Assert(err, IsNil)
- // Sign URL for get function GetObjectWithURL
- str, err = s.bucket.SignURL(objectName, HTTPGet, 60)
- c.Assert(err, IsNil)
- c.Assert(strings.Contains(str, HTTPParamExpires+"="), Equals, true)
- c.Assert(strings.Contains(str, HTTPParamAccessKeyID+"="), Equals, true)
- c.Assert(strings.Contains(str, HTTPParamSignature+"="), Equals, true)
- // Get object with URL
- body, err = s.bucket.GetObjectWithURL(str)
- c.Assert(err, IsNil)
- str, err = readBody(body)
- c.Assert(err, IsNil)
- c.Assert(str, Equals, objectValue)
- // Key
- objectName = "test/此情无计可消除/才下眉头/却上 心头/。,;:‘’“”?()『』【】《》!@#¥%……&×/test+ =-_*&^%$#@!`~[]{}()<>|\\/?.,;.txt"
- // Sign URL for function PutObjectWithURL
- str, err = s.bucket.SignURL(objectName, HTTPPut, 60)
- c.Assert(err, IsNil)
- // Put object with URL
- err = s.bucket.PutObjectWithURL(str, strings.NewReader(objectValue))
- c.Assert(err, IsNil)
- // Sign URL for function GetObjectWithURL
- str, err = s.bucket.SignURL(objectName, HTTPGet, 60)
- c.Assert(err, IsNil)
- // Get object with URL
- body, err = s.bucket.GetObjectWithURL(str)
- c.Assert(err, IsNil)
- str, err = readBody(body)
- c.Assert(err, IsNil)
- c.Assert(str, Equals, objectValue)
- // Put object
- err = s.bucket.PutObject(objectName, bytes.NewReader([]byte(objectValue)))
- c.Assert(err, IsNil)
- // Get object
- body, err = s.bucket.GetObject(objectName)
- c.Assert(err, IsNil)
- str, err = readBody(body)
- c.Assert(err, IsNil)
- c.Assert(str, Equals, objectValue)
- // Delete object
- err = s.bucket.DeleteObject(objectName)
- c.Assert(err, IsNil)
- }
- func (s *OssBucketSuite) TestSignURLWithEscapedKeyAndPorxy(c *C) {
- // Key with '/'
- objectName := "zyimg/86/e8/653b5dc97bb0022051a84c632bc4"
- objectValue := "弃我去者,昨日之日不可留;乱我心者,今日之日多烦忧。长风万里送秋雁,对此可以酣高楼。蓬莱文章建安骨,中间小谢又清发。" +
- "俱怀逸兴壮思飞,欲上青天揽明月。抽刀断水水更流,举杯销愁愁更愁。人生在世不称意,明朝散发弄扁舟。"
- client, err := New(endpoint, accessID, accessKey, AuthProxy(proxyHost, proxyUser, proxyPasswd))
- bucket, err := client.Bucket(bucketName)
- // Sign URL for put
- str, err := bucket.SignURL(objectName, HTTPPut, 60)
- c.Assert(err, IsNil)
- c.Assert(strings.Contains(str, HTTPParamExpires+"="), Equals, true)
- c.Assert(strings.Contains(str, HTTPParamAccessKeyID+"="), Equals, true)
- c.Assert(strings.Contains(str, HTTPParamSignature+"="), Equals, true)
- // Put object with URL
- err = bucket.PutObjectWithURL(str, strings.NewReader(objectValue))
- c.Assert(err, IsNil)
- // Sign URL for function GetObjectWithURL
- str, err = bucket.SignURL(objectName, HTTPGet, 60)
- c.Assert(err, IsNil)
- c.Assert(strings.Contains(str, HTTPParamExpires+"="), Equals, true)
- c.Assert(strings.Contains(str, HTTPParamAccessKeyID+"="), Equals, true)
- c.Assert(strings.Contains(str, HTTPParamSignature+"="), Equals, true)
- // Get object with URL
- body, err := bucket.GetObjectWithURL(str)
- c.Assert(err, IsNil)
- str, err = readBody(body)
- c.Assert(err, IsNil)
- c.Assert(str, Equals, objectValue)
- // Key with Chinese chars
- objectName = "test/此情无计可消除/才下眉头/却上 心头/。,;:‘’“”?()『』【】《》!@#¥%……&×/test+ =-_*&^%$#@!`~[]{}()<>|\\/?.,;.txt"
- // Sign URL for function PutObjectWithURL
- str, err = bucket.SignURL(objectName, HTTPPut, 60)
- c.Assert(err, IsNil)
- // Put object with URL
- err = bucket.PutObjectWithURL(str, strings.NewReader(objectValue))
- c.Assert(err, IsNil)
- // Sign URL for function GetObjectWithURL
- str, err = bucket.SignURL(objectName, HTTPGet, 60)
- c.Assert(err, IsNil)
- // Get object with URL
- body, err = bucket.GetObjectWithURL(str)
- c.Assert(err, IsNil)
- str, err = readBody(body)
- c.Assert(err, IsNil)
- c.Assert(str, Equals, objectValue)
- // Put object
- err = bucket.PutObject(objectName, bytes.NewReader([]byte(objectValue)))
- c.Assert(err, IsNil)
- // Get object
- body, err = bucket.GetObject(objectName)
- c.Assert(err, IsNil)
- str, err = readBody(body)
- c.Assert(err, IsNil)
- c.Assert(str, Equals, objectValue)
- // Delete object
- err = bucket.DeleteObject(objectName)
- c.Assert(err, IsNil)
- }
- // TestPutObjectType
- func (s *OssBucketSuite) TestPutObjectType(c *C) {
- objectName := objectNamePrefix + "tptt"
- objectValue := "乱石穿空,惊涛拍岸,卷起千堆雪。 江山如画,一时多少豪杰。"
- // Put
- err := s.bucket.PutObject(objectName, strings.NewReader(objectValue))
- c.Assert(err, IsNil)
- // Check
- time.Sleep(time.Second)
- body, err := s.bucket.GetObject(objectName)
- c.Assert(err, IsNil)
- str, err := readBody(body)
- c.Assert(err, IsNil)
- c.Assert(str, Equals, objectValue)
- meta, err := s.bucket.GetObjectDetailedMeta(objectName)
- c.Assert(err, IsNil)
- c.Assert(meta.Get("Content-Type"), Equals, "application/octet-stream")
- err = s.bucket.DeleteObject(objectName)
- c.Assert(err, IsNil)
- // Put
- err = s.bucket.PutObject(objectName+".txt", strings.NewReader(objectValue))
- c.Assert(err, IsNil)
- meta, err = s.bucket.GetObjectDetailedMeta(objectName + ".txt")
- c.Assert(err, IsNil)
- c.Assert(meta.Get("Content-Type"), Equals, "text/plain; charset=utf-8")
- err = s.bucket.DeleteObject(objectName + ".txt")
- c.Assert(err, IsNil)
- // Put
- err = s.bucket.PutObject(objectName+".apk", strings.NewReader(objectValue))
- c.Assert(err, IsNil)
- meta, err = s.bucket.GetObjectDetailedMeta(objectName + ".apk")
- c.Assert(err, IsNil)
- c.Assert(meta.Get("Content-Type"), Equals, "application/vnd.android.package-archive")
- err = s.bucket.DeleteObject(objectName + ".txt")
- c.Assert(err, IsNil)
- }
- // TestPutObject
- func (s *OssBucketSuite) TestPutObjectKeyChars(c *C) {
- objectName := objectNamePrefix + "tpokc"
- objectValue := "白日依山尽,黄河入海流。欲穷千里目,更上一层楼。"
- // Put
- objectKey := objectName + "十步杀一人,千里不留行。事了拂衣去,深藏身与名"
- err := s.bucket.PutObject(objectKey, strings.NewReader(objectValue))
- c.Assert(err, IsNil)
- // Check
- body, err := s.bucket.GetObject(objectKey)
- c.Assert(err, IsNil)
- str, err := readBody(body)
- c.Assert(err, IsNil)
- c.Assert(str, Equals, objectValue)
- err = s.bucket.DeleteObject(objectKey)
- c.Assert(err, IsNil)
- // Put
- objectKey = objectName + "ごきげん如何ですかおれの顔をよく拝んでおけ"
- err = s.bucket.PutObject(objectKey, strings.NewReader(objectValue))
- c.Assert(err, IsNil)
- // Check
- body, err = s.bucket.GetObject(objectKey)
- c.Assert(err, IsNil)
- str, err = readBody(body)
- c.Assert(err, IsNil)
- c.Assert(str, Equals, objectValue)
- err = s.bucket.DeleteObject(objectKey)
- c.Assert(err, IsNil)
- // Put
- objectKey = objectName + "~!@#$%^&*()_-+=|\\[]{}<>,./?"
- err = s.bucket.PutObject(objectKey, strings.NewReader(objectValue))
- c.Assert(err, IsNil)
- // Check
- body, err = s.bucket.GetObject(objectKey)
- c.Assert(err, IsNil)
- str, err = readBody(body)
- c.Assert(err, IsNil)
- c.Assert(str, Equals, objectValue)
- err = s.bucket.DeleteObject(objectKey)
- c.Assert(err, IsNil)
- // Put
- objectKey = "go/中国 日本 +-#&=*"
- err = s.bucket.PutObject(objectKey, strings.NewReader(objectValue))
- c.Assert(err, IsNil)
- // Check
- body, err = s.bucket.GetObject(objectKey)
- c.Assert(err, IsNil)
- str, err = readBody(body)
- c.Assert(err, IsNil)
- c.Assert(str, Equals, objectValue)
- err = s.bucket.DeleteObject(objectKey)
- c.Assert(err, IsNil)
- }
- // TestPutObjectNegative
- func (s *OssBucketSuite) TestPutObjectNegative(c *C) {
- objectName := objectNamePrefix + "tpon"
- objectValue := "大江东去,浪淘尽,千古风流人物。 "
- // Put
- objectName = objectNamePrefix + "tpox"
- err := s.bucket.PutObject(objectName, strings.NewReader(objectValue),
- Meta("meta-my", "myprop"))
- c.Assert(err, IsNil)
- // Check meta
- body, err := s.bucket.GetObject(objectName)
- c.Assert(err, IsNil)
- str, err := readBody(body)
- c.Assert(err, IsNil)
- c.Assert(str, Equals, objectValue)
- meta, err := s.bucket.GetObjectDetailedMeta(objectName)
- c.Assert(err, IsNil)
- c.Assert(meta.Get("X-Oss-Meta-My"), Not(Equals), "myprop")
- c.Assert(meta.Get("X-Oss-Meta-My"), Equals, "")
- err = s.bucket.DeleteObject(objectName)
- c.Assert(err, IsNil)
- // Invalid option
- err = s.bucket.PutObject(objectName, strings.NewReader(objectValue),
- IfModifiedSince(pastDate))
- c.Assert(err, NotNil)
- err = s.bucket.PutObjectFromFile(objectName, "bucket.go", IfModifiedSince(pastDate))
- c.Assert(err, NotNil)
- err = s.bucket.PutObjectFromFile(objectName, "/tmp/xxx")
- c.Assert(err, NotNil)
- }
- // TestPutObjectFromFile
- func (s *OssBucketSuite) TestPutObjectFromFile(c *C) {
- objectName := objectNamePrefix + "tpoff"
- localFile := "../sample/BingWallpaper-2015-11-07.jpg"
- newFile := "newpic11.jpg"
- // Put
- err := s.bucket.PutObjectFromFile(objectName, localFile)
- c.Assert(err, IsNil)
- // Check
- err = s.bucket.GetObjectToFile(objectName, newFile)
- c.Assert(err, IsNil)
- eq, err := compareFiles(localFile, newFile)
- c.Assert(err, IsNil)
- c.Assert(eq, Equals, true)
- acl, err := s.bucket.GetObjectACL(objectName)
- c.Assert(err, IsNil)
- testLogger.Println("aclRes:", acl)
- c.Assert(acl.ACL, Equals, "default")
- err = s.bucket.DeleteObject(objectName)
- c.Assert(err, IsNil)
- // Put with properties
- options := []Option{
- Expires(futureDate),
- ObjectACL(ACLPublicRead),
- Meta("myprop", "mypropval"),
- }
- os.Remove(newFile)
- err = s.bucket.PutObjectFromFile(objectName, localFile, options...)
- c.Assert(err, IsNil)
- // Check
- err = s.bucket.GetObjectToFile(objectName, newFile)
- c.Assert(err, IsNil)
- eq, err = compareFiles(localFile, newFile)
- c.Assert(err, IsNil)
- c.Assert(eq, Equals, true)
- acl, err = s.bucket.GetObjectACL(objectName)
- c.Assert(err, IsNil)
- testLogger.Println("GetObjectACL:", acl)
- c.Assert(acl.ACL, Equals, string(ACLPublicRead))
- meta, err := s.bucket.GetObjectDetailedMeta(objectName)
- c.Assert(err, IsNil)
- testLogger.Println("GetObjectDetailedMeta:", meta)
- c.Assert(meta.Get("X-Oss-Meta-Myprop"), Equals, "mypropval")
- err = s.bucket.DeleteObject(objectName)
- c.Assert(err, IsNil)
- os.Remove(newFile)
- }
- // TestPutObjectFromFile
- func (s *OssBucketSuite) TestPutObjectFromFileType(c *C) {
- objectName := objectNamePrefix + "tpoffwm"
- localFile := "../sample/BingWallpaper-2015-11-07.jpg"
- newFile := "newpic11.jpg"
- // Put
- err := s.bucket.PutObjectFromFile(objectName, localFile)
- c.Assert(err, IsNil)
- // Check
- err = s.bucket.GetObjectToFile(objectName, newFile)
- c.Assert(err, IsNil)
- eq, err := compareFiles(localFile, newFile)
- c.Assert(err, IsNil)
- c.Assert(eq, Equals, true)
- meta, err := s.bucket.GetObjectDetailedMeta(objectName)
- c.Assert(err, IsNil)
- c.Assert(meta.Get("Content-Type"), Equals, "image/jpeg")
- err = s.bucket.DeleteObject(objectName)
- c.Assert(err, IsNil)
- os.Remove(newFile)
- }
- // TestGetObject
- func (s *OssBucketSuite) TestGetObject(c *C) {
- objectName := objectNamePrefix + "tgo"
- objectValue := "长忆观潮,满郭人争江上望。来疑沧海尽成空,万面鼓声中。弄潮儿向涛头立,手把红旗旗不湿。别来几向梦中看,梦觉尚心寒。"
- // Put
- err := s.bucket.PutObject(objectName, strings.NewReader(objectValue))
- c.Assert(err, IsNil)
- // Check
- body, err := s.bucket.GetObject(objectName)
- c.Assert(err, IsNil)
- data, err := ioutil.ReadAll(body)
- body.Close()
- str := string(data)
- c.Assert(str, Equals, objectValue)
- testLogger.Println("GetObjec:", str)
- // Range
- var subObjectValue = string(([]byte(objectValue))[15:36])
- body, err = s.bucket.GetObject(objectName, Range(15, 35))
- c.Assert(err, IsNil)
- data, err = ioutil.ReadAll(body)
- body.Close()
- str = string(data)
- c.Assert(str, Equals, subObjectValue)
- testLogger.Println("GetObject:", str, ",", subObjectValue)
- // If-Modified-Since
- _, err = s.bucket.GetObject(objectName, IfModifiedSince(futureDate))
- c.Assert(err, NotNil)
- // If-Unmodified-Since
- body, err = s.bucket.GetObject(objectName, IfUnmodifiedSince(futureDate))
- c.Assert(err, IsNil)
- data, err = ioutil.ReadAll(body)
- body.Close()
- c.Assert(string(data), Equals, objectValue)
- meta, err := s.bucket.GetObjectDetailedMeta(objectName)
- c.Assert(err, IsNil)
- // If-Match
- body, err = s.bucket.GetObject(objectName, IfMatch(meta.Get("Etag")))
- c.Assert(err, IsNil)
- data, err = ioutil.ReadAll(body)
- body.Close()
- c.Assert(string(data), Equals, objectValue)
- // If-None-Match
- _, err = s.bucket.GetObject(objectName, IfNoneMatch(meta.Get("Etag")))
- c.Assert(err, NotNil)
- // process
- err = s.bucket.PutObjectFromFile(objectName, "../sample/BingWallpaper-2015-11-07.jpg")
- c.Assert(err, IsNil)
- _, err = s.bucket.GetObject(objectName, Process("image/format,png"))
- c.Assert(err, IsNil)
- err = s.bucket.DeleteObject(objectName)
- c.Assert(err, IsNil)
- }
- // TestGetObjectNegative
- func (s *OssBucketSuite) TestGetObjectToWriterNegative(c *C) {
- objectName := objectNamePrefix + "tgotwn"
- objectValue := "长忆观潮,满郭人争江上望。"
- // Object not exist
- _, err := s.bucket.GetObject("NotExist")
- c.Assert(err, NotNil)
- // Constraint invalid
- err = s.bucket.PutObject(objectName, strings.NewReader(objectValue))
- c.Assert(err, IsNil)
- // Out of range
- _, err = s.bucket.GetObject(objectName, Range(15, 1000))
- c.Assert(err, IsNil)
- // Not exist
- err = s.bucket.GetObjectToFile(objectName, "/root/123abc9874")
- c.Assert(err, NotNil)
- // Invalid option
- _, err = s.bucket.GetObject(objectName, ACL(ACLPublicRead))
- c.Assert(err, IsNil)
- err = s.bucket.GetObjectToFile(objectName, "newpic15.jpg", ACL(ACLPublicRead))
- c.Assert(err, IsNil)
- err = s.bucket.DeleteObject(objectName)
- c.Assert(err, IsNil)
- }
- // TestGetObjectToFile
- func (s *OssBucketSuite) TestGetObjectToFile(c *C) {
- objectName := objectNamePrefix + "tgotf"
- objectValue := "江南好,风景旧曾谙;日出江花红胜火,春来江水绿如蓝。能不忆江南?江南忆,最忆是杭州;山寺月中寻桂子,郡亭枕上看潮头。何日更重游!"
- newFile := "newpic15.jpg"
- // Put
- var val = []byte(objectValue)
- err := s.bucket.PutObject(objectName, strings.NewReader(objectValue))
- c.Assert(err, IsNil)
- // Check
- err = s.bucket.GetObjectToFile(objectName, newFile)
- c.Assert(err, IsNil)
- eq, err := compareFileData(newFile, val)
- c.Assert(err, IsNil)
- c.Assert(eq, Equals, true)
- os.Remove(newFile)
- // Range
- err = s.bucket.GetObjectToFile(objectName, newFile, Range(15, 35))
- c.Assert(err, IsNil)
- eq, err = compareFileData(newFile, val[15:36])
- c.Assert(err, IsNil)
- c.Assert(eq, Equals, true)
- os.Remove(newFile)
- err = s.bucket.GetObjectToFile(objectName, newFile, NormalizedRange("15-35"))
- c.Assert(err, IsNil)
- eq, err = compareFileData(newFile, val[15:36])
- c.Assert(err, IsNil)
- c.Assert(eq, Equals, true)
- os.Remove(newFile)
- err = s.bucket.GetObjectToFile(objectName, newFile, NormalizedRange("15-"))
- c.Assert(err, IsNil)
- eq, err = compareFileData(newFile, val[15:])
- c.Assert(err, IsNil)
- c.Assert(eq, Equals, true)
- os.Remove(newFile)
- err = s.bucket.GetObjectToFile(objectName, newFile, NormalizedRange("-10"))
- c.Assert(err, IsNil)
- eq, err = compareFileData(newFile, val[(len(val)-10):len(val)])
- c.Assert(err, IsNil)
- c.Assert(eq, Equals, true)
- os.Remove(newFile)
- // If-Modified-Since
- err = s.bucket.GetObjectToFile(objectName, newFile, IfModifiedSince(futureDate))
- c.Assert(err, NotNil)
- // If-Unmodified-Since
- err = s.bucket.GetObjectToFile(objectName, newFile, IfUnmodifiedSince(futureDate))
- c.Assert(err, IsNil)
- eq, err = compareFileData(newFile, val)
- c.Assert(err, IsNil)
- c.Assert(eq, Equals, true)
- os.Remove(newFile)
- meta, err := s.bucket.GetObjectDetailedMeta(objectName)
- c.Assert(err, IsNil)
- testLogger.Println("GetObjectDetailedMeta:", meta)
- // If-Match
- err = s.bucket.GetObjectToFile(objectName, newFile, IfMatch(meta.Get("Etag")))
- c.Assert(err, IsNil)
- eq, err = compareFileData(newFile, val)
- c.Assert(err, IsNil)
- c.Assert(eq, Equals, true)
- // If-None-Match
- err = s.bucket.GetObjectToFile(objectName, newFile, IfNoneMatch(meta.Get("Etag")))
- c.Assert(err, NotNil)
- // Accept-Encoding:gzip
- err = s.bucket.PutObjectFromFile(objectName, "../sample/The Go Programming Language.html")
- c.Assert(err, IsNil)
- err = s.bucket.GetObjectToFile(objectName, newFile, AcceptEncoding("gzip"))
- c.Assert(err, IsNil)
- os.Remove(newFile)
- err = s.bucket.DeleteObject(objectName)
- c.Assert(err, IsNil)
- }
- // TestListObjects
- func (s *OssBucketSuite) TestListObjects(c *C) {
- objectName := objectNamePrefix + "tlo"
- // List empty bucket
- lor, err := s.bucket.ListObjects()
- c.Assert(err, IsNil)
- left := len(lor.Objects)
- // Put three objects
- err = s.bucket.PutObject(objectName+"1", strings.NewReader(""))
- c.Assert(err, IsNil)
- err = s.bucket.PutObject(objectName+"2", strings.NewReader(""))
- c.Assert(err, IsNil)
- err = s.bucket.PutObject(objectName+"3", strings.NewReader(""))
- c.Assert(err, IsNil)
- // List
- lor, err = s.bucket.ListObjects()
- c.Assert(err, IsNil)
- c.Assert(len(lor.Objects), Equals, left+3)
- // List with prefix
- lor, err = s.bucket.ListObjects(Prefix(objectName + "2"))
- c.Assert(err, IsNil)
- c.Assert(len(lor.Objects), Equals, 1)
- lor, err = s.bucket.ListObjects(Prefix(objectName + "22"))
- c.Assert(err, IsNil)
- c.Assert(len(lor.Objects), Equals, 0)
- // List with max keys
- lor, err = s.bucket.ListObjects(Prefix(objectName), MaxKeys(2))
- c.Assert(err, IsNil)
- c.Assert(len(lor.Objects), Equals, 2)
- // List with marker
- lor, err = s.bucket.ListObjects(Marker(objectName+"1"), MaxKeys(1))
- c.Assert(err, IsNil)
- c.Assert(len(lor.Objects), Equals, 1)
- err = s.bucket.DeleteObject(objectName + "1")
- c.Assert(err, IsNil)
- err = s.bucket.DeleteObject(objectName + "2")
- c.Assert(err, IsNil)
- err = s.bucket.DeleteObject(objectName + "3")
- c.Assert(err, IsNil)
- }
- // TestListObjects
- func (s *OssBucketSuite) TestListObjectsEncodingType(c *C) {
- objectName := objectNamePrefix + "床前明月光,疑是地上霜。举头望明月,低头思故乡。" + "tloet"
- for i := 0; i < 10; i++ {
- err := s.bucket.PutObject(objectName+strconv.Itoa(i), strings.NewReader(""))
- c.Assert(err, IsNil)
- }
- lor, err := s.bucket.ListObjects(Prefix(objectNamePrefix + "床前明月光,"))
- c.Assert(err, IsNil)
- c.Assert(len(lor.Objects), Equals, 10)
- lor, err = s.bucket.ListObjects(Prefix(objectNamePrefix + "床前明月光,"))
- c.Assert(err, IsNil)
- c.Assert(len(lor.Objects), Equals, 10)
- lor, err = s.bucket.ListObjects(Marker(objectNamePrefix + "床前明月光,疑是地上霜。举头望明月,低头思故乡。"))
- c.Assert(err, IsNil)
- c.Assert(len(lor.Objects), Equals, 10)
- lor, err = s.bucket.ListObjects(Prefix(objectNamePrefix + "床前明月光"))
- c.Assert(err, IsNil)
- for i, obj := range lor.Objects {
- c.Assert(obj.Key, Equals, objectNamePrefix+"床前明月光,疑是地上霜。举头望明月,低头思故乡。tloet"+strconv.Itoa(i))
- }
- for i := 0; i < 10; i++ {
- err = s.bucket.DeleteObject(objectName + strconv.Itoa(i))
- c.Assert(err, IsNil)
- }
- // Special characters
- objectName = "go go ` ~ ! @ # $ % ^ & * () - _ + =[] {} \\ | < > , . ? / 0"
- err = s.bucket.PutObject(objectName, strings.NewReader("明月几时有,把酒问青天"))
- c.Assert(err, IsNil)
- lor, err = s.bucket.ListObjects(Prefix(objectName))
- c.Assert(err, IsNil)
- c.Assert(len(lor.Objects), Equals, 1)
- err = s.bucket.DeleteObject(objectName)
- c.Assert(err, IsNil)
- objectName = "go/中国 日本 +-#&=*"
- err = s.bucket.PutObject(objectName, strings.NewReader("明月几时有,把酒问青天"))
- c.Assert(err, IsNil)
- lor, err = s.bucket.ListObjects(Prefix(objectName))
- c.Assert(err, IsNil)
- c.Assert(len(lor.Objects), Equals, 1)
- err = s.bucket.DeleteObject(objectName)
- c.Assert(err, IsNil)
- }
- // TestIsBucketExist
- func (s *OssBucketSuite) TestIsObjectExist(c *C) {
- objectName := objectNamePrefix + "tibe"
- // Put three objects
- err := s.bucket.PutObject(objectName+"1", strings.NewReader(""))
- c.Assert(err, IsNil)
- err = s.bucket.PutObject(objectName+"11", strings.NewReader(""))
- c.Assert(err, IsNil)
- err = s.bucket.PutObject(objectName+"111", strings.NewReader(""))
- c.Assert(err, IsNil)
- // Exist
- exist, err := s.bucket.IsObjectExist(objectName + "11")
- c.Assert(err, IsNil)
- c.Assert(exist, Equals, true)
- exist, err = s.bucket.IsObjectExist(objectName + "1")
- c.Assert(err, IsNil)
- c.Assert(exist, Equals, true)
- exist, err = s.bucket.IsObjectExist(objectName + "111")
- c.Assert(err, IsNil)
- c.Assert(exist, Equals, true)
- // Not exist
- exist, err = s.bucket.IsObjectExist(objectName + "1111")
- c.Assert(err, IsNil)
- c.Assert(exist, Equals, false)
- exist, err = s.bucket.IsObjectExist(objectName)
- c.Assert(err, IsNil)
- c.Assert(exist, Equals, false)
- err = s.bucket.DeleteObject(objectName + "1")
- c.Assert(err, IsNil)
- err = s.bucket.DeleteObject(objectName + "11")
- c.Assert(err, IsNil)
- err = s.bucket.DeleteObject(objectName + "111")
- c.Assert(err, IsNil)
- }
- // TestDeleteObject
- func (s *OssBucketSuite) TestDeleteObject(c *C) {
- objectName := objectNamePrefix + "tdo"
- err := s.bucket.PutObject(objectName, strings.NewReader(""))
- c.Assert(err, IsNil)
- lor, err := s.bucket.ListObjects(Prefix(objectName))
- c.Assert(err, IsNil)
- c.Assert(len(lor.Objects), Equals, 1)
- // Delete
- err = s.bucket.DeleteObject(objectName)
- c.Assert(err, IsNil)
- // Duplicate delete
- err = s.bucket.DeleteObject(objectName)
- c.Assert(err, IsNil)
- lor, err = s.bucket.ListObjects(Prefix(objectName))
- c.Assert(err, IsNil)
- c.Assert(len(lor.Objects), Equals, 0)
- }
- // TestDeleteObjects
- func (s *OssBucketSuite) TestDeleteObjects(c *C) {
- objectName := objectNamePrefix + "tdos"
- // Delete objects
- err := s.bucket.PutObject(objectName, strings.NewReader(""))
- c.Assert(err, IsNil)
- res, err := s.bucket.DeleteObjects([]string{objectName})
- c.Assert(err, IsNil)
- c.Assert(len(res.DeletedObjects), Equals, 1)
- lor, err := s.bucket.ListObjects(Prefix(objectName))
- c.Assert(err, IsNil)
- c.Assert(len(lor.Objects), Equals, 0)
- // Delete objects
- err = s.bucket.PutObject(objectName+"1", strings.NewReader(""))
- c.Assert(err, IsNil)
- err = s.bucket.PutObject(objectName+"2", strings.NewReader(""))
- c.Assert(err, IsNil)
- res, err = s.bucket.DeleteObjects([]string{objectName + "1", objectName + "2"})
- c.Assert(err, IsNil)
- c.Assert(len(res.DeletedObjects), Equals, 2)
- lor, err = s.bucket.ListObjects(Prefix(objectName))
- c.Assert(err, IsNil)
- c.Assert(len(lor.Objects), Equals, 0)
- // Delete 0
- _, err = s.bucket.DeleteObjects([]string{})
- c.Assert(err, NotNil)
- // DeleteObjectsQuiet
- err = s.bucket.PutObject(objectName+"1", strings.NewReader(""))
- c.Assert(err, IsNil)
- err = s.bucket.PutObject(objectName+"2", strings.NewReader(""))
- c.Assert(err, IsNil)
- res, err = s.bucket.DeleteObjects([]string{objectName + "1", objectName + "2"},
- DeleteObjectsQuiet(false))
- c.Assert(err, IsNil)
- c.Assert(len(res.DeletedObjects), Equals, 2)
- lor, err = s.bucket.ListObjects(Prefix(objectName))
- c.Assert(err, IsNil)
- c.Assert(len(lor.Objects), Equals, 0)
- // DeleteObjectsQuiet
- err = s.bucket.PutObject(objectName+"1", strings.NewReader(""))
- c.Assert(err, IsNil)
- err = s.bucket.PutObject(objectName+"2", strings.NewReader(""))
- c.Assert(err, IsNil)
- res, err = s.bucket.DeleteObjects([]string{objectName + "1", objectName + "2"},
- DeleteObjectsQuiet(true))
- c.Assert(err, IsNil)
- c.Assert(len(res.DeletedObjects), Equals, 0)
- lor, err = s.bucket.ListObjects(Prefix(objectName))
- c.Assert(err, IsNil)
- c.Assert(len(lor.Objects), Equals, 0)
- // EncodingType
- err = s.bucket.PutObject("中国人", strings.NewReader(""))
- c.Assert(err, IsNil)
- res, err = s.bucket.DeleteObjects([]string{"中国人"})
- c.Assert(err, IsNil)
- c.Assert(len(res.DeletedObjects), Equals, 1)
- c.Assert(res.DeletedObjects[0], Equals, "中国人")
- // EncodingType
- err = s.bucket.PutObject("中国人", strings.NewReader(""))
- c.Assert(err, IsNil)
- res, err = s.bucket.DeleteObjects([]string{"中国人"}, DeleteObjectsQuiet(false))
- c.Assert(err, IsNil)
- c.Assert(len(res.DeletedObjects), Equals, 1)
- c.Assert(res.DeletedObjects[0], Equals, "中国人")
- // EncodingType
- err = s.bucket.PutObject("中国人", strings.NewReader(""))
- c.Assert(err, IsNil)
- res, err = s.bucket.DeleteObjects([]string{"中国人"}, DeleteObjectsQuiet(true))
- c.Assert(err, IsNil)
- c.Assert(len(res.DeletedObjects), Equals, 0)
- // Special characters
- key := "A ' < > \" & ~ ` ! @ # $ % ^ & * ( ) [] {} - _ + = / | \\ ? . , : ; A"
- err = s.bucket.PutObject(key, strings.NewReader("value"))
- c.Assert(err, IsNil)
- _, err = s.bucket.DeleteObjects([]string{key})
- c.Assert(err, IsNil)
- ress, err := s.bucket.ListObjects(Prefix(key))
- c.Assert(err, IsNil)
- c.Assert(len(ress.Objects), Equals, 0)
- // Not exist
- _, err = s.bucket.DeleteObjects([]string{"NotExistObject"})
- c.Assert(err, IsNil)
- }
- // TestSetObjectMeta
- func (s *OssBucketSuite) TestSetObjectMeta(c *C) {
- objectName := objectNamePrefix + "tsom"
- err := s.bucket.PutObject(objectName, strings.NewReader(""))
- c.Assert(err, IsNil)
- err = s.bucket.SetObjectMeta(objectName,
- Expires(futureDate),
- Meta("myprop", "mypropval"))
- c.Assert(err, IsNil)
- meta, err := s.bucket.GetObjectDetailedMeta(objectName)
- c.Assert(err, IsNil)
- testLogger.Println("Meta:", meta)
- c.Assert(meta.Get("Expires"), Equals, futureDate.Format(http.TimeFormat))
- c.Assert(meta.Get("X-Oss-Meta-Myprop"), Equals, "mypropval")
- acl, err := s.bucket.GetObjectACL(objectName)
- c.Assert(err, IsNil)
- c.Assert(acl.ACL, Equals, "default")
- // Invalid option
- err = s.bucket.SetObjectMeta(objectName, AcceptEncoding("url"))
- c.Assert(err, IsNil)
- // Invalid option value
- err = s.bucket.SetObjectMeta(objectName, ServerSideEncryption("invalid"))
- c.Assert(err, NotNil)
- err = s.bucket.DeleteObject(objectName)
- c.Assert(err, IsNil)
- // Not exist
- err = s.bucket.SetObjectMeta(objectName, Expires(futureDate))
- c.Assert(err, NotNil)
- }
- // TestGetObjectMeta
- func (s *OssBucketSuite) TestGetObjectMeta(c *C) {
- objectName := objectNamePrefix + "tgom"
- // Put
- err := s.bucket.PutObject(objectName, strings.NewReader(""))
- c.Assert(err, IsNil)
- meta, err := s.bucket.GetObjectMeta(objectName)
- c.Assert(err, IsNil)
- c.Assert(len(meta) > 0, Equals, true)
- err = s.bucket.DeleteObject(objectName)
- c.Assert(err, IsNil)
- _, err = s.bucket.GetObjectMeta("NotExistObject")
- c.Assert(err, NotNil)
- }
- // TestGetObjectDetailedMeta
- func (s *OssBucketSuite) TestGetObjectDetailedMeta(c *C) {
- objectName := objectNamePrefix + "tgodm"
- // Put
- err := s.bucket.PutObject(objectName, strings.NewReader(""),
- Expires(futureDate), Meta("myprop", "mypropval"))
- c.Assert(err, IsNil)
- // Check
- meta, err := s.bucket.GetObjectDetailedMeta(objectName)
- c.Assert(err, IsNil)
- testLogger.Println("GetObjectDetailedMeta:", meta)
- c.Assert(meta.Get("Expires"), Equals, futureDate.Format(http.TimeFormat))
- c.Assert(meta.Get("X-Oss-Meta-Myprop"), Equals, "mypropval")
- c.Assert(meta.Get("Content-Length"), Equals, "0")
- c.Assert(len(meta.Get("Date")) > 0, Equals, true)
- c.Assert(len(meta.Get("X-Oss-Request-Id")) > 0, Equals, true)
- c.Assert(len(meta.Get("Last-Modified")) > 0, Equals, true)
- // IfModifiedSince/IfModifiedSince
- _, err = s.bucket.GetObjectDetailedMeta(objectName, IfModifiedSince(futureDate))
- c.Assert(err, NotNil)
- meta, err = s.bucket.GetObjectDetailedMeta(objectName, IfUnmodifiedSince(futureDate))
- c.Assert(err, IsNil)
- c.Assert(meta.Get("Expires"), Equals, futureDate.Format(http.TimeFormat))
- c.Assert(meta.Get("X-Oss-Meta-Myprop"), Equals, "mypropval")
- // IfMatch/IfNoneMatch
- _, err = s.bucket.GetObjectDetailedMeta(objectName, IfNoneMatch(meta.Get("Etag")))
- c.Assert(err, NotNil)
- meta, err = s.bucket.GetObjectDetailedMeta(objectName, IfMatch(meta.Get("Etag")))
- c.Assert(err, IsNil)
- c.Assert(meta.Get("Expires"), Equals, futureDate.Format(http.TimeFormat))
- c.Assert(meta.Get("X-Oss-Meta-Myprop"), Equals, "mypropval")
- err = s.bucket.DeleteObject(objectName)
- c.Assert(err, IsNil)
- _, err = s.bucket.GetObjectDetailedMeta("NotExistObject")
- c.Assert(err, NotNil)
- }
- // TestSetAndGetObjectAcl
- func (s *OssBucketSuite) TestSetAndGetObjectAcl(c *C) {
- objectName := objectNamePrefix + "tsgba"
- err := s.bucket.PutObject(objectName, strings.NewReader(""))
- c.Assert(err, IsNil)
- // Default
- acl, err := s.bucket.GetObjectACL(objectName)
- c.Assert(err, IsNil)
- c.Assert(acl.ACL, Equals, "default")
- // Set ACL_PUBLIC_RW
- err = s.bucket.SetObjectACL(objectName, ACLPublicReadWrite)
- c.Assert(err, IsNil)
- acl, err = s.bucket.GetObjectACL(objectName)
- c.Assert(err, IsNil)
- c.Assert(acl.ACL, Equals, string(ACLPublicReadWrite))
- // Set ACL_PRIVATE
- err = s.bucket.SetObjectACL(objectName, ACLPrivate)
- c.Assert(err, IsNil)
- acl, err = s.bucket.GetObjectACL(objectName)
- c.Assert(err, IsNil)
- c.Assert(acl.ACL, Equals, string(ACLPrivate))
- // Set ACL_PUBLIC_R
- err = s.bucket.SetObjectACL(objectName, ACLPublicRead)
- c.Assert(err, IsNil)
- acl, err = s.bucket.GetObjectACL(objectName)
- c.Assert(err, IsNil)
- c.Assert(acl.ACL, Equals, string(ACLPublicRead))
- err = s.bucket.DeleteObject(objectName)
- c.Assert(err, IsNil)
- }
- // TestSetAndGetObjectAclNegative
- func (s *OssBucketSuite) TestSetAndGetObjectAclNegative(c *C) {
- objectName := objectNamePrefix + "tsgban"
- // Object not exist
- err := s.bucket.SetObjectACL(objectName, ACLPublicRead)
- c.Assert(err, NotNil)
- }
- // TestCopyObject
- func (s *OssBucketSuite) TestCopyObject(c *C) {
- objectName := objectNamePrefix + "tco"
- objectValue := "男儿何不带吴钩,收取关山五十州。请君暂上凌烟阁,若个书生万户侯?"
- err := s.bucket.PutObject(objectName, strings.NewReader(objectValue),
- ACL(ACLPublicRead), Meta("my", "myprop"))
- c.Assert(err, IsNil)
- // Copy
- var objectNameDest = objectName + "dest"
- _, err = s.bucket.CopyObject(objectName, objectNameDest)
- c.Assert(err, IsNil)
- // Check
- lor, err := s.bucket.ListObjects(Prefix(objectName))
- c.Assert(err, IsNil)
- testLogger.Println("objects:", lor.Objects)
- c.Assert(len(lor.Objects), Equals, 2)
- body, err := s.bucket.GetObject(objectName)
- c.Assert(err, IsNil)
- str, err := readBody(body)
- c.Assert(err, IsNil)
- c.Assert(str, Equals, objectValue)
- err = s.bucket.DeleteObject(objectNameDest)
- c.Assert(err, IsNil)
- // Copy with constraints x-oss-copy-source-if-modified-since
- _, err = s.bucket.CopyObject(objectName, objectNameDest, CopySourceIfModifiedSince(futureDate))
- c.Assert(err, NotNil)
- testLogger.Println("CopyObject:", err)
- // Copy with constraints x-oss-copy-source-if-unmodified-since
- _, err = s.bucket.CopyObject(objectName, objectNameDest, CopySourceIfUnmodifiedSince(futureDate))
- c.Assert(err, IsNil)
- // Check
- lor, err = s.bucket.ListObjects(Prefix(objectName))
- c.Assert(err, IsNil)
- testLogger.Println("objects:", lor.Objects)
- c.Assert(len(lor.Objects), Equals, 2)
- body, err = s.bucket.GetObject(objectName)
- c.Assert(err, IsNil)
- str, err = readBody(body)
- c.Assert(err, IsNil)
- c.Assert(str, Equals, objectValue)
- err = s.bucket.DeleteObject(objectNameDest)
- c.Assert(err, IsNil)
- // Copy with constraints x-oss-copy-source-if-match
- meta, err := s.bucket.GetObjectDetailedMeta(objectName)
- c.Assert(err, IsNil)
- testLogger.Println("GetObjectDetailedMeta:", meta)
- _, err = s.bucket.CopyObject(objectName, objectNameDest, CopySourceIfMatch(meta.Get("Etag")))
- c.Assert(err, IsNil)
- // Check
- body, err = s.bucket.GetObject(objectName)
- c.Assert(err, IsNil)
- str, err = readBody(body)
- c.Assert(err, IsNil)
- c.Assert(str, Equals, objectValue)
- err = s.bucket.DeleteObject(objectNameDest)
- c.Assert(err, IsNil)
- // Copy with constraints x-oss-copy-source-if-none-match
- _, err = s.bucket.CopyObject(objectName, objectNameDest, CopySourceIfNoneMatch(meta.Get("Etag")))
- c.Assert(err, NotNil)
- // Copy with constraints x-oss-metadata-directive
- _, err = s.bucket.CopyObject(objectName, objectNameDest, Meta("my", "mydestprop"),
- MetadataDirective(MetaCopy))
- c.Assert(err, IsNil)
- // Check
- body, err = s.bucket.GetObject(objectName)
- c.Assert(err, IsNil)
- str, err = readBody(body)
- c.Assert(err, IsNil)
- c.Assert(str, Equals, objectValue)
- destMeta, err := s.bucket.GetObjectDetailedMeta(objectNameDest)
- c.Assert(err, IsNil)
- c.Assert(meta.Get("X-Oss-Meta-My"), Equals, "myprop")
- acl, err := s.bucket.GetObjectACL(objectNameDest)
- c.Assert(err, IsNil)
- c.Assert(acl.ACL, Equals, "default")
- err = s.bucket.DeleteObject(objectNameDest)
- c.Assert(err, IsNil)
- // Copy with constraints x-oss-metadata-directive and self defined dest object meta
- options := []Option{
- ObjectACL(ACLPublicReadWrite),
- Meta("my", "mydestprop"),
- MetadataDirective(MetaReplace),
- }
- _, err = s.bucket.CopyObject(objectName, objectNameDest, options...)
- c.Assert(err, IsNil)
- // Check
- body, err = s.bucket.GetObject(objectName)
- c.Assert(err, IsNil)
- str, err = readBody(body)
- c.Assert(err, IsNil)
- c.Assert(str, Equals, objectValue)
- destMeta, err = s.bucket.GetObjectDetailedMeta(objectNameDest)
- c.Assert(err, IsNil)
- c.Assert(destMeta.Get("X-Oss-Meta-My"), Equals, "mydestprop")
- acl, err = s.bucket.GetObjectACL(objectNameDest)
- c.Assert(err, IsNil)
- c.Assert(acl.ACL, Equals, string(ACLPublicReadWrite))
- err = s.bucket.DeleteObject(objectNameDest)
- c.Assert(err, IsNil)
- err = s.bucket.DeleteObject(objectName)
- c.Assert(err, IsNil)
- }
- // TestCopyObjectToOrFrom
- func (s *OssBucketSuite) TestCopyObjectToOrFrom(c *C) {
- objectName := objectNamePrefix + "tcotof"
- objectValue := "男儿何不带吴钩,收取关山五十州。请君暂上凌烟阁,若个书生万户侯?"
- destBucket := bucketName + "-dest"
- objectNameDest := objectName + "dest"
- s.client.CreateBucket(destBucket)
- destBuck, err := s.client.Bucket(destBucket)
- c.Assert(err, IsNil)
- err = s.bucket.PutObject(objectName, strings.NewReader(objectValue))
- c.Assert(err, IsNil)
- // Copy from
- _, err = destBuck.CopyObjectFrom(bucketName, objectName, objectNameDest)
- c.Assert(err, IsNil)
- // Check
- body, err := destBuck.GetObject(objectNameDest)
- c.Assert(err, IsNil)
- str, err := readBody(body)
- c.Assert(err, IsNil)
- c.Assert(str, Equals, objectValue)
- err = s.bucket.DeleteObject(objectName)
- c.Assert(err, IsNil)
- // Copy to
- _, err = destBuck.CopyObjectTo(bucketName, objectName, objectNameDest)
- c.Assert(err, IsNil)
- // Check
- body, err = s.bucket.GetObject(objectName)
- c.Assert(err, IsNil)
- str, err = readBody(body)
- c.Assert(err, IsNil)
- c.Assert(str, Equals, objectValue)
- // Clean
- err = destBuck.DeleteObject(objectNameDest)
- c.Assert(err, IsNil)
- err = s.bucket.DeleteObject(objectName)
- c.Assert(err, IsNil)
- err = s.client.DeleteBucket(destBucket)
- c.Assert(err, IsNil)
- }
- // TestCopyObjectToOrFromNegative
- func (s *OssBucketSuite) TestCopyObjectToOrFromNegative(c *C) {
- objectName := objectNamePrefix + "tcotofn"
- destBucket := bucketName + "-destn"
- objectNameDest := objectName + "destn"
- // Object not exist
- _, err := s.bucket.CopyObjectTo(bucketName, objectName, objectNameDest)
- c.Assert(err, NotNil)
- // Bucket not exist
- _, err = s.bucket.CopyObjectFrom(destBucket, objectNameDest, objectName)
- c.Assert(err, NotNil)
- }
- // TestAppendObject
- func (s *OssBucketSuite) TestAppendObject(c *C) {
- objectName := objectNamePrefix + "tao"
- objectValue := "昨夜雨疏风骤,浓睡不消残酒。试问卷帘人,却道海棠依旧。知否?知否?应是绿肥红瘦。"
- var val = []byte(objectValue)
- var localFile = "testx.txt"
- var nextPos int64
- var midPos = 1 + rand.Intn(len(val)-1)
- var err = createFileAndWrite(localFile+"1", val[0:midPos])
- c.Assert(err, IsNil)
- err = createFileAndWrite(localFile+"2", val[midPos:])
- c.Assert(err, IsNil)
- // String append
- nextPos, err = s.bucket.AppendObject(objectName, strings.NewReader("昨夜雨疏风骤,浓睡不消残酒。试问卷帘人,"), nextPos)
- c.Assert(err, IsNil)
- nextPos, err = s.bucket.AppendObject(objectName, strings.NewReader("却道海棠依旧。知否?知否?应是绿肥红瘦。"), nextPos)
- c.Assert(err, IsNil)
- body, err := s.bucket.GetObject(objectName)
- c.Assert(err, IsNil)
- str, err := readBody(body)
- c.Assert(err, IsNil)
- c.Assert(str, Equals, objectValue)
- err = s.bucket.DeleteObject(objectName)
- c.Assert(err, IsNil)
- // Byte append
- nextPos = 0
- nextPos, err = s.bucket.AppendObject(objectName, bytes.NewReader(val[0:midPos]), nextPos)
- c.Assert(err, IsNil)
- nextPos, err = s.bucket.AppendObject(objectName, bytes.NewReader(val[midPos:]), nextPos)
- c.Assert(err, IsNil)
- body, err = s.bucket.GetObject(objectName)
- c.Assert(err, IsNil)
- str, err = readBody(body)
- c.Assert(err, IsNil)
- c.Assert(str, Equals, objectValue)
- err = s.bucket.DeleteObject(objectName)
- c.Assert(err, IsNil)
- // File append
- options := []Option{
- ObjectACL(ACLPublicReadWrite),
- Meta("my", "myprop"),
- }
- fd, err := os.Open(localFile + "1")
- c.Assert(err, IsNil)
- defer fd.Close()
- nextPos = 0
- nextPos, err = s.bucket.AppendObject(objectName, fd, nextPos, options...)
- c.Assert(err, IsNil)
- meta, err := s.bucket.GetObjectDetailedMeta(objectName)
- c.Assert(err, IsNil)
- testLogger.Println("GetObjectDetailedMeta:", meta, ",", nextPos)
- c.Assert(meta.Get("X-Oss-Object-Type"), Equals, "Appendable")
- c.Assert(meta.Get("X-Oss-Meta-My"), Equals, "myprop")
- c.Assert(meta.Get("x-oss-Meta-Mine"), Equals, "")
- c.Assert(meta.Get("X-Oss-Next-Append-Position"), Equals, strconv.FormatInt(nextPos, 10))
- acl, err := s.bucket.GetObjectACL(objectName)
- c.Assert(err, IsNil)
- testLogger.Println("GetObjectACL:", acl)
- c.Assert(acl.ACL, Equals, string(ACLPublicReadWrite))
- // Second append
- options = []Option{
- ObjectACL(ACLPublicRead),
- Meta("my", "myproptwo"),
- Meta("mine", "mypropmine"),
- }
- fd, err = os.Open(localFile + "2")
- c.Assert(err, IsNil)
- defer fd.Close()
- nextPos, err = s.bucket.AppendObject(objectName, fd, nextPos, options...)
- c.Assert(err, IsNil)
- body, err = s.bucket.GetObject(objectName)
- c.Assert(err, IsNil)
- str, err = readBody(body)
- c.Assert(err, IsNil)
- c.Assert(str, Equals, objectValue)
- meta, err = s.bucket.GetObjectDetailedMeta(objectName)
- c.Assert(err, IsNil)
- testLogger.Println("GetObjectDetailedMeta xxx:", meta)
- c.Assert(meta.Get("X-Oss-Object-Type"), Equals, "Appendable")
- c.Assert(meta.Get("X-Oss-Meta-My"), Equals, "myprop")
- c.Assert(meta.Get("x-Oss-Meta-Mine"), Equals, "")
- c.Assert(meta.Get("X-Oss-Next-Append-Position"), Equals, strconv.FormatInt(nextPos, 10))
- acl, err = s.bucket.GetObjectACL(objectName)
- c.Assert(err, IsNil)
- c.Assert(acl.ACL, Equals, string(ACLPublicRead))
- err = s.bucket.DeleteObject(objectName)
- c.Assert(err, IsNil)
- }
- // TestAppendObjectNegative
- func (s *OssBucketSuite) TestAppendObjectNegative(c *C) {
- objectName := objectNamePrefix + "taon"
- nextPos := int64(0)
- nextPos, err := s.bucket.AppendObject(objectName, strings.NewReader("ObjectValue"), nextPos)
- c.Assert(err, IsNil)
- nextPos, err = s.bucket.AppendObject(objectName, strings.NewReader("ObjectValue"), 0)
- c.Assert(err, NotNil)
- err = s.bucket.DeleteObject(objectName)
- c.Assert(err, IsNil)
- }
- // TestContentType
- func (s *OssBucketSuite) TestAddContentType(c *C) {
- opts := addContentType(nil, "abc.txt")
- typ, err := findOption(opts, HTTPHeaderContentType, "")
- c.Assert(err, IsNil)
- c.Assert(typ, Equals, "text/plain; charset=utf-8")
- opts = addContentType(nil)
- typ, err = findOption(opts, HTTPHeaderContentType, "")
- c.Assert(err, IsNil)
- c.Assert(len(opts), Equals, 1)
- c.Assert(typ, Equals, "application/octet-stream")
- opts = addContentType(nil, "abc.txt", "abc.pdf")
- typ, err = findOption(opts, HTTPHeaderContentType, "")
- c.Assert(err, IsNil)
- c.Assert(typ, Equals, "text/plain; charset=utf-8")
- opts = addContentType(nil, "abc", "abc.txt", "abc.pdf")
- typ, err = findOption(opts, HTTPHeaderContentType, "")
- c.Assert(err, IsNil)
- c.Assert(typ, Equals, "text/plain; charset=utf-8")
- opts = addContentType(nil, "abc", "abc", "edf")
- typ, err = findOption(opts, HTTPHeaderContentType, "")
- c.Assert(err, IsNil)
- c.Assert(typ, Equals, "application/octet-stream")
- opts = addContentType([]Option{Meta("meta", "my")}, "abc", "abc.txt", "abc.pdf")
- typ, err = findOption(opts, HTTPHeaderContentType, "")
- c.Assert(err, IsNil)
- c.Assert(len(opts), Equals, 2)
- c.Assert(typ, Equals, "text/plain; charset=utf-8")
- }
- func (s *OssBucketSuite) TestGetConfig(c *C) {
- client, err := New(endpoint, accessID, accessKey, UseCname(true),
- Timeout(11, 12), SecurityToken("token"), EnableMD5(false))
- c.Assert(err, IsNil)
- bucket, err := client.Bucket(bucketName)
- c.Assert(err, IsNil)
- c.Assert(bucket.getConfig().HTTPTimeout.ConnectTimeout, Equals, time.Second*11)
- c.Assert(bucket.getConfig().HTTPTimeout.ReadWriteTimeout, Equals, time.Second*12)
- c.Assert(bucket.getConfig().HTTPTimeout.HeaderTimeout, Equals, time.Second*12)
- c.Assert(bucket.getConfig().HTTPTimeout.IdleConnTimeout, Equals, time.Second*12)
- c.Assert(bucket.getConfig().HTTPTimeout.LongTimeout, Equals, time.Second*12*10)
- c.Assert(bucket.getConfig().SecurityToken, Equals, "token")
- c.Assert(bucket.getConfig().IsCname, Equals, true)
- c.Assert(bucket.getConfig().IsEnableMD5, Equals, false)
- }
- func (s *OssBucketSuite) TestSTSToken(c *C) {
- objectName := objectNamePrefix + "tst"
- objectValue := "红藕香残玉簟秋。轻解罗裳,独上兰舟。云中谁寄锦书来?雁字回时,月满西楼。"
- stsClient := sts.NewClient(stsaccessID, stsaccessKey, stsARN, "oss_test_sess")
- resp, err := stsClient.AssumeRole(1800)
- c.Assert(err, IsNil)
- client, err := New(endpoint, resp.Credentials.AccessKeyId, resp.Credentials.AccessKeySecret,
- SecurityToken(resp.Credentials.SecurityToken))
- c.Assert(err, IsNil)
- bucket, err := client.Bucket(bucketName)
- c.Assert(err, IsNil)
- // Put
- err = bucket.PutObject(objectName, strings.NewReader(objectValue))
- c.Assert(err, IsNil)
- // Get
- body, err := bucket.GetObject(objectName)
- c.Assert(err, IsNil)
- str, err := readBody(body)
- c.Assert(err, IsNil)
- c.Assert(str, Equals, objectValue)
- // List
- lor, err := bucket.ListObjects()
- c.Assert(err, IsNil)
- testLogger.Println("Objects:", lor.Objects)
- // Put with URL
- signedURL, err := bucket.SignURL(objectName, HTTPPut, 3600)
- c.Assert(err, IsNil)
- err = bucket.PutObjectWithURL(signedURL, strings.NewReader(objectValue))
- c.Assert(err, IsNil)
- // Get with URL
- signedURL, err = bucket.SignURL(objectName, HTTPGet, 3600)
- c.Assert(err, IsNil)
- body, err = bucket.GetObjectWithURL(signedURL)
- c.Assert(err, IsNil)
- str, err = readBody(body)
- c.Assert(err, IsNil)
- c.Assert(str, Equals, objectValue)
- // Delete
- err = bucket.DeleteObject(objectName)
- c.Assert(err, IsNil)
- }
- func (s *OssBucketSuite) TestSTSTonekNegative(c *C) {
- objectName := objectNamePrefix + "tstg"
- localFile := objectName + ".jpg"
- client, err := New(endpoint, accessID, accessKey, SecurityToken("Invalid"))
- c.Assert(err, IsNil)
- _, err = client.ListBuckets()
- c.Assert(err, NotNil)
- bucket, err := client.Bucket(bucketName)
- c.Assert(err, IsNil)
- err = bucket.PutObject(objectName, strings.NewReader(""))
- c.Assert(err, NotNil)
- err = bucket.PutObjectFromFile(objectName, "")
- c.Assert(err, NotNil)
- _, err = bucket.GetObject(objectName)
- c.Assert(err, NotNil)
- err = bucket.GetObjectToFile(objectName, "")
- c.Assert(err, NotNil)
- _, err = bucket.ListObjects()
- c.Assert(err, NotNil)
- err = bucket.SetObjectACL(objectName, ACLPublicRead)
- c.Assert(err, NotNil)
- _, err = bucket.GetObjectACL(objectName)
- c.Assert(err, NotNil)
- err = bucket.UploadFile(objectName, localFile, MinPartSize)
- c.Assert(err, NotNil)
- err = bucket.DownloadFile(objectName, localFile, MinPartSize)
- c.Assert(err, NotNil)
- _, err = bucket.IsObjectExist(objectName)
- c.Assert(err, NotNil)
- _, err = bucket.ListMultipartUploads()
- c.Assert(err, NotNil)
- err = bucket.DeleteObject(objectName)
- c.Assert(err, NotNil)
- _, err = bucket.DeleteObjects([]string{objectName})
- c.Assert(err, NotNil)
- err = client.DeleteBucket(bucketName)
- c.Assert(err, NotNil)
- }
- func (s *OssBucketSuite) TestUploadBigFile(c *C) {
- objectName := objectNamePrefix + "tubf"
- bigFile := "D:\\tmp\\bigfile.zip"
- newFile := "D:\\tmp\\newbigfile.zip"
- exist, err := isFileExist(bigFile)
- c.Assert(err, IsNil)
- if !exist {
- return
- }
- // Put
- start := GetNowSec()
- err = s.bucket.PutObjectFromFile(objectName, bigFile)
- c.Assert(err, IsNil)
- end := GetNowSec()
- testLogger.Println("Put big file:", bigFile, "use sec:", end-start)
- // Check
- start = GetNowSec()
- err = s.bucket.GetObjectToFile(objectName, newFile)
- c.Assert(err, IsNil)
- end = GetNowSec()
- testLogger.Println("Get big file:", bigFile, "use sec:", end-start)
- start = GetNowSec()
- eq, err := compareFiles(bigFile, newFile)
- c.Assert(err, IsNil)
- c.Assert(eq, Equals, true)
- end = GetNowSec()
- testLogger.Println("Compare big file:", bigFile, "use sec:", end-start)
- err = s.bucket.DeleteObject(objectName)
- c.Assert(err, IsNil)
- }
- func (s *OssBucketSuite) TestSymlink(c *C) {
- objectName := objectNamePrefix + "符号链接"
- targetObjectName := objectNamePrefix + "符号链接目标文件"
- err := s.bucket.DeleteObject(objectName)
- c.Assert(err, IsNil)
- err = s.bucket.DeleteObject(targetObjectName)
- c.Assert(err, IsNil)
- meta, err := s.bucket.GetSymlink(objectName)
- c.Assert(err, NotNil)
- // Put symlink
- err = s.bucket.PutSymlink(objectName, targetObjectName)
- c.Assert(err, IsNil)
- err = s.bucket.PutObject(targetObjectName, strings.NewReader("target"))
- c.Assert(err, IsNil)
- err = s.bucket.PutSymlink(objectName, targetObjectName)
- c.Assert(err, IsNil)
- meta, err = s.bucket.GetSymlink(objectName)
- c.Assert(err, IsNil)
- c.Assert(meta.Get(HTTPHeaderOssSymlinkTarget), Equals, targetObjectName)
- // List object
- lor, err := s.bucket.ListObjects()
- c.Assert(err, IsNil)
- exist, v := s.getObject(lor.Objects, objectName)
- c.Assert(exist, Equals, true)
- c.Assert(v.Type, Equals, "Symlink")
- body, err := s.bucket.GetObject(objectName)
- c.Assert(err, IsNil)
- str, err := readBody(body)
- c.Assert(err, IsNil)
- c.Assert(str, Equals, "target")
- meta, err = s.bucket.GetSymlink(targetObjectName)
- c.Assert(err, NotNil)
- err = s.bucket.PutObject(objectName, strings.NewReader("src"))
- c.Assert(err, IsNil)
- body, err = s.bucket.GetObject(objectName)
- c.Assert(err, IsNil)
- str, err = readBody(body)
- c.Assert(err, IsNil)
- c.Assert(str, Equals, "src")
- err = s.bucket.DeleteObject(objectName)
- c.Assert(err, IsNil)
- err = s.bucket.DeleteObject(targetObjectName)
- c.Assert(err, IsNil)
- // Put symlink again
- objectName = objectNamePrefix + "symlink"
- targetObjectName = objectNamePrefix + "symlink-target"
- err = s.bucket.PutSymlink(objectName, targetObjectName)
- c.Assert(err, IsNil)
- err = s.bucket.PutObject(targetObjectName, strings.NewReader("target1"))
- c.Assert(err, IsNil)
- meta, err = s.bucket.GetSymlink(objectName)
- c.Assert(err, IsNil)
- c.Assert(meta.Get(HTTPHeaderOssSymlinkTarget), Equals, targetObjectName)
- body, err = s.bucket.GetObject(objectName)
- c.Assert(err, IsNil)
- str, err = readBody(body)
- c.Assert(err, IsNil)
- c.Assert(str, Equals, "target1")
- err = s.bucket.DeleteObject(objectName)
- c.Assert(err, IsNil)
- err = s.bucket.DeleteObject(targetObjectName)
- c.Assert(err, IsNil)
- }
- // TestRestoreObject
- func (s *OssBucketSuite) TestRestoreObject(c *C) {
- objectName := objectNamePrefix + "restore"
- // List objects
- lor, err := s.archiveBucket.ListObjects()
- c.Assert(err, IsNil)
- left := len(lor.Objects)
- // Put object
- err = s.archiveBucket.PutObject(objectName, strings.NewReader(""))
- c.Assert(err, IsNil)
- // List
- lor, err = s.archiveBucket.ListObjects()
- c.Assert(err, IsNil)
- c.Assert(len(lor.Objects), Equals, left+1)
- for _, object := range lor.Objects {
- c.Assert(object.StorageClass, Equals, string(StorageArchive))
- c.Assert(object.Type, Equals, "Normal")
- }
- // Head object
- meta, err := s.archiveBucket.GetObjectDetailedMeta(objectName)
- c.Assert(err, IsNil)
- _, ok := meta["X-Oss-Restore"]
- c.Assert(ok, Equals, false)
- c.Assert(meta.Get("X-Oss-Storage-Class"), Equals, "Archive")
- // Error restore object
- err = s.archiveBucket.RestoreObject("notexistobject")
- c.Assert(err, NotNil)
- // Restore object
- err = s.archiveBucket.RestoreObject(objectName)
- c.Assert(err, IsNil)
- // Head object
- meta, err = s.archiveBucket.GetObjectDetailedMeta(objectName)
- c.Assert(err, IsNil)
- c.Assert(meta.Get("X-Oss-Restore"), Equals, "ongoing-request=\"true\"")
- c.Assert(meta.Get("X-Oss-Storage-Class"), Equals, "Archive")
- }
- // TestProcessObject
- func (s *OssBucketSuite) TestProcessObject(c *C) {
- objectName := objectNamePrefix + "_process_src.jpg"
- err := s.bucket.PutObjectFromFile(objectName, "../sample/BingWallpaper-2015-11-07.jpg")
- c.Assert(err, IsNil)
- // If bucket-name not specified, it is saved to the current bucket by default.
- destObjName := objectNamePrefix + "_process_dest_1.jpg"
- process := fmt.Sprintf("image/resize,w_100|sys/saveas,o_%v", base64.URLEncoding.EncodeToString([]byte(destObjName)))
- result, err := s.bucket.ProcessObject(objectName, process)
- c.Assert(err, IsNil)
- exist, _ := s.bucket.IsObjectExist(destObjName)
- c.Assert(exist, Equals, true)
- c.Assert(result.Bucket, Equals, "")
- c.Assert(result.Object, Equals, destObjName)
- destObjName = objectNamePrefix + "_process_dest_1.jpg"
- process = fmt.Sprintf("image/resize,w_100|sys/saveas,o_%v,b_%v", base64.URLEncoding.EncodeToString([]byte(destObjName)), base64.URLEncoding.EncodeToString([]byte(s.bucket.BucketName)))
- result, err = s.bucket.ProcessObject(objectName, process)
- c.Assert(err, IsNil)
- exist, _ = s.bucket.IsObjectExist(destObjName)
- c.Assert(exist, Equals, true)
- c.Assert(result.Bucket, Equals, s.bucket.BucketName)
- c.Assert(result.Object, Equals, destObjName)
- //no support process
- process = fmt.Sprintf("image/resize,w_100|saveas,o_%v,b_%v", base64.URLEncoding.EncodeToString([]byte(destObjName)), base64.URLEncoding.EncodeToString([]byte(s.bucket.BucketName)))
- result, err = s.bucket.ProcessObject(objectName, process)
- c.Assert(err, NotNil)
- }
- // Private
- func createFileAndWrite(fileName string, data []byte) error {
- os.Remove(fileName)
- fo, err := os.Create(fileName)
- if err != nil {
- return err
- }
- defer fo.Close()
- bytes, err := fo.Write(data)
- if err != nil {
- return err
- }
- if bytes != len(data) {
- return fmt.Errorf(fmt.Sprintf("write %d bytes not equal data length %d", bytes, len(data)))
- }
- return nil
- }
- // Compare the content between fileL and fileR
- func compareFiles(fileL string, fileR string) (bool, error) {
- finL, err := os.Open(fileL)
- if err != nil {
- return false, err
- }
- defer finL.Close()
- finR, err := os.Open(fileR)
- if err != nil {
- return false, err
- }
- defer finR.Close()
- statL, err := finL.Stat()
- if err != nil {
- return false, err
- }
- statR, err := finR.Stat()
- if err != nil {
- return false, err
- }
- if statL.Size() != statR.Size() {
- return false, nil
- }
- size := statL.Size()
- if size > 102400 {
- size = 102400
- }
- bufL := make([]byte, size)
- bufR := make([]byte, size)
- for {
- n, _ := finL.Read(bufL)
- if 0 == n {
- break
- }
- n, _ = finR.Read(bufR)
- if 0 == n {
- break
- }
- if !bytes.Equal(bufL, bufR) {
- return false, nil
- }
- }
- return true, nil
- }
- // Compare the content of file and data
- func compareFileData(file string, data []byte) (bool, error) {
- fin, err := os.Open(file)
- if err != nil {
- return false, err
- }
- defer fin.Close()
- stat, err := fin.Stat()
- if err != nil {
- return false, err
- }
- if stat.Size() != (int64)(len(data)) {
- return false, nil
- }
- buf := make([]byte, stat.Size())
- n, err := fin.Read(buf)
- if err != nil {
- return false, err
- }
- if stat.Size() != (int64)(n) {
- return false, errors.New("read error")
- }
- if !bytes.Equal(buf, data) {
- return false, nil
- }
- return true, nil
- }
- func walkDir(dirPth, suffix string) ([]string, error) {
- var files = []string{}
- suffix = strings.ToUpper(suffix)
- err := filepath.Walk(dirPth,
- func(filename string, fi os.FileInfo, err error) error {
- if err != nil {
- return err
- }
- if fi.IsDir() {
- return nil
- }
- if strings.HasSuffix(strings.ToUpper(fi.Name()), suffix) {
- files = append(files, filename)
- }
- return nil
- })
- return files, err
- }
- func removeTempFiles(path string, prefix string) error {
- files, err := walkDir(path, prefix)
- if err != nil {
- return nil
- }
- for _, file := range files {
- os.Remove(file)
- }
- return nil
- }
- func isFileExist(filename string) (bool, error) {
- _, err := os.Stat(filename)
- if err != nil && os.IsNotExist(err) {
- return false, nil
- } else if err != nil {
- return false, err
- } else {
- return true, nil
- }
- }
- func readBody(body io.ReadCloser) (string, error) {
- data, err := ioutil.ReadAll(body)
- body.Close()
- if err != nil {
- return "", err
- }
- return string(data), nil
- }
- func (s *OssBucketSuite) getObject(objects []ObjectProperties, object string) (bool, ObjectProperties) {
- for _, v := range objects {
- if v.Key == object {
- return true, v
- }
- }
- return false, ObjectProperties{}
- }
|