add zone in requests

yfodil · Jul 9, 2024 · f9f8fb7 · f9f8fb7
1 parent 2808572
commit f9f8fb7
Show file tree

Hide file tree

Showing 5 changed files with 8 additions and 0 deletions.
diff --git a/builder/scaleway/step_create_server.go b/builder/scaleway/step_create_server.go
@@ -43,6 +43,7 @@ func (s *stepCreateServer) Run(ctx context.Context, state multistep.StateBag) mu
 		Name:           c.ServerName,
 		Image:          c.Image,
 		Tags:           tags,
+		Zone:           scw.Zone(c.Zone),
 	}
 
 	if c.ImageSizeInGB != 0 {

diff --git a/builder/scaleway/step_remove_volume.go b/builder/scaleway/step_remove_volume.go
@@ -37,6 +37,7 @@ func (s *stepRemoveVolume) Cleanup(state multistep.StateBag) {
 
 	err := instanceAPI.DeleteVolume(&instance.DeleteVolumeRequest{
 		VolumeID: volumeID,
+		Zone:     scw.Zone(c.Zone),
 	})
 	if err != nil {
 		err := fmt.Errorf("error removing volume: %s", err)

diff --git a/builder/scaleway/step_server_info.go b/builder/scaleway/step_server_info.go
@@ -14,13 +14,15 @@ type stepServerInfo struct{}
 
 func (s *stepServerInfo) Run(ctx context.Context, state multistep.StateBag) multistep.StepAction {
 	instanceAPI := instance.NewAPI(state.Get("client").(*scw.Client))
+	c := state.Get("config").(*Config)
 	ui := state.Get("ui").(packersdk.Ui)
 	serverID := state.Get("server_id").(string)
 
 	ui.Say("Waiting for server to become active...")
 
 	instanceResp, err := instanceAPI.WaitForServer(&instance.WaitForServerRequest{
 		ServerID: serverID,
+		Zone:     scw.Zone(c.Zone),
 	}, scw.WithContext(ctx))
 	if err != nil {
 		err := fmt.Errorf("error waiting for server to become booted: %s", err)

diff --git a/builder/scaleway/step_shutdown.go b/builder/scaleway/step_shutdown.go
@@ -23,6 +23,7 @@ func (s *stepShutdown) Run(ctx context.Context, state multistep.StateBag) multis
 	_, err := instanceAPI.ServerAction(&instance.ServerActionRequest{
 		Action:   instance.ServerActionPoweroff,
 		ServerID: serverID,
+		Zone:     scw.Zone(c.Zone),
 	}, scw.WithContext(ctx))
 	if err != nil {
 		err := fmt.Errorf("error stopping server: %s", err)

diff --git a/builder/scaleway/step_sweep.go b/builder/scaleway/step_sweep.go
@@ -20,13 +20,15 @@ func (s *stepSweep) Run(_ context.Context, _ multistep.StateBag) multistep.StepA
 func (s *stepSweep) Cleanup(state multistep.StateBag) {
 	instanceAPI := instance.NewAPI(state.Get("client").(*scw.Client))
 	ui := state.Get("ui").(packersdk.Ui)
+	c := state.Get("config").(*Config)
 	snapshots := state.Get("snapshots").([]ArtifactSnapshot)
 	imageID := state.Get("image_id").(string)
 
 	ui.Say("Deleting Image...")
 
 	err := instanceAPI.DeleteImage(&instance.DeleteImageRequest{
 		ImageID: imageID,
+		Zone:    scw.Zone(c.Zone),
 	})
 	if err != nil {
 		err := fmt.Errorf("error deleting image: %s", err)
@@ -39,6 +41,7 @@ func (s *stepSweep) Cleanup(state multistep.StateBag) {
 	for _, snapshot := range snapshots {
 		err = instanceAPI.DeleteSnapshot(&instance.DeleteSnapshotRequest{
 			SnapshotID: snapshot.ID,
+			Zone:       scw.Zone(c.Zone),
 		})
 		if err != nil {
 			err := fmt.Errorf("error deleting snapshot: %s", err)