141 lines
3.7 KiB
Go
141 lines
3.7 KiB
Go
package openstack
|
|
|
|
import (
|
|
"fmt"
|
|
"io/ioutil"
|
|
"log"
|
|
|
|
"github.com/gophercloud/gophercloud/openstack/compute/v2/extensions/keypairs"
|
|
"github.com/gophercloud/gophercloud/openstack/compute/v2/servers"
|
|
"github.com/mitchellh/multistep"
|
|
"github.com/mitchellh/packer/packer"
|
|
)
|
|
|
|
type StepRunSourceServer struct {
|
|
Name string
|
|
SourceImage string
|
|
SourceImageName string
|
|
SecurityGroups []string
|
|
Networks []string
|
|
AvailabilityZone string
|
|
UserData string
|
|
UserDataFile string
|
|
ConfigDrive bool
|
|
server *servers.Server
|
|
}
|
|
|
|
func (s *StepRunSourceServer) Run(state multistep.StateBag) multistep.StepAction {
|
|
config := state.Get("config").(Config)
|
|
flavor := state.Get("flavor_id").(string)
|
|
ui := state.Get("ui").(packer.Ui)
|
|
|
|
// We need the v2 compute client
|
|
computeClient, err := config.computeV2Client()
|
|
if err != nil {
|
|
err = fmt.Errorf("Error initializing compute client: %s", err)
|
|
state.Put("error", err)
|
|
return multistep.ActionHalt
|
|
}
|
|
|
|
networks := make([]servers.Network, len(s.Networks))
|
|
for i, networkUuid := range s.Networks {
|
|
networks[i].UUID = networkUuid
|
|
}
|
|
|
|
userData := []byte(s.UserData)
|
|
if s.UserDataFile != "" {
|
|
userData, err = ioutil.ReadFile(s.UserDataFile)
|
|
if err != nil {
|
|
err = fmt.Errorf("Error reading user data file: %s", err)
|
|
state.Put("error", err)
|
|
return multistep.ActionHalt
|
|
}
|
|
}
|
|
|
|
ui.Say("Launching server...")
|
|
|
|
serverOpts := servers.CreateOpts{
|
|
Name: s.Name,
|
|
ImageRef: s.SourceImage,
|
|
ImageName: s.SourceImageName,
|
|
FlavorRef: flavor,
|
|
SecurityGroups: s.SecurityGroups,
|
|
Networks: networks,
|
|
AvailabilityZone: s.AvailabilityZone,
|
|
UserData: userData,
|
|
ConfigDrive: &s.ConfigDrive,
|
|
}
|
|
|
|
var serverOptsExt servers.CreateOptsBuilder
|
|
keyName, hasKey := state.GetOk("keyPair")
|
|
if hasKey {
|
|
serverOptsExt = keypairs.CreateOptsExt{
|
|
CreateOptsBuilder: serverOpts,
|
|
KeyName: keyName.(string),
|
|
}
|
|
} else {
|
|
serverOptsExt = serverOpts
|
|
}
|
|
|
|
s.server, err = servers.Create(computeClient, serverOptsExt).Extract()
|
|
if err != nil {
|
|
err := fmt.Errorf("Error launching source server: %s", err)
|
|
state.Put("error", err)
|
|
ui.Error(err.Error())
|
|
return multistep.ActionHalt
|
|
}
|
|
|
|
ui.Message(fmt.Sprintf("Server ID: %s", s.server.ID))
|
|
log.Printf("server id: %s", s.server.ID)
|
|
|
|
ui.Say("Waiting for server to become ready...")
|
|
stateChange := StateChangeConf{
|
|
Pending: []string{"BUILD"},
|
|
Target: []string{"ACTIVE"},
|
|
Refresh: ServerStateRefreshFunc(computeClient, s.server),
|
|
StepState: state,
|
|
}
|
|
latestServer, err := WaitForState(&stateChange)
|
|
if err != nil {
|
|
err := fmt.Errorf("Error waiting for server (%s) to become ready: %s", s.server.ID, err)
|
|
state.Put("error", err)
|
|
ui.Error(err.Error())
|
|
return multistep.ActionHalt
|
|
}
|
|
|
|
s.server = latestServer.(*servers.Server)
|
|
state.Put("server", s.server)
|
|
|
|
return multistep.ActionContinue
|
|
}
|
|
|
|
func (s *StepRunSourceServer) Cleanup(state multistep.StateBag) {
|
|
if s.server == nil {
|
|
return
|
|
}
|
|
|
|
config := state.Get("config").(Config)
|
|
ui := state.Get("ui").(packer.Ui)
|
|
|
|
// We need the v2 compute client
|
|
computeClient, err := config.computeV2Client()
|
|
if err != nil {
|
|
ui.Error(fmt.Sprintf("Error terminating server, may still be around: %s", err))
|
|
return
|
|
}
|
|
|
|
ui.Say(fmt.Sprintf("Terminating the source server: %s ...", s.server.ID))
|
|
if err := servers.Delete(computeClient, s.server.ID).ExtractErr(); err != nil {
|
|
ui.Error(fmt.Sprintf("Error terminating server, may still be around: %s", err))
|
|
return
|
|
}
|
|
|
|
stateChange := StateChangeConf{
|
|
Pending: []string{"ACTIVE", "BUILD", "REBUILD", "SUSPENDED", "SHUTOFF", "STOPPED"},
|
|
Refresh: ServerStateRefreshFunc(computeClient, s.server),
|
|
Target: []string{"DELETED"},
|
|
}
|
|
|
|
WaitForState(&stateChange)
|
|
}
|