feat: 实现端停用与删除的消息作废与群主转让级联

internal/admin/endpoints.go

@@ -320,18 +320,39 @@ func (h *Handler) handleEndpointPatch(w http.ResponseWriter, r *http.Request) {
 		return
 	}
 
-	wasEnabled, err := h.patchEndpoint(r.Context(), id, req.Name, req.Remark, req.DefaultDelaySeconds, req.Enabled)
-	if err != nil {
-		if errors.Is(err, sql.ErrNoRows) {
+	hasMeta := req.Name != nil || req.Remark != nil || req.DefaultDelaySeconds != nil
+	var wasEnabled bool
+	var err error
+	if hasMeta || (req.Enabled != nil && h.identity == nil) {
+		wasEnabled, err = h.patchEndpoint(r.Context(), id, req.Name, req.Remark, req.DefaultDelaySeconds, req.Enabled)
+		if err != nil {
+			if errors.Is(err, sql.ErrNoRows) {
+				h.audit(actorString(p), "endpoint_patch", id, "not_found", ip)
+				httpx.WriteError(w, http.StatusNotFound, "not_found", "端不存在")
+				return
+			}
+			h.audit(actorString(p), "endpoint_patch", id, "error", ip)
+			httpx.WriteError(w, http.StatusInternalServerError, "internal", "内部错误")
+			return
+		}
+	}
+	if req.Enabled != nil && h.identity != nil {
+		var found bool
+		found, err = h.setEndpointEnabled(r.Context(), id, *req.Enabled)
+		if err != nil {
+			h.audit(actorString(p), "endpoint_patch", id, "error", ip)
+			httpx.WriteError(w, http.StatusInternalServerError, "internal", "内部错误")
+			return
+		}
+		if !found {
 			h.audit(actorString(p), "endpoint_patch", id, "not_found", ip)
 			httpx.WriteError(w, http.StatusNotFound, "not_found", "端不存在")
 			return
 		}
-		h.audit(actorString(p), "endpoint_patch", id, "error", ip)
-		httpx.WriteError(w, http.StatusInternalServerError, "internal", "内部错误")
-		return
-	}
-	if req.Enabled != nil && !*req.Enabled && wasEnabled {
+		if !*req.Enabled {
+			_, _ = h.kickEndpoint(r.Context(), id)
+		}
+	} else if req.Enabled != nil && !*req.Enabled && wasEnabled {
 		_, _ = h.kickEndpoint(r.Context(), id)
 	}
 	row, err := h.getEndpoint(r.Context(), id)