feat(pkg/gitreceive/storage): add convenience funcs for dealing with object storage

Author: Aaron Schlesinger

pkg/gitreceive/storage/bucket.go

@@ -0,0 +1,8 @@
+package storage
+
+func CreateBucket(s3Client *s3.Client, bucketName string) error {
+	_, err := s3Client.CreateBucket(&s3.CreateBucketInput{
+		Bucket: aws.String(bucketName),
+	})
+	return err
+}

pkg/gitreceive/storage/client.go

@@ -0,0 +1,23 @@
+package storage
+
+import (
+	"github.com/aws/aws-sdk-go/aws"
+	"github.com/aws/aws-sdk-go/aws/session"
+	"github.com/aws/aws-sdk-go/service/s3"
+)
+
+func GetClient() (*s3.S3, error) {
+	awsCfg := new(aws.Config)
+	endpt, err := getEndpoint()
+	if err != nil {
+		return nil, err
+	}
+	awsCfg.Endpoint = endpt
+	creds, err := getCreds()
+	if err != nil {
+		return nil, err
+	}
+	awsCfg.Credentials = creds
+	svc := s3.New(session.New(awsCfg), &aws.Config{})
+	return svc, nil
+}

pkg/gitreceive/storage/exists.go

@@ -0,0 +1,19 @@
+package storage
+
+import (
+	"github.com/aws/aws-sdk-go/aws"
+	"github.com/aws/aws-sdk-go/service/s3"
+)
+
+func ObjectExists(s3Client *s3.S3, bucket, objName string) bool {
+	// see https://godoc.org/github.com/aws/aws-sdk-go/service/s3#example-S3-HeadObject
+	in := &s3.HeadObjectInput{
+		Bucket: aws.String(bucket),
+		Key:    aws.String(objName),
+	}
+	resp, err := svc.HeadObject(in)
+	if err != nil {
+		return false
+	}
+	return resp != nil
+}

pkg/gitreceive/storage/upload.go

@@ -0,0 +1,12 @@
+package storage
+
+import (
+	"io"
+
+	"github.com/aws/aws-sdk-go/service/s3"
+)
+
+func Upload(s3Client *s3.S3, bucketName, objKey string, reader io.Reader) error {
+	// see https://godoc.org/github.com/aws/aws-sdk-go/service/s3#example-S3-PutObject
+	return nil
+}