Remaining sprocs (#41)

* Removed SPROCs

* Update to latest packages

Author: galvesribeiro

.vscode/launch.json

@@ -1,27 +1,27 @@
-{
-   // Use IntelliSense to find out which attributes exist for C# debugging
-   // Use hover for the description of the existing attributes
-   // For further information visit https://github.com/OmniSharp/omnisharp-vscode/blob/master/debugger-launchjson.md
-   "version": "0.2.0",
-   "configurations": [
-        {
-            "name": ".NET Core Launch (console)",
-            "type": "coreclr",
-            "request": "launch",
-            "preLaunchTask": "build",
-            // If you have changed target frameworks, make sure to update the program path.
-            "program": "${workspaceFolder}/test/Orleans.CosmosDB.Tests/bin/Debug/netcoreapp3.0/Orleans.CosmosDB.Tests.dll",
-            "args": [],
-            "cwd": "${workspaceFolder}/test/Orleans.CosmosDB.Tests",
-            // For more information about the 'console' field, see https://aka.ms/VSCode-CS-LaunchJson-Console
-            "console": "internalConsole",
-            "stopAtEntry": false
-        },
-        {
-            "name": ".NET Core Attach",
-            "type": "coreclr",
-            "request": "attach",
-            "processId": "${command:pickProcess}"
-        }
-    ]
+{
+   // Use IntelliSense to find out which attributes exist for C# debugging
+   // Use hover for the description of the existing attributes
+   // For further information visit https://github.com/OmniSharp/omnisharp-vscode/blob/master/debugger-launchjson.md
+   "version": "0.2.0",
+   "configurations": [
+        {
+            "name": ".NET Core Launch (console)",
+            "type": "coreclr",
+            "request": "launch",
+            "preLaunchTask": "build",
+            // If you have changed target frameworks, make sure to update the program path.
+            "program": "${workspaceFolder}/test/Orleans.CosmosDB.Tests/bin/Debug/netcoreapp3.1/Orleans.CosmosDB.Tests.dll",
+            "args": [],
+            "cwd": "${workspaceFolder}/test/Orleans.CosmosDB.Tests",
+            // For more information about the 'console' field, see https://aka.ms/VSCode-CS-LaunchJson-Console
+            "console": "internalConsole",
+            "stopAtEntry": false
+        },
+        {
+            "name": ".NET Core Attach",
+            "type": "coreclr",
+            "request": "attach",
+            "processId": "${command:pickProcess}"
+        }
+    ]
 }

global.json

@@ -1,5 +1,5 @@
 {
   "sdk": {
-    "version": "3.0.100"
+    "version": "3.1.100"
   }
 }

src/Orleans.Clustering.CosmosDB/CosmosDBGatewayListProvider.cs

@@ -1,5 +1,5 @@
-using Microsoft.Azure.Documents;
-using Microsoft.Azure.Documents.Client;
+using Microsoft.Azure.Cosmos;
+using Microsoft.Azure.Cosmos.Linq;
 using Microsoft.Extensions.Logging;
 using Microsoft.Extensions.Options;
 using Orleans.Clustering.CosmosDB.Models;
@@ -21,7 +21,8 @@ internal class CosmosDBGatewayListProvider : IGatewayListProvider
         private readonly ILoggerFactory _loggerFactory;
         private readonly TimeSpan _maxStaleness;
         private readonly string _clusterId;
-        private DocumentClient _dbClient;
+        private CosmosClient _cosmos;
+        private Container _container;
 
         public TimeSpan MaxStaleness => this._maxStaleness;
 
@@ -38,38 +39,40 @@ public CosmosDBGatewayListProvider(ILoggerFactory loggerFactory, IOptions<Cosmos
 
         public async Task<IList<Uri>> GetGateways()
         {
-            try
-            {
-                var spResponse = await this._dbClient.ExecuteStoredProcedureAsync<List<SiloEntity>>(
-                    UriFactory.CreateStoredProcedureUri(this._options.DB, this._options.Collection, SPROC),
-                    new RequestOptions { PartitionKey = new PartitionKey(this._clusterId) },
-                    this._clusterId);
+            var query = this._container
+                    .GetItemLinqQueryable<SiloEntity>(requestOptions: new QueryRequestOptions { PartitionKey = new PartitionKey(this._clusterId) })
+                        .Where(g => g.EntityType == nameof(SiloEntity) &&
+                            g.Status == SiloStatus.Active &&
+                            g.ProxyPort.HasValue && g.ProxyPort.Value != 0).ToFeedIterator();
 
-                var uris = spResponse.Response.Select(ConvertToGatewayUri).ToList();
-                return uris;
-            }
-            catch (Exception)
+            var entities = new List<SiloEntity>();
+            do
             {
-                throw;
-            }
+                var items = await query.ReadNextAsync();
+                entities.AddRange(items);
+            } while (query.HasMoreResults);
+
+            var uris = entities.Select(ConvertToGatewayUri).ToList();
+            return uris;
         }
 
-        public async Task InitializeGatewayListProvider()
+        public Task InitializeGatewayListProvider()
         {
             if (this._options.Client != null)
             {
-                this._dbClient = this._options.Client;
+                this._cosmos = this._options.Client;
             }
             else
             {
-                this._dbClient = new DocumentClient(new Uri(this._options.AccountEndpoint), this._options.AccountKey,
-                new ConnectionPolicy
-                {
-                    ConnectionMode = this._options.ConnectionMode,
-                    ConnectionProtocol = this._options.ConnectionProtocol
-                });
+                this._cosmos = new CosmosClient(
+                    this._options.AccountEndpoint,
+                    this._options.AccountKey,
+                    new CosmosClientOptions { ConnectionMode = this._options.ConnectionMode }
+                );
             }
-            await this._dbClient.OpenAsync();
+            this._container = this._cosmos.GetDatabase(this._options.DB).GetContainer(this._options.Collection);
+
+            return Task.CompletedTask;
         }
 
         private static Uri ConvertToGatewayUri(SiloEntity gateway)