summaryrefslogtreecommitdiffstats
path: root/vendor/github.com/mattermost/mattermost-server/v6/shared
diff options
context:
space:
mode:
Diffstat (limited to 'vendor/github.com/mattermost/mattermost-server/v6/shared')
-rw-r--r--vendor/github.com/mattermost/mattermost-server/v6/shared/filestore/s3store.go36
1 files changed, 24 insertions, 12 deletions
diff --git a/vendor/github.com/mattermost/mattermost-server/v6/shared/filestore/s3store.go b/vendor/github.com/mattermost/mattermost-server/v6/shared/filestore/s3store.go
index f938f4d5..c45f626a 100644
--- a/vendor/github.com/mattermost/mattermost-server/v6/shared/filestore/s3store.go
+++ b/vendor/github.com/mattermost/mattermost-server/v6/shared/filestore/s3store.go
@@ -255,18 +255,25 @@ func (b *S3FileBackend) CopyFile(oldPath, newPath string) error {
oldPath = filepath.Join(b.pathPrefix, oldPath)
newPath = filepath.Join(b.pathPrefix, newPath)
srcOpts := s3.CopySrcOptions{
- Bucket: b.bucket,
- Object: oldPath,
- Encryption: encrypt.NewSSE(),
+ Bucket: b.bucket,
+ Object: oldPath,
}
+ if b.encrypt {
+ srcOpts.Encryption = encrypt.NewSSE()
+ }
+
dstOpts := s3.CopyDestOptions{
- Bucket: b.bucket,
- Object: newPath,
- Encryption: encrypt.NewSSE(),
+ Bucket: b.bucket,
+ Object: newPath,
}
+ if b.encrypt {
+ dstOpts.Encryption = encrypt.NewSSE()
+ }
+
if _, err := b.client.CopyObject(context.Background(), dstOpts, srcOpts); err != nil {
return errors.Wrapf(err, "unable to copy file from %s to %s", oldPath, newPath)
}
+
return nil
}
@@ -274,14 +281,19 @@ func (b *S3FileBackend) MoveFile(oldPath, newPath string) error {
oldPath = filepath.Join(b.pathPrefix, oldPath)
newPath = filepath.Join(b.pathPrefix, newPath)
srcOpts := s3.CopySrcOptions{
- Bucket: b.bucket,
- Object: oldPath,
- Encryption: encrypt.NewSSE(),
+ Bucket: b.bucket,
+ Object: oldPath,
+ }
+ if b.encrypt {
+ srcOpts.Encryption = encrypt.NewSSE()
}
+
dstOpts := s3.CopyDestOptions{
- Bucket: b.bucket,
- Object: newPath,
- Encryption: encrypt.NewSSE(),
+ Bucket: b.bucket,
+ Object: newPath,
+ }
+ if b.encrypt {
+ dstOpts.Encryption = encrypt.NewSSE()
}
if _, err := b.client.CopyObject(context.Background(), dstOpts, srcOpts); err != nil {