@@ -51,8 +51,6 @@ type s3MediaServer struct {
5151 bucket string
5252 uploadPrefix string
5353 downloadPrefix string
54-
55- ctx context.Context
5654}
5755
5856var _ mediaServer = (* httpPutMediaServer )(nil )
@@ -95,8 +93,6 @@ func createS3MediaServer(bg *config.BridgeValues, parsed *url.URL, logger *logru
9593 bucketName := pathSplitted [0 ]
9694 uploadPrefix := strings .Join (pathSplitted [1 :], "/" )
9795
98- ctx := context .Background ()
99-
10096 var s3BaseUrl string
10197 if useSSL {
10298 s3BaseUrl = "https://" + parsed .Host
@@ -115,7 +111,7 @@ func createS3MediaServer(bg *config.BridgeValues, parsed *url.URL, logger *logru
115111 }).Debug ("configured minio client" )
116112
117113 // This will return an error if the bucket does not exist
118- headBucketResult , err := client .HeadBucket (ctx , & s3.HeadBucketInput {Bucket : aws .String (bucketName )})
114+ headBucketResult , err := client .HeadBucket (context . TODO () , & s3.HeadBucketInput {Bucket : aws .String (bucketName )})
119115 if err != nil {
120116 return nil , fmt .Errorf ("failed checking if bucket exists: %w" , err )
121117 }
@@ -131,7 +127,6 @@ func createS3MediaServer(bg *config.BridgeValues, parsed *url.URL, logger *logru
131127 logger : logger ,
132128 },
133129
134- ctx : ctx ,
135130 s3client : client ,
136131
137132 bucket : bucketName ,
@@ -206,10 +201,11 @@ func (h *httpPutMediaServer) handleFilesUpload(fi *config.FileInfo) (string, err
206201 h .logger .Debugf ("mediaserver upload url: %s" , url )
207202
208203 req .Header .Set ("Content-Type" , "binary/octet-stream" )
209- _ , err = client .Do (req )
204+ resp , err : = client .Do (req )
210205 if err != nil {
211206 return "" , fmt .Errorf ("mediaserver upload failed, could not Do request: %#v" , err )
212207 }
208+ defer resp .Body .Close ()
213209
214210 return h .httpDownloadPrefix + "/" + sha1sum + "/" + fi .Name , nil
215211}
@@ -244,7 +240,7 @@ func (h *s3MediaServer) handleFilesUpload(fi *config.FileInfo) (string, error) {
244240
245241 // We do not bother with multipart uploads for now, as files are expected to be small (less than 5GB).
246242 // If needed, we can implement that later.
247- info , err := h .s3client .PutObject (h . ctx , & s3.PutObjectInput {
243+ info , err := h .s3client .PutObject (context . TODO () , & s3.PutObjectInput {
248244 Bucket : aws .String (h .bucket ),
249245 Key : aws .String (key ),
250246 Body : bytes .NewReader (* fi .Data ),
0 commit comments