feat(CLOUDDEV-2535): Add live migration (#96)

* feat(CLOUDDEV-2535): Add instance live migration support
* test(CLOUDDEV-2535): Add unit tests for instance live migration

Author: Zwergpro

instances.go

@@ -38,6 +38,7 @@ const (
 	instancesInterfaces            = "interfaces"
 	instancesPutIntoServerGroup    = "put_into_servergroup"
 	instancesRemoveFromServerGroup = "remove_from_servergroup"
+	instancesLiveMigration         = "migrate"
 )
 
 // InstancesService is an interface for creating and managing Instances with the EdgecenterCloud API.
@@ -58,6 +59,7 @@ type InstancesService interface {
 	InterfaceList(context.Context, string) ([]InstancePortInterface, *Response, error)
 	PutIntoServerGroup(context.Context, string, *InstancePutIntoServerGroupRequest) (*TaskResponse, *Response, error)
 	RemoveFromServerGroup(context.Context, string) (*TaskResponse, *Response, error)
+	Migrate(context.Context, string, *InstanceMigrateRequest) (*TaskResponse, *Response, error)
 
 	InstanceAction
 	InstanceFlavor
@@ -262,6 +264,11 @@ type InstanceCheckFlavorVolumeRequest struct {
 	Volumes []InstanceVolumeCreate `json:"volumes" required:"true" validate:"required,dive"`
 }
 
+// InstanceMigrateRequest represents a request to migrate an Instance to another availability zone.
+type InstanceMigrateRequest struct {
+	AvailabilityZone string `json:"availability_zone"  required:"true"`
+}
+
 type InstanceAvailableNames struct {
 	AllowedBMNameWinTemplates []string `json:"allowed_bm_name_win_templates"`
 	NameTemplatesLimited      bool     `json:"name_templates_limited"`
@@ -471,6 +478,37 @@ func (s *InstancesServiceOp) Delete(ctx context.Context, instanceID string, opts
 	return tasks, resp, err
 }
 
+// Migrate the Instance to another availability zone.
+func (s *InstancesServiceOp) Migrate(ctx context.Context, instanceID string, reqBody *InstanceMigrateRequest) (*TaskResponse, *Response, error) {
+	if resp, err := isValidUUID(instanceID, "instanceID"); err != nil {
+		return nil, resp, err
+	}
+
+	if resp, err := s.client.Validate(); err != nil {
+		return nil, resp, err
+	}
+
+	path := fmt.Sprintf(
+		"%s/%s/%s",
+		s.client.addProjectRegionPath(instancesBasePathV1),
+		instanceID,
+		instancesLiveMigration,
+	)
+
+	req, err := s.client.NewRequest(ctx, http.MethodPost, path, reqBody)
+	if err != nil {
+		return nil, nil, err
+	}
+
+	tasks := new(TaskResponse)
+	resp, err := s.client.Do(ctx, req, tasks)
+	if err != nil {
+		return nil, resp, err
+	}
+
+	return tasks, resp, err
+}
+
 // MetadataGet instance detailed metadata (tags).
 func (s *InstancesServiceOp) MetadataGet(ctx context.Context, instanceID string) (*MetadataDetailed, *Response, error) {
 	if resp, err := isValidUUID(instanceID, "instanceID"); err != nil {

instances_test.go

@@ -1411,3 +1411,45 @@ func TestInstances_RemoveFromServerGroup_ResponseError(t *testing.T) {
 	assert.Error(t, err)
 	assert.Equal(t, resp.StatusCode, 400)
 }
+
+func TestInstances_Migrate(t *testing.T) {
+	setup()
+	defer teardown()
+
+	request := &InstanceMigrateRequest{AvailabilityZone: "ru-1"}
+	expectedResp := &TaskResponse{Tasks: []string{taskID}}
+	URL := path.Join(instancesBasePathV1, strconv.Itoa(projectID), strconv.Itoa(regionID), testResourceID, instancesLiveMigration)
+
+	mux.HandleFunc(URL, func(w http.ResponseWriter, r *http.Request) {
+		testMethod(t, r, http.MethodPost)
+		resp, err := json.Marshal(expectedResp)
+		if err != nil {
+			t.Errorf("failed to marshal response: %v", err)
+		}
+		_, _ = fmt.Fprint(w, string(resp))
+	})
+
+	respActual, resp, err := client.Instances.Migrate(ctx, testResourceID, request)
+	require.NoError(t, err)
+	require.Equal(t, resp.StatusCode, 200)
+	assert.Equal(t, expectedResp, respActual)
+}
+
+func TestInstances_Migrate_ResponseError(t *testing.T) {
+	setup()
+	defer teardown()
+
+	request := &InstanceMigrateRequest{AvailabilityZone: "ru-1"}
+
+	URL := path.Join(instancesBasePathV1, strconv.Itoa(projectID), strconv.Itoa(regionID), testResourceID, instancesLiveMigration)
+	mux.HandleFunc(URL, func(w http.ResponseWriter, r *http.Request) {
+		testMethod(t, r, http.MethodPost)
+		w.WriteHeader(http.StatusBadRequest)
+		_, _ = fmt.Fprint(w, "Bad request")
+	})
+
+	respActual, resp, err := client.Instances.Migrate(ctx, testResourceID, request)
+	assert.Nil(t, respActual)
+	assert.Error(t, err)
+	assert.Equal(t, resp.StatusCode, 400)
+}