package internal

import (
	"context"
	"fmt"
	"strings"

	"github.com/minio/minio-go/v7"
	"github.com/minio/minio-go/v7/pkg/credentials"
)

var (
	MinioClient *minio.Client
)

func Backup(ctx context.Context) error {
	var err error
	var getErrors = []string{}
	bucketNames := GetEnvWithDefault("BUCKET_NAMES", "")
	backupRoot := GetEnvWithDefault("BACKUP_ROOT", "/backup")

	MinioClient, err = minio.New(GetEnvWithDefault("S3_HOST", "localhost"), &minio.Options{
		Creds:  credentials.NewStaticV4(GetEnvWithDefault("S3_ACCESS_KEY_ID", ""), GetEnvWithDefault("S3_ACCESS_KEY_SECRET", ""), ""),
		Secure: GetEnvWithDefault("S3_USE_SSL", "") == "true",
		Region: GetEnvWithDefault("S3_REGION", "us-east-1"),
	})
	if err != nil {
		return err
	}

	for _, bucket := range strings.Split(bucketNames, ",") {
		bucket = strings.TrimSpace(bucket)
		for object := range MinioClient.ListObjects(ctx, bucket, minio.ListObjectsOptions{Recursive: true}) {
			getError := MinioClient.FGetObject(ctx, bucket, object.Key, fmt.Sprintf("%s/%s/%s", backupRoot, bucket, object.Key), minio.GetObjectOptions{})
			if getError != nil {
				getErrors = append(getErrors, getError.Error())
			}
		}
	}

	if len(getErrors) > 0 {
		err = fmt.Errorf("%d errors retrieving objects: %s", len(getErrors), strings.Join(getErrors, ", "))
	}

	return err
}