Browse Source

Add delete folder and files inside

HEAD
Yang Luo 3 years ago
parent
commit
42842cd481
3 changed files with 9 additions and 6 deletions
  1. +6
    -3
      object/file.go
  2. +1
    -1
      object/store_provider.go
  3. +2
    -2
      storage/aliyun.go

+ 6
- 3
object/file.go View File

@@ -28,10 +28,13 @@ func DeleteFile(storeId string, key string, isLeaf bool) bool {
}

if isLeaf {
objectKey := fmt.Sprintf("%s", key)
storage.DeleteObject(store.Bucket, objectKey)
storage.DeleteObject(store.Bucket, key)
return true
} else {
return false
objects := storage.ListObjects(store.Bucket, key)
for _, object := range objects {
storage.DeleteObject(store.Bucket, object.Key)
}
return true
}
}

+ 1
- 1
object/store_provider.go View File

@@ -66,7 +66,7 @@ func (store *Store) createPathIfNotExisted(tokens []string, size int64, lastModi
}

func (store *Store) Populate() {
objects := storage.ListObjects(store.Bucket)
objects := storage.ListObjects(store.Bucket, "")
for _, object := range objects {
lastModifiedTime := object.LastModified.Local().Format(time.RFC3339)



+ 2
- 2
storage/aliyun.go View File

@@ -20,14 +20,14 @@ func getBucket(bucketName string) *oss.Bucket {
return bucket
}

func ListObjects(bucketName string) []oss.ObjectProperties {
func ListObjects(bucketName string, prefix string) []oss.ObjectProperties {
bucket := getBucket(bucketName)

res := []oss.ObjectProperties{}
marker := oss.Marker("")
i := 0
for {
resp, err := bucket.ListObjects(oss.MaxKeys(1000), marker)
resp, err := bucket.ListObjects(oss.Prefix(prefix), oss.MaxKeys(1000), marker)
if err != nil {
panic(err)
}


Loading…
Cancel
Save