2014-05-24 21:27:58 +02:00
|
|
|
package command
|
|
|
|
|
|
|
|
import (
|
2014-07-13 18:34:35 +02:00
|
|
|
"bytes"
|
2014-06-19 01:42:13 +02:00
|
|
|
"fmt"
|
2014-06-19 06:36:44 +02:00
|
|
|
"os"
|
2014-07-13 18:34:35 +02:00
|
|
|
"sort"
|
2014-05-24 21:27:58 +02:00
|
|
|
"strings"
|
|
|
|
|
2014-06-19 01:42:13 +02:00
|
|
|
"github.com/hashicorp/terraform/terraform"
|
2014-05-24 21:27:58 +02:00
|
|
|
)
|
|
|
|
|
|
|
|
// ApplyCommand is a Command implementation that applies a Terraform
|
|
|
|
// configuration and actually builds or changes infrastructure.
|
|
|
|
type ApplyCommand struct {
|
2014-07-13 05:21:46 +02:00
|
|
|
Meta
|
|
|
|
|
2014-07-13 05:37:30 +02:00
|
|
|
ShutdownCh <-chan struct{}
|
2014-05-24 21:27:58 +02:00
|
|
|
}
|
|
|
|
|
2014-06-19 01:42:13 +02:00
|
|
|
func (c *ApplyCommand) Run(args []string) int {
|
2014-07-12 06:30:40 +02:00
|
|
|
var statePath, stateOutPath string
|
2014-06-19 06:36:44 +02:00
|
|
|
|
2014-07-13 05:21:46 +02:00
|
|
|
args = c.Meta.process(args)
|
|
|
|
|
2014-07-18 20:37:27 +02:00
|
|
|
cmdFlags := c.Meta.flagSet("apply")
|
2014-07-12 06:30:40 +02:00
|
|
|
cmdFlags.StringVar(&statePath, "state", DefaultStateFilename, "path")
|
|
|
|
cmdFlags.StringVar(&stateOutPath, "state-out", "", "path")
|
2014-06-19 01:42:13 +02:00
|
|
|
cmdFlags.Usage = func() { c.Ui.Error(c.Help()) }
|
|
|
|
if err := cmdFlags.Parse(args); err != nil {
|
|
|
|
return 1
|
|
|
|
}
|
|
|
|
|
2014-07-12 06:32:34 +02:00
|
|
|
var configPath string
|
2014-06-19 01:42:13 +02:00
|
|
|
args = cmdFlags.Args()
|
2014-07-12 06:30:40 +02:00
|
|
|
if len(args) > 1 {
|
|
|
|
c.Ui.Error("The apply command expacts at most one argument.")
|
2014-06-19 01:42:13 +02:00
|
|
|
cmdFlags.Usage()
|
|
|
|
return 1
|
2014-07-12 06:32:34 +02:00
|
|
|
} else if len(args) == 1 {
|
|
|
|
configPath = args[0]
|
|
|
|
} else {
|
|
|
|
var err error
|
|
|
|
configPath, err = os.Getwd()
|
|
|
|
if err != nil {
|
|
|
|
c.Ui.Error(fmt.Sprintf("Error getting pwd: %s", err))
|
|
|
|
}
|
2014-06-19 01:42:13 +02:00
|
|
|
}
|
|
|
|
|
2014-07-18 00:14:26 +02:00
|
|
|
// Prepare the extra hooks to count resources
|
|
|
|
countHook := new(CountHook)
|
|
|
|
c.Meta.extraHooks = []terraform.Hook{countHook}
|
|
|
|
|
2014-07-12 06:30:40 +02:00
|
|
|
// If we don't specify an output path, default to out normal state
|
|
|
|
// path.
|
2014-06-19 06:36:44 +02:00
|
|
|
if stateOutPath == "" {
|
|
|
|
stateOutPath = statePath
|
|
|
|
}
|
2014-06-19 01:42:13 +02:00
|
|
|
|
2014-07-12 06:30:40 +02:00
|
|
|
// Build the context based on the arguments given
|
2014-07-27 02:45:38 +02:00
|
|
|
ctx, planned, err := c.Context(configPath, statePath)
|
2014-07-01 19:02:13 +02:00
|
|
|
if err != nil {
|
|
|
|
c.Ui.Error(err.Error())
|
|
|
|
return 1
|
2014-06-19 01:42:13 +02:00
|
|
|
}
|
2014-07-03 22:12:45 +02:00
|
|
|
if !validateContext(ctx, c.Ui) {
|
|
|
|
return 1
|
|
|
|
}
|
2014-06-19 01:42:13 +02:00
|
|
|
|
2014-07-27 02:45:38 +02:00
|
|
|
// Plan if we haven't already
|
|
|
|
if !planned {
|
|
|
|
if _, err := ctx.Plan(nil); err != nil {
|
|
|
|
c.Ui.Error(fmt.Sprintf(
|
|
|
|
"Error creating plan: %s", err))
|
|
|
|
return 1
|
|
|
|
}
|
|
|
|
}
|
|
|
|
|
2014-07-13 02:03:55 +02:00
|
|
|
// Start the apply in a goroutine so that we can be interrupted.
|
2014-07-08 06:20:48 +02:00
|
|
|
var state *terraform.State
|
|
|
|
var applyErr error
|
|
|
|
doneCh := make(chan struct{})
|
2014-07-03 02:01:02 +02:00
|
|
|
go func() {
|
2014-07-08 06:20:48 +02:00
|
|
|
defer close(doneCh)
|
|
|
|
state, applyErr = ctx.Apply()
|
2014-07-03 02:01:02 +02:00
|
|
|
}()
|
|
|
|
|
2014-07-13 02:03:55 +02:00
|
|
|
// Wait for the apply to finish or for us to be interrupted so
|
|
|
|
// we can handle it properly.
|
2014-07-03 02:01:02 +02:00
|
|
|
err = nil
|
|
|
|
select {
|
|
|
|
case <-c.ShutdownCh:
|
|
|
|
c.Ui.Output("Interrupt received. Gracefully shutting down...")
|
|
|
|
|
|
|
|
// Stop execution
|
2014-07-03 20:46:40 +02:00
|
|
|
ctx.Stop()
|
2014-07-03 02:01:02 +02:00
|
|
|
|
|
|
|
// Still get the result, since there is still one
|
|
|
|
select {
|
|
|
|
case <-c.ShutdownCh:
|
|
|
|
c.Ui.Error(
|
|
|
|
"Two interrupts received. Exiting immediately. Note that data\n" +
|
|
|
|
"loss may have occurred.")
|
|
|
|
return 1
|
2014-07-08 06:20:48 +02:00
|
|
|
case <-doneCh:
|
2014-07-03 02:01:02 +02:00
|
|
|
}
|
2014-07-08 06:20:48 +02:00
|
|
|
case <-doneCh:
|
2014-07-03 02:01:02 +02:00
|
|
|
}
|
|
|
|
|
2014-07-08 06:20:48 +02:00
|
|
|
if state != nil {
|
|
|
|
// Write state out to the file
|
|
|
|
f, err := os.Create(stateOutPath)
|
|
|
|
if err == nil {
|
|
|
|
err = terraform.WriteState(state, f)
|
|
|
|
f.Close()
|
|
|
|
}
|
|
|
|
if err != nil {
|
|
|
|
c.Ui.Error(fmt.Sprintf("Failed to save state: %s", err))
|
|
|
|
return 1
|
|
|
|
}
|
2014-06-19 01:42:13 +02:00
|
|
|
}
|
|
|
|
|
2014-07-08 06:20:48 +02:00
|
|
|
if applyErr != nil {
|
2014-07-18 00:18:00 +02:00
|
|
|
c.Ui.Error(fmt.Sprintf(
|
|
|
|
"Error applying plan:\n\n"+
|
|
|
|
"%s\n\n"+
|
|
|
|
"Terraform does not automatically rollback in the face of errors.\n"+
|
|
|
|
"Instead, your Terraform state file has been partially updated with\n"+
|
|
|
|
"any resources that successfully completed. Please address the error\n"+
|
|
|
|
"above and apply again to incrementally change your infrastructure.",
|
|
|
|
applyErr))
|
2014-06-19 06:36:44 +02:00
|
|
|
return 1
|
|
|
|
}
|
|
|
|
|
2014-07-13 18:20:27 +02:00
|
|
|
c.Ui.Output(c.Colorize().Color(fmt.Sprintf(
|
|
|
|
"[reset][bold][green]\n"+
|
2014-07-18 00:14:26 +02:00
|
|
|
"Apply complete! Resources: %d added, %d changed, %d destroyed.",
|
|
|
|
countHook.Added,
|
|
|
|
countHook.Changed,
|
|
|
|
countHook.Removed)))
|
|
|
|
|
|
|
|
if countHook.Added > 0 || countHook.Changed > 0 {
|
|
|
|
c.Ui.Output(c.Colorize().Color(fmt.Sprintf(
|
|
|
|
"[reset]\n"+
|
|
|
|
"The state of your infrastructure has been saved to the path\n"+
|
|
|
|
"below. This state is required to modify and destroy your\n"+
|
|
|
|
"infrastructure, so keep it safe. To inspect the complete state\n"+
|
|
|
|
"use the `terraform show` command.\n\n"+
|
|
|
|
"State path: %s",
|
|
|
|
stateOutPath)))
|
|
|
|
}
|
2014-06-19 01:42:13 +02:00
|
|
|
|
2014-07-13 18:34:35 +02:00
|
|
|
// If we have outputs, then output those at the end.
|
|
|
|
if len(state.Outputs) > 0 {
|
|
|
|
outputBuf := new(bytes.Buffer)
|
|
|
|
outputBuf.WriteString("[reset][bold][green]\nOutputs:\n\n")
|
|
|
|
|
|
|
|
// Output the outputs in alphabetical order
|
|
|
|
keyLen := 0
|
|
|
|
keys := make([]string, 0, len(state.Outputs))
|
|
|
|
for key, _ := range state.Outputs {
|
|
|
|
keys = append(keys, key)
|
|
|
|
if len(key) > keyLen {
|
|
|
|
keyLen = len(key)
|
|
|
|
}
|
|
|
|
}
|
|
|
|
sort.Strings(keys)
|
|
|
|
|
|
|
|
for _, k := range keys {
|
|
|
|
v := state.Outputs[k]
|
|
|
|
|
|
|
|
outputBuf.WriteString(fmt.Sprintf(
|
|
|
|
" %s%s = %s\n",
|
|
|
|
k,
|
|
|
|
strings.Repeat(" ", keyLen-len(k)),
|
|
|
|
v))
|
|
|
|
}
|
|
|
|
|
|
|
|
c.Ui.Output(c.Colorize().Color(
|
|
|
|
strings.TrimSpace(outputBuf.String())))
|
|
|
|
}
|
|
|
|
|
2014-05-24 21:27:58 +02:00
|
|
|
return 0
|
|
|
|
}
|
|
|
|
|
|
|
|
func (c *ApplyCommand) Help() string {
|
|
|
|
helpText := `
|
2014-07-12 06:30:40 +02:00
|
|
|
Usage: terraform apply [options] [dir]
|
2014-05-24 21:27:58 +02:00
|
|
|
|
2014-07-12 06:30:40 +02:00
|
|
|
Builds or changes infrastructure according to Terraform configuration
|
|
|
|
files .
|
2014-05-24 21:27:58 +02:00
|
|
|
|
|
|
|
Options:
|
|
|
|
|
2014-07-13 05:21:46 +02:00
|
|
|
-no-color If specified, output won't contain any color.
|
|
|
|
|
2014-07-12 06:30:40 +02:00
|
|
|
-state=path Path to read and save state (unless state-out
|
|
|
|
is specified). Defaults to "terraform.tfstate".
|
2014-06-19 06:36:44 +02:00
|
|
|
|
2014-07-12 06:30:40 +02:00
|
|
|
-state-out=path Path to write state to that is different than
|
|
|
|
"-state". This can be used to preserve the old
|
|
|
|
state.
|
2014-05-24 21:27:58 +02:00
|
|
|
|
2014-07-18 20:37:27 +02:00
|
|
|
-var 'foo=bar' Set a variable in the Terraform configuration. This
|
|
|
|
flag can be set multiple times.
|
|
|
|
|
|
|
|
-var-file=foo Set variables in the Terraform configuration from
|
|
|
|
a file. If "terraform.tfvars" is present, it will be
|
|
|
|
automatically loaded if this flag is not specified.
|
|
|
|
|
|
|
|
|
2014-05-24 21:27:58 +02:00
|
|
|
`
|
|
|
|
return strings.TrimSpace(helpText)
|
|
|
|
}
|
|
|
|
|
|
|
|
func (c *ApplyCommand) Synopsis() string {
|
2014-06-27 23:43:23 +02:00
|
|
|
return "Builds or changes infrastructure"
|
|
|
|
}
|