add ContextStorageFactory

persist context to file

Author: Oceania2018

.gitignore

@@ -291,3 +291,4 @@ __pycache__/
 /docs/_build
 *.RestApi.xml
 /BotSharp.WebHost/App_Data/AgentStorage
+/BotSharp.WebHost/App_Data/SessionStorage

BotSharp.Core/AgentStorage/AgentStorageFactory.cs

@@ -19,7 +19,7 @@ public AgentStorageFactory(IPlatformSettings setting, Func<string, IAgentStorage
             this.platformSetting = setting;
         }
 
-        public async Task<IAgentStorage<TAgent>> Get()
+        public IAgentStorage<TAgent> Get()
         {
             IAgentStorage<TAgent> storage = null;
             string storageName = this.platformSetting.AgentStorage;

BotSharp.Core/AgentStorage/AgentStorageInFile.cs

@@ -16,9 +16,6 @@ namespace BotSharp.Core.AgentStorage
     public class AgentStorageInFile<TAgent> : IAgentStorage<TAgent> 
         where TAgent : AgentBase
     {
-        private static CSRedisClient csredis;
-        private static string prefix = String.Empty;
-
         private static string storageDir;
 
         public AgentStorageInFile()
@@ -27,7 +24,7 @@ public AgentStorageInFile()
             var db = config.GetSection("Database:Default").Value;
             storageDir = config.GetSection($"Database:ConnectionStrings:{db}").Value;
             string contentDir = AppDomain.CurrentDomain.GetData("DataPath").ToString();
-            storageDir = storageDir.Replace("|DataDirectory|", contentDir + Path.DirectorySeparatorChar);
+            storageDir = storageDir.Replace("|DataDirectory|", contentDir + Path.DirectorySeparatorChar + "AgentStorage" + Path.DirectorySeparatorChar);
 
             if (!Directory.Exists(storageDir))
             {

BotSharp.Core/ContextStorage/ContextStorageFactory.cs

@@ -0,0 +1,28 @@
+using BotSharp.Platform.Abstraction;
+using System;
+using System.Collections.Generic;
+using System.Text;
+using System.Threading.Tasks;
+
+namespace BotSharp.Core.ContextStorage
+{
+    public class ContextStorageFactory<T> : IContextStorageFactory<T>
+    {
+        private readonly Func<string, IContextStorage<T>> func;
+        private readonly IPlatformSettings platformSetting;
+
+        public ContextStorageFactory(IPlatformSettings setting, Func<string, IContextStorage<T>> serviceAccessor)
+        {
+            this.func = serviceAccessor;
+            this.platformSetting = setting;
+        }
+
+        public IContextStorage<T> Get()
+        {
+            IContextStorage<T> storage = null;
+            string storageName = this.platformSetting.ContextStorage;
+            storage = func(storageName);
+            return storage as IContextStorage<T>;
+        }
+    }
+}

BotSharp.Core/ContextStorage/ContextStorageInFile.cs

@@ -1,12 +1,51 @@
 using BotSharp.Platform.Abstraction;
+using Microsoft.Extensions.Configuration;
+using Newtonsoft.Json;
+using Newtonsoft.Json.Serialization;
 using System;
 using System.Collections.Generic;
+using System.IO;
 using System.Text;
+using System.Threading.Tasks;
 
 namespace BotSharp.Core.ContextStorage
 {
-    public class ContextStorageInFile : IContextStorage
+    public class ContextStorageInFile<T> : IContextStorage<T>
     {
+        private static string storageDir;
 
+        public ContextStorageInFile()
+        {
+            IConfiguration config = (IConfiguration)AppDomain.CurrentDomain.GetData("Configuration");
+            var db = config.GetSection("Database:Default").Value;
+            storageDir = config.GetSection($"Database:ConnectionStrings:{db}").Value;
+            string contentDir = AppDomain.CurrentDomain.GetData("DataPath").ToString();
+            storageDir = storageDir.Replace("|DataDirectory|", contentDir + Path.DirectorySeparatorChar + "SessionStorage" + Path.DirectorySeparatorChar);
+
+            if (!Directory.Exists(storageDir))
+            {
+                Directory.CreateDirectory(storageDir);
+            }
+        }
+
+        public async Task<bool> Persist(string sessionId, T[] context)
+        {
+            var json = JsonConvert.SerializeObject(context, new JsonSerializerSettings
+            {
+                NullValueHandling = NullValueHandling.Ignore,
+                Formatting = Formatting.Indented,
+                ContractResolver = new CamelCasePropertyNamesContractResolver(),
+                Converters = new List<JsonConverter>
+                {
+                    new Newtonsoft.Json.Converters.StringEnumConverter()
+                }
+            });
+
+            string dataPath = Path.Combine(storageDir, sessionId + ".json");
+
+            File.WriteAllText(dataPath, json);
+
+            return true;
+        }
     }
 }

BotSharp.Core/ContextStorage/ContextStorageServiceRegister.cs

@@ -0,0 +1,35 @@
+using BotSharp.Platform.Abstraction;
+using Microsoft.Extensions.DependencyInjection;
+using System;
+using System.Collections.Generic;
+using System.Text;
+
+namespace BotSharp.Core.ContextStorage
+{
+    public class ContextStorageServiceRegister
+    {
+        public static void Register<T>(IServiceCollection services)
+        {
+            services.AddSingleton<IContextStorageFactory<T>, ContextStorageFactory<T>>();
+
+            services.AddSingleton<ContextStorageInFile<T>>();
+
+            services.AddSingleton(factory =>
+            {
+                Func<string, IContextStorage<T>> accesor = key =>
+                {
+                    if (key.Equals("ContextStorageInFile"))
+                    {
+                        return factory.GetService<ContextStorageInFile<T>>();
+                    }
+                    else
+                    {
+                        throw new ArgumentException($"Not Support key : {key}");
+                    }
+                };
+
+                return accesor;
+            });
+        }
+    }
+}

BotSharp.Core/PlatformBuilderBase.cs

@@ -32,12 +32,11 @@ public PlatformBuilderBase(IAgentStorageFactory<TAgent> agentStorageFactory, IPl
         {
             this.agentStorageFactory = agentStorageFactory;
             this.settings = settings;
+            GetAgentStorage();
         }
 
         public async Task<List<TAgent>> GetAllAgents()
         {
-            await GetStorage();
-
             return await Storage.Query();
         }
 
@@ -80,15 +79,11 @@ private AgentImportHeader LoadMeta(string dataDir)
 
         public async Task<TAgent> GetAgentById(string agentId)
         {
-            GetStorage();
-
             return await Storage.FetchById(agentId);
         }
 
         public async Task<TAgent> GetAgentByName(string agentName)
         {
-            await GetStorage();
-
             return await Storage.FetchByName(agentName);
         }
 
@@ -195,7 +190,7 @@ public virtual async Task<TResult> TextRequest<TResult>(AiRequest request)
 
             Console.WriteLine($"TextResponse: {aiResponse.Intent}, {request.SessionId}");
 
-            return await AssembleResult<TResult>(aiResponse);
+            return await AssembleResult<TResult>(request, aiResponse);
         }
 
         public virtual async Task<TextClassificationResult> FallbackResponse(AiRequest request)
@@ -222,27 +217,25 @@ public virtual async Task<TextClassificationResult> FallbackResponse(AiRequest r
             }
         }
 
-        public virtual async Task<TResult> AssembleResult<TResult>(AiResponse response)
+        public virtual async Task<TResult> AssembleResult<TResult>(AiRequest request, AiResponse response)
         {
             throw new NotImplementedException();
         }
 
         public virtual async Task<bool> SaveAgent(TAgent agent)
         {
-            await GetStorage();
-
             // default save agent in FileStorage
             await Storage.Persist(agent);
 
             return true;
         }
-
-        protected async Task<IAgentStorage<TAgent>> GetStorage()
+        protected IAgentStorage<TAgent> GetAgentStorage()
         {
             if (Storage == null)
             {
-                Storage = await agentStorageFactory.Get();
+                Storage = agentStorageFactory.Get();
             }
+
             return Storage;
         }
     }

BotSharp.Core/PlatformSettingsBase.cs

@@ -16,10 +16,13 @@ public PlatformSettingsBase()
         {
             BotEngine = "BotSharpNLU";
             AgentStorage = "AgentStorageInFile";
+            ContextStorage = "ContextStorageInFile";
         }
 
         public string BotEngine { get; set; }
 
+        public string ContextStorage { get; set; }
+
         public string AgentStorage { get; set; }
     }
 

BotSharp.Platform.Abstraction/IAgentStorageFactory.cs

@@ -6,6 +6,6 @@ namespace BotSharp.Platform.Abstraction
 {
     public interface IAgentStorageFactory<TAgent> where TAgent : AgentBase
     {
-        Task<IAgentStorage<TAgent>> Get();
+        IAgentStorage<TAgent> Get();
     }
 }

BotSharp.Platform.Abstraction/IContextStorage.cs

@@ -1,10 +1,12 @@
 using System;
 using System.Collections.Generic;
 using System.Text;
+using System.Threading.Tasks;
 
 namespace BotSharp.Platform.Abstraction
 {
-    public interface IContextStorage
+    public interface IContextStorage<T>
     {
+        Task<bool> Persist(string sessionId, T[] context);
     }
 }