evalphobia / aws-sdk-go-v2-wrapper

import (

	"context"

	"time"

)

// XExistObject checks if the object exists or not.

func (svc *S3) XExistObject(ctx context.Context, bucket, path string) (bool, error) {

	res, err := svc.HeadObject(ctx, HeadObjectRequest{

		Bucket: bucket,

		Key:    path,

	})

	if err != nil {

		return false, err

	}

	return res.Exists, nil

}

// XGetObjectFromPath gets an object from `path`.

func (svc *S3) XGetObjectFromPath(ctx context.Context, bucket, path string) (*GetObjectResult, error) {

	return svc.GetObject(ctx, GetObjectRequest{

		Bucket: bucket,

		Key:    path,

	})

}

// XGetPresignURL gets an presigned url of the object for GET.

func (svc *S3) XGetPresignURL(ctx context.Context, bucket, path string, dur time.Duration) (string, error) {

	in := GetObjectRequest{

		Bucket: bucket,

		Key:    path,

	}.ToInput()

	r := svc.client.GetObjectRequest(in)

	return r.Presign(dur)

}

// XDeleteObjectFromPath deletes an object from `path`.

}

// XPutObjectToPath puts an object to the `path` and bytes data.

func (svc *S3) XPutObjectToPath(ctx context.Context, bucket, path string, data []byte) (*PutObjectResult, error) {

	return svc.PutObject(ctx, PutObjectRequest{

		Bucket:    bucket,

		Key:       path,

		BodyBytes: data,

	})

}