fix copy logic and tests
This commit is contained in:
parent
8cc82ca8d2
commit
305592d8ed
|
@ -33,12 +33,17 @@ func (s *StepAMIRegionCopy) Run(ctx context.Context, state multistep.StateBag) m
|
||||||
|
|
||||||
ami := amis[s.OriginalRegion]
|
ami := amis[s.OriginalRegion]
|
||||||
// Always copy back into original region to preserve the ami name
|
// Always copy back into original region to preserve the ami name
|
||||||
|
if s.EncryptBootVolume != nil || s.AMISkipBuildRegion {
|
||||||
|
// if we haven't specificed encryption and we aren't skipping the save
|
||||||
|
// to the build region, we don't have anything to delete
|
||||||
s.toDelete = ami
|
s.toDelete = ami
|
||||||
|
}
|
||||||
|
|
||||||
|
if s.EncryptBootVolume != nil {
|
||||||
if !s.AMISkipBuildRegion {
|
if !s.AMISkipBuildRegion {
|
||||||
s.Regions = append(s.Regions, s.OriginalRegion)
|
s.Regions = append(s.Regions, s.OriginalRegion)
|
||||||
}
|
}
|
||||||
|
if *s.EncryptBootVolume {
|
||||||
if s.EncryptBootVolume != nil && *s.EncryptBootVolume {
|
|
||||||
// encrypt_boot is true, so we have to copy the temporary
|
// encrypt_boot is true, so we have to copy the temporary
|
||||||
// AMI with required encryption setting.
|
// AMI with required encryption setting.
|
||||||
// temp image was created by stepCreateAMI.
|
// temp image was created by stepCreateAMI.
|
||||||
|
@ -47,6 +52,7 @@ func (s *StepAMIRegionCopy) Run(ctx context.Context, state multistep.StateBag) m
|
||||||
}
|
}
|
||||||
s.RegionKeyIds[s.OriginalRegion] = s.AMIKmsKeyId
|
s.RegionKeyIds[s.OriginalRegion] = s.AMIKmsKeyId
|
||||||
}
|
}
|
||||||
|
}
|
||||||
|
|
||||||
if len(s.Regions) == 0 {
|
if len(s.Regions) == 0 {
|
||||||
return multistep.ActionContinue
|
return multistep.ActionContinue
|
||||||
|
@ -99,6 +105,10 @@ func (s *StepAMIRegionCopy) Cleanup(state multistep.StateBag) {
|
||||||
ec2conn := state.Get("ec2").(*ec2.EC2)
|
ec2conn := state.Get("ec2").(*ec2.EC2)
|
||||||
ui := state.Get("ui").(packer.Ui)
|
ui := state.Get("ui").(packer.Ui)
|
||||||
|
|
||||||
|
if len(s.toDelete) == 0 {
|
||||||
|
return
|
||||||
|
}
|
||||||
|
|
||||||
// Delete the unencrypted amis and snapshots
|
// Delete the unencrypted amis and snapshots
|
||||||
ui.Say("Deregistering the AMI and deleting unencrypted temporary " +
|
ui.Say("Deregistering the AMI and deleting unencrypted temporary " +
|
||||||
"AMIs and snapshots")
|
"AMIs and snapshots")
|
||||||
|
|
|
@ -101,11 +101,11 @@ func TestStepAmiRegionCopy_nil_encryption(t *testing.T) {
|
||||||
state := tState()
|
state := tState()
|
||||||
stepAMIRegionCopy.Run(context.Background(), state)
|
stepAMIRegionCopy.Run(context.Background(), state)
|
||||||
|
|
||||||
if stepAMIRegionCopy.toDelete != "ami-12345" {
|
if stepAMIRegionCopy.toDelete != "" {
|
||||||
t.Fatalf("Should delete original intermediary ami even if not encrypted")
|
t.Fatalf("Shouldn't have an intermediary ami if encrypt is nil")
|
||||||
}
|
}
|
||||||
if len(stepAMIRegionCopy.Regions) == 0 {
|
if len(stepAMIRegionCopy.Regions) != 0 {
|
||||||
t.Fatalf("Should have added original ami to original region")
|
t.Fatalf("Should not have added original ami to original region")
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|
||||||
|
@ -179,7 +179,7 @@ func TestStepAmiRegionCopy_true_AMISkipBuildRegion(t *testing.T) {
|
||||||
if stepAMIRegionCopy.toDelete == "" {
|
if stepAMIRegionCopy.toDelete == "" {
|
||||||
t.Fatalf("Should delete original AMI if skip_save_build_region=true")
|
t.Fatalf("Should delete original AMI if skip_save_build_region=true")
|
||||||
}
|
}
|
||||||
if len(stepAMIRegionCopy.Regions) == 0 {
|
if len(stepAMIRegionCopy.Regions) != 0 {
|
||||||
t.Fatalf("Should not have added original ami to Regions")
|
t.Fatalf("Should not have added original ami to Regions")
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|
Loading…
Reference in New Issue