feat(stacks): migrate stack data from previous portainer version

api/bolt/migrate_dbversion11.go

@@ -1,5 +1,7 @@
 package bolt
 
+import "github.com/portainer/portainer"
+
 func (m *Migrator) updateEndpointsToVersion12() error {
 	legacyEndpoints, err := m.EndpointService.Endpoints()
 	if err != nil {
@@ -35,3 +37,21 @@ func (m *Migrator) updateEndpointGroupsToVersion12() error {
 
 	return nil
 }
+
+func (m *Migrator) updateStacksToVersion12() error {
+	legacyStacks, err := m.StackService.Stacks()
+	if err != nil {
+		return err
+	}
+
+	for _, stack := range legacyStacks {
+		stack.Type = portainer.DockerSwarmStack
+
+		err = m.StackService.UpdateStack(stack.ID, &stack)
+		if err != nil {
+			return err
+		}
+	}
+
+	return nil
+}

api/bolt/migrator.go

@@ -4,27 +4,30 @@ import "github.com/portainer/portainer"
 
 // Migrator defines a service to migrate data after a Portainer version update.
 type Migrator struct {
-	UserService            *UserService
-	EndpointService        *EndpointService
+	CurrentDBVersion int
+	store            *Store
+
 	EndpointGroupService   *EndpointGroupService
+	EndpointService        *EndpointService
 	ResourceControlService *ResourceControlService
 	SettingsService        *SettingsService
+	StackService           *StackService
+	UserService            *UserService
 	VersionService         *VersionService
-	CurrentDBVersion       int
-	store                  *Store
 }
 
 // NewMigrator creates a new Migrator.
 func NewMigrator(store *Store, version int) *Migrator {
 	return &Migrator{
-		UserService:            store.UserService,
-		EndpointService:        store.EndpointService,
-		EndpointGroupService:   store.EndpointGroupService,
-		ResourceControlService: store.ResourceControlService,
-		SettingsService:        store.SettingsService,
-		VersionService:         store.VersionService,
 		CurrentDBVersion:       version,
 		store:                  store,
+		EndpointGroupService:   store.EndpointGroupService,
+		EndpointService:        store.EndpointService,
+		ResourceControlService: store.ResourceControlService,
+		SettingsService:        store.SettingsService,
+		StackService:           store.StackService,
+		UserService:            store.UserService,
+		VersionService:         store.VersionService,
 	}
 }
 
@@ -122,6 +125,7 @@ func (m *Migrator) Migrate() error {
 		}
 	}
 
+	// Portainer 1.17.1-dev
 	if m.CurrentDBVersion < 12 {
 		err := m.updateEndpointsToVersion12()
 		if err != nil {
@@ -132,6 +136,11 @@ func (m *Migrator) Migrate() error {
 		if err != nil {
 			return err
 		}
+
+		err = m.updateStacksToVersion12()
+		if err != nil {
+			return err
+		}
 	}
 
 	err := m.VersionService.StoreDBVersion(portainer.DBVersion)

api/http/handler/stacks/stack_delete.go

@@ -46,7 +46,20 @@ func (handler *Handler) stackDelete(w http.ResponseWriter, r *http.Request) *htt
 		}
 	}
 
-	endpoint, err := handler.EndpointService.Endpoint(stack.EndpointID)
+	// TODO: this is a work-around for stacks created with Portainer version >= 1.17.1
+	// The EndpointID property is not available for these stacks, this API endpoint
+	// can use the optional EndpointID query parameter to set a valid endpoint identifier to be
+	// used in the context of this request.
+	endpointID, err := request.RetrieveNumericQueryParameter(r, "endpointId", true)
+	if err != nil {
+		return &httperror.HandlerError{http.StatusBadRequest, "Invalid query parameter: endpointId", err}
+	}
+	endpointIdentifier := stack.EndpointID
+	if endpointID != 0 {
+		endpointIdentifier = portainer.EndpointID(endpointID)
+	}
+
+	endpoint, err := handler.EndpointService.Endpoint(endpointIdentifier)
 	if err == portainer.ErrEndpointNotFound {
 		return &httperror.HandlerError{http.StatusNotFound, "Unable to find the endpoint associated to the stack inside the database", err}
 	} else if err != nil {

api/http/handler/stacks/stack_update.go

@@ -36,7 +36,7 @@ func (payload *updateSwarmStackPayload) Validate(r *http.Request) error {
 	return nil
 }
 
-// PUT request on /api/stacks/:id
+// PUT request on /api/stacks/:id?endpointId=<endpointId>
 func (handler *Handler) stackUpdate(w http.ResponseWriter, r *http.Request) *httperror.HandlerError {
 	stackID, err := request.RetrieveRouteVariableValue(r, "id")
 	if err != nil {
@@ -66,6 +66,17 @@ func (handler *Handler) stackUpdate(w http.ResponseWriter, r *http.Request) *htt
 		}
 	}
 
+	// TODO: this is a work-around for stacks created with Portainer version >= 1.17.1
+	// The EndpointID property is not available for these stacks, this API endpoint
+	// can use the optional EndpointID query parameter to associate a valid endpoint identifier to the stack.
+	endpointID, err := request.RetrieveNumericQueryParameter(r, "endpointId", true)
+	if err != nil {
+		return &httperror.HandlerError{http.StatusBadRequest, "Invalid query parameter: endpointId", err}
+	}
+	if endpointID != int(stack.EndpointID) {
+		stack.EndpointID = portainer.EndpointID(endpointID)
+	}
+
 	endpoint, err := handler.EndpointService.Endpoint(stack.EndpointID)
 	if err == portainer.ErrEndpointNotFound {
 		return &httperror.HandlerError{http.StatusNotFound, "Unable to find the endpoint associated to the stack inside the database", err}