51 lines
1.4 KiB
Go
51 lines
1.4 KiB
Go
package fs
|
|
|
|
import (
|
|
"context"
|
|
"fmt"
|
|
"os"
|
|
"path/filepath"
|
|
|
|
"git.solsynth.dev/hypernet/paperclip/pkg/filekit/models"
|
|
pkg "git.solsynth.dev/hypernet/paperclip/pkg/internal"
|
|
jsoniter "github.com/json-iterator/go"
|
|
"github.com/minio/minio-go/v7"
|
|
"github.com/spf13/viper"
|
|
)
|
|
|
|
func DownloadFileToLocal(meta models.Attachment, dst int) (string, error) {
|
|
destMap := viper.GetStringMap(fmt.Sprintf("destinations.%d", dst))
|
|
|
|
var dest models.BaseDestination
|
|
rawDest, _ := jsoniter.Marshal(destMap)
|
|
_ = jsoniter.Unmarshal(rawDest, &dest)
|
|
|
|
switch dest.Type {
|
|
case models.DestinationTypeLocal:
|
|
var destConfigured models.LocalDestination
|
|
_ = jsoniter.Unmarshal(rawDest, &destConfigured)
|
|
|
|
return filepath.Join(destConfigured.Path, meta.Uuid), nil
|
|
case models.DestinationTypeS3:
|
|
var destConfigured models.S3Destination
|
|
_ = jsoniter.Unmarshal(rawDest, &destConfigured)
|
|
|
|
client, err := destConfigured.GetClient()
|
|
client.SetAppInfo("HyperNet.Paperclip", pkg.AppVersion)
|
|
if err != nil {
|
|
return "", fmt.Errorf("unable to configure s3 client: %v", err)
|
|
}
|
|
|
|
inDst := filepath.Join(os.TempDir(), meta.Uuid)
|
|
|
|
err = client.FGetObject(context.Background(), destConfigured.Bucket, meta.Uuid, inDst, minio.GetObjectOptions{})
|
|
if err != nil {
|
|
return "", fmt.Errorf("unable to upload file to s3: %v", err)
|
|
}
|
|
|
|
return inDst, nil
|
|
default:
|
|
return "", fmt.Errorf("invalid destination: unsupported protocol %s", dest.Type)
|
|
}
|
|
}
|