lots of updates

Author: magiccodingman

Magic.IndexedDb/Cache.cs

@@ -8,9 +8,10 @@ namespace Magic.IndexedDb
 {
     internal static class Cache
     {
+        public static long JsMessageSizeBytes { get; set; } = 31000;
         /// <summary>
         /// this is the wwwroot path of "./magicDB.js" for importing the script
         /// </summary>
-        public const string MagicDbJsImportPath = "./magicDB.js";
+        public const string MagicDbJsImportPath = "/magicDB.js";
     }
 }

Magic.IndexedDb/Extensions/MagicCompoundExtension.cs

@@ -0,0 +1,17 @@
+using System;
+using System.Collections.Generic;
+using System.Linq;
+using System.Linq.Expressions;
+using System.Text;
+using System.Threading.Tasks;
+
+namespace Magic.IndexedDb
+{
+    public static class MagicCompoundExtension
+    {
+        public static IMagicCompoundIndex Create<T>(params Expression<Func<T, object>>[] keySelectors)
+        {
+            return InternalMagicCompoundIndex<T>.Create(keySelectors);
+        }
+    }
+}

Magic.IndexedDb/Extensions/MagicJsInvoke.cs

@@ -34,6 +34,32 @@ internal async Task CallJsAsync(string modulePath, string functionName,
             return await MagicStreamJsAsync<T>(modulePath, functionName, token, args) ?? default;
         }
 
+        ///
+        internal async Task CallInvokeDefaultJsAsync(string modulePath, string functionName,
+            params object[] args)
+        {
+
+            var throwAway = await CallInvokeDefaultJsAsync<bool>(modulePath, functionName, args);
+
+            return;
+        }
+
+        /// <summary>
+        /// Utilizes InvokeAsync normally with no special serialization or streaming.
+        /// </summary>
+        /// <typeparam name="T"></typeparam>
+        /// <param name="modulePath"></param>
+        /// <param name="functionName"></param>
+        /// <param name="token"></param>
+        /// <param name="args"></param>
+        /// <returns></returns>
+        internal async Task<T?> CallInvokeDefaultJsAsync<T>(string modulePath, string functionName,
+            params object[] args)
+        {
+            var response = await _jsModule.InvokeAsync<T>("JsHandler", modulePath, functionName, args);
+            return response;
+        }
+
         internal async IAsyncEnumerable<T?> CallYieldJsAsync<T>(
     string modulePath,
     string functionName,
@@ -90,7 +116,7 @@ internal async Task CallJsAsync(string modulePath, string functionName,
 
             // Send to JS
             var responseStreamRef = await _jsModule.InvokeAsync<IJSStreamReference>("streamedJsHandler", token,
-                streamRef, instanceId, DotNetObjectReference.Create(this));
+                streamRef, instanceId, DotNetObjectReference.Create(this), Cache.JsMessageSizeBytes);
 
             // 🚀 Convert the stream reference back to JSON in C#
             await using var responseStream = await responseStreamRef.OpenReadStreamAsync(long.MaxValue, token);

Magic.IndexedDb/Extensions/MagicTableTools.cs

@@ -0,0 +1,19 @@
+using Magic.IndexedDb.Interfaces;
+using System;
+using System.Collections.Generic;
+using System.Linq;
+using System.Linq.Expressions;
+using System.Text;
+using System.Threading.Tasks;
+
+namespace Magic.IndexedDb
+{
+    public class MagicTableTool<T> where T : class, IMagicTableBase, new()
+    {
+        protected CreateCompoundIndex CreateCompoundIndex(params Expression<Func<T, object>>[] keySelectors)
+        {
+            return MagicCompoundExtension.Create<T>(keySelectors);
+        }
+    }
+
+}

Magic.IndexedDb/Extensions/ServiceCollectionExtensions.cs

@@ -9,17 +9,33 @@
 using System.Text;
 using System.Threading.Tasks;
 
-namespace Magic.IndexedDb.Extensions
+namespace Magic.IndexedDb
 {
+    public enum BlazorInteropMode : long
+    {
+        /// <summary>
+        /// SignalR default interop send/receive is 32 KB. 
+        /// This will default to 31 KB for safety.
+        /// </summary>
+        SignalR = 31 * 1024,       // 31 KB in bytes
+
+        /// <summary>
+        /// WASM default interop send/receive is 16 MB. 
+        /// This will default to 15 MB for safety.
+        /// </summary>
+        WASM = 15 * 1024 * 1024    // 15 MB in bytes
+    }
+
     public static class ServiceCollectionExtensions
     {
-        public static IServiceCollection AddBlazorDB(this IServiceCollection services, Action<DbStore> options)
+        public static IServiceCollection AddBlazorDB(this IServiceCollection services, BlazorInteropMode interoptMode)
         {
-            services.TryAddScoped<IMagicManager, IndexedDbManager>();
+            return services.AddBlazorDB((long)interoptMode);
+        }
 
-            var dbStore = new DbStore();
-            options(dbStore);
-            _ = services.AddSingleton(dbStore);
+        public static IServiceCollection AddBlazorDB(this IServiceCollection services, long jsMessageSizeBytes)
+        {
+            services.AddSingleton<IMagicDbFactory>(sp => new MagicDbFactory(jsMessageSizeBytes));
 
             MagicValidator.ValidateTables();
 

Magic.IndexedDb/Factories/EncryptionFactory.cs

@@ -6,6 +6,18 @@ namespace Magic.IndexedDb
     public interface IMagicDbFactory
     {
 
+        /// <summary>
+        /// Allows manually inserting database names and schema names via strings. 
+        /// Please be careful, Magic IndexDB can't protect you from potential issues 
+        /// if you use this.
+        /// </summary>
+        /// <typeparam name="T"></typeparam>
+        /// <param name="databaseNameOverride"></param>
+        /// <param name="schemaNameOverride"></param>
+        /// <returns></returns>
+        ValueTask<IMagicQuery<T>> QueryOverride<T>(string? databaseNameOverride = null, 
+            string? schemaNameOverride = null) where T : class, IMagicTableBase, new();
+
         /// <summary>
         /// Opens a ready query to utilize IndexDB database and capabilities utilizing LINQ to IndexDB. 
         /// Use example: IMagicQuery<Person> query = await _MagicDb.Query<Person>();
@@ -14,7 +26,27 @@ public interface IMagicDbFactory
         /// <param name="databaseNameOverride"></param>
         /// <param name="schemaNameOverride"></param>
         /// <returns></returns>
-        ValueTask<IMagicQuery<T>> Query<T>(string? databaseNameOverride = null, string? schemaNameOverride = null) where T : class;
+        ValueTask<IMagicQuery<T>> Query<T>()
+                        where T : class, IMagicTableBase, new();
+
+        /// <summary>
+        /// Opens a query for a table to a specified database.
+        /// </summary>
+        /// <typeparam name="T"></typeparam>
+        /// <param name="dbSetSelector"></param>
+        /// <returns></returns>
+        ValueTask<IMagicQuery<T>> Query<T>(Func<T, IndexedDbSet> dbSetSelector) where T : class, IMagicTableBase, new();
+
+        /// <summary>
+        /// Utilize any Database you want, but be careful that it's assigned! 
+        /// Highly suggested you utilize `Query<T>(Func<T, IndexedDbSet> dbSetSelector)`
+        /// </summary>
+        /// <typeparam name="T"></typeparam>
+        /// <param name="indexedDbSet"></param>
+        /// <returns></returns>
+        ValueTask<IMagicQuery<T>> Query<T>(IndexedDbSet indexedDbSet)
+                        where T : class, IMagicTableBase, new();
+
         Task<QuotaUsage> GetStorageEstimateAsync(CancellationToken cancellationToken = default);
     }
 }