Merge pull request #398 from iceljc/features/add-state-change-hook-remove-state

add hook

Author: Oceania2018

src/Infrastructure/BotSharp.Abstraction/Conversations/Models/StateChangeModel.cs

@@ -12,13 +12,13 @@ public class StateChangeModel
     public string Name { get; set; }
 
     [JsonPropertyName("before_value")]
-    public string BeforeValue { get; set; }
+    public string? BeforeValue { get; set; }
 
     [JsonPropertyName("before_active_rounds")]
     public int? BeforeActiveRounds { get; set; }
 
     [JsonPropertyName("after_value")]
-    public string AfterValue { get; set; }
+    public string? AfterValue { get; set; }
 
     [JsonPropertyName("after_active_rounds")]
     public int? AfterActiveRounds { get; set; }

src/Infrastructure/BotSharp.Core/Conversations/Services/ConversationStateService.cs

@@ -201,9 +201,9 @@ public void Save()
             var key = pair.Key;
             var curValue = pair.Value;
 
-            if (!_historyStates.TryGetValue(key, out var historyValue) 
-                || historyValue == null 
-                || historyValue.Values.IsNullOrEmpty() 
+            if (!_historyStates.TryGetValue(key, out var historyValue)
+                || historyValue == null
+                || historyValue.Values.IsNullOrEmpty()
                 || !curValue.Versioning)
             {
                 states.Add(curValue);
@@ -232,8 +232,9 @@ public bool RemoveState(string name)
         if (!ContainsState(name)) return false;
 
         var routingCtx = _services.GetRequiredService<IRoutingContext>();
-        var leafNode = _curStates[name].Values?.LastOrDefault();
-        if (leafNode == null) return false;
+        var value = _curStates[name];
+        var leafNode = value?.Values?.LastOrDefault();
+        if (value == null || !value.Versioning || leafNode == null) return false;
 
         _curStates[name].Values.Add(new StateValue
         {
@@ -246,6 +247,24 @@ public bool RemoveState(string name)
             UpdateTime = DateTime.UtcNow
         });
 
+        var hooks = _services.GetServices<IConversationHook>();
+        foreach (var hook in hooks)
+        {
+            hook.OnStateChanged(new StateChangeModel
+            {
+                ConversationId = _conversationId,
+                MessageId = routingCtx.MessageId,
+                Name = name,
+                BeforeValue = leafNode.Data,
+                BeforeActiveRounds = leafNode.ActiveRounds,
+                AfterValue = null,
+                AfterActiveRounds = leafNode.ActiveRounds,
+                DataType = leafNode.DataType,
+                Source = leafNode.Source,
+                Readonly = _curStates[name].Readonly
+            }).Wait();
+        }
+
         return true;
     }