|
|
|
|
@ -15,10 +15,19 @@ import (
|
|
|
|
|
type Config struct {
|
|
|
|
|
common.PackerConfig `mapstructure:",squash"`
|
|
|
|
|
|
|
|
|
|
Paths []string `mapstructure:"paths"`
|
|
|
|
|
AccountFile string `mapstructure:"account_file"`
|
|
|
|
|
|
|
|
|
|
DiskSizeGb int64 `mapstructure:"disk_size"`
|
|
|
|
|
DiskType string `mapstructure:"disk_type"`
|
|
|
|
|
KeepOriginalImage bool `mapstructure:"keep_input_artifact"`
|
|
|
|
|
MachineType string `mapstructure:"machine_type"`
|
|
|
|
|
Network string `mapstructure:"network"`
|
|
|
|
|
Paths []string `mapstructure:"paths"`
|
|
|
|
|
Subnetwork string `mapstructure:"subnetwork"`
|
|
|
|
|
Zone string `mapstructure:"zone"`
|
|
|
|
|
|
|
|
|
|
ctx interpolate.Context
|
|
|
|
|
Account googlecompute.AccountFile
|
|
|
|
|
ctx interpolate.Context
|
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
type PostProcessor struct {
|
|
|
|
|
@ -35,12 +44,38 @@ func (p *PostProcessor) Configure(raws ...interface{}) error {
|
|
|
|
|
return err
|
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
errs := new(packer.MultiError)
|
|
|
|
|
|
|
|
|
|
if len(p.config.Paths) == 0 {
|
|
|
|
|
errs = packer.MultiErrorAppend(
|
|
|
|
|
errs, fmt.Errorf("paths must be specified"))
|
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
// Set defaults.
|
|
|
|
|
if p.config.DiskSizeGb == 0 {
|
|
|
|
|
p.config.DiskSizeGb = 200
|
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
if p.config.DiskType == "" {
|
|
|
|
|
p.config.DiskType = "pd-ssd"
|
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
if p.config.MachineType == "" {
|
|
|
|
|
p.config.MachineType = "n1-highcpu-4"
|
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
if p.config.Network == "" && p.config.Subnetwork == "" {
|
|
|
|
|
p.config.Network = "default"
|
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
if len(errs.Errors) > 0 {
|
|
|
|
|
return errs
|
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
return nil
|
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
func (p *PostProcessor) PostProcess(ui packer.Ui, artifact packer.Artifact) (packer.Artifact, bool, error) {
|
|
|
|
|
ui.Say("Starting googlecompute-export...")
|
|
|
|
|
ui.Say(fmt.Sprintf("Exporting image to destinations: %v", p.config.Paths))
|
|
|
|
|
if artifact.BuilderId() != googlecompute.BuilderId {
|
|
|
|
|
err := fmt.Errorf(
|
|
|
|
|
"Unknown artifact type: %s\nCan only export from Google Compute Engine builder artifacts.",
|
|
|
|
|
@ -48,79 +83,90 @@ func (p *PostProcessor) PostProcess(ui packer.Ui, artifact packer.Artifact) (pac
|
|
|
|
|
return nil, p.config.KeepOriginalImage, err
|
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
result := &Artifact{paths: p.config.Paths}
|
|
|
|
|
builderAccountFile := artifact.State("AccountFilePath").(string)
|
|
|
|
|
builderImageName := artifact.State("ImageName").(string)
|
|
|
|
|
builderProjectId := artifact.State("ProjectId").(string)
|
|
|
|
|
builderZone := artifact.State("BuildZone").(string)
|
|
|
|
|
|
|
|
|
|
if len(p.config.Paths) > 0 {
|
|
|
|
|
accountKeyFilePath := artifact.State("AccountFilePath").(string)
|
|
|
|
|
imageName := artifact.State("ImageName").(string)
|
|
|
|
|
imageSizeGb := artifact.State("ImageSizeGb").(int64)
|
|
|
|
|
projectId := artifact.State("ProjectId").(string)
|
|
|
|
|
zone := artifact.State("BuildZone").(string)
|
|
|
|
|
|
|
|
|
|
// Set up instance configuration.
|
|
|
|
|
instanceName := fmt.Sprintf("%s-exporter", artifact.Id())
|
|
|
|
|
metadata := map[string]string{
|
|
|
|
|
"image_name": imageName,
|
|
|
|
|
"name": instanceName,
|
|
|
|
|
"paths": strings.Join(p.config.Paths, " "),
|
|
|
|
|
"startup-script": StartupScript,
|
|
|
|
|
"zone": zone,
|
|
|
|
|
}
|
|
|
|
|
exporterConfig := googlecompute.Config{
|
|
|
|
|
InstanceName: instanceName,
|
|
|
|
|
SourceImageProjectId: "debian-cloud",
|
|
|
|
|
SourceImage: "debian-8-jessie-v20160629",
|
|
|
|
|
DiskName: instanceName,
|
|
|
|
|
DiskSizeGb: imageSizeGb + 10,
|
|
|
|
|
DiskType: "pd-standard",
|
|
|
|
|
Metadata: metadata,
|
|
|
|
|
MachineType: "n1-standard-4",
|
|
|
|
|
Zone: zone,
|
|
|
|
|
Network: "default",
|
|
|
|
|
RawStateTimeout: "5m",
|
|
|
|
|
Scopes: []string{
|
|
|
|
|
"https://www.googleapis.com/auth/userinfo.email",
|
|
|
|
|
"https://www.googleapis.com/auth/compute",
|
|
|
|
|
"https://www.googleapis.com/auth/devstorage.full_control",
|
|
|
|
|
},
|
|
|
|
|
}
|
|
|
|
|
exporterConfig.CalcTimeout()
|
|
|
|
|
|
|
|
|
|
// Set up credentials and GCE driver.
|
|
|
|
|
if accountKeyFilePath != "" {
|
|
|
|
|
err := googlecompute.ProcessAccountFile(&exporterConfig.Account, accountKeyFilePath)
|
|
|
|
|
if err != nil {
|
|
|
|
|
return nil, p.config.KeepOriginalImage, err
|
|
|
|
|
}
|
|
|
|
|
ui.Say(fmt.Sprintf("Exporting image %v to destination: %v", builderImageName, p.config.Paths))
|
|
|
|
|
|
|
|
|
|
if p.config.Zone == "" {
|
|
|
|
|
p.config.Zone = builderZone
|
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
// Set up credentials for GCE driver.
|
|
|
|
|
if builderAccountFile != "" {
|
|
|
|
|
err := googlecompute.ProcessAccountFile(&p.config.Account, builderAccountFile)
|
|
|
|
|
if err != nil {
|
|
|
|
|
return nil, p.config.KeepOriginalImage, err
|
|
|
|
|
}
|
|
|
|
|
driver, err := googlecompute.NewDriverGCE(ui, projectId, &exporterConfig.Account)
|
|
|
|
|
}
|
|
|
|
|
if p.config.AccountFile != "" {
|
|
|
|
|
err := googlecompute.ProcessAccountFile(&p.config.Account, p.config.AccountFile)
|
|
|
|
|
if err != nil {
|
|
|
|
|
return nil, p.config.KeepOriginalImage, err
|
|
|
|
|
}
|
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
// Set up the state.
|
|
|
|
|
state := new(multistep.BasicStateBag)
|
|
|
|
|
state.Put("config", &exporterConfig)
|
|
|
|
|
state.Put("driver", driver)
|
|
|
|
|
state.Put("ui", ui)
|
|
|
|
|
|
|
|
|
|
// Build the steps.
|
|
|
|
|
steps := []multistep.Step{
|
|
|
|
|
&googlecompute.StepCreateSSHKey{
|
|
|
|
|
Debug: p.config.PackerDebug,
|
|
|
|
|
DebugKeyPath: fmt.Sprintf("gce_%s.pem", p.config.PackerBuildName),
|
|
|
|
|
},
|
|
|
|
|
&googlecompute.StepCreateInstance{
|
|
|
|
|
Debug: p.config.PackerDebug,
|
|
|
|
|
},
|
|
|
|
|
new(googlecompute.StepWaitStartupScript),
|
|
|
|
|
new(googlecompute.StepTeardownInstance),
|
|
|
|
|
}
|
|
|
|
|
// Set up exporter instance configuration.
|
|
|
|
|
exporterName := fmt.Sprintf("%s-exporter", artifact.Id())
|
|
|
|
|
exporterMetadata := map[string]string{
|
|
|
|
|
"image_name": builderImageName,
|
|
|
|
|
"name": exporterName,
|
|
|
|
|
"paths": strings.Join(p.config.Paths, " "),
|
|
|
|
|
"startup-script": StartupScript,
|
|
|
|
|
"zone": p.config.Zone,
|
|
|
|
|
}
|
|
|
|
|
exporterConfig := googlecompute.Config{
|
|
|
|
|
DiskName: exporterName,
|
|
|
|
|
DiskSizeGb: p.config.DiskSizeGb,
|
|
|
|
|
DiskType: p.config.DiskType,
|
|
|
|
|
InstanceName: exporterName,
|
|
|
|
|
MachineType: p.config.MachineType,
|
|
|
|
|
Metadata: exporterMetadata,
|
|
|
|
|
Network: p.config.Network,
|
|
|
|
|
RawStateTimeout: "5m",
|
|
|
|
|
SourceImageFamily: "debian-9-worker",
|
|
|
|
|
SourceImageProjectId: "compute-image-tools",
|
|
|
|
|
Subnetwork: p.config.Subnetwork,
|
|
|
|
|
Zone: p.config.Zone,
|
|
|
|
|
Scopes: []string{
|
|
|
|
|
"https://www.googleapis.com/auth/compute",
|
|
|
|
|
"https://www.googleapis.com/auth/devstorage.full_control",
|
|
|
|
|
"https://www.googleapis.com/auth/userinfo.email",
|
|
|
|
|
},
|
|
|
|
|
}
|
|
|
|
|
exporterConfig.CalcTimeout()
|
|
|
|
|
|
|
|
|
|
// Run the steps.
|
|
|
|
|
p.runner = common.NewRunner(steps, p.config.PackerConfig, ui)
|
|
|
|
|
p.runner.Run(state)
|
|
|
|
|
driver, err := googlecompute.NewDriverGCE(ui, builderProjectId, &p.config.Account)
|
|
|
|
|
if err != nil {
|
|
|
|
|
return nil, p.config.KeepOriginalImage, err
|
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
// Set up the state.
|
|
|
|
|
state := new(multistep.BasicStateBag)
|
|
|
|
|
state.Put("config", &exporterConfig)
|
|
|
|
|
state.Put("driver", driver)
|
|
|
|
|
state.Put("ui", ui)
|
|
|
|
|
|
|
|
|
|
// Build the steps.
|
|
|
|
|
steps := []multistep.Step{
|
|
|
|
|
&googlecompute.StepCreateSSHKey{
|
|
|
|
|
Debug: p.config.PackerDebug,
|
|
|
|
|
DebugKeyPath: fmt.Sprintf("gce_%s.pem", p.config.PackerBuildName),
|
|
|
|
|
},
|
|
|
|
|
&googlecompute.StepCreateInstance{
|
|
|
|
|
Debug: p.config.PackerDebug,
|
|
|
|
|
},
|
|
|
|
|
new(googlecompute.StepWaitStartupScript),
|
|
|
|
|
new(googlecompute.StepTeardownInstance),
|
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
// Run the steps.
|
|
|
|
|
p.runner = common.NewRunner(steps, p.config.PackerConfig, ui)
|
|
|
|
|
p.runner.Run(state)
|
|
|
|
|
|
|
|
|
|
result := &Artifact{paths: p.config.Paths}
|
|
|
|
|
|
|
|
|
|
return result, p.config.KeepOriginalImage, nil
|
|
|
|
|
}
|
|
|
|
|
|