feat: add strategy edit flow, notification center, and UI polish

manager/domain/enums.go

@@ -14,6 +14,7 @@ const (
 	PermissionRead         PermissionKey = "permission.read"
 	ScheduleStrategyCreate PermissionKey = "schedule_strategy.create"
 	ScheduleStrategyRead   PermissionKey = "schedule_strategy.read"
+	ScheduleStrategyUpdate PermissionKey = "schedule_strategy.update"
 	ScheduleStrategyDelete PermissionKey = "schedule_strategy.delete"
 	ScheduleIntentRead     PermissionKey = "schedule_intent.read"
 	ScheduleIntentDelete   PermissionKey = "schedule_intent.delete"

manager/domain/interface.go

@@ -67,6 +67,7 @@ type Repository interface {
 	BatchUpdateIntentsState(ctx context.Context, intentIDs []bson.ObjectID, newState IntentState) error
 	QueryStrategies(ctx context.Context, opt *QueryStrategyOptions) error
 	QueryIntents(ctx context.Context, opt *QueryIntentOptions) error
+	UpdateStrategy(ctx context.Context, strategyID bson.ObjectID, update bson.M) error
 	DeleteStrategy(ctx context.Context, strategyID bson.ObjectID) error
 	DeleteIntents(ctx context.Context, intentIDs []bson.ObjectID) error
 	DeleteIntentsByStrategyID(ctx context.Context, strategyID bson.ObjectID) error
@@ -91,6 +92,7 @@ type Service interface {
 	CreateScheduleStrategy(ctx context.Context, operator *Claims, strategy *ScheduleStrategy) error
 	ListScheduleStrategies(ctx context.Context, filterOpts *QueryStrategyOptions) error
 	ListScheduleIntents(ctx context.Context, filterOpts *QueryIntentOptions) error
+	UpdateScheduleStrategy(ctx context.Context, operator *Claims, strategyID string, strategy *ScheduleStrategy) error
 	DeleteScheduleStrategy(ctx context.Context, operator *Claims, strategyID string) error
 	DeleteScheduleIntents(ctx context.Context, operator *Claims, intentIDs []string) error
 	GetPodPIDMapping(ctx context.Context, nodeID string) (*PodPIDMappingResponse, error)

manager/migration/005_add_schedule_strategy_update_permission.down.json

@@ -0,0 +1,24 @@
+[
+    {
+        "update": "roles",
+        "updates": [
+            {
+                "q": { "name": "admin" },
+                "u": {
+                    "$pull": {
+                        "policies": { "permissionKey": "schedule_strategy.update" }
+                    }
+                }
+            }
+        ]
+    },
+    {
+        "delete": "permissions",
+        "deletes": [
+            {
+                "q": { "key": "schedule_strategy.update" },
+                "limit": 1
+            }
+        ]
+    }
+]

manager/migration/005_add_schedule_strategy_update_permission.up.json

@@ -0,0 +1,26 @@
+[
+    {
+        "insert": "permissions",
+        "documents": [
+            {
+                "key": "schedule_strategy.update",
+                "resource": "schedule_strategy",
+                "action": "update",
+                "description": "Update schedule strategies"
+            }
+        ]
+    },
+    {
+        "update": "roles",
+        "updates": [
+            {
+                "q": { "name": "admin" },
+                "u": {
+                    "$push": {
+                        "policies": { "permissionKey": "schedule_strategy.update", "self": false }
+                    }
+                }
+            }
+        ]
+    }
+]

manager/repository/strategy_repo.go

@@ -158,6 +158,14 @@ func (r *repo) DeleteStrategy(ctx context.Context, strategyID bson.ObjectID) err
 	return err
 }
 
+func (r *repo) UpdateStrategy(ctx context.Context, strategyID bson.ObjectID, update bson.M) error {
+	if update == nil {
+		return errors.New("nil update")
+	}
+	_, err := r.db.Collection(scheduleStrategyCollection).UpdateOne(ctx, bson.M{"_id": strategyID}, update)
+	return err
+}
+
 func (r *repo) DeleteIntents(ctx context.Context, intentIDs []bson.ObjectID) error {
 	if len(intentIDs) == 0 {
 		return nil

manager/rest/routes.go

@@ -40,6 +40,7 @@ func (h *Handler) SetupRoutes(engine *echo.Echo) {
 
 		// strategy routes
 		apiV1.POST("/strategies", h.echoHandler(h.CreateScheduleStrategy), echo.WrapMiddleware(h.GetAuthMiddleware(domain.ScheduleStrategyCreate)))
+		apiV1.PUT("/strategies", h.echoHandler(h.UpdateScheduleStrategy), echo.WrapMiddleware(h.GetAuthMiddleware(domain.ScheduleStrategyUpdate)))
 		apiV1.GET("/strategies/self", h.echoHandler(h.ListSelfScheduleStrategies), echo.WrapMiddleware(h.GetAuthMiddleware(domain.ScheduleStrategyRead)))
 		apiV1.DELETE("/strategies", h.echoHandler(h.DeleteScheduleStrategy), echo.WrapMiddleware(h.GetAuthMiddleware(domain.ScheduleStrategyDelete)))
 		apiV1.GET("/intents/self", h.echoHandler(h.ListSelfScheduleIntents), echo.WrapMiddleware(h.GetAuthMiddleware(domain.ScheduleIntentRead)))

manager/rest/strategy_hdl.go

@@ -21,6 +21,16 @@ type CreateScheduleStrategyRequest struct {
 	ExecutionTime     int64           `json:"executionTime,omitempty"`
 }
 
+type UpdateScheduleStrategyRequest struct {
+	StrategyID        string          `json:"strategyId"`
+	StrategyNamespace string          `json:"strategyNamespace,omitempty"`
+	LabelSelectors    []LabelSelector `json:"labelSelectors,omitempty"`
+	K8sNamespace      []string        `json:"k8sNamespace,omitempty"`
+	CommandRegex      string          `json:"commandRegex,omitempty"`
+	Priority          int             `json:"priority,omitempty"`
+	ExecutionTime     int64           `json:"executionTime,omitempty"`
+}
+
 // CreateScheduleStrategy godoc
 // @Summary Create schedule strategy
 // @Description Create a new schedule strategy.
@@ -75,6 +85,63 @@ func (h *Handler) CreateScheduleStrategy(w http.ResponseWriter, r *http.Request)
 	h.JSONResponse(ctx, w, http.StatusOK, response)
 }
 
+// UpdateScheduleStrategy godoc
+// @Summary Update schedule strategy
+// @Description Update an existing schedule strategy.
+// @Tags Strategies
+// @Accept json
+// @Produce json
+// @Security BearerAuth
+// @Param request body UpdateScheduleStrategyRequest true "Schedule strategy payload"
+// @Success 200 {object} SuccessResponse[EmptyResponse]
+// @Failure 400 {object} ErrorResponse
+// @Failure 401 {object} ErrorResponse
+// @Failure 403 {object} ErrorResponse
+// @Failure 404 {object} ErrorResponse
+// @Failure 500 {object} ErrorResponse
+// @Router /api/v1/strategies [put]
+func (h *Handler) UpdateScheduleStrategy(w http.ResponseWriter, r *http.Request) {
+	ctx := r.Context()
+	var req UpdateScheduleStrategyRequest
+	if err := h.JSONBind(r, &req); err != nil {
+		h.ErrorResponse(ctx, w, http.StatusBadRequest, "Invalid request body", err)
+		return
+	}
+	if req.StrategyID == "" {
+		h.ErrorResponse(ctx, w, http.StatusBadRequest, "Strategy ID is required", nil)
+		return
+	}
+
+	strategy := &domain.ScheduleStrategy{
+		StrategyNamespace: req.StrategyNamespace,
+		LabelSelectors:    make([]domain.LabelSelector, len(req.LabelSelectors)),
+		K8sNamespace:      req.K8sNamespace,
+		CommandRegex:      req.CommandRegex,
+		Priority:          req.Priority,
+		ExecutionTime:     req.ExecutionTime,
+	}
+	for i, ls := range req.LabelSelectors {
+		strategy.LabelSelectors[i] = domain.LabelSelector{
+			Key:   ls.Key,
+			Value: ls.Value,
+		}
+	}
+
+	claims, ok := h.GetClaimsFromContext(ctx)
+	if !ok {
+		h.ErrorResponse(ctx, w, http.StatusUnauthorized, "Unauthorized", nil)
+		return
+	}
+
+	if err := h.Svc.UpdateScheduleStrategy(ctx, &claims, req.StrategyID, strategy); err != nil {
+		h.HandleError(ctx, w, err)
+		return
+	}
+
+	response := NewSuccessResponse[string](nil)
+	h.JSONResponse(ctx, w, http.StatusOK, response)
+}
+
 type ListSchedulerStrategiesResponse struct {
 	Strategies []*ScheduleStrategy `json:"strategies"`
 }