Method Delete

service/admin/node.go:220–256

(c *gin.Context)

}

func (s *SingleNodeService) Delete(c *gin.Context) error {
	dep := dependency.FromContext(c)
	nodeClient := dep.NodeClient()

	ctx := context.WithValue(c, inventory.LoadNodeStoragePolicy{}, true)
	existing, err := nodeClient.GetNodeById(ctx, s.ID)
	if err != nil {
		return serializer.NewError(serializer.CodeDBError, "Failed to get node", err)
	}

	if existing.Type == node.TypeMaster {
		return serializer.NewError(serializer.CodeInvalidActionOnSystemNode, "", nil)
	}

	if len(existing.Edges.StoragePolicy) > 0 {
		return serializer.NewError(
			serializer.CodeNodeUsedByStoragePolicy,
			strings.Join(lo.Map(existing.Edges.StoragePolicy, func(i *ent.StoragePolicy, _ int) string {
				return i.Name
			}), ", "),
			nil,
		)
	}

	// insert dummpy disabled node in nodepool to evict it
	disabledNode := &ent.Node{
		ID:     s.ID,
		Type:   node.TypeSlave,
		Status: node.StatusSuspended,
	}
	np, err := dep.NodePool(c)
	if err != nil {
		return serializer.NewError(serializer.CodeInternalSetting, "Failed to get node pool", err)
	}
	np.Upsert(c, disabledNode)
	return nodeClient.Delete(c, s.ID)
}