google_storage.go

package yuri

///disclaimer::
///Do not use the this storage class
///I only created it with my use case in mind
import (
	"context"
	"fmt"
	"io"
	"os"
	"time"

	"cloud.google.com/go/storage"
	"google.golang.org/api/option"
)

func InitGoogleStorage(path string) (*storage.Client, error) {
	opt := option.WithCredentialsFile(path)
	ctx := context.Background()
	client, err := storage.NewClient(ctx, opt)
	return client, err

}

type GoogleStorage struct {
	Client    *storage.Client
	ProjectId string
}

func CreateBucket(Client *storage.Client, projectId, bucketName string) error {
	ctx := context.Background()
	bucket := Client.Bucket(bucketName)
	ctx, cancel := context.WithTimeout(ctx, time.Second*20)
	defer cancel()
	if err := bucket.Create(ctx, projectId, nil); err != nil {
		return err
	}
	return nil

}

func UploadFile(Client *storage.Client, bucket, objectName, filename string, isPublic bool) (*storage.Writer, error) {
	ctx := context.Background()
	f, err := os.Open(filename)
	if err != nil {
		return nil, err
	}
	defer f.Close()
	ctx, cancel := context.WithTimeout(ctx, time.Second*50)
	defer cancel()
	handle := Client.Bucket(bucket).Object(objectName)

	wc := handle.NewWriter(ctx)
	///wc.MediaLink="cdn.codesahara.com/itachi"
	if isPublic {
		wc.ACL = []storage.ACLRule{{Entity: storage.AllUsers, Role: storage.RoleReader}}
	}
	contentType, err := GetFileContentTypeWithExtension(filename)
	if err != nil {
		return nil, err
	}
	wc.ContentType = contentType

	if _, err = io.Copy(wc, f); err != nil {
		return nil, fmt.Errorf("io.Copy: %v", err)
	}
	if err := wc.Close(); err != nil {
		return nil, fmt.Errorf("Writer.Close: %v", err)
	}
	return wc, nil
}