Trying to get rid of SQLite initialisation error

Author: polterguy

plugins/magic.lambda.sqlite/magic.lambda.sqlite/Connect.cs

@@ -8,6 +8,7 @@
 using magic.data.common.helpers;
 using magic.lambda.sqlite.helpers;
 using magic.data.common.contracts;
+using magic.node.contracts;
 
 namespace magic.lambda.sqlite
 {
@@ -19,14 +20,17 @@ public class Connect : ISlotAsync
     {
         readonly IDataSettings _settings;
         readonly IInitializer _initializer;
+        readonly IRootResolver _resolver;
 
         /// <summary>
         /// Creates a new instance of your class.
         /// </summary>
+        /// <param name="resolver">Required to find the absolute path.</param>
         /// <param name="settings">Configuration settings for your application.</param>
         /// <param name="initializer">Initialiser invoked as connections are created, allowing you to dynamically load extensions, etc.</param>
-        public Connect(IDataSettings settings, IInitializer initializer)
-        {
+        public Connect(IRootResolver resolver, IDataSettings settings, IInitializer initializer)
+    {
+            _resolver = resolver;
             _settings = settings;
             _initializer = initializer;
         }
@@ -42,6 +46,7 @@ public async Task SignalAsync(ISignaler signaler, Node input)
             using (var shutdownLock = new ShutdownLock())
             {
                 using (var connection = new SqliteConnectionWrapper(
+                    _resolver,
                     Executor.GetConnectionString(
                         input,
                         "sqlite",

plugins/magic.lambda.sqlite/magic.lambda.sqlite/IInitializer.cs

@@ -4,6 +4,7 @@
 
 using System.Threading.Tasks;
 using Microsoft.Data.Sqlite;
+using magic.node.contracts;
 
 namespace magic.lambda.sqlite
 {
@@ -15,7 +16,8 @@ public interface IInitializer
         /// <summary>
         /// Initializes the database, invoked every single time you create a new database connection.
         /// </summary>
+        /// <param name="resolver">Required to resolve absolute paths</param>
         /// <param name="connection">Recently created SQLite database connection</param>
-        Task Initialize(SqliteConnection connection);
+        Task Initialize(IRootResolver resolver, SqliteConnection connection);
     }
 }

plugins/magic.lambda.sqlite/magic.lambda.sqlite/helpers/SqliteConnectionWrapper.cs

@@ -3,6 +3,7 @@
  */
 
 using System;
+using magic.node.contracts;
 using Microsoft.Data.Sqlite;
 
 namespace magic.lambda.sqlite.helpers
@@ -15,12 +16,12 @@ internal sealed class SqliteConnectionWrapper : IDisposable
     {
         readonly Lazy<SqliteConnection> _connection;
 
-        public SqliteConnectionWrapper(string connectionString, IInitializer initializer = null)
+        public SqliteConnectionWrapper(IRootResolver resolver, string connectionString, IInitializer initializer = null)
         {
             _connection = new Lazy<SqliteConnection>(() =>
             {
                 var connection = new SqliteConnection(connectionString);
-                initializer?.Initialize(connection);
+                initializer?.Initialize(resolver, connection);
                 return connection;
             });
         }

plugins/magic.library/Initializer.cs

@@ -107,6 +107,7 @@ public static void AddMagic(this IServiceCollection services, IConfiguration con
         public static void AddMagicData(this IServiceCollection services, IConfiguration configuration)
         {
             services.AddTransient<IDataSettings, AppSettingsDataSettings>();
+            SQLitePCL.Batteries_V2.Init();
         }
 
         /// <summary>

plugins/magic.library/internals/RootResolver.cs

@@ -6,6 +6,7 @@
 using Microsoft.Extensions.Configuration;
 using magic.node.contracts;
 using magic.node.extensions;
+using System.Linq;
 
 namespace magic.library.internals
 {
@@ -42,5 +43,15 @@ public string AbsolutePath(string path)
             // DynamicFiles should always end with a slash (/).
             return DynamicFiles + path.Replace("\\", "/").TrimStart('/');
         }
+
+        public string RuntimePath(string path)
+        {
+            var entities = DynamicFiles.Split(['/'], System.StringSplitOptions.RemoveEmptyEntries).ToList();
+            entities.RemoveAt(entities.Count - 1);
+            var root = "/" + string.Join('/', entities) + "/";
+
+            // DynamicFiles should always end with a slash (/).
+            return root + path.Replace("\\", "/").TrimStart('/');
+        }
     }
 }

plugins/magic.library/internals/SQLiteInitializer.cs

@@ -6,6 +6,7 @@
 using System.Threading.Tasks;
 using Microsoft.Data.Sqlite;
 using magic.lambda.sqlite;
+using magic.node.contracts;
 
 namespace magic.library.internals
 {
@@ -16,21 +17,22 @@ internal class SQLiteInitializer : IInitializer
     {
         private static readonly SemaphoreSlim _lock = new(1, 1);
 
-        public async Task Initialize(SqliteConnection connection)
+        public async Task Initialize(IRootResolver resolver, SqliteConnection connection)
         {
             await connection.OpenAsync();
-            await EnsureVectorLoadedAsync(connection);
+            await EnsureVectorLoadedAsync(resolver, connection);
         }
 
         /*
          * Ensures serialized initialization of vector lib.
          */
-        private static async Task EnsureVectorLoadedAsync(SqliteConnection connection)
+        private static async Task EnsureVectorLoadedAsync(IRootResolver resolver, SqliteConnection connection)
         {
             await _lock.WaitAsync();
             try
-            {
-                connection.LoadExtension("./sqlite-plugins/vector");
+      {
+                connection.EnableExtensions();
+                connection.LoadExtension(resolver.RuntimePath("sqlite-plugins/vector"));
             }
             finally
             {

plugins/magic.node/magic.node.extensions/contracts/IRootResolver.cs

@@ -41,5 +41,12 @@ public interface IRootResolver
         /// <param name="path">Relative path of file or folder.</param>
         /// <returns>Absolute file or folder path.</returns>
         string AbsolutePath(string path);
+
+        /// <summary>
+        /// Returns the absolute path to the runtime given the relative path as an argument.
+        /// </summary>
+        /// <param name="path">Relative path of file or folder.</param>
+        /// <returns>Absolute file or folder path.</returns>
+        string RuntimePath(string path);
     }
 }