pkg/frontend/openshiftcluster_delete.go

package frontend

// Copyright (c) Microsoft Corporation.
// Licensed under the Apache License 2.0.

import (
	"context"
	"net/http"
	"net/url"

	"github.com/go-chi/chi/v5"
	"github.com/sirupsen/logrus"

	"github.com/Azure/ARO-RP/pkg/api"
	"github.com/Azure/ARO-RP/pkg/database/cosmosdb"
	"github.com/Azure/ARO-RP/pkg/frontend/middleware"
)

func (f *frontend) deleteOpenShiftCluster(w http.ResponseWriter, r *http.Request) {
	ctx := r.Context()
	log := ctx.Value(middleware.ContextKeyLog).(*logrus.Entry)

	dbOpenShiftClusters, err := f.dbGroup.OpenShiftClusters()
	if err != nil {
		reply(log, w, nil, nil, err)
	}

	var header http.Header
	_, err = dbOpenShiftClusters.Patch(ctx, r.URL.Path, func(doc *api.OpenShiftClusterDocument) error {
		return f._deleteOpenShiftCluster(ctx, r, &header, doc)
	})
	switch {
	case cosmosdb.IsErrorStatusCode(err, http.StatusNotFound):
		err = statusCodeError(http.StatusNoContent)
	case err == nil:
		err = statusCodeError(http.StatusAccepted)
	}

	frontendOperationResultLog(log, r.Method, err)
	reply(log, w, header, nil, err)
}

func (f *frontend) _deleteOpenShiftCluster(ctx context.Context, r *http.Request, header *http.Header, doc *api.OpenShiftClusterDocument) error {
	correlationData := api.GetCorrelationDataFromCtx(r.Context())

	_, err := f.validateSubscriptionState(ctx, doc.Key, api.SubscriptionStateRegistered, api.SubscriptionStateWarned, api.SubscriptionStateSuspended)
	if err != nil {
		return err
	}

	err = validateTerminalProvisioningState(doc.OpenShiftCluster.Properties.ProvisioningState)
	if err != nil {
		return err
	}

	doc.OpenShiftCluster.Properties.LastProvisioningState = doc.OpenShiftCluster.Properties.ProvisioningState
	doc.OpenShiftCluster.Properties.ProvisioningState = api.ProvisioningStateDeleting
	doc.CorrelationData = correlationData
	doc.Dequeues = 0

	subId := chi.URLParam(r, "subscriptionId")
	resourceProviderNamespace := chi.URLParam(r, "resourceProviderNamespace")

	doc.AsyncOperationID, err = f.newAsyncOperation(ctx, subId, resourceProviderNamespace, doc)
	if err != nil {
		return err
	}

	u, err := url.Parse(r.Header.Get("Referer"))
	if err != nil {
		return err
	}

	*header = http.Header{}

	u.Path = f.operationResultsPath(subId, resourceProviderNamespace, doc.AsyncOperationID)
	(*header)["Location"] = []string{u.String()}

	u.Path = f.operationsPath(subId, resourceProviderNamespace, doc.AsyncOperationID)
	(*header)["Azure-AsyncOperation"] = []string{u.String()}

	return nil
}