retain order

Signed-off-by: Huabing Zhao <[email protected]>

Author: zhaohuabing

internal/message/watchutil.go

@@ -117,15 +117,21 @@ func coalesceUpdates[K comparable, V any](runner string, updates []watchable.Upd
 	result := make([]watchable.Update[K, V], 0, len(updates))
 	indexByKey := make(map[K]int, len(updates))
 
-	for _, update := range updates {
-		if idx, ok := indexByKey[update.Key]; ok {
-			result[idx] = update
+	for i := len(updates) - 1; i >= 0; i-- {
+		update := updates[i]
+		if _, ok := indexByKey[update.Key]; ok {
 			continue
 		}
+
 		indexByKey[update.Key] = len(result)
 		result = append(result, update)
 	}
 
+	// Reverse the result slice to restore the original order
+	for left, right := 0, len(result)-1; left < right; left, right = left+1, right-1 {
+		result[left], result[right] = result[right], result[left]
+	}
+
 	logger.WithValues("runner", runner).Info("coalesced updates", "count", len(result), "before", len(updates))
 
 	return result

internal/message/watchutil_internal_test.go

@@ -29,13 +29,15 @@ func TestMergeUpdates(t *testing.T) {
 			name: "latest update per key delete state wins",
 			input: []watchable.Update[string, int]{
 				{Key: "foo", Value: 1},
-				{Key: "foo", Value: 2},
 				{Key: "bar", Delete: true, Value: 10},
+				{Key: "baz", Value: 5},
 				{Key: "bar", Delete: true, Value: 11},
+				{Key: "foo", Value: 2},
 			},
 			expected: []watchable.Update[string, int]{
-				{Key: "foo", Value: 2},
+				{Key: "baz", Value: 5},
 				{Key: "bar", Delete: true, Value: 11},
+				{Key: "foo", Value: 2},
 			},
 		},
 	}