1 files changed, 11 insertions, 1 deletions
diff --git a/lib/Emails.Transactional.Plugin/src/TEmailEntryPoint.cs b/lib/Emails.Transactional.Plugin/src/TEmailEntryPoint.cs
index 8e7319a..42ba0ce 100644
--- a/lib/Emails.Transactional.Plugin/src/TEmailEntryPoint.cs
+++ b/lib/Emails.Transactional.Plugin/src/TEmailEntryPoint.cs
@@ -24,7 +24,6 @@
 
 using System;
 using System.Threading.Tasks;
-using System.Collections.Generic;
 
 using Emails.Transactional.Endpoints;
 
@@ -33,6 +32,8 @@ using Minio.DataModel.Tracing;
 
 using VNLib.Utils.Logging;
 using VNLib.Plugins;
+using VNLib.Plugins.Extensions.Loading;
+using VNLib.Plugins.Extensions.Loading.Sql;
 using VNLib.Plugins.Extensions.Loading.Routing;
 
 namespace Emails.Transactional
@@ -64,6 +65,9 @@ namespace Emails.Transactional
             //Route send oauth endpoint
             this.Route<SendEndpoint>();
 
+            //Create databases
+            _ = this.ObserveWork(CreateDatabasesasync, 550);
+
             Log.Information("Plugin loaded");
         }
 
@@ -77,5 +81,11 @@ namespace Emails.Transactional
         {
             throw new NotImplementedException();
         }
+
+        private async Task CreateDatabasesasync()
+        {
+            //Create the operation database
+            await this.EnsureDbCreatedAsync<EmailDbCtx>(this);
+        }
     }
 }