package ecs import ( "context" "fmt" "github.com/denverdino/aliyungo/common" "github.com/denverdino/aliyungo/ecs" "github.com/hashicorp/packer/helper/multistep" "github.com/hashicorp/packer/packer" ) type stepCheckAlicloudSourceImage struct { SourceECSImageId string } func (s *stepCheckAlicloudSourceImage) Run(_ context.Context, state multistep.StateBag) multistep.StepAction { client := state.Get("client").(*ecs.Client) config := state.Get("config").(Config) ui := state.Get("ui").(packer.Ui) args := &ecs.DescribeImagesArgs{ RegionId: common.Region(config.AlicloudRegion), ImageId: config.AlicloudSourceImage, } args.PageSize = 50 images, _, err := client.DescribeImages(args) if err != nil { err := fmt.Errorf("Error querying alicloud image: %s", err) state.Put("error", err) ui.Error(err.Error()) return multistep.ActionHalt } // Describe markerplace image args.ImageOwnerAlias = ecs.ImageOwnerMarketplace imageMarkets, _, err := client.DescribeImages(args) if err != nil { err := fmt.Errorf("Error querying alicloud marketplace image: %s", err) state.Put("error", err) ui.Error(err.Error()) return multistep.ActionHalt } if len(imageMarkets) > 0 { images = append(images, imageMarkets...) } if len(images) == 0 { err := fmt.Errorf("No alicloud image was found matching filters: %v", config.AlicloudSourceImage) state.Put("error", err) ui.Error(err.Error()) return multistep.ActionHalt } ui.Message(fmt.Sprintf("Found image ID: %s", images[0].ImageId)) state.Put("source_image", &images[0]) return multistep.ActionContinue } func (s *stepCheckAlicloudSourceImage) Cleanup(multistep.StateBag) {}