pulumi/pkg/backend/cloud/stack.go

// Copyright 2016-2017, Pulumi Corporation.  All rights reserved.

package cloud

import (
	"encoding/json"

	"github.com/pulumi/pulumi/pkg/backend"
	"github.com/pulumi/pulumi/pkg/backend/cloud/apitype"
	"github.com/pulumi/pulumi/pkg/engine"
	"github.com/pulumi/pulumi/pkg/operations"
	"github.com/pulumi/pulumi/pkg/pack"
	"github.com/pulumi/pulumi/pkg/resource"
	"github.com/pulumi/pulumi/pkg/resource/config"
	"github.com/pulumi/pulumi/pkg/resource/deploy"
	"github.com/pulumi/pulumi/pkg/tokens"
)

// Stack is a cloud stack.  This simply adds some cloud-specific properties atop the standard backend stack interface.
type Stack interface {
	backend.Stack
	CloudURL() string  // the URL to the cloud containing this stack.
	OrgName() string   // the organization that owns this stack.
	CloudName() string // the PPC in which this stack is running.
}

// cloudStack is a cloud stack descriptor.
type cloudStack struct {
	name      tokens.QName     // the stack's name.
	cloudURL  string           // the URL to the cloud containing this stack.
	orgName   string           // the organization that owns this stack.
	cloudName string           // the PPC in which this stack is running.
	config    config.Map       // the stack's config bag.
	snapshot  *deploy.Snapshot // a snapshot representing the latest deployment state.
	b         *cloudBackend    // a pointer to the backend this stack belongs to.
}

func newStack(apistack apitype.Stack, b *cloudBackend) Stack {
	// Create a fake snapshot out of this stack.
	// TODO[pulumi/pulumi-service#249]: add time, version, etc. info to the manifest.
	stackName := apistack.StackName
	var resources []*resource.State
	for _, res := range apistack.Resources {
		resources = append(resources, resource.NewState(
			tokens.Type(res.Type),
			resource.URN(res.URN),
			res.Custom,
			false,
			resource.ID(res.ID),
			resource.NewPropertyMapFromMap(res.Inputs),
			resource.NewPropertyMapFromMap(res.Outputs),
			resource.URN(res.Parent),
			res.Protect,
		))
	}
	snapshot := deploy.NewSnapshot(stackName, deploy.Manifest{}, resources)

	// Now assemble all the pieces into a stack structure.
	return &cloudStack{
		name:      stackName,
		cloudURL:  b.cloudURL,
		orgName:   apistack.OrgName,
		cloudName: apistack.CloudName,
		config:    nil, // TODO[pulumi/pulumi-service#249]: add the config variables.
		snapshot:  snapshot,
		b:         b,
	}
}

func (s *cloudStack) Name() tokens.QName         { return s.name }
func (s *cloudStack) Config() config.Map         { return s.config }
func (s *cloudStack) Snapshot() *deploy.Snapshot { return s.snapshot }
func (s *cloudStack) Backend() backend.Backend   { return s.b }
func (s *cloudStack) CloudURL() string           { return s.cloudURL }
func (s *cloudStack) OrgName() string            { return s.orgName }
func (s *cloudStack) CloudName() string          { return s.cloudName }

func (s *cloudStack) Remove(force bool) (bool, error) {
	return backend.RemoveStack(s, force)
}

func (s *cloudStack) Preview(pkg *pack.Package, root string, debug bool, opts engine.PreviewOptions) error {
	return backend.PreviewStack(s, pkg, root, debug, opts)
}

func (s *cloudStack) Update(pkg *pack.Package, root string, debug bool, opts engine.DeployOptions) error {
	return backend.UpdateStack(s, pkg, root, debug, opts)
}

func (s *cloudStack) Destroy(pkg *pack.Package, root string, debug bool, opts engine.DestroyOptions) error {
	return backend.DestroyStack(s, pkg, root, debug, opts)
}

func (s *cloudStack) GetLogs(query operations.LogQuery) ([]operations.LogEntry, error) {
	return backend.GetStackLogs(s, query)
}

func (s *cloudStack) ExportDeployment() (json.RawMessage, error) {
	return backend.ExportStackDeployment(s)
}

func (s *cloudStack) ImportDeployment(deployment json.RawMessage) error {
	return backend.ImportStackDeployment(s, deployment)
}