Skip to content

Commit

Permalink
add test case
Browse files Browse the repository at this point in the history
  • Loading branch information
dengwu12 committed Mar 27, 2017
1 parent 2dd7ecc commit 4a6a375
Show file tree
Hide file tree
Showing 3 changed files with 97 additions and 1 deletion.
7 changes: 7 additions & 0 deletions lib/command_test.go
Original file line number Diff line number Diff line change
Expand Up @@ -1085,6 +1085,13 @@ func (s *OssutilCommandSuite) TestStorageURL(c *C) {
c.Assert(storageURL.IsCloudURL(), Equals, false)
c.Assert(storageURL.IsFileURL(), Equals, true)
c.Assert(storageURL.ToString(), Equals, "oss://bucket/中文测试")

err = cloudURL.Init("oss:///abc/d", URLEncodingType)
c.Assert(err, NotNil)

cloudURL.object = "\\d"
err = cloudURL.checkObjectPrefix()
c.Assert(err, NotNil)
}

func (s *OssutilCommandSuite) TestErrOssDownloadFile(c *C) {
Expand Down
38 changes: 37 additions & 1 deletion lib/cp_test.go
Original file line number Diff line number Diff line change
Expand Up @@ -1374,8 +1374,20 @@ func (s *OssutilCommandSuite) TestRangeGet(c *C) {
object := randStr(10)
s.putObject(bucketName, object, uploadFileName, c)

// test range put
err := s.initCopyWithRange(uploadFileName, CloudURLToString(bucketName, object), false, true, false, DefaultBigFileThreshold, "1-2")
c.Assert(err, IsNil)
err = copyCommand.RunCommand()
c.Assert(err, NotNil)

// test range copy
err = s.initCopyWithRange(CloudURLToString(bucketName, object), CloudURLToString(bucketName, object + "dest"), false, true, false, DefaultBigFileThreshold, "1-2")
c.Assert(err, IsNil)
err = copyCommand.RunCommand()
c.Assert(err, NotNil)

// test range get
err := s.initCopyWithRange(CloudURLToString(bucketName, object), downloadFileName, false, true, false, DefaultBigFileThreshold, "")
err = s.initCopyWithRange(CloudURLToString(bucketName, object), downloadFileName, false, true, false, DefaultBigFileThreshold, "")
c.Assert(err, IsNil)
err = copyCommand.RunCommand()
c.Assert(err, IsNil)
Expand Down Expand Up @@ -1906,3 +1918,27 @@ func (s *OssutilCommandSuite) TestCPURLEncoding(c *C) {

s.removeBucket(bucketName, true, c)
}

func (s *OssutilCommandSuite) TestCPFunction(c *C) {
var srcURL CloudURL
srcURL.bucket = ""
var destURL CloudURL
err := copyCommand.checkCopyArgs([]StorageURLer{srcURL}, destURL, operationTypePut)
c.Assert(err, NotNil)

err = copyCommand.getFileListStatistic("notexistdir")
c.Assert(err, NotNil)

chFiles := make(chan fileInfoType, 100)
err = copyCommand.getFileList("notexistdir", chFiles)

bucketName := bucketNamePrefix + randLowStr(10)
bucket, err := copyCommand.command.ossBucket(bucketName)
destURL.bucket = bucketName
destURL.object = "abc"
var fileInfo fileInfoType
fileInfo.filePath = "a"
fileInfo.dir = "notexistdir"
_, err, _, _, _ = copyCommand.uploadFile(bucket, destURL, fileInfo)
c.Assert(err, NotNil)
}
53 changes: 53 additions & 0 deletions lib/ls_test.go
Original file line number Diff line number Diff line change
Expand Up @@ -421,10 +421,44 @@ func (s *OssutilCommandSuite) TestListMultipartUploads(c *C) {
s.removeBucket(bucketName, true, c)
}

func (s *OssutilCommandSuite) TestListMultipartUploadsError(c *C) {
bucketName := bucketNamePrefix + randLowStr(10)
s.putBucket(bucketName, c)

cfile := randStr(10)
data := fmt.Sprintf("[Credentials]\nendpoint=%s\naccessKeyID=%s\naccessKeySecret=%s", endpoint, "abc", accessKeySecret)
s.createFile(cfile, data, c)

command := "ls"
var args []string
str := ""
limitedNum := strconv.FormatInt(-1, 10)
ok := true
options := OptionMapType{
"endpoint": &str,
"accessKeyID": &str,
"accessKeySecret": &str,
"stsToken": &str,
"configFile": &cfile,
"limitedNum": &limitedNum,
"multipart": &ok,
}
showElapse, err := cm.RunCommand(command, args, options)
c.Assert(err, NotNil)
c.Assert(showElapse, Equals, false)

os.Remove(cfile)

s.removeBucket(bucketName, true, c)
}

func (s *OssutilCommandSuite) TestListLimitedMarker(c *C) {
bucketName := bucketNamePrefix + randLowStr(10)
s.putBucket(bucketName, c)

bucketName1 := bucketNamePrefix + randLowStr(10)
s.putBucket(bucketName1, c)

// list bucket
buckets := s.listLimitedMarker("", "", "ls ", -1, "", "", c)
c.Assert(FindPos(bucketName, buckets) != -1, Equals, true)
Expand All @@ -433,6 +467,10 @@ func (s *OssutilCommandSuite) TestListLimitedMarker(c *C) {
buckets = s.listLimitedMarker("", "", "ls ", 0, "", "", c)
c.Assert(len(buckets), Equals, 0)

// list bucket
buckets = s.listLimitedMarker("", "", "ls ", 1, "", "", c)
c.Assert(len(buckets), Equals, 1)

buckets = s.listLimitedMarker("", "", "ls ", -1, "t", "", c)
c.Assert(FindPos(bucketName, buckets), Equals, -1)

Expand Down Expand Up @@ -475,9 +513,18 @@ func (s *OssutilCommandSuite) TestListLimitedMarker(c *C) {
objects = s.listLimitedMarker(bucketName, "", "ls ", 6, "", "", c)
c.Assert(len(objects), Equals, 5)

objects = s.listLimitedMarker(bucketName, "", "ls -d", 6, "", "", c)
c.Assert(len(objects), Equals, 5)

objects = s.listLimitedMarker(bucketName, "", "ls ", 2, "", "", c)
c.Assert(len(objects), Equals, 2)

objects = s.listLimitedMarker(bucketName, "", "ls -d", 2, "", "", c)
c.Assert(len(objects), Equals, 2)

objects = s.listLimitedMarker(bucketName, "", "ls ", 0, "", "", c)
c.Assert(len(objects), Equals, 0)

objects = s.listLimitedMarker(bucketName, "", "ls ", 2, fmt.Sprintf("%s%d", objectPrefix, 1), "", c)
c.Assert(len(objects), Equals, 2)

Expand All @@ -498,6 +545,9 @@ func (s *OssutilCommandSuite) TestListLimitedMarker(c *C) {
objects = s.listLimitedMarker(bucketName, "", "ls -m", 2, "", uploadIDs[0], c)
c.Assert(len(objects), Equals, 2)

objects = s.listLimitedMarker(bucketName, "", "ls -md", 2, "", uploadIDs[0], c)
c.Assert(len(objects), Equals, 2)

objects = s.listLimitedMarker(bucketName, "", "ls -m", 10, "", uploadIDs[1], c)
c.Assert(len(objects), Equals, 5)

Expand Down Expand Up @@ -531,6 +581,9 @@ func (s *OssutilCommandSuite) TestListLimitedMarker(c *C) {

objects = s.listLimitedMarker(bucketName, "", "ls -a", 20, "t", uploadIDs[0], c)
c.Assert(len(objects), Equals, 0)

s.removeBucket(bucketName, true, c)
s.removeBucket(bucketName1, true, c)
}

func (s *OssutilCommandSuite) TestListURLEncoding(c *C) {
Expand Down

0 comments on commit 4a6a375

Please sign in to comment.