initial cosmos sdk update

dlmelendez · Nov 12, 2019 · 31ce326 · 31ce326
1 parent be691c4
commit 31ce326
Show file tree

Hide file tree

Showing 22 changed files with 830 additions and 908 deletions.
diff --git a/src/ElCamino.AspNetCore.Identity.CosmosDB/Constants.cs b/src/ElCamino.AspNetCore.Identity.CosmosDB/Constants.cs
@@ -11,7 +11,7 @@ namespace ElCamino.AspNetCore.Identity.CosmosDB
     public static class Constants
     {
 
-        public static class DocumentCollectionIds
+        public static class ContainerIds
         {
             public const string DefaultIdentityCollection = "identity";
         }

diff --git a/src/ElCamino.AspNetCore.Identity.CosmosDB/ElCamino.AspNetCore.Identity.CosmosDB.csproj b/src/ElCamino.AspNetCore.Identity.CosmosDB/ElCamino.AspNetCore.Identity.CosmosDB.csproj
@@ -34,7 +34,7 @@
 
   <ItemGroup>
     <PackageReference Include="Microsoft.AspNetCore.Identity" Version="2.2.0" />
-    <PackageReference Include="Microsoft.Azure.DocumentDB.Core" Version="2.2.0" />
+    <PackageReference Include="Microsoft.Azure.Cosmos" Version="3.4.1" />
     <PackageReference Include="Microsoft.Extensions.DependencyInjection" Version="2.2.0" />
     <PackageReference Include="Microsoft.Extensions.Identity.Stores" Version="2.2.0" />
     <PackageReference Include="System.ComponentModel.TypeConverter" Version="4.3.0" />

diff --git a/src/ElCamino.AspNetCore.Identity.CosmosDB/Extensions/IQueryableExtensions.cs b/src/ElCamino.AspNetCore.Identity.CosmosDB/Extensions/IQueryableExtensions.cs
@@ -12,8 +12,16 @@ internal static class IQueryableExtensions
     {
         public static Task<List<TSource>> ToListAsync<TSource>(this IEnumerable<TSource> source, Func<TSource, bool> where = null, CancellationToken cancellationToken = default(CancellationToken))
         {
-            if(where == null)
+
+            if (where == null)
+            {
+                List<TSource> list = source as List<TSource>;
+                if (list != null)
+                {
+                    return Task.FromResult(list);
+                }
                 return Task.Run(() => { return source.ToList(); }, cancellationToken);
+            }
             else
                 return Task.Run(() => { return source.Where(where).ToList(); }, cancellationToken);
         }
@@ -22,17 +30,17 @@ public static Task<TSource> FirstOrDefaultAsync<TSource>(this IEnumerable<TSourc
         {
             return Task.Run(() => {
                 if (where == null)
-                    return source.Where(where).FirstOrDefault();
-                return source.Where(where).FirstOrDefault(where);
+                    return source.FirstOrDefault();
+                return source.FirstOrDefault(where);
             }, cancellationToken);
         }
 
         public static Task<TSource> SingleOrDefaultAsync<TSource>(this IEnumerable<TSource> source, Func<TSource, bool> where = null, CancellationToken cancellationToken = default(CancellationToken))
         {
             return Task.Run(() => {
                 if(where == null)
-                    return source.Where(where).SingleOrDefault();
-                return source.Where(where).SingleOrDefault(where);
+                    return source.SingleOrDefault();
+                return source.Where(where).SingleOrDefault();
             }, cancellationToken);
         }
     }

diff --git a/src/ElCamino.AspNetCore.Identity.CosmosDB/Helpers/JsonHelpers.cs b/src/ElCamino.AspNetCore.Identity.CosmosDB/Helpers/JsonHelpers.cs
diff --git a/src/ElCamino.AspNetCore.Identity.CosmosDB/Helpers/PartitionKeyHelper.cs b/src/ElCamino.AspNetCore.Identity.CosmosDB/Helpers/PartitionKeyHelper.cs
@@ -0,0 +1,23 @@
+using System;
+using System.Collections.Generic;
+using System.Text;
+
+namespace ElCamino.AspNetCore.Identity.CosmosDB.Helpers
+{
+    public static class PartitionKeyHelper
+    {
+        public static string GetPartitionKeyFromId(string id)
+        {
+            id = id?.ToString()?.Trim();
+            if (!string.IsNullOrWhiteSpace(id))
+            {
+                if (id.Length > 4)
+                {
+                    return id.Substring(id.Length - 4, 4);
+                }
+            }
+
+            return string.Empty;
+        }
+    }
+}