SemianiakaVY/BotSharp
1
0
Fork 0
Code Issues Pull requests Actions Packages Projects Releases Wiki Activity

Merge pull request #376 from iceljc/features/refine-state-node

Browse source 
refine state node
This commit is contained in:
C. Oceania 2024-03-29 16:39:31 -05:00 committed by GitHub
parent 14a0ea1d63 fc7a82de01
commit e1e7f98bff
No known key found for this signature in database
GPG key ID: B5690EEEBB952194
1 changed files with 35 additions and 41 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

76
src/Infrastructure/BotSharp.Core/Conversations/Services/ConversationStateService.cs
View file

@ -43,60 +43,54 @@ public class ConversationStateService : IConversationStateService, IDisposable
var preValue = string.Empty;
var currentValue = value.ToString();
var hooks = _services.GetServices<IConversationHook>();
var preActiveRounds = -1;
var curActiveRounds = activeRounds > 0 ? activeRounds : -1;
if (ContainsState(name) && _states.TryGetValue(name, out var pair))
{
var lastNode = pair?.Values.LastOrDefault();
preActiveRounds = lastNode?.ActiveRounds ?? -1;
preValue = lastNode?.Data ?? string.Empty;
}
if (!ContainsState(name) || preValue != currentValue || (preValue == currentValue && preActiveRounds > 0))
_logger.LogInformation($"[STATE] {name} = {value}");
var routingCtx = _services.GetRequiredService<IRoutingContext>();
if (!ContainsState(name) || preValue != currentValue)
{
_logger.LogInformation($"[STATE] {name} = {value}");
var routingCtx = _services.GetRequiredService<IRoutingContext>();
if (!ContainsState(name) || preValue != currentValue)
foreach (var hook in hooks)
{
foreach (var hook in hooks)
hook.OnStateChanged(new StateChangeModel
{
hook.OnStateChanged(new StateChangeModel
{
ConversationId = _conversationId,
MessageId = routingCtx.MessageId,
Name = name,
BeforeValue = preValue,
AfterValue = currentValue
}).Wait();
}
ConversationId = _conversationId,
MessageId = routingCtx.MessageId,
Name = name,
BeforeValue = preValue,
AfterValue = currentValue
}).Wait();
}
var newPair = new StateKeyValue
{
Key = name,
Versioning = isNeedVersion
};
}
var newValue = new StateValue
{
Data = currentValue,
MessageId = routingCtx.MessageId,
Active = true,
ActiveRounds = curActiveRounds,
UpdateTime = DateTime.UtcNow,
};
var newPair = new StateKeyValue
{
Key = name,
Versioning = isNeedVersion
};
if (!isNeedVersion || !_states.ContainsKey(name))
{
newPair.Values = new List<StateValue> { newValue };
_states[name] = newPair;
}
else
{
_states[name].Values.Add(newValue);
}
var newValue = new StateValue
{
Data = currentValue,
MessageId = routingCtx.MessageId,
Active = true,
ActiveRounds = activeRounds > 0 ? activeRounds : -1,
UpdateTime = DateTime.UtcNow,
};
if (!isNeedVersion || !_states.ContainsKey(name))
{
newPair.Values = new List<StateValue> { newValue };
_states[name] = newPair;
}
else
{
_states[name].Values.Add(newValue);
}
return this;