[MM-49455] - Self-serve workspace deletion (#22200)

* [MM-49455] - Self-serve workspace deletion

* add subscription id to deletion request

* add server telemetry

* fix mocks

* feedback impl

api4/cloud.go

@@ -56,6 +56,8 @@ func (api *API) InitCloud() {
 
 	// GET /api/v4/cloud/cws-health-check
 	api.BaseRoutes.Cloud.Handle("/check-cws-connection", api.APIHandler(handleCheckCWSConnection)).Methods("GET")
+
+	api.BaseRoutes.Cloud.Handle("/delete-workspace", api.APISessionRequired(selfServeDeleteWorkspace)).Methods(http.MethodDelete)
 }
 
 func getSubscription(c *Context, w http.ResponseWriter, r *http.Request) {
@@ -142,8 +144,8 @@ func changeSubscription(c *Context, w http.ResponseWriter, r *http.Request) {
 		return
 	}
 
-	if subscriptionChange.DowngradeFeedback != nil {
-		c.App.Srv().GetTelemetryService().SendTelemetry("downgrade_feedback", subscriptionChange.DowngradeFeedback.ToMap())
+	if subscriptionChange.Feedback != nil {
+		c.App.Srv().GetTelemetryService().SendTelemetry("downgrade_feedback", subscriptionChange.Feedback.ToMap())
 	}
 
 	json, err := json.Marshal(changedSub)
@@ -774,3 +776,28 @@ func handleCheckCWSConnection(c *Context, w http.ResponseWriter, r *http.Request
 
 	ReturnStatusOK(w)
 }
+
+func selfServeDeleteWorkspace(c *Context, w http.ResponseWriter, r *http.Request) {
+	bodyBytes, err := io.ReadAll(r.Body)
+	if err != nil {
+		c.Err = model.NewAppError("Api4.selfServeDeleteWorkspace", "api.cloud.app_error", nil, err.Error(), http.StatusBadRequest)
+		return
+	}
+	defer r.Body.Close()
+
+	var deleteRequest *model.WorkspaceDeletionRequest
+	if err = json.Unmarshal(bodyBytes, &deleteRequest); err != nil {
+		c.Err = model.NewAppError("Api4.selfServeDeleteWorkspace", "api.cloud.app_error", nil, err.Error(), http.StatusInternalServerError)
+		return
+	}
+
+	if err := c.App.Cloud().SelfServeDeleteWorkspace(c.AppContext.Session().UserId, deleteRequest); err != nil {
+		c.Err = model.NewAppError("Api4.selfServeDeleteWorkspace", "api.server.cws.delete_workspace.app_error", nil, "CWS Server failed to delete workspace.", http.StatusInternalServerError)
+		return
+	}
+
+	c.App.Srv().GetTelemetryService().SendTelemetry("delete_workspace_feedback", deleteRequest.Feedback.ToMap())
+
+	ReturnStatusOK(w)
+
+}

einterfaces/cloud.go

@@ -47,4 +47,6 @@ type CloudInterface interface {
 	HandleLicenseChange() error
 
 	CheckCWSConnection(userId string) error
+
+	SelfServeDeleteWorkspace(userID string, deletionRequest *model.WorkspaceDeletionRequest) error
 }

einterfaces/mocks/CloudInterface.go

@@ -540,6 +540,20 @@ func (_m *CloudInterface) SelfHostedSignupAvailable() error {
 	return r0
 }
 
+// SelfServeDeleteWorkspace provides a mock function with given fields: userID, deletionRequest
+func (_m *CloudInterface) SelfServeDeleteWorkspace(userID string, deletionRequest *model.WorkspaceDeletionRequest) error {
+	ret := _m.Called(userID, deletionRequest)
+
+	var r0 error
+	if rf, ok := ret.Get(0).(func(string, *model.WorkspaceDeletionRequest) error); ok {
+		r0 = rf(userID, deletionRequest)
+	} else {
+		r0 = ret.Error(0)
+	}
+
+	return r0
+}
+
 // UpdateCloudCustomer provides a mock function with given fields: userID, customerInfo
 func (_m *CloudInterface) UpdateCloudCustomer(userID string, customerInfo *model.CloudCustomerInfo) (*model.CloudCustomer, error) {
 	ret := _m.Called(userID, customerInfo)

i18n/en.json

@@ -2587,6 +2587,10 @@
     "id": "api.scheme.patch_scheme.license.error",
     "translation": "Your license does not support update permissions schemes"
   },
+  {
+    "id": "api.server.cws.delete_workspace.app_error",
+    "translation": "CWS Server failed to delete workspace."
+  },
   {
     "id": "api.server.cws.health_check.app_error",
     "translation": "CWS Server is not available."

model/cloud.go

@@ -264,10 +264,10 @@ type CloudWorkspaceOwner struct {
 }
 
 type SubscriptionChange struct {
-	ProductID         string             `json:"product_id"`
-	Seats             int                `json:"seats"`
-	DowngradeFeedback *DowngradeFeedback `json:"downgrade_feedback"`
-	ShippingAddress   *Address           `json:"shipping_address"`
+	ProductID       string    `json:"product_id"`
+	Seats           int       `json:"seats"`
+	Feedback        *Feedback `json:"downgrade_feedback"`
+	ShippingAddress *Address  `json:"shipping_address"`
 }
 
 // TODO remove BoardsLimits.
@@ -314,11 +314,16 @@ type CreateSubscriptionRequest struct {
 	DiscountID            string   `json:"discount_id"`
 }
 
-type DowngradeFeedback struct {
+type Feedback struct {
 	Reason   string `json:"reason"`
 	Comments string `json:"comments"`
 }
 
+type WorkspaceDeletionRequest struct {
+	SubscriptionID string    `json:"subscription_id"`
+	Feedback       *Feedback `json:"delete_feedback"`
+}
+
 func (p *Product) IsYearly() bool {
 	return p.RecurringInterval == RecurringIntervalYearly
 }
@@ -327,7 +332,7 @@ func (p *Product) IsMonthly() bool {
 	return p.RecurringInterval == RecurringIntervalMonthly
 }
 
-func (df *DowngradeFeedback) ToMap() map[string]any {
+func (df *Feedback) ToMap() map[string]any {
 	var res map[string]any
 	feedback, err := json.Marshal(df)
 	if err != nil {