fix s3 location when using custom endpoint (#656)

livekit · Apr 17, 2024 · ea24d03 · ea24d03
1 parent b9cecd7
commit ea24d03
Showing 1 changed file with 6 additions and 1 deletion.
diff --git a/pkg/pipeline/sink/uploader/s3.go b/pkg/pipeline/sink/uploader/s3.go
@@ -201,5 +201,10 @@ func (u *S3Uploader) upload(localFilepath, storageFilepath string, outputType ty
 		return "", 0, wrap("S3", err)
 	}
 
-	return fmt.Sprintf("https://%s.s3.amazonaws.com/%s", *u.bucket, storageFilepath), stat.Size(), nil
+	endpoint := "s3.amazonaws.com"
+	if u.awsConfig.Endpoint != nil {
+		endpoint = *u.awsConfig.Endpoint
+	}
+
+	return fmt.Sprintf("https://%s.%s/%s", *u.bucket, endpoint, storageFilepath), stat.Size(), nil
 }