package vagrantcloud import ( "context" "fmt" "strings" "github.com/hashicorp/packer/helper/multistep" "github.com/hashicorp/packer/packer" ) type stepReleaseVersion struct { } func (s *stepReleaseVersion) Run(_ context.Context, state multistep.StateBag) multistep.StepAction { client := state.Get("client").(*VagrantCloudClient) ui := state.Get("ui").(packer.Ui) box := state.Get("box").(*Box) version := state.Get("version").(*Version) config := state.Get("config").(Config) ui.Say(fmt.Sprintf("Releasing version: %s", version.Version)) if config.NoRelease { ui.Message("Not releasing version due to configuration") return multistep.ActionContinue } path := fmt.Sprintf("box/%s/version/%v/release", box.Tag, version.Version) resp, err := client.Put(path) if err != nil || (resp.StatusCode != 200) { cloudErrors := &VagrantCloudErrors{} if err := decodeBody(resp, cloudErrors); err != nil { state.Put("error", fmt.Errorf("Error parsing provider response: %s", err)) return multistep.ActionHalt } if strings.Contains(cloudErrors.FormatErrors(), "already been released") { ui.Message("Not releasing version, already released") return multistep.ActionContinue } state.Put("error", fmt.Errorf("Error releasing version: %s", cloudErrors.FormatErrors())) return multistep.ActionHalt } ui.Message(fmt.Sprintf("Version successfully released and available")) return multistep.ActionContinue } func (s *stepReleaseVersion) Cleanup(state multistep.StateBag) { // No cleanup }