resource_google_project_service.go

package google

import (
	"fmt"
	"log"
	"strings"

	"github.com/hashicorp/errwrap"
	"github.com/hashicorp/terraform/helper/schema"
)

func resourceGoogleProjectService() *schema.Resource {
	return &schema.Resource{
		Create: resourceGoogleProjectServiceCreate,
		Read:   resourceGoogleProjectServiceRead,
		Delete: resourceGoogleProjectServiceDelete,
		Update: resourceGoogleProjectServiceUpdate,

		Importer: &schema.ResourceImporter{
			State: schema.ImportStatePassthrough,
		},

		Schema: map[string]*schema.Schema{
			"service": {
				Type:     schema.TypeString,
				Required: true,
				ForceNew: true,
			},
			"project": &schema.Schema{
				Type:     schema.TypeString,
				Optional: true,
				Computed: true,
				ForceNew: true,
			},
			"disable_on_destroy": &schema.Schema{
				Type:     schema.TypeBool,
				Optional: true,
				Default:  true,
			},
		},
	}
}

func resourceGoogleProjectServiceCreate(d *schema.ResourceData, meta interface{}) error {
	config := meta.(*Config)

	project, err := getProject(d, config)
	if err != nil {
		return err
	}

	srv := d.Get("service").(string)

	if err = enableService(srv, project, config); err != nil {
		return errwrap.Wrapf("Error enabling service: {{err}}", err)
	}

	d.SetId(projectServiceId{project, srv}.terraformId())
	return resourceGoogleProjectServiceRead(d, meta)
}

func resourceGoogleProjectServiceRead(d *schema.ResourceData, meta interface{}) error {
	config := meta.(*Config)

	id, err := parseProjectServiceId(d.Id())
	if err != nil {
		return err
	}

	project, err := config.clientResourceManager.Projects.Get(id.project).Do()
	if err != nil {
		return handleNotFoundError(err, d, id.project)
	}
	if project.LifecycleState == "DELETE_REQUESTED" {
		log.Printf("[WARN] Removing %s from state, its project is deleted", id.terraformId())
		d.SetId("")
		return nil
	}

	services, err := getApiServices(id.project, config, map[string]struct{}{})
	if err != nil {
		return err
	}

	d.Set("project", id.project)

	for _, s := range services {
		if s == id.service {
			d.Set("service", s)
			return nil
		}
	}

	// The service is not enabled server-side, so remove it from state
	d.SetId("")
	return nil
}

func resourceGoogleProjectServiceDelete(d *schema.ResourceData, meta interface{}) error {
	config := meta.(*Config)

	if disable := d.Get("disable_on_destroy"); !(disable.(bool)) {
		log.Printf("Not disabling service '%s', because disable_on_destroy is false.", d.Id())
		d.SetId("")
		return nil
	}

	id, err := parseProjectServiceId(d.Id())
	if err != nil {
		return err
	}

	project, err := config.clientResourceManager.Projects.Get(id.project).Do()
	if err != nil {
		return handleNotFoundError(err, d, id.project)
	}
	if project.LifecycleState == "DELETE_REQUESTED" {
		log.Printf("[WARN] Removing %s from state, its project is deleted", id.terraformId())
		d.SetId("")
		return nil
	}

	if err = disableService(id.service, id.project, config); err != nil {
		return fmt.Errorf("Error disabling service: %s", err)
	}

	d.SetId("")
	return nil
}

func resourceGoogleProjectServiceUpdate(d *schema.ResourceData, meta interface{}) error {
	// The only thing that can be updated without a ForceNew is whether to disable the service on resource delete.
	// This doesn't require any calls to any APIs since it's all internal state.
	// This update is a no-op.
	return nil
}

// Parts that make up the id of a `google_project_service` resource.
// Project is included in order to allow multiple projects to enable the same service within the same Terraform state
type projectServiceId struct {
	project string
	service string
}

func (id projectServiceId) terraformId() string {
	return fmt.Sprintf("%s/%s", id.project, id.service)
}

func parseProjectServiceId(id string) (*projectServiceId, error) {
	parts := strings.Split(id, "/")
	if len(parts) != 2 {
		return nil, fmt.Errorf("Invalid google_project_service id format, expecting `{project}/{service}`, found %s", id)
	}

	return &projectServiceId{parts[0], parts[1]}, nil
}