Update oss_service.go
This commit is contained in:
@@ -186,17 +186,6 @@ func newS3OSS(cfg *models.OssApi) (OSSProvider, error) {
|
|||||||
return nil, fmt.Errorf("error creando cliente S3/MinIO: %w", err)
|
return nil, fmt.Errorf("error creando cliente S3/MinIO: %w", err)
|
||||||
}
|
}
|
||||||
|
|
||||||
// Verificar que el bucket existe
|
|
||||||
ctx, cancel := context.WithTimeout(context.Background(), 10*time.Second)
|
|
||||||
defer cancel()
|
|
||||||
exists, err := client.BucketExists(ctx, cfg.BucketName)
|
|
||||||
if err != nil {
|
|
||||||
return nil, fmt.Errorf("error verificando bucket S3: %w", err)
|
|
||||||
}
|
|
||||||
if !exists {
|
|
||||||
return nil, fmt.Errorf("bucket '%s' no existe en S3/MinIO", cfg.BucketName)
|
|
||||||
}
|
|
||||||
|
|
||||||
return &s3OSS{
|
return &s3OSS{
|
||||||
client: client,
|
client: client,
|
||||||
bucketName: cfg.BucketName,
|
bucketName: cfg.BucketName,
|
||||||
|
|||||||
Reference in New Issue
Block a user