package vmware import ( "errors" "fmt" "github.com/mitchellh/mapstructure" "github.com/mitchellh/multistep" "github.com/mitchellh/packer/packer" "log" "os" "path/filepath" "time" ) const BuilderId = "mitchellh.vmware" type Builder struct { config config driver Driver runner multistep.Runner } type config struct { DiskName string `mapstructure:"vmdk_name"` ISOUrl string `mapstructure:"iso_url"` VMName string `mapstructure:"vm_name"` OutputDir string `mapstructure:"output_directory"` HTTPDir string `mapstructure:"http_directory"` BootCommand []string `mapstructure:"boot_command"` BootWait time.Duration SSHUser string `mapstructure:"ssh_username"` SSHPassword string `mapstructure:"ssh_password"` SSHWaitTimeout time.Duration RawBootWait string `mapstructure:"boot_wait"` RawSSHWaitTimeout string `mapstructure:"ssh_wait_timeout"` } func (b *Builder) Prepare(raw interface{}) (err error) { err = mapstructure.Decode(raw, &b.config) if err != nil { return } if b.config.DiskName == "" { b.config.DiskName = "disk" } if b.config.VMName == "" { b.config.VMName = "packer" } if b.config.OutputDir == "" { b.config.OutputDir = "vmware" } // Accumulate any errors errs := make([]error, 0) if b.config.ISOUrl == "" { errs = append(errs, errors.New("An iso_url must be specified.")) } if b.config.SSHUser == "" { errs = append(errs, errors.New("An ssh_username must be specified.")) } if b.config.RawBootWait != "" { b.config.BootWait, err = time.ParseDuration(b.config.RawBootWait) if err != nil { errs = append(errs, fmt.Errorf("Failed parsing boot_wait: %s", err)) } } if b.config.RawSSHWaitTimeout == "" { b.config.RawSSHWaitTimeout = "20m" } b.config.SSHWaitTimeout, err = time.ParseDuration(b.config.RawSSHWaitTimeout) if err != nil { errs = append(errs, fmt.Errorf("Failed parsing ssh_wait_timeout: %s", err)) } b.driver, err = b.newDriver() if err != nil { errs = append(errs, fmt.Errorf("Failed creating VMware driver: %s", err)) } if len(errs) > 0 { return &packer.MultiError{errs} } return nil } func (b *Builder) Run(ui packer.Ui, hook packer.Hook) packer.Artifact { steps := []multistep.Step{ &stepPrepareOutputDir{}, &stepCreateDisk{}, &stepCreateVMX{}, &stepHTTPServer{}, &stepRun{}, &stepTypeBootCommand{}, &stepWaitForSSH{}, &stepProvision{}, } // Setup the state bag state := make(map[string]interface{}) state["config"] = &b.config state["driver"] = b.driver state["hook"] = hook state["ui"] = ui // Run! b.runner = &multistep.BasicRunner{Steps: steps} b.runner.Run(state) // If we were interrupted or cancelled, then just exit. if _, ok := state[multistep.StateCancelled]; ok { return nil } if _, ok := state[multistep.StateHalted]; ok { return nil } // Compile the artifact list files := make([]string, 0, 10) visit := func(path string, info os.FileInfo, err error) error { files = append(files, path) return err } if err := filepath.Walk(b.config.OutputDir, visit); err != nil { ui.Error(fmt.Sprintf("Error collecting result files: %s", err)) return nil } return &Artifact{b.config.OutputDir, files} } func (b *Builder) Cancel() { if b.runner != nil { log.Println("Cancelling the step runner...") b.runner.Cancel() } } func (b *Builder) newDriver() (Driver, error) { fusionAppPath := "/Applications/VMware Fusion.app" return &Fusion5Driver{fusionAppPath}, nil }