Function NewPublishedStorage

gcs/public.go:41–88

NewPublishedStorage creates a GCS-backed published storage.

(bucket, prefix, credentialsFile, serviceAccountJSON,
	project, endpoint, defaultACL, storageClass, encryptionKey string,
	disableMultiDel, debug bool)

// NewPublishedStorage creates a GCS-backed published storage.
func NewPublishedStorage(bucket, prefix, credentialsFile, serviceAccountJSON,
	project, endpoint, defaultACL, storageClass, encryptionKey string,
	disableMultiDel, debug bool) (*PublishedStorage, error) {

	ctx := context.TODO()
	opts := make([]option.ClientOption, 0, 4)

	if endpoint != "" {
		opts = append(opts, option.WithEndpoint(endpoint), option.WithoutAuthentication())
	} else if credentialsFile != "" {
		opts = append(opts, option.WithAuthCredentialsFile(option.ServiceAccount, credentialsFile))
	} else if serviceAccountJSON != "" {
		opts = append(opts, option.WithAuthCredentialsJSON(option.ServiceAccount, []byte(serviceAccountJSON)))
	}

	if project != "" {
		opts = append(opts, option.WithQuotaProject(project))
	}

	// When pointing at a non-production endpoint (an explicit override or the
	// STORAGE_EMULATOR_HOST hook the GCS Go client honours natively), force
	// JSON reads. The default XML download API uses virtual-host-style URLs
	// (https://<bucket>.storage.googleapis.com/...) that emulators and most
	// dev/staging endpoints can't serve under a single listener; the JSON API
	// uses path-based URLs that work the same against real GCS or an emulator.
	if endpoint != "" || os.Getenv("STORAGE_EMULATOR_HOST") != "" {
		opts = append(opts, storage.WithJSONReads())
	}

	client, err := storage.NewClient(ctx, opts...)
	if err != nil {
		return nil, err
	}

	result := &PublishedStorage{
		client:          client,
		bucket:          client.Bucket(bucket),
		bucketName:      bucket,
		prefix:          prefix,
		acl:             defaultACL,
		storageClass:    storageClass,
		encryptionKey:   encryptionKey,
		disableMultiDel: disableMultiDel,
		debug:           debug,
	}

	return result, nil
}

func (g *PublishedStorage) String() string {
	return fmt.Sprintf("GCS: %s/%s", g.bucketName, g.prefix)