Added GetUploadQueueStats.

Author: Chriztiaan

PowerSync/PowerSync.Common/Client/PowerSyncDatabase.cs

@@ -419,6 +419,49 @@ await Database.WriteTransaction(async tx =>
         Database.Close();
         Closed = true;
     }
+    /**
+ * Get upload queue size estimate and count.
+ */
+    //   async getUploadQueueStats(includeSize?: boolean): Promise<UploadQueueStats> {
+    //     return this.readTransaction(async (tx) => {
+    //       if (includeSize) {
+    //         const result = await tx.execute(
+    //           `SELECT SUM(cast(data as blob) + 20) as size, count(*) as count FROM ${PSInternalTable.CRUD}`
+    //         );
+
+    //         const row = result.rows!.item(0);
+    //         return new UploadQueueStats(row?.count ?? 0, row?.size ?? 0);
+    //       } else {
+    //         const result = await tx.execute(`SELECT count(*) as count FROM ${PSInternalTable.CRUD}`);
+    //         const row = result.rows!.item(0);
+    //         return new UploadQueueStats(row?.count ?? 0);
+    //       }
+    //     });
+    //   }
+
+    private record UploadQueueStatsResult(int size, int count);
+    /// <summary>
+    /// Get upload queue size estimate and count.
+    /// </summary>
+    public async Task<UploadQueueStats> GetUploadQueueStats(bool includeSize = false)
+    {
+        if (includeSize)
+        {
+            var result = await Database.Get<UploadQueueStatsResult>(
+                $"SELECT SUM(cast(data as blob) + 20) as size, count(*) as count FROM {PSInternalTable.CRUD}"
+            );
+
+            return new UploadQueueStats(result.count, result.size);
+        }
+        else
+        {
+            var result = await Database.Get<UploadQueueStatsResult>(
+                $"SELECT count(*) as count FROM {PSInternalTable.CRUD}"
+            );
+            return new UploadQueueStats(result.count);
+        }
+    }
+
 
     /// <summary>
     /// Get a batch of crud data to upload.