wehub-resource-sync
103 lines
2.9 KiB
C#
103 lines
2.9 KiB
C#
namespace Lib.flow;
|
|
|
|
[Guid("e64f95e4-c045-400f-98ca-7c020ad46174")]
|
|
internal sealed class Switch : Instance<Switch>
|
|
{
|
|
[Output(Guid = "9300b07e-977d-47b0-908e-c4b1e5e53a64")]
|
|
public readonly Slot<Command> Output = new();
|
|
|
|
[Output(Guid = "044538A4-4499-4F8F-8843-D880677EE1E7")]
|
|
public readonly Slot<int> Count = new();
|
|
|
|
public Switch()
|
|
{
|
|
Output.UpdateAction += Update;
|
|
Count.UpdateAction += UpdateCount;
|
|
}
|
|
|
|
private void UpdateCount(EvaluationContext context)
|
|
{
|
|
var commands = Commands.GetCollectedTypedInputs();
|
|
if (commands == null)
|
|
{
|
|
Count.Value = 0;
|
|
return;
|
|
}
|
|
|
|
Count.Value = commands.Count;
|
|
}
|
|
|
|
private void Update(EvaluationContext context)
|
|
{
|
|
var commandSlot = Commands;
|
|
var commands = commandSlot.GetCollectedTypedInputs();
|
|
var index = Index.GetValue(context);
|
|
|
|
if (commands.Count == 0 || index == -1)
|
|
{
|
|
Count.Value = 0;
|
|
return;
|
|
}
|
|
|
|
// Do all
|
|
_activeIndices.Clear();
|
|
if (index == -2)
|
|
{
|
|
for (int i = 0; i < commands.Count; i++)
|
|
{
|
|
_activeIndices.Add(i);
|
|
commands[i].GetValue(context);
|
|
}
|
|
|
|
for (int i = 0; i < commands.Count; i++)
|
|
{
|
|
_activeIndices.Add(i);
|
|
commands[i].Value?.RestoreAction?.Invoke(context);
|
|
}
|
|
}
|
|
else
|
|
{
|
|
index %= commands.Count;
|
|
if (index < 0)
|
|
{
|
|
index += commands.Count;
|
|
}
|
|
|
|
_activeIndices.Add(index);
|
|
commands[index].GetValue(context);
|
|
commands[index].Value?.RestoreAction?.Invoke(context);
|
|
}
|
|
|
|
if (OptimizeInvalidation.GetValue(context))
|
|
{
|
|
var count = _activeIndices.Count;
|
|
if (commandSlot.LimitMultiInputInvalidationToIndices.Length == count)
|
|
{
|
|
var switchList = commandSlot.LimitMultiInputInvalidationToIndices;
|
|
for (int i = 0; i < count; i++)
|
|
{
|
|
switchList[i] = _activeIndices[i];
|
|
}
|
|
}
|
|
else
|
|
{
|
|
commandSlot.LimitMultiInputInvalidationToIndices = _activeIndices.ToArray();
|
|
}
|
|
}
|
|
|
|
Count.Value = commands.Count;
|
|
}
|
|
|
|
private readonly List<int> _activeIndices = new();
|
|
|
|
[Input(Guid = "988DD1B5-636D-4A78-9592-2C6601401CC1")]
|
|
public readonly MultiInputSlot<Command> Commands = new();
|
|
|
|
[Input(Guid = "00FD2794-567A-4F9B-A900-C2EBF9760764")]
|
|
public readonly InputSlot<int> Index = new();
|
|
|
|
[Input(Guid = "E896B269-D17E-417F-BE1F-2D6E9ADDAE91")]
|
|
public readonly InputSlot<bool> OptimizeInvalidation = new();
|
|
|
|
|
|
} |