46 lines
1.0 KiB
Go
46 lines
1.0 KiB
Go
package storage
|
|
|
|
import (
|
|
"context"
|
|
"io"
|
|
|
|
"github.com/aws/aws-sdk-go-v2/aws"
|
|
"github.com/aws/aws-sdk-go-v2/config"
|
|
"github.com/aws/aws-sdk-go-v2/feature/s3/manager"
|
|
"github.com/aws/aws-sdk-go-v2/service/s3"
|
|
)
|
|
|
|
type Storage interface {
|
|
Store(path string, content io.Reader) error
|
|
}
|
|
|
|
type Uploader interface {
|
|
Upload(ctx context.Context, input *s3.PutObjectInput, opts ...func(*manager.Uploader)) (*manager.UploadOutput, error)
|
|
}
|
|
|
|
type S3 struct {
|
|
bucket string
|
|
svc Uploader
|
|
}
|
|
|
|
func (s *S3) Store(path string, content io.Reader) error {
|
|
_, err := s.svc.Upload(context.Background(), &s3.PutObjectInput{
|
|
Bucket: aws.String(s.bucket),
|
|
Key: aws.String(path),
|
|
Body: content,
|
|
})
|
|
return err
|
|
}
|
|
|
|
func New(bucket string) (Storage, error) {
|
|
cfg, err := config.LoadDefaultConfig(context.Background())
|
|
if err != nil {
|
|
return nil, err
|
|
}
|
|
client := s3.NewFromConfig(cfg)
|
|
uploader := manager.NewUploader(client, func(u *manager.Uploader) {
|
|
u.PartSize = 5 * 1024 * 1024
|
|
})
|
|
return &S3{bucket: bucket, svc: uploader}, nil
|
|
}
|