Skip to content

Commit 78e27c2

Browse files
committed
Delete upload files after session committed
1 parent 774d4c2 commit 78e27c2

File tree

1 file changed

+6
-7
lines changed

1 file changed

+6
-7
lines changed

models/upload.go

Lines changed: 6 additions & 7 deletions
Original file line numberDiff line numberDiff line change
@@ -119,6 +119,10 @@ func DeleteUploads(uploads ...*Upload) (err error) {
119119
return fmt.Errorf("delete uploads: %v", err)
120120
}
121121

122+
if err = sess.Commit(); err != nil {
123+
return err
124+
}
125+
122126
for _, upload := range uploads {
123127
localPath := upload.LocalPath()
124128
if !com.IsFile(localPath) {
@@ -130,12 +134,7 @@ func DeleteUploads(uploads ...*Upload) (err error) {
130134
}
131135
}
132136

133-
return sess.Commit()
134-
}
135-
136-
// DeleteUpload delete a upload
137-
func DeleteUpload(u *Upload) error {
138-
return DeleteUploads(u)
137+
return nil
139138
}
140139

141140
// DeleteUploadByUUID deletes a upload by UUID
@@ -148,7 +147,7 @@ func DeleteUploadByUUID(uuid string) error {
148147
return fmt.Errorf("GetUploadByUUID: %v", err)
149148
}
150149

151-
if err := DeleteUpload(upload); err != nil {
150+
if err := DeleteUploads(upload); err != nil {
152151
return fmt.Errorf("DeleteUpload: %v", err)
153152
}
154153

0 commit comments

Comments
 (0)