Merge pull request gofiber#1144 from mstgnz/main

fix Minio concurrency issues for content type
mstgnz · Dec 18, 2023 · 1f2db3a · 1f2db3a
2 parents 114b6f3 + 9ace749
commit 1f2db3a
Showing 1 changed file with 4 additions and 0 deletions.
diff --git a/minio/minio.go b/minio/minio.go
@@ -6,6 +6,7 @@ import (
 	"errors"
 	"log"
 	"net/http"
+	"sync"
 	"time"
 
 	"github.com/minio/minio-go/v7"
@@ -18,6 +19,7 @@ type Storage struct {
 	minio *minio.Client
 	cfg   Config
 	ctx   context.Context
+	mu    sync.Mutex
 }
 
 // New creates a new storage
@@ -92,10 +94,12 @@ func (s *Storage) Set(key string, val []byte, exp time.Duration) error {
 	file := bytes.NewReader(val)
 
 	// set content type
+	s.mu.Lock()
 	s.cfg.PutObjectOptions.ContentType = http.DetectContentType(val)
 
 	// put object
 	_, err := s.minio.PutObject(s.ctx, s.cfg.Bucket, key, file, file.Size(), s.cfg.PutObjectOptions)
+	s.mu.Unlock()
 
 	return err
 }