fix(versioning): close gaps surfaced by the smoke drill

Running the §9.4 smoke drill end-to-end uncovered three real defects
that the unit suite did not catch:

- RuleVersionSubscriber recorded a duplicate UPSTREAM row whenever the
  registry echoed back a no-op change identical to the latest ledger
  row (typically right after BOOTSTRAP). Now dedupes upstream events
  whose content hash already matches the current head, with an explicit
  test in versioning_test.go.
- writeVersioningResp mapped every bizerror to HTTP 200/UnknownError;
  bizerror.InvalidArgument (eg. empty rollback reason) now returns
  HTTP 400 with its original code so the frontend can act on it.
  Covered by a new handler/rule_version_test.go.
- The 409 VERSION_CONFLICT toast auto-dismissed after the default
  duration; users could miss the Reload button entirely. Pinned with
  duration: 0 so the notification stays until acknowledged.

Author: mochengqian

pkg/console/handler/rule_version.go

@@ -151,6 +151,7 @@ func writeVersioningResp(c *gin.Context, data any, err error) {
 		return
 	}
 	var conflict *versioning.ConflictError
+	var bizErr bizerror.Error
 	switch {
 	case errors.As(err, &conflict):
 		c.JSON(http.StatusConflict, gin.H{
@@ -164,6 +165,8 @@ func writeVersioningResp(c *gin.Context, data any, err error) {
 		c.JSON(http.StatusOK, model.NewBizErrorResp(bizerror.New(bizerror.NotFoundError, err.Error())))
 	case errors.Is(err, versioning.ErrRollbackToDelete):
 		c.JSON(http.StatusOK, model.NewBizErrorResp(bizerror.New(bizerror.InvalidArgument, err.Error())))
+	case errors.As(err, &bizErr) && bizErr.Code() == bizerror.InvalidArgument:
+		c.JSON(http.StatusBadRequest, model.NewBizErrorResp(bizErr))
 	default:
 		c.JSON(http.StatusOK, model.NewBizErrorResp(bizerror.New(bizerror.UnknownError, err.Error())))
 	}

pkg/console/handler/rule_version_test.go

@@ -0,0 +1,40 @@
+/*
+ * Licensed to the Apache Software Foundation (ASF) under one or more
+ * contributor license agreements.  See the NOTICE file distributed with
+ * this work for additional information regarding copyright ownership.
+ * The ASF licenses this file to You under the Apache License, Version 2.0
+ * (the "License"); you may not use this file except in compliance with
+ * the License.  You may obtain a copy of the License at
+ *
+ *     http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ */
+
+package handler
+
+import (
+	"net/http"
+	"net/http/httptest"
+	"testing"
+
+	"github.com/gin-gonic/gin"
+	"github.com/stretchr/testify/require"
+
+	"github.com/apache/dubbo-admin/pkg/common/bizerror"
+)
+
+func TestWriteVersioningRespMapsInvalidArgumentToBadRequest(t *testing.T) {
+	gin.SetMode(gin.TestMode)
+	recorder := httptest.NewRecorder()
+	c, _ := gin.CreateTestContext(recorder)
+
+	writeVersioningResp(c, nil, bizerror.New(bizerror.InvalidArgument, "rollback reason is required"))
+
+	require.Equal(t, http.StatusBadRequest, recorder.Code)
+	require.JSONEq(t, `{"code":"InvalidArgument","message":"rollback reason is required","data":null}`, recorder.Body.String())
+}

pkg/core/versioning/subscriber.go

@@ -160,12 +160,14 @@ func (s *Subscriber) record(event events.Event) error {
 	author := "system:upstream"
 	reason := ""
 	var rolledBackFromID *int64
+	hinted := false
 	if ctx := event.Context(); ctx != nil {
 		if registry := ctx[sourceRegistryContextKey]; registry != "" {
 			author = "system:" + registry
 		}
 	}
 	if hint, ok := s.hints.Take(res.ResourceKind(), res.ResourceKey(), hash); ok {
+		hinted = true
 		source = hint.Source
 		if source == "" {
 			source = SourceAdmin
@@ -194,6 +196,15 @@ func (s *Subscriber) record(event events.Event) error {
 	if author == "" {
 		author = "system:unknown"
 	}
+	if !hinted && source == SourceUpstream && op != OperationDelete {
+		latest, err := s.store.LatestVersion(ruleKind, resourceKey)
+		if err != nil {
+			return err
+		}
+		if latest != nil && latest.ContentHash == hash {
+			return nil
+		}
+	}
 	_, err = s.store.InsertVersion(InsertRequest{
 		RuleKind:         ruleKind,
 		Mesh:             mesh,

pkg/core/versioning/versioning_test.go

@@ -229,6 +229,44 @@ func TestSubscriberRespectsRegistrySourceContext(t *testing.T) {
 	require.Equal(t, "system:zookeeper", items[0].Author)
 }
 
+func TestSubscriberSkipsNoopUpstreamEchoAfterBootstrap(t *testing.T) {
+	store := NewMemoryStore()
+	hints := NewAdminHintRegistry()
+	sub := NewSubscriber(meshresource.ConditionRouteKind, store, hints, 5, 0)
+
+	original := meshresource.NewConditionRouteResourceWithAttributes("demo.condition-router", "mesh")
+	original.Spec = &meshproto.ConditionRoute{Key: "demo", Priority: 1}
+	require.NoError(t, RecordBootstrap(store, 5, original))
+	require.NoError(t, sub.ProcessEvent(events.NewResourceChangedEventWithContext(
+		cache.Updated,
+		nil,
+		original,
+		map[string]string{"source-registry": "zookeeper"},
+	)))
+
+	items, err := store.ListVersions(meshresource.ConditionRouteKind, original.ResourceKey())
+	require.NoError(t, err)
+	require.Len(t, items, 1)
+	require.Equal(t, SourceBootstrap, items[0].Source)
+	require.True(t, items[0].IsCurrent)
+
+	changed := meshresource.NewConditionRouteResourceWithAttributes("demo.condition-router", "mesh")
+	changed.Spec = &meshproto.ConditionRoute{Key: "demo", Priority: 2}
+	require.NoError(t, sub.ProcessEvent(events.NewResourceChangedEventWithContext(
+		cache.Updated,
+		original,
+		changed,
+		map[string]string{"source-registry": "zookeeper"},
+	)))
+
+	items, err = store.ListVersions(meshresource.ConditionRouteKind, original.ResourceKey())
+	require.NoError(t, err)
+	require.Len(t, items, 2)
+	require.Equal(t, SourceUpstream, items[0].Source)
+	require.Equal(t, "system:zookeeper", items[0].Author)
+	require.True(t, items[0].IsCurrent)
+}
+
 func TestSubscriberRecordsDeleteWithAdminHintSnapshot(t *testing.T) {
 	store := NewMemoryStore()
 	hints := NewAdminHintRegistry()

ui-vue3/src/views/traffic/_shared/ruleVersion.ts

@@ -77,6 +77,7 @@ export const notifyVersionConflict = (
   if (isVersionConflict(e)) {
     notification.warning({
       key: 'rule-version-conflict',
+      duration: 0,
       message: '版本冲突',
       description: '规则已被其他操作更新，请重新加载当前版本后再提交。',
       btn: options?.reload