RavenDB-21993 - debug assert node tag for operations tracking in chan…

…ges api
djordjedjukic · May 17, 2024 · c66f90a · c66f90a
1 parent 7a02829
commit c66f90a
Showing 1 changed file with 5 additions and 0 deletions.
diff --git a/src/Raven.Client/Documents/Changes/DatabaseChanges.cs b/src/Raven.Client/Documents/Changes/DatabaseChanges.cs
@@ -1,4 +1,5 @@
 using System;
+using System.Diagnostics;
 using System.Net.Http;
 using System.Threading.Tasks;
 using Raven.Client.Documents.Operations;
@@ -59,6 +60,8 @@ internal IChangesObservable<AggressiveCacheChange> ForAggressiveCaching()
 
         public IChangesObservable<OperationStatusChange> ForOperationId(long operationId)
         {
+            Debug.Assert(string.IsNullOrEmpty(_nodeTag) == false, "Changes API must be provided a node tag in order to track node-specific operations.");
+
             var counter = GetOrAddConnectionState("operations/" + operationId, "watch-operation", "unwatch-operation", operationId.ToString());
 
             var taskedObservable = new ChangesObservable<OperationStatusChange, DatabaseConnectionState>(
@@ -70,6 +73,8 @@ public IChangesObservable<OperationStatusChange> ForOperationId(long operationId
 
         public IChangesObservable<OperationStatusChange> ForAllOperations()
         {
+            Debug.Assert(string.IsNullOrEmpty(_nodeTag) == false, "Changes API must be provided a node tag in order to track node-specific operations.");
+
             var counter = GetOrAddConnectionState("all-operations", "watch-operations", "unwatch-operations", null);
 
             var taskedObservable = new ChangesObservable<OperationStatusChange, DatabaseConnectionState>(