Update LoadExtension.cs

Author: polterguy

plugins/magic.lambda.sqlite/magic.lambda.sqlite/LoadExtension.cs

@@ -2,13 +2,13 @@
  * Magic Cloud, copyright (c) 2023 Thomas Hansen. See the attached LICENSE file for details. For license inquiries you can send an email to thomas@ainiro.io
  */
 
+using System.Linq;
 using System.Threading.Tasks;
 using magic.node;
+using magic.node.extensions;
 using magic.signals.contracts;
-using magic.data.common.helpers;
 using magic.lambda.sqlite.helpers;
-using magic.node.extensions;
-using System.Linq;
+using System.Threading;
 
 namespace magic.lambda.sqlite
 {
@@ -18,6 +18,9 @@ namespace magic.lambda.sqlite
     [Slot(Name = "sqlite.load-extension")]
     public class LoadExtension : ISlotAsync
     {
+        // Ensuring synchronized access.
+        readonly static SemaphoreSlim _semaphore = new (1,1);
+
         /// <summary>
         /// Handles the signal for the class.
         /// </summary>
@@ -26,13 +29,20 @@ public class LoadExtension : ISlotAsync
         /// <returns>An awaitable task.</returns>
         public async Task SignalAsync(ISignaler signaler, Node input)
         {
-            var connection = signaler.Peek<SqliteConnectionWrapper>("sqlite.connect").Connection;
-            connection.LoadExtension(
-                input.Children.FirstOrDefault(x => x.Name == "file")?.GetEx<string>() ?? 
-                    throw new HyperlambdaException("No [file] argument provided to [sqlite.load-extension]"),
-                input.Children.FirstOrDefault(x => x.Name == "proc")?.GetEx<string>() ?? 
-                    throw new HyperlambdaException("No [proc] argument provided to [sqlite.load-extension]")
-            );
+            await _semaphore.WaitAsync();
+            try
+            {
+                var connection = signaler.Peek<SqliteConnectionWrapper>("sqlite.connect").Connection;
+                connection.LoadExtension(
+                    input.Children.FirstOrDefault(x => x.Name == "file")?.GetEx<string>() ?? 
+                        throw new HyperlambdaException("No [file] argument provided to [sqlite.load-extension]"),
+                    input.Children.FirstOrDefault(x => x.Name == "proc")?.GetEx<string>() ?? 
+                        throw new HyperlambdaException("No [proc] argument provided to [sqlite.load-extension]"));
+            }
+            finally
+            {
+                _semaphore.Release();
+            }
         }
     }
 }