resource_parser.go

// Copyright (c) HashiCorp, Inc.
// SPDX-License-Identifier: MPL-2.0

//go:generate go run internal/generate_resources.go
package iamutil

import (
	"fmt"
	"net/url"
	"strings"

	"github.com/hashicorp/go-gcp-common/gcputil"
)

const (
	resourceParsingErrorTmpl = `invalid resource "%s": %v`
	errorMultipleServices    = `please provide a self-link or full resource name for non-service-unique resource type`
	errorMultipleVersions    = `please provide a self-link with version instead; multiple versions of this resource exist, all non-preferred`
)

// ResourceParser handles parsing resource ID and REST
// config from a given resource ID or name.
type ResourceParser interface {
	Parse(string) (Resource, error)
}

// GeneratedResources implements ResourceParser - a value
// is generated using internal/generate_iam.go
type GeneratedResources map[string]map[string]map[string]RestResource

func getResourceFromVersions(rawName string, versionMap map[string]RestResource) (*RestResource, error) {
	possibleVer := make([]string, 0, len(versionMap))
	for v, config := range versionMap {
		if config.IsPreferredVersion || len(versionMap) == 1 {
			return &config, nil
		}
		if strings.Contains(v, "alpha") {
			continue
		}
		if strings.Contains(v, "beta") {
			continue
		}
		possibleVer = append(possibleVer, v)
	}
	if len(possibleVer) == 1 {
		cfg := versionMap[possibleVer[0]]
		return &cfg, nil
	}
	return nil, fmt.Errorf(resourceParsingErrorTmpl, rawName, errorMultipleVersions)
}

func (apis GeneratedResources) GetRestConfig(rawName string, fullName *gcputil.FullResourceName, prefix string) (*RestResource, error) {
	relName := fullName.RelativeResourceName
	if relName == nil {
		return nil, fmt.Errorf(resourceParsingErrorTmpl, rawName, fmt.Errorf("relative name does not exist: %s", rawName))
	}

	serviceMap, ok := apis[relName.TypeKey]
	if !ok {
		return nil, fmt.Errorf(resourceParsingErrorTmpl, rawName, fmt.Errorf("unsupported resource type: %s", relName.TypeKey))
	}

	if len(prefix) > 0 {
		for _, versionMap := range serviceMap {
			for _, config := range versionMap {
				if strings.HasPrefix(config.GetMethod.BaseURL+config.GetMethod.Path, prefix) {
					return &config, nil
				}
			}
		}
		return nil, fmt.Errorf(resourceParsingErrorTmpl, rawName, fmt.Errorf("unsupported service/version for resource with prefix %s", prefix))
	} else if len(fullName.Service) > 0 {
		versionMap, ok := serviceMap[fullName.Service]
		if !ok {
			return nil, fmt.Errorf(resourceParsingErrorTmpl, rawName, fmt.Errorf("unsupported service %s for resource %s", fullName.Service, relName.TypeKey))
		}

		return getResourceFromVersions(rawName, versionMap)
	} else if len(serviceMap) == 1 {
		for _, versionMap := range serviceMap {
			return getResourceFromVersions(rawName, versionMap)
		}
	}
	return nil, fmt.Errorf(resourceParsingErrorTmpl, rawName, errorMultipleServices)
}

func (apis GeneratedResources) Parse(rawName string) (Resource, error) {
	rUrl, err := url.Parse(rawName)
	if err != nil {
		return nil, fmt.Errorf(`resource "%s" is invalid URI`, rawName)
	}

	var relName *gcputil.RelativeResourceName
	var prefix, service string
	if rUrl.Scheme != "" {
		selfLink, err := gcputil.ParseProjectResourceSelfLink(rawName)
		if err != nil {
			return nil, err
		}
		relName = selfLink.RelativeResourceName
		prefix = selfLink.Prefix
	} else if rUrl.Host != "" {
		fullName, err := gcputil.ParseFullResourceName(rawName)
		if err != nil {
			return nil, err
		}
		relName = fullName.RelativeResourceName
		service = fullName.Service
	} else {
		relName, err = gcputil.ParseRelativeName(rawName)
		if err != nil {
			return nil, err
		}
	}

	if relName == nil {
		return nil, fmt.Errorf(resourceParsingErrorTmpl, rawName, "nil relative name")
	}

	cfg, err := apis.GetRestConfig(
		rawName,
		&gcputil.FullResourceName{
			Service:              service,
			RelativeResourceName: relName,
		},
		prefix)
	if err != nil {
		return nil, err
	}
	switch cfg.TypeKey {
	case "projects/datasets":
		return &DatasetResource{relativeId: relName, config: cfg}, nil
	default:
		return &IamResource{relativeId: relName, config: cfg}, nil
	}
}