UnrealEngineUWP/Engine/Plugins/Runtime/Metasound/Source/MetasoundStandardNodes/Private/MetasoundTriggerCounterNode.cpp

// Copyright Epic Games, Inc. All Rights Reserved.
#include "CoreMinimal.h"

#include "MetasoundBuilderInterface.h"
#include "MetasoundDataReferenceCollection.h"
#include "MetasoundExecutableOperator.h"
#include "MetasoundFacade.h"
#include "MetasoundNode.h"
#include "MetasoundNodeInterface.h"
#include "MetasoundNodeRegistrationMacro.h"
#include "MetasoundOperatorInterface.h"
#include "MetasoundPrimitives.h"
#include "MetasoundStandardNodesNames.h"
#include "MetasoundStandardNodesCategories.h"
#include "MetasoundTrigger.h"
#include "MetasoundParamHelper.h"

#define LOCTEXT_NAMESPACE "MetasoundStandardNodes_CounterNode"

namespace Metasound
{
	namespace TriggerCounterVertexNames
	{
		METASOUND_PARAM(InputInTrigger, "In", "Trigger Input to count.");
		METASOUND_PARAM(InputReset, "Reset", "Resets the counter to zero and the value back to the start value.");
		METASOUND_PARAM(InputStartValue, "Start Value", "The value to set the ouput to on init and reset.");
		METASOUND_PARAM(InputStepSize, "Step Size", "The value to add to the current value for each input trigger. Can be negative.");
		METASOUND_PARAM(InputAutoResetCount, "Reset Count", "The number of input triggers to automatically set the count back to Start Count. If 0, won't auto-reset.");
		METASOUND_PARAM(OutputOnTrigger, "On Trigger", "Triggered when the input is triggered.");
		METASOUND_PARAM(OutputOnReset, "On Reset", "Triggered when the input reset trigger is triggered or if the counter automatically resets.");
		METASOUND_PARAM(OutputCount, "Count", "The current raw trigger count (i.e. number of times the input trigger has been triggered).");
		METASOUND_PARAM(OutputValue, "Value", "The current value of the node given the starting value and step size.");
	}

	class FTriggerCounterOperator : public TExecutableOperator<FTriggerCounterOperator>
	{
		public:
			static const FNodeClassMetadata& GetNodeInfo();
			static const FVertexInterface& GetVertexInterface();
			static TUniquePtr<IOperator> CreateOperator(const FCreateOperatorParams& InParams, FBuildErrorArray& OutErrors);

			FTriggerCounterOperator(const FOperatorSettings& InSettings,
				const FTriggerReadRef& InTriggerIn,
				const FTriggerReadRef& InTriggerReset,
				const FFloatReadRef& InStartValue,
				const FFloatReadRef& InStepSize,
				const FInt32ReadRef& InAutoResetCount);

			virtual FDataReferenceCollection GetInputs() const override;
			virtual FDataReferenceCollection GetOutputs() const override;

			void Execute();

		private:
			FTriggerReadRef TriggerIn;
			FTriggerReadRef TriggerReset;
			FFloatReadRef StartValue;
			FFloatReadRef StepSize;
			FInt32ReadRef AutoResetCount;

			FTriggerWriteRef TriggerOut;
			FTriggerWriteRef TriggerOnReset;
			FFloatWriteRef OutValue;
			FInt32WriteRef OutCount;

			// Internal state to do the counting math
			int32 CurrentAutoResetCount = 0;
			int32 CurrentTriggerCount = 0;
			float CurrentValue = 0.0f;
	};

	FTriggerCounterOperator::FTriggerCounterOperator(const FOperatorSettings& InSettings, 
		const FTriggerReadRef& InTriggerIn, 
		const FTriggerReadRef& InTriggerReset,
		const FFloatReadRef& InStartValue,
		const FFloatReadRef& InStepSize,
		const FInt32ReadRef& InAutoResetCount)
		: TriggerIn(InTriggerIn)
		, TriggerReset(InTriggerReset)
		, StartValue(InStartValue)
		, StepSize(InStepSize)
		, AutoResetCount(InAutoResetCount)
		, TriggerOut(FTriggerWriteRef::CreateNew(InSettings))
		, TriggerOnReset(FTriggerWriteRef::CreateNew(InSettings))
		, OutValue(FFloatWriteRef::CreateNew(*StartValue))
		, OutCount(FInt32WriteRef::CreateNew(0))
	{
		CurrentAutoResetCount = FMath::Max(0, *AutoResetCount);
	}

	FDataReferenceCollection FTriggerCounterOperator::GetInputs() const
	{
		using namespace TriggerCounterVertexNames;

		FDataReferenceCollection InputDataReferences;
		InputDataReferences.AddDataReadReference(METASOUND_GET_PARAM_NAME(InputInTrigger), TriggerIn);
		InputDataReferences.AddDataReadReference(METASOUND_GET_PARAM_NAME(InputReset), TriggerReset);
		InputDataReferences.AddDataReadReference(METASOUND_GET_PARAM_NAME(InputStartValue), StartValue);
		InputDataReferences.AddDataReadReference(METASOUND_GET_PARAM_NAME(InputStepSize), StepSize);
		InputDataReferences.AddDataReadReference(METASOUND_GET_PARAM_NAME(InputAutoResetCount), AutoResetCount);

		return InputDataReferences;
	}

	FDataReferenceCollection FTriggerCounterOperator::GetOutputs() const
	{
		using namespace TriggerCounterVertexNames;

		FDataReferenceCollection OutputDataReferences;
		OutputDataReferences.AddDataReadReference(METASOUND_GET_PARAM_NAME(OutputOnTrigger), TriggerOut);
		OutputDataReferences.AddDataReadReference(METASOUND_GET_PARAM_NAME(OutputOnReset), TriggerOnReset);
		OutputDataReferences.AddDataReadReference(METASOUND_GET_PARAM_NAME(OutputCount), OutCount);
		OutputDataReferences.AddDataReadReference(METASOUND_GET_PARAM_NAME(OutputValue), OutValue);

		return OutputDataReferences;
	}

	void FTriggerCounterOperator::Execute()
	{	
		TriggerOnReset->AdvanceBlock();
		TriggerOut->AdvanceBlock();

		// Update the current auto reset count
		CurrentAutoResetCount = FMath::Max(0, *AutoResetCount);

		TriggerReset->ExecuteBlock(
			[&](int32 StartFrame, int32 EndFrame)
			{
			},
			[this](int32 StartFrame, int32 EndFrame)
			{
				CurrentTriggerCount = 0;
				*OutValue = *StartValue;

				TriggerOnReset->TriggerFrame(StartFrame);
			}
		);

		TriggerIn->ExecuteBlock(
			[&](int32 StartFrame, int32 EndFrame)
			{
			},
			[this](int32 StartFrame, int32 EndFrame)
			{
				++CurrentTriggerCount;

				if (CurrentAutoResetCount > 0 && CurrentTriggerCount >= CurrentAutoResetCount)
				{
					CurrentTriggerCount = 0;
					*OutValue = *StartValue;
					TriggerOnReset->TriggerFrame(StartFrame);
				}
				else
				{
					*OutValue += *StepSize;
				}

				*OutCount = CurrentTriggerCount;
				TriggerOut->TriggerFrame(StartFrame);
			}
		);

	}

	TUniquePtr<IOperator> FTriggerCounterOperator::CreateOperator(const FCreateOperatorParams& InParams, FBuildErrorArray& OutErrors)
	{
		using namespace TriggerCounterVertexNames;

		const FInputVertexInterface& InputInterface = GetVertexInterface().GetInputInterface();
		FTriggerReadRef TriggerIn = InParams.InputDataReferences.GetDataReadReferenceOrConstruct<FTrigger>(METASOUND_GET_PARAM_NAME(InputInTrigger), InParams.OperatorSettings);
		FTriggerReadRef TriggerReset = InParams.InputDataReferences.GetDataReadReferenceOrConstruct<FTrigger>(METASOUND_GET_PARAM_NAME(InputReset), InParams.OperatorSettings);
		FFloatReadRef StartValue = InParams.InputDataReferences.GetDataReadReferenceOrConstructWithVertexDefault<float>(InputInterface, METASOUND_GET_PARAM_NAME(InputStartValue), InParams.OperatorSettings);
		FFloatReadRef StepSize = InParams.InputDataReferences.GetDataReadReferenceOrConstructWithVertexDefault<float>(InputInterface, METASOUND_GET_PARAM_NAME(InputStepSize), InParams.OperatorSettings);
		FInt32ReadRef AutoResetCount = InParams.InputDataReferences.GetDataReadReferenceOrConstructWithVertexDefault<int32>(InputInterface, METASOUND_GET_PARAM_NAME(InputAutoResetCount), InParams.OperatorSettings);

		return MakeUnique<FTriggerCounterOperator>(InParams.OperatorSettings, TriggerIn, TriggerReset, StartValue, StepSize, AutoResetCount);
	}

	const FVertexInterface& FTriggerCounterOperator::GetVertexInterface()
	{
		using namespace TriggerCounterVertexNames;

		static const FVertexInterface Interface(
			FInputVertexInterface(
				TInputDataVertexModel<FTrigger>(METASOUND_GET_PARAM_NAME_AND_TT(InputInTrigger)),
				TInputDataVertexModel<FTrigger>(METASOUND_GET_PARAM_NAME_AND_TT(InputReset)),
				TInputDataVertexModel<float>(METASOUND_GET_PARAM_NAME_AND_TT(InputStartValue), 0.0f),
				TInputDataVertexModel<float>(METASOUND_GET_PARAM_NAME_AND_TT(InputStepSize), 1),
				TInputDataVertexModel<int32>(METASOUND_GET_PARAM_NAME_AND_TT(InputAutoResetCount), 0)
			),
			FOutputVertexInterface(
				TOutputDataVertexModel<FTrigger>(METASOUND_GET_PARAM_NAME_AND_TT(OutputOnTrigger)),
				TOutputDataVertexModel<FTrigger>(METASOUND_GET_PARAM_NAME_AND_TT(OutputOnReset)),
				TOutputDataVertexModel<int32>(METASOUND_GET_PARAM_NAME_AND_TT(OutputCount)),
				TOutputDataVertexModel<float>(METASOUND_GET_PARAM_NAME_AND_TT(OutputValue))
			)
		);

		return Interface;
	}

	const FNodeClassMetadata& FTriggerCounterOperator::GetNodeInfo()
	{
		auto InitNodeInfo = []() -> FNodeClassMetadata
		{
			FNodeClassMetadata Info;
			Info.ClassName = {Metasound::StandardNodes::Namespace, TEXT("Trigger Counter"), TEXT("")};
			Info.MajorVersion = 1;
			Info.MinorVersion = 0;
			Info.DisplayName = LOCTEXT("Metasound_TriggerCounterNodeDisplayName", "Trigger Counter");
			Info.Description = LOCTEXT("Metasound_TriggerCounterNodeDescription", "Counts the trigger inputs. Supports a start count value, counting by a step size, and auto resetting back to the start count.");
			Info.Author = PluginAuthor;
			Info.PromptIfMissing = PluginNodeMissingPrompt;
			Info.DefaultInterface = GetVertexInterface();
			Info.CategoryHierarchy.Emplace(StandardNodes::TriggerUtils);

			return Info;
		};

		static const FNodeClassMetadata Info = InitNodeInfo();
		return Info;
	}

	class FTriggerCounterNode : public FNodeFacade
	{
	public:
		FTriggerCounterNode(const FNodeInitData& InInitData)
			: FNodeFacade(InInitData.InstanceName, InInitData.InstanceID, TFacadeOperatorClass<FTriggerCounterOperator>())
		{
		}

		virtual ~FTriggerCounterNode() = default;
	};

	METASOUND_REGISTER_NODE(FTriggerCounterNode)
}

#undef LOCTEXT_NAMESPACE // MetasoundTriggerDelayNode