(#484) Added PendingOperations to client. (#485)

sdk/dotnet/src/Microsoft.Datasync.Client.SQLiteStore/OfflineSQLiteStore.cs

@@ -73,18 +73,10 @@ public override void DefineTable(string tableName, JObject tableDefinition)
             Arguments.IsValidTableName(tableName, true, nameof(tableName));
             Arguments.IsNotNull(tableDefinition, nameof(tableDefinition));
 
-            //if (Initialized)
-            //{
-            //    throw new InvalidOperationException("Cannot define a table after the offline store has been initialized.");
-            //}
             if (!tableMap.ContainsKey(tableName))
             {
                 tableMap.Add(tableName, new TableDefinition(tableName, tableDefinition));
             }
-            //else
-            //{
-            //    throw new InvalidOperationException("Cannot define a table twice");
-            //}
         }
 
         /// <summary>

sdk/dotnet/src/Microsoft.Datasync.Client/DatasyncClient.cs

@@ -155,6 +155,11 @@ public DatasyncClient(Uri endpoint, AuthenticationProvider authenticationProvide
         /// </summary>
         public string InstallationId { get => HttpClient.InstallationId; }
 
+        /// <summary>
+        /// The number of pending operations, or null if the offline store has not been defined.
+        /// </summary>
+        public long? PendingOperations { get => SyncContext?.PendingOperations; }
+
         /// <summary>
         /// The serializer to use for serializing and deserializing content.
         /// </summary>

sdk/dotnet/src/Microsoft.Datasync.Client/Offline/SyncContext.cs

@@ -99,6 +99,11 @@ internal SyncContext(DatasyncClient client, IOfflineStore store)
         /// </remarks>
         internal IPushContext PushContext { get; set; }
 
+        /// <summary>
+        /// The number of pending operations in the operations queue.
+        /// </summary>
+        internal long PendingOperations { get => OperationsQueue.PendingOperations; }
+
         /// <summary>
         /// Initialize the synchronization context for this offline store.
         /// </summary>

sdk/dotnet/test/Microsoft.Datasync.Integration.Test/Client/OfflineTableOfT/DeleteItemAsync.Test.cs

@@ -31,6 +31,7 @@ public async Task DeleteItemAsync_Basic()
             // Act
             await table!.DeleteItemAsync(item);
             Assert.Equal(MovieCount, MovieServer.GetMovieCount());
+            Assert.Equal(1, client.PendingOperations);
 
             await table!.PushItemsAsync();
             Assert.Equal(MovieCount - 1, MovieServer.GetMovieCount());

sdk/dotnet/test/Microsoft.Datasync.Integration.Test/Client/OfflineTableOfT/InsertItemAsync.Test.cs

@@ -32,6 +32,10 @@ public async Task CreateItemAsync_Basic()
 
             // Act
             await table!.InsertItemAsync(movieToAdd);
+
+            // There should be one pending operation right now.
+            Assert.Equal(1, client.PendingOperations);
+
             await table!.PushItemsAsync();
             var result = await table!.GetItemAsync(movieToAdd.Id);
 

sdk/dotnet/test/Microsoft.Datasync.Integration.Test/Client/OfflineTableOfT/ReplaceItemAsync.Test.cs

@@ -31,6 +31,10 @@ public async Task ReplaceItemAsync_Basic()
 
             // Act
             await table!.ReplaceItemAsync(expected);
+
+            // There should be one pending operation
+            Assert.Equal(1, client.PendingOperations);
+
             await table!.PushItemsAsync();
             var response = await table!.GetItemAsync(id);